stream

Documentation

Index

• type Stream
  • func NewStream(ctx context.Context, cfg config.Config, db *dao.DB) (*Stream, error)
  • func (s *Stream) AddWALTable(ctx context.Context, source config.Source, target config.Target) error
  • func (s *Stream) ApplySnapshot(mode config.SnapMode, source config.Source, target config.Target, ...) (header creek.SnapshotHeader, err error)
  • func (s *Stream) CreateSchema(ctx context.Context, source config.Source, target config.Target) error
  • func (s *Stream) Done() <-chan struct{}
  • func (s *Stream) NewSnapshot(mode config.SnapMode, source config.Source, target config.Target) (heder creek.SnapshotHeader, err error)
  • func (s *Stream) PauseWAL(target config.Target)
  • func (s *Stream) RemoveWALTable(target config.Target) error
  • func (s *Stream) ResumeWAL(target config.Target, skipToLSN pglogrepl.LSN)
  • func (s *Stream) SnapsDone() <-chan struct{}
  • func (s *Stream) StartListenAPI()

Types

type Stream

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

func NewStream

func NewStream(ctx context.Context, cfg config.Config, db *dao.DB) (*Stream, error)

func (*Stream) AddWALTable

func (s *Stream) AddWALTable(ctx context.Context, source config.Source, target config.Target) error

func (*Stream) ApplySnapshot

func (s *Stream) ApplySnapshot(mode config.SnapMode, source config.Source, target config.Target, snapTopic string) (header creek.SnapshotHeader, err error)

func (*Stream) CreateSchema

func (s *Stream) CreateSchema(ctx context.Context, source config.Source, target config.Target) error

func (*Stream) Done

func (s *Stream) Done() <-chan struct{}

func (*Stream) NewSnapshot

func (s *Stream) NewSnapshot(mode config.SnapMode, source config.Source, target config.Target) (heder creek.SnapshotHeader, err error)

func (*Stream) PauseWAL

func (s *Stream) PauseWAL(target config.Target)

func (*Stream) RemoveWALTable

func (s *Stream) RemoveWALTable(target config.Target) error

func (*Stream) ResumeWAL

func (s *Stream) ResumeWAL(target config.Target, skipToLSN pglogrepl.LSN)

func (*Stream) SnapsDone

func (s *Stream) SnapsDone() <-chan struct{}

SnapsDone returns a channel that sends a message when all snapshots are finished

func (*Stream) StartListenAPI

func (s *Stream) StartListenAPI()