Versions in this module Expand all Collapse all v1 v1.16.3 Oct 23, 2019 Changes in this version + func EnsureLoggingAgentDeployment(f *framework.Framework, appName string) error + func EnsureLoggingAgentRestartsCount(f *framework.Framework, appName string, maxRestarts int) error + func GetNodeIds(cs clientset.Interface) []string + func WaitForLogs(c LogChecker, interval, timeout time.Duration) error + type FiniteLoggingPod interface + ExpectedLineCount func() int + func NewLoadLoggingPod(podName string, nodeName string, totalLines int, loggingDuration time.Duration) FiniteLoggingPod + type IngestionPred func(string, []LogEntry) (bool, error) + var UntilFirstEntry IngestionPred = func(_ string, entries []LogEntry) (bool, error) { ... } + func UntilFirstEntryFromLocation(location string) IngestionPred + func UntilFirstEntryFromLog(log string) IngestionPred + type LogChecker interface + EntriesIngested func() (bool, error) + Timeout func() error + func NewFullIngestionPodLogChecker(p LogProvider, slack float64, pods ...FiniteLoggingPod) LogChecker + func NewLogChecker(p LogProvider, pred IngestionPred, timeout TimeoutFun, names ...string) LogChecker + func NewNumberedLogChecker(p LogProvider, pred NumberedIngestionPred, timeout NumberedTimeoutFun, ...) LogChecker + type LogEntry struct + JSONPayload map[string]interface{} + Location string + LogName string + TextPayload string + func (entry LogEntry) TryGetEntryNumber() (int, bool) + type LogProvider interface + Cleanup func() + Init func() error + LoggingAgentName func() string + ReadEntries func(name string) []LogEntry + type LoggingPod interface + Name func() string + Start func(f *framework.Framework) error + func NewExecLoggingPod(podName string, cmd []string) LoggingPod + func NewRepeatingLoggingPod(podName string, line string) LoggingPod + func StartAndReturnSelf(p LoggingPod, f *framework.Framework) (LoggingPod, error) + type LogsQueueCollection interface + Pop func(name string) []LogEntry + Push func(name string, logs ...LogEntry) + func NewLogsQueueCollection(queueSize int) LogsQueueCollection + type NumberedIngestionPred func(string, map[int]bool) (bool, error) + type NumberedTimeoutFun func([]string, map[string]map[int]bool) error + type TimeoutFun func([]string, []bool) error + var JustTimeout TimeoutFun = func(names []string, ingested []bool) error { ... }