stream

Documentation

Index

• type StreamOperator
  • func New(ctx context.Context) *StreamOperator
  • func (r *StreamOperator) Exec(drain chan<- error)
  • func (r *StreamOperator) GetOutput() <-chan interface{}
  • func (r *StreamOperator) SetInput(in <-chan interface{})

Types

type StreamOperator

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

StreamOperator is an operator takes streamed items of type map, array, or slice and unpacks and emits each item individually downstream.

func New

func New(ctx context.Context) *StreamOperator

New creates a *StreamOperator value

func (*StreamOperator) Exec

func (r *StreamOperator) Exec(drain chan<- error)

Exec is the execution starting point for the executor node.

func (*StreamOperator) GetOutput

func (r *StreamOperator) GetOutput() <-chan interface{}

GetOutput returns the output channel of the executer node

func (*StreamOperator) SetInput

func (r *StreamOperator) SetInput(in <-chan interface{})

SetInput sets the input channel for the executor node