sql

type ExecFunc func(*sql.Tx, streams.Message) error

type Executor interface {
	// Exec executes a query on the given transaction.
	Exec(*sql.Tx, streams.Message) error
}

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

type Transaction interface {
	// Begin handles the start of a SQL transaction.
	Begin(*sql.Tx) error
	// Commit handles the commit of a SQL transaction.
	Commit(*sql.Tx) error
}