sql

package

v0.1.1 Latest Latest Go to latest Published: Jun 7, 2018 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type InsertFunc func(*sql.Tx, interface{}, interface{}) error

type Sink struct {
	// contains filtered or unexported fields
}

func NewSink(db *sql.DB, fn InsertFunc, batch int, opts ...SinkFunc) *Sink

NewSink creates a new batch sql insert sink.

func (p *Sink) Close() error

Close closes the processor.

func (p *Sink) Process(key, value interface{}) error

Process processes the stream record.

func (p *Sink) WithContext(ctx streams.Context)

WithContext sets the context on the Processor.

type SinkFunc func(*Sink)

func WithBeginFn(fn TxFunc) SinkFunc

func WithCommitFn(fn TxFunc) SinkFunc

type TxFunc func(*sql.Tx) error