postgres

Documentation

Index

• type Source
  • func NewSource(uri *url.URL, logger *zap.Logger) (*Source, error)
  • func (s *Source) Close() error
  • func (s *Source) Connect(ctx context.Context, checkpoint *replicator.Checkpoint) error
  • func (s *Source) Disconnect(ctx context.Context) error
  • func (s *Source) Next(ctx context.Context) (replicator.Event, error)
  • func (s *Source) Stats() replicator.SourceStats

Types

type Source

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

func NewSource

func NewSource(uri *url.URL, logger *zap.Logger) (*Source, error)

func (*Source) Close

func (s *Source) Close() error

func (*Source) Connect

func (s *Source) Connect(ctx context.Context, checkpoint *replicator.Checkpoint) error

func (*Source) Disconnect

func (s *Source) Disconnect(ctx context.Context) error

func (*Source) Next

func (s *Source) Next(ctx context.Context) (replicator.Event, error)

func (*Source) Stats

func (s *Source) Stats() replicator.SourceStats