pipeline

Documentation

Index

• type Destination
  • func NewDestination(ctx context.Context, addr string, opts ...Option) (Destination, error)
• type Option
  • func WithConnMaxIdle(i int) Option
  • func WithConnMaxLife(d time.Duration) Option
  • func WithConnMaxOpen(o int) Option
• type Source
  • func NewSource(ctx context.Context, addr string, opts ...Option) (Source, error)

Types

type Destination

type Destination interface {
	io.Closer

	// Exec executes the given statement with arguments,
	// detects the given statement and pick the proper execution(sync/async) to finish the job.
	Exec(ctx context.Context, statement string, args ...any) error
}

func NewDestination

func NewDestination(ctx context.Context, addr string, opts ...Option) (Destination, error)

type Option

type Option func(db *sql.DB)

func WithConnMaxIdle

func WithConnMaxIdle(i int) Option

func WithConnMaxLife

func WithConnMaxLife(d time.Duration) Option

func WithConnMaxOpen

func WithConnMaxOpen(o int) Option

type Source

type Source interface {
	io.Closer

	Pipe(ctx context.Context, destination Destination) error
}

func NewSource

func NewSource(ctx context.Context, addr string, opts ...Option) (Source, error)