Documentation ¶
Index ¶
- func CheckNotZero(t *testing.T, target string, msg string) int64
- func CheckZero(t *testing.T, target string, msg string) int64
- func ClearDir(t *testing.T, dir string)
- func CountLines(t *testing.T, pattern string) int
- func GetMatches(t *testing.T, pattern string) []string
- func NewActionPluginStaticInfo(factory pipeline.PluginFactory, config pipeline.AnyConfig, ...) []*pipeline.ActionPluginStaticInfo
- func NewConfig(config any, params map[string]int) any
- func NewEmptyActionPluginParams() *pipeline.ActionPluginParams
- func NewEmptyOutputPluginParams() *pipeline.OutputPluginParams
- func NewPipeline(actions []*pipeline.ActionPluginStaticInfo, pipelineOpts ...string) *pipeline.Pipeline
- func NewPipelineMock(actions []*pipeline.ActionPluginStaticInfo, pipelineOpts ...string) (*pipeline.Pipeline, *fake.Plugin, *devnull.Plugin)
- func NewPluginStaticInfo(factory pipeline.PluginFactory, config pipeline.AnyConfig) *pipeline.PluginStaticInfo
- func RunCase(testCase *Case, inputInfo *pipeline.InputPluginInfo, eventCount int, ...)
- func SendPack(t *testing.T, p *pipeline.Pipeline, msgs []Msg) int64
- func WaitForEvents(x *atomic.Int32)
- func WaitProcessEvents(t *testing.T, count int, checkInterval, maxTime time.Duration, pattern string)
- type Case
- type Msg
- type Opts
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewActionPluginStaticInfo ¶
func NewActionPluginStaticInfo(factory pipeline.PluginFactory, config pipeline.AnyConfig, mode pipeline.MatchMode, conds pipeline.MatchConditions, matchInvert bool) []*pipeline.ActionPluginStaticInfo
func NewEmptyActionPluginParams ¶ added in v0.9.3
func NewEmptyActionPluginParams() *pipeline.ActionPluginParams
func NewEmptyOutputPluginParams ¶
func NewEmptyOutputPluginParams() *pipeline.OutputPluginParams
func NewPipeline ¶
func NewPipeline(actions []*pipeline.ActionPluginStaticInfo, pipelineOpts ...string) *pipeline.Pipeline
func NewPipelineMock ¶
func NewPluginStaticInfo ¶
func NewPluginStaticInfo(factory pipeline.PluginFactory, config pipeline.AnyConfig) *pipeline.PluginStaticInfo
func RunCase ¶
func RunCase(testCase *Case, inputInfo *pipeline.InputPluginInfo, eventCount int, pipelineOpts ...string)
func WaitForEvents ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.