sqlsink

Documentation

Index

• func NewSQLSink(query Query, opt sink.SinkOption) sink.Sink
• type Query

Functions

func NewSQLSink

func NewSQLSink(query Query, opt sink.SinkOption) sink.Sink

Types

type Query

type Query struct {
	DB *sql.DB

	CS map[string]sql.Stmt
	US map[string]sql.Stmt
	DS map[string]sql.Stmt

	// data must be a struct pointer
	Create map[string]func(topicId []byte, data interface{}, tp time.Time) error
	Update map[string]func(topicId []byte, data interface{}, tp time.Time) error
	Delete map[string]func(topicId []byte, tp time.Time) error
}