dao

Documentation

Index

• type DB
  • func New(ctx context.Context, uri string) (*DB, error)
  • func (db *DB) CopyTable(old string, new string) error
  • func (db *DB) CreateTable(target config.Target, fields []Field) error
  • func (db *DB) GetActiveStreams() (map[config.Target]config.Source, error)
  • func (db *DB) GetStreamLocation(source config.Source, target config.Target) (lsn string, ts time.Time, err error)
  • func (db *DB) LogNotification(call string, err error)
  • func (db *DB) PersistMessage(message creek.WAL, target string) error
  • func (db *DB) PersistSnapshotData(target string, data []creek.SnapRow, pk []string) error
  • func (db *DB) SetActive(target config.Target, active bool) error
  • func (db *DB) SetContext(ctx context.Context)
  • func (db *DB) StartAPI() <-chan string
  • func (db *DB) SwapAndDropTable(namespace string, old string, new string) error
  • func (db *DB) UpdateLocation(source config.Source, target config.Target, lsn string, ts time.Time) error
  • func (db *DB) UpdateLocationWithContext(ctx context.Context, source config.Source, target config.Target, lsn string, ...) error
• type Field

Types

type DB

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

func New

func New(ctx context.Context, uri string) (*DB, error)

func (*DB) CopyTable

func (db *DB) CopyTable(old string, new string) error

func (*DB) CreateTable

func (db *DB) CreateTable(target config.Target, fields []Field) error

func (*DB) GetActiveStreams

func (db *DB) GetActiveStreams() (map[config.Target]config.Source, error)

func (*DB) GetStreamLocation

func (db *DB) GetStreamLocation(source config.Source, target config.Target) (lsn string, ts time.Time, err error)

func (*DB) LogNotification

func (db *DB) LogNotification(call string, err error)

func (*DB) PersistMessage

func (db *DB) PersistMessage(message creek.WAL, target string) error

func (*DB) PersistSnapshotData

func (db *DB) PersistSnapshotData(target string, data []creek.SnapRow, pk []string) error

func (*DB) SetActive

func (db *DB) SetActive(target config.Target, active bool) error

func (*DB) SetContext

func (db *DB) SetContext(ctx context.Context)

func (*DB) StartAPI

func (db *DB) StartAPI() <-chan string

func (*DB) SwapAndDropTable

func (db *DB) SwapAndDropTable(namespace string, old string, new string) error

func (*DB) UpdateLocation

func (db *DB) UpdateLocation(source config.Source, target config.Target, lsn string, ts time.Time) error

func (*DB) UpdateLocationWithContext

func (db *DB) UpdateLocationWithContext(ctx context.Context, source config.Source, target config.Target, lsn string, ts time.Time) error

type Field

type Field struct {
	Name     string
	DataType string
	Pk       bool
}