dblog

Documentation

Index

• func IsSupportedKeyType(keyType string) bool
• func NewStorage(src abstract.Source, pgStorage tablequery.StorageTableQueryable, ...) (abstract.Storage, error)
• 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)

Functions

func IsSupportedKeyType

func IsSupportedKeyType(keyType string) bool

func NewStorage

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

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)