db

Documentation

Index

• func IsMarshallingError(err error) bool
• type ChangeItemMarshaller
• type Client
• type DDLExecutor
• type DDLFactory
• type MarshallingError
• type StreamInserter
• type Streamer

Functions

func IsMarshallingError

func IsMarshallingError(err error) bool

Types

type ChangeItemMarshaller

type ChangeItemMarshaller func(item abstract.ChangeItem) ([]any, error)

type Client

type Client interface {
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
}

type DDLExecutor

type DDLExecutor interface {
	ExecDDL(fn DDLFactory) error
}

type DDLFactory

type DDLFactory func(distributed bool, cluster string) (string, error)

type MarshallingError

type MarshallingError interface {
	IsMarshallingError()
	error
}

type StreamInserter

type StreamInserter interface {
	StreamInsert(query string, marshaller ChangeItemMarshaller) (Streamer, error)
}

type Streamer

type Streamer interface {
	Append(row abstract.ChangeItem) error
	Commit() error
	Close() error
}