EnsureLoggingAgentDeployment checks that logging agent is present on each node and returns an error if that's not true.

EnsureLoggingAgentRestartsCount checks that each logging agent was restarted no more than maxRestarts times and returns an error if there's a pod which exceeds this number of restarts.

GetNodeIds returns the list of node names and panics in case of failure.

NewExecLoggingPod returns a logging pod that produces logs through executing a command, passed in cmd.

NewFullIngestionPodLogChecker returns a log checks that works with numbered log entries generated by load logging pods and waits until all entries are ingested.

NewLoadLoggingPod returns a logging pod that generates totalLines random lines over period of length loggingDuration.

NewLogChecker constructs a LogChecker for a list of names from custom IngestionPred and TimeoutFun.

NewLogsQueueCollection returns a new LogsQueueCollection where each queue is created with a default size of queueSize.

NewNumberedLogChecker returns a log checker that works with numbered log entries generated by load logging pods.

NewRepeatingLoggingPod returns a logging pod that each second prints line value to its stdout.

StartAndReturnSelf is a helper method to start a logging pod and immediately return it.

UntilFirstEntryFromLocation is a IngestionPred that checks that at least one entry from the log with a given name was ingested.

UntilFirstEntryFromLog is a IngestionPred that checks that at least one entry from the log with a given name was ingested.

WaitForLogs checks that logs are ingested, as reported by the log checker until the timeout has passed.

JustTimeout returns the error with the list of names for which backend is still still missing logs.

UntilFirstEntry is a IngestionPred that checks that at least one entry was ingested.

LogEntry represents a log entry, received from the logging backend.

FiniteLoggingPod is a logging pod that emits a known number of log lines.

LogChecker is an interface for an entity that can check whether logging backend contains all wanted log entries.

LoggingPod is an interface of a pod that can be started and that logs something to its stdout, possibly indefinitely.

LogProvider interface provides an API to get logs from the logging backend.

LogsQueueCollection is a thread-safe set of named log queues.

IngestionPred is a type of a function that checks whether all required log entries were ingested.

NumberedIngestionPred is a IngestionPred that takes into account sequential numbers of ingested entries.

NumberedTimeoutFun is a TimeoutFun that takes into account sequential numbers of ingested entries.

TimeoutFun is a function that is called when the waiting times out.