psdbconnectv1alpha1

type ConnectClient interface {
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (Connect_SyncClient, error)
}

type ConnectServer interface {
	Sync(*SyncRequest, Connect_SyncServer) error
}

type Connect_SyncClient interface {
	Recv() (*SyncResponse, error)
	grpc.ClientStream
}

type Connect_SyncServer interface {
	Send(*SyncResponse) error
	grpc.ServerStream
}

type DeletedRow struct {
	Result *query.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

type SyncRequest struct {
	TableName      string       `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	Cursor         *TableCursor `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	TabletType     TabletType   `` /* 129-byte string literal not displayed */
	IncludeInserts bool         `protobuf:"varint,4,opt,name=include_inserts,json=includeInserts,proto3" json:"include_inserts,omitempty"`
	IncludeUpdates bool         `protobuf:"varint,5,opt,name=include_updates,json=includeUpdates,proto3" json:"include_updates,omitempty"`
	IncludeDeletes bool         `protobuf:"varint,6,opt,name=include_deletes,json=includeDeletes,proto3" json:"include_deletes,omitempty"`
	Columns        []string     `protobuf:"bytes,7,rep,name=columns,proto3" json:"columns,omitempty"`
	// if specified, these cells are used to pick source tablets from.
	// defaults to the cell of the vtgate serving the VStream API.
	Cells []string `protobuf:"bytes,8,rep,name=cells,proto3" json:"cells,omitempty"`
	// contains filtered or unexported fields
}

type SyncResponse struct {
	Result  []*query.QueryResult `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"`
	Cursor  *TableCursor         `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Error   *vtrpc.RPCError      `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	Deletes []*DeletedRow        `protobuf:"bytes,4,rep,name=deletes,proto3" json:"deletes,omitempty"`
	Updates []*UpdatedRow        `protobuf:"bytes,5,rep,name=updates,proto3" json:"updates,omitempty"`
	// contains filtered or unexported fields
}

type TableCursor struct {
	Shard       string             `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard,omitempty"`
	Keyspace    string             `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Position    string             `protobuf:"bytes,3,opt,name=position,proto3" json:"position,omitempty"`
	LastKnownPk *query.QueryResult `protobuf:"bytes,4,opt,name=last_known_pk,json=lastKnownPk,proto3" json:"last_known_pk,omitempty"`
	// contains filtered or unexported fields
}

type TabletType int32

type UnimplementedConnectServer struct {
}

type UnsafeConnectServer interface {
	// contains filtered or unexported methods
}

type UpdatedRow struct {
	Before *query.QueryResult `protobuf:"bytes,1,opt,name=before,proto3" json:"before,omitempty"`
	After  *query.QueryResult `protobuf:"bytes,2,opt,name=after,proto3" json:"after,omitempty"`
	// contains filtered or unexported fields
}