go-vitess.v1: gopkg.in/src-d/go-vitess.v1/vt/binlog/binlogplayertest Index | Files

package binlogplayertest

import "gopkg.in/src-d/go-vitess.v1/vt/binlog/binlogplayertest"

Index

Package Files

player.go

func Run Uses

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

Run runs the test suite

type FakeBinlogStreamer Uses

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

FakeBinlogStreamer is our implementation of UpdateStream

func NewFakeBinlogStreamer Uses

func NewFakeBinlogStreamer(t *testing.T) *FakeBinlogStreamer

NewFakeBinlogStreamer returns the test instance for UpdateStream

func (*FakeBinlogStreamer) HandlePanic Uses

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

HandlePanic is part of the UpdateStream interface

func (*FakeBinlogStreamer) StreamKeyRange Uses

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 Uses

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

Package binlogplayertest imports 11 packages (graph). Updated 2019-06-13. Refresh now. Tools for package owners.