fork

type Distributor interface {
	Distribute(sample *bitflow.Sample, header *bitflow.Header) ([]Subpipeline, error)
	String() string
}

type GenericDistributor struct {
	RegexDistributor
	GetKeys     func(sample *bitflow.Sample, header *bitflow.Header) []string
	Description string
}

type Merger struct {
	bitflow.AbstractSampleProcessor
	// contains filtered or unexported fields
}

type MultiFileDistributor struct {
	bitflow.TagTemplate
	PipelineCache

	Endpoints          *bitflow.EndpointFactory
	Config             bitflow.FileSink // Configuration parameters in this field will be used for file outputs
	ExtendSubPipelines func(fileName string, pipe *bitflow.SamplePipeline)
}

type MultiMetricSource struct {
	MultiPipeline
	bitflow.AbstractSampleProcessor
	// contains filtered or unexported fields
}

type MultiPipeline struct {
	SequentialClose bool
	// contains filtered or unexported fields
}

type MultiplexDistributor struct {
	PipelineArray
}

type PipelineArray struct {
	Subpipelines []*bitflow.SamplePipeline
	// contains filtered or unexported fields
}

type PipelineBuildFunc func(key string) ([]*bitflow.SamplePipeline, error)

type PipelineCache struct {
	// contains filtered or unexported fields
}

type RegexDistributor struct {
	Pipelines map[string]func() ([]*bitflow.SamplePipeline, error)

	ExactMatch bool // Key patterns must match exactly, no glob (*) processing
	RegexMatch bool // Overrides ExactMatch -> treat key patterns as regexes
	// contains filtered or unexported fields
}

type RoundRobinDistributor struct {
	PipelineArray
	Weights []int // Optionally define weights for the pipelines (same order as pipelines). Only values >= 1 will be counted. Default weight is 1.
	// contains filtered or unexported fields
}

type SampleFork struct {
	MultiPipeline
	bitflow.NoopProcessor

	Distributor Distributor

	// TODO implement fatal/non-fatal sub-pipeline errors
	// If true, errors of subpipelines will be logged but don't stop the entire MultiPipeline
	// Finished pipelines must be reported through LogFinishedPipeline()
	NonfatalErrors bool

	ForkPath []string
	// contains filtered or unexported fields
}

type Subpipeline struct {
	Pipe *bitflow.SamplePipeline
	Key  string
}

type TagDistributor struct {
	RegexDistributor
	bitflow.TagTemplate
}