pipelaner

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

type BaseLaneConfig struct {
	OutputBufferSize           int64    `pipelane:"output_buffer"`
	Threads                    int64    `pipelane:"threads"`
	StartGCAfterMessageProcess bool     `pipelane:"start_gc_after_message_process"`
	SourceName                 string   `pipelane:"source_name"`
	Inputs                     []string `pipelane:"inputs"`
	Internal
}

type Config struct {
	Input map[string]any `pipeline:"input"`
	Map   map[string]any `pipeline:"map"`
	Sink  map[string]any `pipeline:"sink"`
	// contains filtered or unexported fields
}

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

type Generator interface {
	Init
	Generate(ctx *Context, input chan<- any)
}

type Generators map[string]Generator

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

type Init interface {
	Init(ctx *Context) error
}

type Internal struct {
	Name     string    `pipelane:"-"`
	LaneType LaneTypes `pipelane:"-"`
	Extended any       `pipelane:"-"`
	// contains filtered or unexported fields
}

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

type LaneTypes string

type LogFormat string

type Map interface {
	Init
	Map(ctx *Context, val any) any
}

type Maps map[string]Map

type MethodGenerator func(ctx *Context, input chan<- any)

type MethodMap func(ctx *Context, val any) any

type MethodSink func(ctx *Context, val any)

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

type Sink interface {
	Init
	Sink(ctx *Context, val any)
}

type Sinks map[string]Sink

type TreeLanes struct {
	Items map[string]*LaneItem
}