postgres

Documentation

Index

• Variables
• func Apply(ctx context.Context, connString string, idleTimeout time.Duration, ...)
• type DBExecutorContext

Variables

var Connect func(ctx context.Context, connString string) (DBExecutorContext, error) = connect

Connect function returns object that can execute sql against target database

var Logger *logrus.Entry

Logger provides access to the PostgreSQL specific logging facility

Functions

func Apply

func Apply(ctx context.Context, connString string, idleTimeout time.Duration, messages <-chan kafka.Message)

Apply function reads messages from `messages` channel and applies changes to the target PostgreSQL database

Types

type DBExecutorContext

type DBExecutorContext interface {
	Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)
}

DBExecutorContext interface represents sql executor with context support