pipeline

Documentation

Index

• type Destination
  • func NewDestination(ctx context.Context, addr string, addrConnMax, bufSegCap int) (Destination, error)
• type Source
  • func NewSource(ctx context.Context, addr string, addrConnMax int) (Source, error)

Types

type Destination

type Destination interface {
	io.Closer

	// Flush executes all caching sql.
	Flush(ctx context.Context) error

	// Exec executes the given sql.
	Exec(ctx context.Context, sql string) error
}

func NewDestination

func NewDestination(ctx context.Context, addr string, addrConnMax, bufSegCap int) (Destination, error)

type Source

type Source interface {
	io.Closer

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

func NewSource

func NewSource(ctx context.Context, addr string, addrConnMax int) (Source, error)