streamengine

Documentation

Index

• type StreamEngine
  • func New(processor goduck.Processor, streams []goduck.Stream) *StreamEngine
  • func NewFromEndpoint(e endpoint.Endpoint, decoder goduck.EndpointDecoder, streams []goduck.Stream) *StreamEngine
  • func (e *StreamEngine) Run(ctx context.Context) error

Types

type StreamEngine

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

StreamEngine is an engine that processes a of messages from a stream, with the order preserved.

func New

func New(processor goduck.Processor, streams []goduck.Stream) *StreamEngine

New creates a new StreamEngine

func NewFromEndpoint

func NewFromEndpoint(
	e endpoint.Endpoint,
	decoder goduck.EndpointDecoder,
	streams []goduck.Stream,
) *StreamEngine

NewFromEndpoint creates a StreamEngine from a go-kit endpoint

func (*StreamEngine) Run

func (e *StreamEngine) Run(ctx context.Context) error

Run starts processing the messages, until @ctx is closed