psdbconnectv1alpha1

May 25, 2023

Changes in this version

type SyncRequest

+ Cells []string

+ func (x *SyncRequest) GetCells() []string

type TabletType

+ const TabletType_batch

+ const TabletType_read_only

Apr 25, 2023

Changes in this version

+ type DeletedRow struct

+ Result *query.QueryResult

+ func (*DeletedRow) Descriptor() ([]byte, []int)

+ func (*DeletedRow) ProtoMessage()

+ func (m *DeletedRow) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *DeletedRow) MarshalToVT(dAtA []byte) (int, error)

+ func (m *DeletedRow) MarshalVT() (dAtA []byte, err error)

+ func (m *DeletedRow) SizeVT() (n int)

+ func (m *DeletedRow) UnmarshalVT(dAtA []byte) error

+ func (x *DeletedRow) GetResult() *query.QueryResult

+ func (x *DeletedRow) ProtoReflect() protoreflect.Message

+ func (x *DeletedRow) Reset()

+ func (x *DeletedRow) String() string

type SyncRequest

+ Columns []string

+ IncludeDeletes bool

+ IncludeInserts bool

+ IncludeUpdates bool

+ func (x *SyncRequest) GetColumns() []string

+ func (x *SyncRequest) GetIncludeDeletes() bool

+ func (x *SyncRequest) GetIncludeInserts() bool

+ func (x *SyncRequest) GetIncludeUpdates() bool

type SyncResponse

+ Deletes []*DeletedRow

+ Updates []*UpdatedRow

+ func (x *SyncResponse) GetDeletes() []*DeletedRow

+ func (x *SyncResponse) GetUpdates() []*UpdatedRow

+ type UpdatedRow struct

+ After *query.QueryResult

+ Before *query.QueryResult

+ func (*UpdatedRow) Descriptor() ([]byte, []int)

+ func (*UpdatedRow) ProtoMessage()

+ func (m *UpdatedRow) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *UpdatedRow) MarshalToVT(dAtA []byte) (int, error)

+ func (m *UpdatedRow) MarshalVT() (dAtA []byte, err error)

+ func (m *UpdatedRow) SizeVT() (n int)

+ func (m *UpdatedRow) UnmarshalVT(dAtA []byte) error

+ func (x *UpdatedRow) GetAfter() *query.QueryResult

+ func (x *UpdatedRow) GetBefore() *query.QueryResult

+ func (x *UpdatedRow) ProtoReflect() protoreflect.Message

+ func (x *UpdatedRow) Reset()

+ func (x *UpdatedRow) String() string

May 24, 2022

Changes in this version

+ var Connect_ServiceDesc = grpc.ServiceDesc

+ var ErrIntOverflow = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")

+ var File_psdbconnect_v1alpha1_proto protoreflect.FileDescriptor

+ var TabletType_name = map[int32]string

+ var TabletType_value = map[string]int32

+ func RegisterConnectServer(s grpc.ServiceRegistrar, srv ConnectServer)

+ type ConnectClient interface

+ Sync func(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (Connect_SyncClient, error)

+ func NewConnectClient(cc grpc.ClientConnInterface) ConnectClient

+ type ConnectServer interface

+ Sync func(*SyncRequest, Connect_SyncServer) error

+ type Connect_SyncClient interface

+ Recv func() (*SyncResponse, error)

+ type Connect_SyncServer interface

+ Send func(*SyncResponse) error

+ type SyncRequest struct

+ Cursor *TableCursor

+ TableName string

+ TabletType TabletType

+ func (*SyncRequest) Descriptor() ([]byte, []int)

+ func (*SyncRequest) ProtoMessage()

+ func (m *SyncRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SyncRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SyncRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *SyncRequest) SizeVT() (n int)

+ func (m *SyncRequest) UnmarshalVT(dAtA []byte) error

+ func (x *SyncRequest) GetCursor() *TableCursor

+ func (x *SyncRequest) GetTableName() string

+ func (x *SyncRequest) GetTabletType() TabletType

+ func (x *SyncRequest) ProtoReflect() protoreflect.Message

+ func (x *SyncRequest) Reset()

+ func (x *SyncRequest) String() string

+ type SyncResponse struct

+ Cursor *TableCursor

+ Error *vtrpc.RPCError

+ Result []*query.QueryResult

+ func (*SyncResponse) Descriptor() ([]byte, []int)

+ func (*SyncResponse) ProtoMessage()

+ func (m *SyncResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SyncResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SyncResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *SyncResponse) SizeVT() (n int)

+ func (m *SyncResponse) UnmarshalVT(dAtA []byte) error

+ func (x *SyncResponse) GetCursor() *TableCursor

+ func (x *SyncResponse) GetError() *vtrpc.RPCError

+ func (x *SyncResponse) GetResult() []*query.QueryResult

+ func (x *SyncResponse) ProtoReflect() protoreflect.Message

+ func (x *SyncResponse) Reset()

+ func (x *SyncResponse) String() string

+ type TableCursor struct

+ Keyspace string

+ LastKnownPk *query.QueryResult

+ Position string

+ Shard string

+ func (*TableCursor) Descriptor() ([]byte, []int)

+ func (*TableCursor) ProtoMessage()

+ func (m *TableCursor) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *TableCursor) MarshalToVT(dAtA []byte) (int, error)

+ func (m *TableCursor) MarshalVT() (dAtA []byte, err error)

+ func (m *TableCursor) SizeVT() (n int)

+ func (m *TableCursor) UnmarshalVT(dAtA []byte) error

+ func (x *TableCursor) GetKeyspace() string

+ func (x *TableCursor) GetLastKnownPk() *query.QueryResult

+ func (x *TableCursor) GetPosition() string

+ func (x *TableCursor) GetShard() string

+ func (x *TableCursor) ProtoReflect() protoreflect.Message

+ func (x *TableCursor) Reset()

+ func (x *TableCursor) String() string

+ type TabletType int32

+ const TabletType_primary

+ const TabletType_replica

+ func (TabletType) Descriptor() protoreflect.EnumDescriptor

+ func (TabletType) EnumDescriptor() ([]byte, []int)

+ func (TabletType) Type() protoreflect.EnumType

+ func (x TabletType) Enum() *TabletType

+ func (x TabletType) Number() protoreflect.EnumNumber

+ func (x TabletType) String() string

+ type UnimplementedConnectServer struct

+ func (UnimplementedConnectServer) Sync(*SyncRequest, Connect_SyncServer) error

+ type UnsafeConnectServer interface