test

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 Offset
  • func (o Offset) ByStream(_ string) int64
  • func (o Offset) Current() int64
• type Opts
  • func (o Opts) Has(opt string) bool

Functions

func CheckNotZero

func CheckNotZero(t *testing.T, target string, msg string) int64

func CheckZero

func CheckZero(t *testing.T, target string, msg string) int64

func ClearDir

func ClearDir(t *testing.T, dir string)

func CountLines

func CountLines(t *testing.T, pattern string) int

func GetMatches

func GetMatches(t *testing.T, pattern string) []string

func NewActionPluginStaticInfo

func NewActionPluginStaticInfo(factory pipeline.PluginFactory, config pipeline.AnyConfig, mode pipeline.MatchMode, conds pipeline.MatchConditions, matchInvert bool) []*pipeline.ActionPluginStaticInfo

func NewConfig

func NewConfig(config any, params map[string]int) any

func NewEmptyActionPluginParams

func NewEmptyActionPluginParams() *pipeline.ActionPluginParams

func NewEmptyOutputPluginParams

func NewEmptyOutputPluginParams() *pipeline.OutputPluginParams

func NewPipeline

func NewPipeline(actions []*pipeline.ActionPluginStaticInfo, pipelineOpts ...string) *pipeline.Pipeline

func NewPipelineMock

func NewPipelineMock(actions []*pipeline.ActionPluginStaticInfo, pipelineOpts ...string) (*pipeline.Pipeline, *fake.Plugin, *devnull.Plugin)

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 SendPack

func SendPack(t *testing.T, p *pipeline.Pipeline, msgs []Msg) int64

func WaitForEvents

func WaitForEvents(x *atomic.Int32)

func WaitProcessEvents

func WaitProcessEvents(t *testing.T, count int, checkInterval, maxTime time.Duration, pattern string)

Types

type Case

type Case struct {
	Prepare func()
	Act     func(pipeline *pipeline.Pipeline)
	Assert  func(pipeline *pipeline.Pipeline)
	Out     func(event *pipeline.Event)
}

type Msg

type Msg []byte

type Offset

type Offset int64

func (Offset) ByStream

func (o Offset) ByStream(_ string) int64

func (Offset) Current

func (o Offset) Current() int64

type Opts

type Opts []string

func (Opts) Has

func (o Opts) Has(opt string) bool