Versions in this module Expand all Collapse all v0 v0.1.0 May 21, 2024 Changes in this version + const ModeCDC + const ModeSnapshot + var ErrFindAllShardsInKeyspaceReturnedNothing = errors.New("FindAllShardsInKeyspace returned nothing") + var ErrNoInitializedIterator = errors.New("no initialized iterator") + var ErrNoIterator = errors.New("combined doesn't have an iterator") + type Combined struct + func NewCombined(ctx context.Context, params CombinedParams) (*Combined, error) + func (c *Combined) HasNext(ctx context.Context) (bool, error) + func (c *Combined) Next(ctx context.Context) (sdk.Record, error) + func (c *Combined) Stop(ctx context.Context) error + type CombinedParams struct + Address string + BatchSize int + Columns []string + KeyColumn string + Keyspace string + MaxRetries int + OrderingColumn string + Password string + Position *Position + RetryTimeout time.Duration + Snapshot bool + Table string + TabletType string + Username string + type Mode string + type Position struct + Keyspace string + LastProcessedElementValue any + Mode Mode + ShardGtids []*binlogdata.ShardGtid + func ParsePosition(sdkPosition sdk.Position) (*Position, error) + func (p *Position) MarshalSDKPosition() (sdk.Position, error)
Go to main page