Documentation ¶
Index ¶
- type FlushReport
- type Msg
- type MsgProcessor
- func AutoFlushed(processor MsgProcessor, ctx context.Context, interval time.Duration) MsgProcessor
- func Buffered(dst MsgProcessor, capacity int) MsgProcessor
- func HandleErrors(processor MsgProcessor, ch chan<- error) MsgProcessor
- func HandleEvents(processor MsgProcessor, chErr chan<- error, chProcess chan<- ProcessReport, ...) MsgProcessor
- func HandleFlush(processor MsgProcessor, ch chan<- FlushReport) MsgProcessor
- func HandleProcess(processor MsgProcessor, ch chan<- ProcessReport) MsgProcessor
- func Sharded(keyProvider ShardKeyProvider, processors ...MsgProcessor) MsgProcessor
- func Transformed(processor MsgProcessor, transformer Transformer) MsgProcessor
- type ProcessReport
- type ShardKeyProvideFunc
- type ShardKeyProvider
- type Source
- type Stream
- type TransformFunc
- type Transformer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FlushReport ¶
type MsgProcessor ¶
func AutoFlushed ¶
func AutoFlushed(processor MsgProcessor, ctx context.Context, interval time.Duration) MsgProcessor
func Buffered ¶
func Buffered(dst MsgProcessor, capacity int) MsgProcessor
func HandleErrors ¶
func HandleErrors(processor MsgProcessor, ch chan<- error) MsgProcessor
func HandleEvents ¶
func HandleEvents(processor MsgProcessor, chErr chan<- error, chProcess chan<- ProcessReport, chFlush chan<- FlushReport) MsgProcessor
func HandleFlush ¶
func HandleFlush(processor MsgProcessor, ch chan<- FlushReport) MsgProcessor
func HandleProcess ¶
func HandleProcess(processor MsgProcessor, ch chan<- ProcessReport) MsgProcessor
func Sharded ¶
func Sharded(keyProvider ShardKeyProvider, processors ...MsgProcessor) MsgProcessor
func Transformed ¶
func Transformed(processor MsgProcessor, transformer Transformer) MsgProcessor
type ProcessReport ¶
type ShardKeyProvideFunc ¶
func (ShardKeyProvideFunc) ProvideShardKey ¶
func (s ShardKeyProvideFunc) ProvideShardKey(item interface{}) ([]byte, error)
type ShardKeyProvider ¶
type TransformFunc ¶
type TransformFunc func(original interface{}) (interface{}, error)
func (TransformFunc) Transform ¶
func (tf TransformFunc) Transform(original interface{}) (interface{}, error)
type Transformer ¶
type Transformer interface {
Transform(original interface{}) (interface{}, error)
}
Click to show internal directories.
Click to hide internal directories.