binlogplayertest

Documentation

Index

• func Run(t *testing.T, bpc binlogplayer.Client, tablet *topodatapb.Tablet, ...)
• type FakeBinlogStreamer
  • func NewFakeBinlogStreamer(t *testing.T) *FakeBinlogStreamer
  • func (fake *FakeBinlogStreamer) HandlePanic(err *error)
  • func (fake *FakeBinlogStreamer) StreamKeyRange(ctx context.Context, position string, keyRange *topodatapb.KeyRange, ...) error
  • func (fake *FakeBinlogStreamer) StreamTables(ctx context.Context, position string, tables []string, ...) error

Functions

func Run

func Run(t *testing.T, bpc binlogplayer.Client, tablet *topodatapb.Tablet, fake *FakeBinlogStreamer)

Run runs the test suite

Types

type FakeBinlogStreamer

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

FakeBinlogStreamer is our implementation of UpdateStream

func NewFakeBinlogStreamer

func NewFakeBinlogStreamer(t *testing.T) *FakeBinlogStreamer

NewFakeBinlogStreamer returns the test instance for UpdateStream

func (*FakeBinlogStreamer) HandlePanic

func (fake *FakeBinlogStreamer) HandlePanic(err *error)

HandlePanic is part of the UpdateStream interface

func (*FakeBinlogStreamer) StreamKeyRange

func (fake *FakeBinlogStreamer) StreamKeyRange(ctx context.Context, position string, keyRange *topodatapb.KeyRange, charset *binlogdatapb.Charset, callback func(reply *binlogdatapb.BinlogTransaction) error) error

StreamKeyRange is part of the UpdateStream interface

func (*FakeBinlogStreamer) StreamTables

func (fake *FakeBinlogStreamer) StreamTables(ctx context.Context, position string, tables []string, charset *binlogdatapb.Charset, callback func(reply *binlogdatapb.BinlogTransaction) error) error

StreamTables is part of the UpdateStream interface