Documentation
¶
Index ¶
- Variables
- func ExecuteCmdZenoGetList(t *testing.T, wg *sync.WaitGroup, files []string)
- func ExecuteCmdZenoGetURL(t *testing.T, wg *sync.WaitGroup, urls []string)
- func StartHandleLogRecord(t *testing.T, wg *sync.WaitGroup, rm log.RecordMatcher, stopCh chan struct{})
- func WaitForGoroutines(t *testing.T, wg *sync.WaitGroup, shouldStopCh chan struct{})
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultTimeout = 60 * time.Second
View Source
var DialTimeout = 10 * time.Second
Functions ¶
func ExecuteCmdZenoGetList ¶
ExecuteCmdZenoGetList executes the Zeno get list command with the e2e logging, file paths and custom config.toml file
func ExecuteCmdZenoGetURL ¶
ExecuteCmdZenoGetURL executes the Zeno get URL command with the e2e logging, URLs and custom config.toml file
func StartHandleLogRecord ¶
func StartHandleLogRecord(t *testing.T, wg *sync.WaitGroup, rm log.RecordMatcher, stopCh chan struct{})
Connects to the log conn and processes log records using the provided RecordMatcher
func WaitForGoroutines ¶
WaitForGoroutines waits for ANY of the following conditions to be met:
- [1] all goroutines in the wait group to finish
- [2] the shouldStop channel is closed
Then send a termination signal to the Zeno controler to gracefully stop Zeno.
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.