dblog

Documentation

Index

• Constants
• func IsSupportedKeyType(keyType string) bool
• func NewPgSignalTable(ctx context.Context, conn *pgxpool.Pool, logger log.Logger, transferID string, ...) (*signalTable, error)
• func NewStorage(logger log.Logger, src abstract.Source, ...) (abstract.Storage, error)
• func SignalTableTableID(schemaName string) *abstract.TableID
• type Storage
  • func (s *Storage) Close()
  • func (s *Storage) EstimateTableRowsCount(table abstract.TableID) (uint64, error)
  • func (s *Storage) ExactTableRowsCount(table abstract.TableID) (uint64, error)
  • func (s *Storage) LoadTable(ctx context.Context, tableDescr abstract.TableDescription, ...) error
  • func (s *Storage) Ping() error
  • func (s *Storage) TableExists(table abstract.TableID) (bool, error)
  • func (s *Storage) TableList(filter abstract.IncludeTableList) (abstract.TableMap, error)
  • func (s *Storage) TableSchema(ctx context.Context, table abstract.TableID) (*abstract.TableSchema, error)

Constants

const (
	SignalTableName = "__data_transfer_signal_table"
)

Functions

func IsSupportedKeyType

func IsSupportedKeyType(keyType string) bool

func NewPgSignalTable

func NewPgSignalTable(
	ctx context.Context,
	conn *pgxpool.Pool,
	logger log.Logger,
	transferID string,
	schemaName string,
) (*signalTable, error)

func NewStorage

func NewStorage(
	logger log.Logger,
	src abstract.Source,
	pgStorage tablequery.StorageTableQueryable,
	conn *pgxpool.Pool,
	chunkSize uint64,
	transferID string,
	keeperSchema string,
	represent dblog.ChangeItemConverter,
	betweenMarksOpts ...func(),
) (abstract.Storage, error)

func SignalTableTableID

func SignalTableTableID(schemaName string) *abstract.TableID

Types

type Storage

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

func (*Storage) Close

func (s *Storage) Close()

func (*Storage) EstimateTableRowsCount

func (s *Storage) EstimateTableRowsCount(table abstract.TableID) (uint64, error)

func (*Storage) ExactTableRowsCount

func (s *Storage) ExactTableRowsCount(table abstract.TableID) (uint64, error)

func (*Storage) LoadTable

func (s *Storage) LoadTable(ctx context.Context, tableDescr abstract.TableDescription, pusher abstract.Pusher) error

func (*Storage) Ping

func (s *Storage) Ping() error

func (*Storage) TableExists

func (s *Storage) TableExists(table abstract.TableID) (bool, error)

func (*Storage) TableList

func (s *Storage) TableList(filter abstract.IncludeTableList) (abstract.TableMap, error)

func (*Storage) TableSchema

func (s *Storage) TableSchema(ctx context.Context, table abstract.TableID) (*abstract.TableSchema, error)