branch

Documentation

Index

• type Branch
  • func (segment *Branch) ImportBranches(condition interface{}, then_branch interface{}, else_branch interface{})
  • func (segment Branch) New(config map[string]string) segments.Segment
  • func (segment *Branch) Run(wg *sync.WaitGroup)
• type Pipeline

Types

type Branch

type Branch struct {
	segments.BaseSegment
	// contains filtered or unexported fields
}

func (*Branch) ImportBranches

func (segment *Branch) ImportBranches(condition interface{}, then_branch interface{}, else_branch interface{})

func (Branch) New

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

func (*Branch) Run

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

type Pipeline

type Pipeline interface {
	Start()
	Close()
	GetInput() chan *pb.EnrichedFlow
	GetOutput() <-chan *pb.EnrichedFlow
	GetDrop() <-chan *pb.EnrichedFlow
}

This mirrors the proper implementation in the pipeline package. This duplication is to avoid the import cycle.