snapshot

Documentation

Index

• Variables
• type Config
• type FetchConfig
  • func (c FetchConfig) Validate() error
• type FetchData
• type FetchWorker
  • func NewFetchWorker(db *pgxpool.Pool, out chan<- FetchData, c FetchConfig) *FetchWorker
  • func (f *FetchWorker) Run(ctx context.Context) error
  • func (f *FetchWorker) Validate(ctx context.Context) error
• type Iterator
  • func NewIterator(ctx context.Context, db *pgxpool.Pool, c Config) (*Iterator, error)
  • func (i *Iterator) Ack(_ context.Context, _ sdk.Position) error
  • func (i *Iterator) Next(ctx context.Context) (sdk.Record, error)
  • func (i *Iterator) Teardown(_ context.Context) error

Variables

var ErrIteratorDone = errors.New("snapshot complete")

Types

type Config

type Config struct {
	Position     sdk.Position
	Tables       []string
	TableKeys    map[string]string
	TXSnapshotID string
}

type FetchConfig

type FetchConfig struct {
	Table        string
	Key          string
	TXSnapshotID string
	FetchSize    int
	Position     position.Position
}

func (FetchConfig) Validate

func (c FetchConfig) Validate() error

type FetchData

type FetchData struct {
	Key      sdk.StructuredData
	Payload  sdk.StructuredData
	Position position.SnapshotPosition
	Table    string
}

type FetchWorker

type FetchWorker struct {
	// contains filtered or unexported fields
}

func NewFetchWorker

func NewFetchWorker(db *pgxpool.Pool, out chan<- FetchData, c FetchConfig) *FetchWorker

func (*FetchWorker) Run

func (f *FetchWorker) Run(ctx context.Context) error

func (*FetchWorker) Validate

func (f *FetchWorker) Validate(ctx context.Context) error

Validate will ensure the config is correct. * Table and keys exist * Key is a primary key

type Iterator

type Iterator struct {
	// contains filtered or unexported fields
}

func NewIterator

func NewIterator(ctx context.Context, db *pgxpool.Pool, c Config) (*Iterator, error)

func (*Iterator) Ack

func (i *Iterator) Ack(_ context.Context, _ sdk.Position) error

func (*Iterator) Next

func (i *Iterator) Next(ctx context.Context) (sdk.Record, error)

func (*Iterator) Teardown

func (i *Iterator) Teardown(_ context.Context) error