cdc

Documentation

Index

• type Manager
  • func NewManager() *Manager
  • func (m *Manager) GetPublisher(dbName string) *Publisher
  • func (m *Manager) WrapContext(ctx context.Context, dbName string) context.Context
• type Op
• type Publisher
  • func NewPublisher(dbName string) *Publisher
  • func (p *Publisher) NewListener() kv.Listener
  • func (p *Publisher) NewStreamer(kvStore kv.KeyValueStore) (*Streamer, error)
• type PublisherKeySpace
  • func NewPublisherKeySpace(dbName string) *PublisherKeySpace
• type Streamer
  • func (s *Streamer) Close()
• type Tx
• type TxListener
  • func (l *TxListener) OnCancel()
  • func (l *TxListener) OnClearRange(opType string, table []byte, lKey []byte, rKey []byte)
  • func (l *TxListener) OnCommit(fdbTx *fdb.Transaction) error
  • func (l *TxListener) OnSet(opType string, table []byte, key []byte, data []byte)

Types

type Manager

type Manager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewManager

func NewManager() *Manager

func (*Manager) GetPublisher

func (m *Manager) GetPublisher(dbName string) *Publisher

func (*Manager) WrapContext

func (m *Manager) WrapContext(ctx context.Context, dbName string) context.Context

type Op

type Op struct {
	Type  string
	Table []byte
	Key   []byte `json:",omitempty"`
	LKey  []byte `json:",omitempty"`
	RKey  []byte `json:",omitempty"`
	Data  []byte `json:",omitempty"`
}

type Publisher

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

func NewPublisher

func NewPublisher(dbName string) *Publisher

func (*Publisher) NewListener

func (p *Publisher) NewListener() kv.Listener

func (*Publisher) NewStreamer

func (p *Publisher) NewStreamer(kvStore kv.KeyValueStore) (*Streamer, error)

type PublisherKeySpace

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

func NewPublisherKeySpace

func NewPublisherKeySpace(dbName string) *PublisherKeySpace

type Streamer

type Streamer struct {
	Txs chan Tx
	// contains filtered or unexported fields
}

func (*Streamer) Close

func (s *Streamer) Close()

type Tx

type Tx struct {
	Ops []Op
}

type TxListener

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

func (*TxListener) OnCancel

func (l *TxListener) OnCancel()

func (*TxListener) OnClearRange

func (l *TxListener) OnClearRange(opType string, table []byte, lKey []byte, rKey []byte)

func (*TxListener) OnCommit

func (l *TxListener) OnCommit(fdbTx *fdb.Transaction) error

func (*TxListener) OnSet

func (l *TxListener) OnSet(opType string, table []byte, key []byte, data []byte)