The highest tagged major version is v6.

sql

package

v0.5.0 Latest Latest Go to latest Published: Jun 27, 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, *streams.Message) error

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

Sink represents a SQL sink processor.

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(msg *streams.Message) error

Process processes the stream record.

func (p *Sink) WithPipe(pipe streams.Pipe)

WithPipe sets the pipe on the Processor.

type SinkFunc func(*Sink)

func WithBeginFn(fn TxFunc) SinkFunc

func WithCommitFn(fn TxFunc) SinkFunc

type TxFunc func(*sql.Tx) error

TxFunc represents a function that receives a sql transaction.