skip

Documentation

Index

• type Skip
  • func (segment Skip) New(config map[string]string) segments.Segment
  • func (segment *Skip) Rewire(chans []chan *flow.FlowMessage, in uint, out uint)
  • func (segment *Skip) Run(wg *sync.WaitGroup)

Types

type Skip

type Skip struct {
	segments.BaseSegment
	AltOut chan<- *flow.FlowMessage // in addition to the BaseSegment declarations, a second Out is provided

	Condition string // optional, default "", if this is evaluated as true, a skip will occur
	Skip      uint   // optional, default 1, the number of segments to skip after this one when condition is true
	Invert    bool   // optional, default false, whether to invert the conditional behaviour
	// contains filtered or unexported fields
}

func (Skip) New

func (segment Skip) New(config map[string]string) segments.Segment

func (*Skip) Rewire

func (segment *Skip) Rewire(chans []chan *flow.FlowMessage, in uint, out uint)

Override default Rewire method for this segment.

func (*Skip) Run

func (segment *Skip) Run(wg *sync.WaitGroup)