Update rowlog for the API change made for the vstream skew alignment feature

Signed-off-by: Rohit Nayak <rohit@planetscale.com>
This commit is contained in:
Rohit Nayak 2021-04-08 15:46:27 +02:00
Родитель bbfe9c6f37
Коммит bf47abd007
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: BA0A4E9168156524
1 изменённых файлов: 2 добавлений и 1 удалений

Просмотреть файл

@ -12,6 +12,7 @@ import (
"strings" "strings"
"sync" "sync"
"time" "time"
vtgatepb "vitess.io/vitess/go/vt/proto/vtgate"
"vitess.io/vitess/go/mysql" "vitess.io/vitess/go/mysql"
"vitess.io/vitess/go/sqltypes" "vitess.io/vitess/go/sqltypes"
@ -155,7 +156,7 @@ func startStreaming(ctx context.Context, vtgate, vtctld, keyspace, tablet, table
log.Fatal(err) log.Fatal(err)
} }
defer conn.Close() defer conn.Close()
reader, err := conn.VStream(ctx, topodatapb.TabletType_MASTER, vgtid, filter) reader, err := conn.VStream(ctx, topodatapb.TabletType_MASTER, vgtid, filter, &vtgatepb.VStreamFlags{})
var fields []*query.Field var fields []*query.Field
var gtid string var gtid string
var plan *TablePlan var plan *TablePlan