Versions in this module Expand all Collapse all v2 v2.6.0 Jan 29, 2019 Changes in this version + type Sink struct + func NewSink(cache cache.Cache, expire time.Duration, batch int) *Sink + func (p *Sink) Close() error + func (p *Sink) Process(msg *streams.Message) error + func (p *Sink) WithPipe(pipe streams.Pipe) Other modules containing this package github.com/msales/streams github.com/msales/streams/v4 github.com/msales/streams/v6
Go to main page