streams

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

type ErrorFunc func(error)

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

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

type FlatMapper func(*Message) ([]*Message, error)

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

type Mapper func(*Message) (*Message, error)

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

type Message struct {
	Ctx   context.Context
	Key   interface{}
	Value interface{}
	// contains filtered or unexported fields
}

type Node interface {
	// Name gets the node name.
	Name() string
	// AddChild adds a child node to the node.
	AddChild(n Node)
	// Children gets the nodes children.
	Children() []Node
	// Processor gets the nodes processor.
	Processor() Processor
}

type Pipe interface {
	// Forward queues the data to all processor children in the topology.
	Forward(*Message) error
	// Forward queues the data to the the given processor(s) child in the topology.
	ForwardToChild(*Message, int) error
	// Commit commits the current state in the sources.
	Commit(*Message) error
}

type Predicate func(*Message) (bool, error)

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

type Processor interface {
	// WithPipe sets the pipe on the Processor.
	WithPipe(Pipe)
	// Process processes the stream Message.
	Process(*Message) error
	// Close closes the processor.
	Close() error
}

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

type Pump interface {
	// Process processes a message in the Pump.
	Process(*Message) error
	// Close closes the pump.
	Close() error
}

type Source interface {
	// Consume gets the next Message from the Source.
	Consume() (*Message, error)
	// Commit marks the consumed Message as processed.
	Commit(interface{}) error
	// Close closes the Source.
	Close() error
}

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

type SourcePump interface {
	// Stop stops the source pump from running.
	Stop()
	// Close closed the source pump.
	Close() error
}

type SourcePumps []SourcePump

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

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

type Task interface {
	// Start starts the streams processors.
	Start() error
	// OnError sets the error handler.
	OnError(fn ErrorFunc)
	// Close stops and closes the streams processors.
	Close() error
}

type TimedPipe interface {
	// Reset resets the accumulative pipe duration.
	Reset()
	// Duration returns the accumulative pipe duration.
	Duration() time.Duration
}

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

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