Versions in this module Expand all Collapse all v1 v1.1.0 Oct 17, 2018 v1.0.0 Aug 31, 2018 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/v2 github.com/msales/streams/v4 github.com/msales/streams/v6
Go to main page