package
0.0.0-20200630053641-03683fefd86d
Repository: https://github.com/blep-ai/automi.git
Documentation: pkg.go.dev
# Functions
CancellationError returns a CancelStreamError.
Error returns a StreamError.
ErrorWithItem returns a StreamError with provided StreamItem.
PanickingError returns a PanicStreamError.
# Structs
StreamError is used to signal runtime stream error.
StreamItem can be used to provide a rich repressentation of streaming data.
# Interfaces
BatchTrigger interface provides logic to trigger when batch is done.
BinOperation interface represents binary opeartions (i.e.
No description provided by the author
No description provided by the author
Operator is an executor node that applies a function on items in the stream.
No description provided by the author
No description provided by the author
UnOperation interface represents unary operations (i.e.
# Type aliases
BatchTriggerFunc a function type adapter that implements BatchTrigger.
BinFunc implements BinOperation as type func(context.Context, interface{}, interface{}).
CancelStreamError signals that all stream activities should stop and the streaming should gracefully end.
ErrorFunc this type is a user-provided function to handle errors.
LogFunc represents a function to handle log events.
PanicStreamError signals that the stream should panic immediately.
UnFunc implements UnOperation as type func (context.Context, interface{}).