Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 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 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 the UpdateStream interface
Click to show internal directories.
Click to hide internal directories.