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 InsertFunc func(*sql.Tx, *streams.Message) error + type Sink struct + func NewSink(db *sql.DB, fn InsertFunc, opts ...SinkFunc) (*Sink, error) + func (p *Sink) Close() error + func (p *Sink) Process(msg *streams.Message) error + func (p *Sink) WithPipe(pipe streams.Pipe) + type SinkFunc func(*Sink) + func WithBatchFrequency(freq time.Duration) SinkFunc + func WithBatchMessages(messages int) SinkFunc + func WithBeginFn(fn TxFunc) SinkFunc + func WithCommitFn(fn TxFunc) SinkFunc + type TxFunc func(*sql.Tx) error Other modules containing this package github.com/msales/streams/v2 github.com/msales/streams/v4 github.com/msales/streams/v6
Go to main page