proto

package

Go to main page

Versions in this module

v0

v0.13.2

Jun 13, 2025

v0.13.1

May 30, 2025

v0.13.0

May 25, 2025

Changes in this version

type GetRequest

+ SecondaryIndexName *string

+ func (x *GetRequest) GetSecondaryIndexName() string

type GetResponse

+ SecondaryIndexKey *string

+ func (x *GetResponse) GetSecondaryIndexKey() string

+ type GetSequenceUpdatesRequest struct

+ Key string

+ Shard int64

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

+ func (*GetSequenceUpdatesRequest) ProtoMessage()

+ func (m *GetSequenceUpdatesRequest) CloneMessageVT() proto.Message

+ func (m *GetSequenceUpdatesRequest) CloneVT() *GetSequenceUpdatesRequest

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

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

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

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

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

+ func (m *GetSequenceUpdatesRequest) UnmarshalVTUnsafe(dAtA []byte) error

+ func (this *GetSequenceUpdatesRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *GetSequenceUpdatesRequest) EqualVT(that *GetSequenceUpdatesRequest) bool

+ func (x *GetSequenceUpdatesRequest) GetKey() string

+ func (x *GetSequenceUpdatesRequest) GetShard() int64

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

+ func (x *GetSequenceUpdatesRequest) Reset()

+ func (x *GetSequenceUpdatesRequest) String() string

+ type GetSequenceUpdatesResponse struct

+ HighestSequenceKey string

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

+ func (*GetSequenceUpdatesResponse) ProtoMessage()

+ func (m *GetSequenceUpdatesResponse) CloneMessageVT() proto.Message

+ func (m *GetSequenceUpdatesResponse) CloneVT() *GetSequenceUpdatesResponse

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

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

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

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

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

+ func (m *GetSequenceUpdatesResponse) UnmarshalVTUnsafe(dAtA []byte) error

+ func (this *GetSequenceUpdatesResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *GetSequenceUpdatesResponse) EqualVT(that *GetSequenceUpdatesResponse) bool

+ func (x *GetSequenceUpdatesResponse) GetHighestSequenceKey() string

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

+ func (x *GetSequenceUpdatesResponse) Reset()

+ func (x *GetSequenceUpdatesResponse) String() string

type OxiaClientClient

+ GetSequenceUpdates func(ctx context.Context, in *GetSequenceUpdatesRequest, opts ...grpc.CallOption) (OxiaClient_GetSequenceUpdatesClient, error)

type OxiaClientServer

+ GetSequenceUpdates func(*GetSequenceUpdatesRequest, OxiaClient_GetSequenceUpdatesServer) error

+ type OxiaClient_GetSequenceUpdatesClient interface

+ Recv func() (*GetSequenceUpdatesResponse, error)

+ type OxiaClient_GetSequenceUpdatesServer interface

+ Send func(*GetSequenceUpdatesResponse) error

type UnimplementedOxiaClientServer

+ func (UnimplementedOxiaClientServer) GetSequenceUpdates(*GetSequenceUpdatesRequest, OxiaClient_GetSequenceUpdatesServer) error

v0.12.0

May 15, 2025

v0.11.16

Apr 16, 2025

v0.11.15

Apr 12, 2025

v0.11.14

Mar 27, 2025

v0.11.13

Mar 26, 2025

v0.11.12

Feb 26, 2025

v0.11.11

Jan 24, 2025

v0.11.10

Jan 15, 2025

v0.11.9

Nov 16, 2024

v0.11.8

Nov 16, 2024

v0.11.7

Nov 13, 2024

v0.11.6

Nov 12, 2024

v0.11.5

Nov 12, 2024

v0.11.4

Nov 10, 2024

v0.11.3

Nov 7, 2024

v0.11.2

Oct 21, 2024

v0.11.1

Oct 17, 2024

v0.11.0

Oct 8, 2024

Changes in this version

type ListRequest

+ SecondaryIndexName *string

+ func (x *ListRequest) GetSecondaryIndexName() string

type PutRequest

+ SecondaryIndexes []*SecondaryIndex

+ func (x *PutRequest) GetSecondaryIndexes() []*SecondaryIndex

type RangeScanRequest

+ SecondaryIndexName *string

+ func (x *RangeScanRequest) GetSecondaryIndexName() string

+ type SecondaryIndex struct

+ IndexName string

+ SecondaryKey string

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

+ func (*SecondaryIndex) ProtoMessage()

+ func (m *SecondaryIndex) CloneMessageVT() proto.Message

+ func (m *SecondaryIndex) CloneVT() *SecondaryIndex

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

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

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

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

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

+ func (m *SecondaryIndex) UnmarshalVTUnsafe(dAtA []byte) error

+ func (this *SecondaryIndex) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *SecondaryIndex) EqualVT(that *SecondaryIndex) bool

+ func (x *SecondaryIndex) GetIndexName() string

+ func (x *SecondaryIndex) GetSecondaryKey() string

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

+ func (x *SecondaryIndex) Reset()

+ func (x *SecondaryIndex) String() string

type StorageEntry

+ SecondaryIndexes []*SecondaryIndex

+ func (x *StorageEntry) GetSecondaryIndexes() []*SecondaryIndex

v0.10.0

Sep 25, 2024

Changes in this version

+ type NewTermOptions struct

+ EnableNotifications bool

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

+ func (*NewTermOptions) ProtoMessage()

+ func (m *NewTermOptions) CloneMessageVT() proto.Message

+ func (m *NewTermOptions) CloneVT() *NewTermOptions

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

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

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

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

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

+ func (m *NewTermOptions) UnmarshalVTUnsafe(dAtA []byte) error

+ func (this *NewTermOptions) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *NewTermOptions) EqualVT(that *NewTermOptions) bool

+ func (x *NewTermOptions) GetEnableNotifications() bool

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

+ func (x *NewTermOptions) Reset()

+ func (x *NewTermOptions) String() string

type NewTermRequest

+ Options *NewTermOptions

+ func (x *NewTermRequest) GetOptions() *NewTermOptions

type Notification

+ KeyRangeLast *string

+ func (x *Notification) GetKeyRangeLast() string

type NotificationType

+ const NotificationType_KEY_RANGE_DELETED

v0.10.0-debug

Oct 11, 2024

v0.9.2-snapshot

Sep 23, 2024

v0.9.1

Sep 19, 2024

v0.9.0

Sep 14, 2024

Changes in this version

type AddFollowerRequest

+ Shard int64

+ func (x *AddFollowerRequest) GetShard() int64

type BecomeLeaderRequest

+ Shard int64

+ func (x *BecomeLeaderRequest) GetShard() int64

type CloseSessionRequest

+ Shard int64

+ func (x *CloseSessionRequest) GetShard() int64

type CreateSessionRequest

+ Shard int64

+ func (x *CreateSessionRequest) GetShard() int64

type DeleteShardRequest

+ Shard int64

+ func (x *DeleteShardRequest) GetShard() int64

type GetStatusRequest

+ Shard int64

+ func (x *GetStatusRequest) GetShard() int64

type ListRequest

+ Shard *int64

+ func (x *ListRequest) GetShard() int64

type NewTermRequest

+ Shard int64

+ func (x *NewTermRequest) GetShard() int64

type NotificationBatch

+ Shard int64

+ func (x *NotificationBatch) GetShard() int64

type NotificationsRequest

+ Shard int64

+ func (x *NotificationsRequest) GetShard() int64

type RangeScanRequest

+ Shard *int64

+ func (x *RangeScanRequest) GetShard() int64

type ReadRequest

+ Shard *int64

+ func (x *ReadRequest) GetShard() int64

type SessionHeartbeat

+ Shard int64

+ func (x *SessionHeartbeat) GetShard() int64

type ShardAssignment

+ Shard int64

+ func (x *ShardAssignment) GetShard() int64

type TruncateRequest

+ Shard int64

+ func (x *TruncateRequest) GetShard() int64

type WriteRequest

+ Shard *int64

+ func (x *WriteRequest) GetShard() int64

v0.8.0

Aug 30, 2024

v0.7.0

Aug 27, 2024

Changes in this version

type OxiaClientClient

+ WriteStream func(ctx context.Context, opts ...grpc.CallOption) (OxiaClient_WriteStreamClient, error)

type OxiaClientServer

+ WriteStream func(OxiaClient_WriteStreamServer) error

+ type OxiaClient_WriteStreamClient interface

+ Recv func() (*WriteResponse, error)

+ Send func(*WriteRequest) error

+ type OxiaClient_WriteStreamServer interface

+ Recv func() (*WriteRequest, error)

+ Send func(*WriteResponse) error

type UnimplementedOxiaClientServer

+ func (UnimplementedOxiaClientServer) WriteStream(OxiaClient_WriteStreamServer) error

v0.6.0

Jun 26, 2024

v0.5.0

May 20, 2024

Changes in this version

+ var KeyComparisonType_name = map[int32]string

+ var KeyComparisonType_value = map[string]int32

type Ack

+ func (m *Ack) UnmarshalVTUnsafe(dAtA []byte) error

type AddFollowerRequest

+ func (m *AddFollowerRequest) UnmarshalVTUnsafe(dAtA []byte) error

type AddFollowerResponse

+ func (m *AddFollowerResponse) UnmarshalVTUnsafe(dAtA []byte) error

type Append

+ func (m *Append) UnmarshalVTUnsafe(dAtA []byte) error

type BecomeLeaderRequest

+ func (m *BecomeLeaderRequest) UnmarshalVTUnsafe(dAtA []byte) error

type BecomeLeaderResponse

+ func (m *BecomeLeaderResponse) UnmarshalVTUnsafe(dAtA []byte) error

type CloseSessionRequest

+ func (m *CloseSessionRequest) UnmarshalVTUnsafe(dAtA []byte) error

type CloseSessionResponse

+ func (m *CloseSessionResponse) UnmarshalVTUnsafe(dAtA []byte) error

type CoordinationShardAssignmentsResponse

+ func (m *CoordinationShardAssignmentsResponse) UnmarshalVTUnsafe(dAtA []byte) error

type CreateSessionRequest

+ func (m *CreateSessionRequest) UnmarshalVTUnsafe(dAtA []byte) error

type CreateSessionResponse

+ func (m *CreateSessionResponse) UnmarshalVTUnsafe(dAtA []byte) error

type DeleteRangeRequest

+ func (m *DeleteRangeRequest) UnmarshalVTUnsafe(dAtA []byte) error

type DeleteRangeResponse

+ func (m *DeleteRangeResponse) UnmarshalVTUnsafe(dAtA []byte) error

type DeleteRequest

+ func (m *DeleteRequest) UnmarshalVTUnsafe(dAtA []byte) error

type DeleteResponse

+ func (m *DeleteResponse) UnmarshalVTUnsafe(dAtA []byte) error

type DeleteShardRequest

+ func (m *DeleteShardRequest) UnmarshalVTUnsafe(dAtA []byte) error

type DeleteShardResponse

+ func (m *DeleteShardResponse) UnmarshalVTUnsafe(dAtA []byte) error

type EntryId

+ func (m *EntryId) UnmarshalVTUnsafe(dAtA []byte) error

type GetRequest

+ ComparisonType KeyComparisonType

+ func (m *GetRequest) UnmarshalVTUnsafe(dAtA []byte) error

+ func (x *GetRequest) GetComparisonType() KeyComparisonType

type GetResponse

+ Key *string

+ func (m *GetResponse) UnmarshalVTUnsafe(dAtA []byte) error

+ func (x *GetResponse) GetKey() string

type GetStatusRequest

+ func (m *GetStatusRequest) UnmarshalVTUnsafe(dAtA []byte) error

type GetStatusResponse

+ func (m *GetStatusResponse) UnmarshalVTUnsafe(dAtA []byte) error

type Int32HashRange

+ func (m *Int32HashRange) UnmarshalVTUnsafe(dAtA []byte) error

type KeepAliveResponse

+ func (m *KeepAliveResponse) UnmarshalVTUnsafe(dAtA []byte) error

+ type KeyComparisonType int32

+ const KeyComparisonType_CEILING

+ const KeyComparisonType_EQUAL

+ const KeyComparisonType_FLOOR

+ const KeyComparisonType_HIGHER

+ const KeyComparisonType_LOWER

+ func (KeyComparisonType) Descriptor() protoreflect.EnumDescriptor

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

+ func (KeyComparisonType) Type() protoreflect.EnumType

+ func (x KeyComparisonType) Enum() *KeyComparisonType

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

+ func (x KeyComparisonType) String() string

type ListRequest

+ func (m *ListRequest) UnmarshalVTUnsafe(dAtA []byte) error

type ListResponse

+ func (m *ListResponse) UnmarshalVTUnsafe(dAtA []byte) error

type LogEntry

+ func (m *LogEntry) UnmarshalVTUnsafe(dAtA []byte) error

type LogEntryValue

+ func (m *LogEntryValue) UnmarshalVTUnsafe(dAtA []byte) error

type NamespaceShardsAssignment

+ func (m *NamespaceShardsAssignment) UnmarshalVTUnsafe(dAtA []byte) error

type NewTermRequest

+ func (m *NewTermRequest) UnmarshalVTUnsafe(dAtA []byte) error

type NewTermResponse

+ func (m *NewTermResponse) UnmarshalVTUnsafe(dAtA []byte) error

type Notification

+ func (m *Notification) UnmarshalVTUnsafe(dAtA []byte) error

type NotificationBatch

+ func (m *NotificationBatch) UnmarshalVTUnsafe(dAtA []byte) error

type NotificationsRequest

+ func (m *NotificationsRequest) UnmarshalVTUnsafe(dAtA []byte) error

type OxiaClientClient

+ RangeScan func(ctx context.Context, in *RangeScanRequest, opts ...grpc.CallOption) (OxiaClient_RangeScanClient, error)

type OxiaClientServer

+ RangeScan func(*RangeScanRequest, OxiaClient_RangeScanServer) error

+ type OxiaClient_RangeScanClient interface

+ Recv func() (*RangeScanResponse, error)

+ type OxiaClient_RangeScanServer interface

+ Send func(*RangeScanResponse) error

type PutRequest

+ PartitionKey *string

+ SequenceKeyDelta []uint64

+ func (m *PutRequest) UnmarshalVTUnsafe(dAtA []byte) error

+ func (x *PutRequest) GetPartitionKey() string

+ func (x *PutRequest) GetSequenceKeyDelta() []uint64

type PutResponse

+ Key *string

+ func (m *PutResponse) UnmarshalVTUnsafe(dAtA []byte) error

+ func (x *PutResponse) GetKey() string

+ type RangeScanRequest struct

+ EndExclusive string

+ ShardId *int64

+ StartInclusive string

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

+ func (*RangeScanRequest) ProtoMessage()

+ func (m *RangeScanRequest) CloneMessageVT() proto.Message

+ func (m *RangeScanRequest) CloneVT() *RangeScanRequest

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

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

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

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

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

+ func (m *RangeScanRequest) UnmarshalVTUnsafe(dAtA []byte) error

+ func (this *RangeScanRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *RangeScanRequest) EqualVT(that *RangeScanRequest) bool

+ func (x *RangeScanRequest) GetEndExclusive() string

+ func (x *RangeScanRequest) GetShardId() int64

+ func (x *RangeScanRequest) GetStartInclusive() string

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

+ func (x *RangeScanRequest) Reset()

+ func (x *RangeScanRequest) String() string

+ type RangeScanResponse struct

+ Records []*GetResponse

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

+ func (*RangeScanResponse) ProtoMessage()

+ func (m *RangeScanResponse) CloneMessageVT() proto.Message

+ func (m *RangeScanResponse) CloneVT() *RangeScanResponse

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

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

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

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

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

+ func (m *RangeScanResponse) UnmarshalVTUnsafe(dAtA []byte) error

+ func (this *RangeScanResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *RangeScanResponse) EqualVT(that *RangeScanResponse) bool

+ func (x *RangeScanResponse) GetRecords() []*GetResponse

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

+ func (x *RangeScanResponse) Reset()

+ func (x *RangeScanResponse) String() string

type ReadRequest

+ func (m *ReadRequest) UnmarshalVTUnsafe(dAtA []byte) error

type ReadResponse

+ func (m *ReadResponse) UnmarshalVTUnsafe(dAtA []byte) error

type SessionHeartbeat

+ func (m *SessionHeartbeat) UnmarshalVTUnsafe(dAtA []byte) error

type SessionMetadata

+ func (m *SessionMetadata) UnmarshalVTUnsafe(dAtA []byte) error

type ShardAssignment

+ func (m *ShardAssignment) UnmarshalVTUnsafe(dAtA []byte) error

type ShardAssignments

+ func (m *ShardAssignments) UnmarshalVTUnsafe(dAtA []byte) error

type ShardAssignmentsRequest

+ func (m *ShardAssignmentsRequest) UnmarshalVTUnsafe(dAtA []byte) error

type SnapshotChunk

+ func (m *SnapshotChunk) UnmarshalVTUnsafe(dAtA []byte) error

type SnapshotResponse

+ func (m *SnapshotResponse) UnmarshalVTUnsafe(dAtA []byte) error

type StorageEntry

+ PartitionKey *string

+ func (m *StorageEntry) UnmarshalVTUnsafe(dAtA []byte) error

+ func (x *StorageEntry) GetPartitionKey() string

type TruncateRequest

+ func (m *TruncateRequest) UnmarshalVTUnsafe(dAtA []byte) error

type TruncateResponse

+ func (m *TruncateResponse) UnmarshalVTUnsafe(dAtA []byte) error

type UnimplementedOxiaClientServer

+ func (UnimplementedOxiaClientServer) RangeScan(*RangeScanRequest, OxiaClient_RangeScanServer) error

type Version

+ func (m *Version) UnmarshalVTUnsafe(dAtA []byte) error

type WriteRequest

+ func (m *WriteRequest) UnmarshalVTUnsafe(dAtA []byte) error

type WriteRequests

+ func (m *WriteRequests) UnmarshalVTUnsafe(dAtA []byte) error

type WriteResponse

+ func (m *WriteResponse) UnmarshalVTUnsafe(dAtA []byte) error

v0.4.0

Apr 26, 2024

v0.3.0

Jan 26, 2024

v0.2.1

Nov 30, 2023

Changes in this version

+ var E_Mempool = &file_storage_proto_extTypes[0]

+ 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_client_proto protoreflect.FileDescriptor

+ var File_replication_proto protoreflect.FileDescriptor

+ var File_storage_proto protoreflect.FileDescriptor

+ var NotificationType_name = map[int32]string

+ var NotificationType_value = map[string]int32

+ var OxiaClient_ServiceDesc = grpc.ServiceDesc

+ var OxiaCoordination_ServiceDesc = grpc.ServiceDesc

+ var OxiaLogReplication_ServiceDesc = grpc.ServiceDesc

+ var ServingStatus_name = map[int32]string

+ var ServingStatus_value = map[string]int32

+ var ShardKeyRouter_name = map[int32]string

+ var ShardKeyRouter_value = map[string]int32

+ var Status_name = map[int32]string

+ var Status_value = map[string]int32

+ func RegisterOxiaClientServer(s grpc.ServiceRegistrar, srv OxiaClientServer)

+ func RegisterOxiaCoordinationServer(s grpc.ServiceRegistrar, srv OxiaCoordinationServer)

+ func RegisterOxiaLogReplicationServer(s grpc.ServiceRegistrar, srv OxiaLogReplicationServer)

+ type Ack struct

+ Offset int64

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

+ func (*Ack) ProtoMessage()

+ func (m *Ack) CloneMessageVT() proto.Message

+ func (m *Ack) CloneVT() *Ack

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

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

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

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

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

+ func (this *Ack) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *Ack) EqualVT(that *Ack) bool

+ func (x *Ack) GetOffset() int64

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

+ func (x *Ack) Reset()

+ func (x *Ack) String() string

+ type AddFollowerRequest struct

+ FollowerHeadEntryId *EntryId

+ FollowerName string

+ Namespace string

+ ShardId int64

+ Term int64

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

+ func (*AddFollowerRequest) ProtoMessage()

+ func (m *AddFollowerRequest) CloneMessageVT() proto.Message

+ func (m *AddFollowerRequest) CloneVT() *AddFollowerRequest

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

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

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

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

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

+ func (this *AddFollowerRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *AddFollowerRequest) EqualVT(that *AddFollowerRequest) bool

+ func (x *AddFollowerRequest) GetFollowerHeadEntryId() *EntryId

+ func (x *AddFollowerRequest) GetFollowerName() string

+ func (x *AddFollowerRequest) GetNamespace() string

+ func (x *AddFollowerRequest) GetShardId() int64

+ func (x *AddFollowerRequest) GetTerm() int64

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

+ func (x *AddFollowerRequest) Reset()

+ func (x *AddFollowerRequest) String() string

+ type AddFollowerResponse struct

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

+ func (*AddFollowerResponse) ProtoMessage()

+ func (m *AddFollowerResponse) CloneMessageVT() proto.Message

+ func (m *AddFollowerResponse) CloneVT() *AddFollowerResponse

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

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

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

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

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

+ func (this *AddFollowerResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *AddFollowerResponse) EqualVT(that *AddFollowerResponse) bool

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

+ func (x *AddFollowerResponse) Reset()

+ func (x *AddFollowerResponse) String() string

+ type Append struct

+ CommitOffset int64

+ Entry *LogEntry

+ Term int64

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

+ func (*Append) ProtoMessage()

+ func (m *Append) CloneMessageVT() proto.Message

+ func (m *Append) CloneVT() *Append

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

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

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

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

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

+ func (this *Append) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *Append) EqualVT(that *Append) bool

+ func (x *Append) GetCommitOffset() int64

+ func (x *Append) GetEntry() *LogEntry

+ func (x *Append) GetTerm() int64

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

+ func (x *Append) Reset()

+ func (x *Append) String() string

+ type BecomeLeaderRequest struct

+ FollowerMaps map[string]*EntryId

+ Namespace string

+ ReplicationFactor uint32

+ ShardId int64

+ Term int64

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

+ func (*BecomeLeaderRequest) ProtoMessage()

+ func (m *BecomeLeaderRequest) CloneMessageVT() proto.Message

+ func (m *BecomeLeaderRequest) CloneVT() *BecomeLeaderRequest

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

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

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

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

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

+ func (this *BecomeLeaderRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *BecomeLeaderRequest) EqualVT(that *BecomeLeaderRequest) bool

+ func (x *BecomeLeaderRequest) GetFollowerMaps() map[string]*EntryId

+ func (x *BecomeLeaderRequest) GetNamespace() string

+ func (x *BecomeLeaderRequest) GetReplicationFactor() uint32

+ func (x *BecomeLeaderRequest) GetShardId() int64

+ func (x *BecomeLeaderRequest) GetTerm() int64

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

+ func (x *BecomeLeaderRequest) Reset()

+ func (x *BecomeLeaderRequest) String() string

+ type BecomeLeaderResponse struct

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

+ func (*BecomeLeaderResponse) ProtoMessage()

+ func (m *BecomeLeaderResponse) CloneMessageVT() proto.Message

+ func (m *BecomeLeaderResponse) CloneVT() *BecomeLeaderResponse

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

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

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

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

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

+ func (this *BecomeLeaderResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *BecomeLeaderResponse) EqualVT(that *BecomeLeaderResponse) bool

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

+ func (x *BecomeLeaderResponse) Reset()

+ func (x *BecomeLeaderResponse) String() string

+ type CloseSessionRequest struct

+ SessionId int64

+ ShardId int64

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

+ func (*CloseSessionRequest) ProtoMessage()

+ func (m *CloseSessionRequest) CloneMessageVT() proto.Message

+ func (m *CloseSessionRequest) CloneVT() *CloseSessionRequest

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

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

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

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

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

+ func (this *CloseSessionRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *CloseSessionRequest) EqualVT(that *CloseSessionRequest) bool

+ func (x *CloseSessionRequest) GetSessionId() int64

+ func (x *CloseSessionRequest) GetShardId() int64

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

+ func (x *CloseSessionRequest) Reset()

+ func (x *CloseSessionRequest) String() string

+ type CloseSessionResponse struct

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

+ func (*CloseSessionResponse) ProtoMessage()

+ func (m *CloseSessionResponse) CloneMessageVT() proto.Message

+ func (m *CloseSessionResponse) CloneVT() *CloseSessionResponse

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

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

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

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

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

+ func (this *CloseSessionResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *CloseSessionResponse) EqualVT(that *CloseSessionResponse) bool

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

+ func (x *CloseSessionResponse) Reset()

+ func (x *CloseSessionResponse) String() string

+ type CoordinationShardAssignmentsResponse struct

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

+ func (*CoordinationShardAssignmentsResponse) ProtoMessage()

+ func (m *CoordinationShardAssignmentsResponse) CloneMessageVT() proto.Message

+ func (m *CoordinationShardAssignmentsResponse) CloneVT() *CoordinationShardAssignmentsResponse

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

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

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

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

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

+ func (this *CoordinationShardAssignmentsResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *CoordinationShardAssignmentsResponse) EqualVT(that *CoordinationShardAssignmentsResponse) bool

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

+ func (x *CoordinationShardAssignmentsResponse) Reset()

+ func (x *CoordinationShardAssignmentsResponse) String() string

+ type CreateSessionRequest struct

+ ClientIdentity string

+ SessionTimeoutMs uint32

+ ShardId int64

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

+ func (*CreateSessionRequest) ProtoMessage()

+ func (m *CreateSessionRequest) CloneMessageVT() proto.Message

+ func (m *CreateSessionRequest) CloneVT() *CreateSessionRequest

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

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

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

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

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

+ func (this *CreateSessionRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *CreateSessionRequest) EqualVT(that *CreateSessionRequest) bool

+ func (x *CreateSessionRequest) GetClientIdentity() string

+ func (x *CreateSessionRequest) GetSessionTimeoutMs() uint32

+ func (x *CreateSessionRequest) GetShardId() int64

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

+ func (x *CreateSessionRequest) Reset()

+ func (x *CreateSessionRequest) String() string

+ type CreateSessionResponse struct

+ SessionId int64

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

+ func (*CreateSessionResponse) ProtoMessage()

+ func (m *CreateSessionResponse) CloneMessageVT() proto.Message

+ func (m *CreateSessionResponse) CloneVT() *CreateSessionResponse

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

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

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

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

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

+ func (this *CreateSessionResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *CreateSessionResponse) EqualVT(that *CreateSessionResponse) bool

+ func (x *CreateSessionResponse) GetSessionId() int64

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

+ func (x *CreateSessionResponse) Reset()

+ func (x *CreateSessionResponse) String() string

+ type DeleteRangeRequest struct

+ EndExclusive string

+ StartInclusive string

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

+ func (*DeleteRangeRequest) ProtoMessage()

+ func (m *DeleteRangeRequest) CloneMessageVT() proto.Message

+ func (m *DeleteRangeRequest) CloneVT() *DeleteRangeRequest

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

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

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

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

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

+ func (this *DeleteRangeRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *DeleteRangeRequest) EqualVT(that *DeleteRangeRequest) bool

+ func (x *DeleteRangeRequest) GetEndExclusive() string

+ func (x *DeleteRangeRequest) GetStartInclusive() string

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

+ func (x *DeleteRangeRequest) Reset()

+ func (x *DeleteRangeRequest) String() string

+ type DeleteRangeResponse struct

+ Status Status

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

+ func (*DeleteRangeResponse) ProtoMessage()

+ func (m *DeleteRangeResponse) CloneMessageVT() proto.Message

+ func (m *DeleteRangeResponse) CloneVT() *DeleteRangeResponse

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

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

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

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

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

+ func (this *DeleteRangeResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *DeleteRangeResponse) EqualVT(that *DeleteRangeResponse) bool

+ func (x *DeleteRangeResponse) GetStatus() Status

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

+ func (x *DeleteRangeResponse) Reset()

+ func (x *DeleteRangeResponse) String() string

+ type DeleteRequest struct

+ ExpectedVersionId *int64

+ Key string

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

+ func (*DeleteRequest) ProtoMessage()

+ func (m *DeleteRequest) CloneMessageVT() proto.Message

+ func (m *DeleteRequest) CloneVT() *DeleteRequest

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

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

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

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

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

+ func (this *DeleteRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *DeleteRequest) EqualVT(that *DeleteRequest) bool

+ func (x *DeleteRequest) GetExpectedVersionId() int64

+ func (x *DeleteRequest) GetKey() string

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

+ func (x *DeleteRequest) Reset()

+ func (x *DeleteRequest) String() string

+ type DeleteResponse struct

+ Status Status

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

+ func (*DeleteResponse) ProtoMessage()

+ func (m *DeleteResponse) CloneMessageVT() proto.Message

+ func (m *DeleteResponse) CloneVT() *DeleteResponse

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

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

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

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

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

+ func (this *DeleteResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *DeleteResponse) EqualVT(that *DeleteResponse) bool

+ func (x *DeleteResponse) GetStatus() Status

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

+ func (x *DeleteResponse) Reset()

+ func (x *DeleteResponse) String() string

+ type DeleteShardRequest struct

+ Namespace string

+ ShardId int64

+ Term int64

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

+ func (*DeleteShardRequest) ProtoMessage()

+ func (m *DeleteShardRequest) CloneMessageVT() proto.Message

+ func (m *DeleteShardRequest) CloneVT() *DeleteShardRequest

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

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

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

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

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

+ func (this *DeleteShardRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *DeleteShardRequest) EqualVT(that *DeleteShardRequest) bool

+ func (x *DeleteShardRequest) GetNamespace() string

+ func (x *DeleteShardRequest) GetShardId() int64

+ func (x *DeleteShardRequest) GetTerm() int64

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

+ func (x *DeleteShardRequest) Reset()

+ func (x *DeleteShardRequest) String() string

+ type DeleteShardResponse struct

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

+ func (*DeleteShardResponse) ProtoMessage()

+ func (m *DeleteShardResponse) CloneMessageVT() proto.Message

+ func (m *DeleteShardResponse) CloneVT() *DeleteShardResponse

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

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

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

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

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

+ func (this *DeleteShardResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *DeleteShardResponse) EqualVT(that *DeleteShardResponse) bool

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

+ func (x *DeleteShardResponse) Reset()

+ func (x *DeleteShardResponse) String() string

+ type EntryId struct

+ Offset int64

+ Term int64

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

+ func (*EntryId) ProtoMessage()

+ func (m *EntryId) CloneMessageVT() proto.Message

+ func (m *EntryId) CloneVT() *EntryId

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

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

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

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

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

+ func (this *EntryId) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *EntryId) EqualVT(that *EntryId) bool

+ func (x *EntryId) GetOffset() int64

+ func (x *EntryId) GetTerm() int64

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

+ func (x *EntryId) Reset()

+ func (x *EntryId) String() string

+ type GetRequest struct

+ IncludeValue bool

+ Key string

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

+ func (*GetRequest) ProtoMessage()

+ func (m *GetRequest) CloneMessageVT() proto.Message

+ func (m *GetRequest) CloneVT() *GetRequest

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

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

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

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

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

+ func (this *GetRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *GetRequest) EqualVT(that *GetRequest) bool

+ func (x *GetRequest) GetIncludeValue() bool

+ func (x *GetRequest) GetKey() string

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

+ func (x *GetRequest) Reset()

+ func (x *GetRequest) String() string

+ type GetResponse struct

+ Status Status

+ Value []byte

+ Version *Version

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

+ func (*GetResponse) ProtoMessage()

+ func (m *GetResponse) CloneMessageVT() proto.Message

+ func (m *GetResponse) CloneVT() *GetResponse

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

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

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

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

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

+ func (this *GetResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *GetResponse) EqualVT(that *GetResponse) bool

+ func (x *GetResponse) GetStatus() Status

+ func (x *GetResponse) GetValue() []byte

+ func (x *GetResponse) GetVersion() *Version

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

+ func (x *GetResponse) Reset()

+ func (x *GetResponse) String() string

+ type GetStatusRequest struct

+ ShardId int64

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

+ func (*GetStatusRequest) ProtoMessage()

+ func (m *GetStatusRequest) CloneMessageVT() proto.Message

+ func (m *GetStatusRequest) CloneVT() *GetStatusRequest

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

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

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

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

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

+ func (this *GetStatusRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *GetStatusRequest) EqualVT(that *GetStatusRequest) bool

+ func (x *GetStatusRequest) GetShardId() int64

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

+ func (x *GetStatusRequest) Reset()

+ func (x *GetStatusRequest) String() string

+ type GetStatusResponse struct

+ CommitOffset int64

+ HeadOffset int64

+ Status ServingStatus

+ Term int64

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

+ func (*GetStatusResponse) ProtoMessage()

+ func (m *GetStatusResponse) CloneMessageVT() proto.Message

+ func (m *GetStatusResponse) CloneVT() *GetStatusResponse

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

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

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

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

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

+ func (this *GetStatusResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *GetStatusResponse) EqualVT(that *GetStatusResponse) bool

+ func (x *GetStatusResponse) GetCommitOffset() int64

+ func (x *GetStatusResponse) GetHeadOffset() int64

+ func (x *GetStatusResponse) GetStatus() ServingStatus

+ func (x *GetStatusResponse) GetTerm() int64

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

+ func (x *GetStatusResponse) Reset()

+ func (x *GetStatusResponse) String() string

+ type Int32HashRange struct

+ MaxHashInclusive uint32

+ MinHashInclusive uint32

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

+ func (*Int32HashRange) ProtoMessage()

+ func (m *Int32HashRange) CloneMessageVT() proto.Message

+ func (m *Int32HashRange) CloneVT() *Int32HashRange

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

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

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

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

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

+ func (this *Int32HashRange) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *Int32HashRange) EqualVT(that *Int32HashRange) bool

+ func (x *Int32HashRange) GetMaxHashInclusive() uint32

+ func (x *Int32HashRange) GetMinHashInclusive() uint32

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

+ func (x *Int32HashRange) Reset()

+ func (x *Int32HashRange) String() string

+ type KeepAliveResponse struct

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

+ func (*KeepAliveResponse) ProtoMessage()

+ func (m *KeepAliveResponse) CloneMessageVT() proto.Message

+ func (m *KeepAliveResponse) CloneVT() *KeepAliveResponse

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

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

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

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

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

+ func (this *KeepAliveResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *KeepAliveResponse) EqualVT(that *KeepAliveResponse) bool

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

+ func (x *KeepAliveResponse) Reset()

+ func (x *KeepAliveResponse) String() string

+ type ListRequest struct

+ EndExclusive string

+ ShardId *int64

+ StartInclusive string

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

+ func (*ListRequest) ProtoMessage()

+ func (m *ListRequest) CloneMessageVT() proto.Message

+ func (m *ListRequest) CloneVT() *ListRequest

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

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

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

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

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

+ func (this *ListRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *ListRequest) EqualVT(that *ListRequest) bool

+ func (x *ListRequest) GetEndExclusive() string

+ func (x *ListRequest) GetShardId() int64

+ func (x *ListRequest) GetStartInclusive() string

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

+ func (x *ListRequest) Reset()

+ func (x *ListRequest) String() string

+ type ListResponse struct

+ Keys []string

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

+ func (*ListResponse) ProtoMessage()

+ func (m *ListResponse) CloneMessageVT() proto.Message

+ func (m *ListResponse) CloneVT() *ListResponse

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

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

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

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

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

+ func (this *ListResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *ListResponse) EqualVT(that *ListResponse) bool

+ func (x *ListResponse) GetKeys() []string

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

+ func (x *ListResponse) Reset()

+ func (x *ListResponse) String() string

+ type LogEntry struct

+ Offset int64

+ Term int64

+ Timestamp uint64

+ Value []byte

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

+ func (*LogEntry) ProtoMessage()

+ func (m *LogEntry) CloneMessageVT() proto.Message

+ func (m *LogEntry) CloneVT() *LogEntry

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

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

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

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

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

+ func (this *LogEntry) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *LogEntry) EqualVT(that *LogEntry) bool

+ func (x *LogEntry) GetOffset() int64

+ func (x *LogEntry) GetTerm() int64

+ func (x *LogEntry) GetTimestamp() uint64

+ func (x *LogEntry) GetValue() []byte

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

+ func (x *LogEntry) Reset()

+ func (x *LogEntry) String() string

+ type LogEntryValue struct

+ Value isLogEntryValue_Value

+ func LogEntryValueFromVTPool() *LogEntryValue

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

+ func (*LogEntryValue) ProtoMessage()

+ func (m *LogEntryValue) CloneMessageVT() proto.Message

+ func (m *LogEntryValue) CloneVT() *LogEntryValue

+ func (m *LogEntryValue) GetValue() isLogEntryValue_Value

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

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

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

+ func (m *LogEntryValue) ResetVT()

+ func (m *LogEntryValue) ReturnToVTPool()

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

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

+ func (this *LogEntryValue) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *LogEntryValue) EqualVT(that *LogEntryValue) bool

+ func (x *LogEntryValue) GetRequests() *WriteRequests

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

+ func (x *LogEntryValue) Reset()

+ func (x *LogEntryValue) String() string

+ type LogEntryValue_Requests struct

+ Requests *WriteRequests

+ func (m *LogEntryValue_Requests) CloneVT() isLogEntryValue_Value

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

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

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

+ func (this *LogEntryValue_Requests) EqualVT(thatIface isLogEntryValue_Value) bool

+ type NamespaceShardsAssignment struct

+ Assignments []*ShardAssignment

+ ShardKeyRouter ShardKeyRouter

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

+ func (*NamespaceShardsAssignment) ProtoMessage()

+ func (m *NamespaceShardsAssignment) CloneMessageVT() proto.Message

+ func (m *NamespaceShardsAssignment) CloneVT() *NamespaceShardsAssignment

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

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

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

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

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

+ func (this *NamespaceShardsAssignment) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *NamespaceShardsAssignment) EqualVT(that *NamespaceShardsAssignment) bool

+ func (x *NamespaceShardsAssignment) GetAssignments() []*ShardAssignment

+ func (x *NamespaceShardsAssignment) GetShardKeyRouter() ShardKeyRouter

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

+ func (x *NamespaceShardsAssignment) Reset()

+ func (x *NamespaceShardsAssignment) String() string

+ type NewTermRequest struct

+ Namespace string

+ ShardId int64

+ Term int64

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

+ func (*NewTermRequest) ProtoMessage()

+ func (m *NewTermRequest) CloneMessageVT() proto.Message

+ func (m *NewTermRequest) CloneVT() *NewTermRequest

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

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

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

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

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

+ func (this *NewTermRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *NewTermRequest) EqualVT(that *NewTermRequest) bool

+ func (x *NewTermRequest) GetNamespace() string

+ func (x *NewTermRequest) GetShardId() int64

+ func (x *NewTermRequest) GetTerm() int64

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

+ func (x *NewTermRequest) Reset()

+ func (x *NewTermRequest) String() string

+ type NewTermResponse struct

+ HeadEntryId *EntryId

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

+ func (*NewTermResponse) ProtoMessage()

+ func (m *NewTermResponse) CloneMessageVT() proto.Message

+ func (m *NewTermResponse) CloneVT() *NewTermResponse

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

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

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

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

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

+ func (this *NewTermResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *NewTermResponse) EqualVT(that *NewTermResponse) bool

+ func (x *NewTermResponse) GetHeadEntryId() *EntryId

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

+ func (x *NewTermResponse) Reset()

+ func (x *NewTermResponse) String() string

+ type Notification struct

+ Type NotificationType

+ VersionId *int64

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

+ func (*Notification) ProtoMessage()

+ func (m *Notification) CloneMessageVT() proto.Message

+ func (m *Notification) CloneVT() *Notification

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

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

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

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

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

+ func (this *Notification) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *Notification) EqualVT(that *Notification) bool

+ func (x *Notification) GetType() NotificationType

+ func (x *Notification) GetVersionId() int64

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

+ func (x *Notification) Reset()

+ func (x *Notification) String() string

+ type NotificationBatch struct

+ Notifications map[string]*Notification

+ Offset int64

+ ShardId int64

+ Timestamp uint64

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

+ func (*NotificationBatch) ProtoMessage()

+ func (m *NotificationBatch) CloneMessageVT() proto.Message

+ func (m *NotificationBatch) CloneVT() *NotificationBatch

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

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

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

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

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

+ func (this *NotificationBatch) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *NotificationBatch) EqualVT(that *NotificationBatch) bool

+ func (x *NotificationBatch) GetNotifications() map[string]*Notification

+ func (x *NotificationBatch) GetOffset() int64

+ func (x *NotificationBatch) GetShardId() int64

+ func (x *NotificationBatch) GetTimestamp() uint64

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

+ func (x *NotificationBatch) Reset()

+ func (x *NotificationBatch) String() string

+ type NotificationType int32

+ const NotificationType_KEY_CREATED

+ const NotificationType_KEY_DELETED

+ const NotificationType_KEY_MODIFIED

+ func (NotificationType) Descriptor() protoreflect.EnumDescriptor

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

+ func (NotificationType) Type() protoreflect.EnumType

+ func (x NotificationType) Enum() *NotificationType

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

+ func (x NotificationType) String() string

+ type NotificationsRequest struct

+ ShardId int64

+ StartOffsetExclusive *int64

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

+ func (*NotificationsRequest) ProtoMessage()

+ func (m *NotificationsRequest) CloneMessageVT() proto.Message

+ func (m *NotificationsRequest) CloneVT() *NotificationsRequest

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

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

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

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

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

+ func (this *NotificationsRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *NotificationsRequest) EqualVT(that *NotificationsRequest) bool

+ func (x *NotificationsRequest) GetShardId() int64

+ func (x *NotificationsRequest) GetStartOffsetExclusive() int64

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

+ func (x *NotificationsRequest) Reset()

+ func (x *NotificationsRequest) String() string

+ type OxiaClientClient interface

+ CloseSession func(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)

+ CreateSession func(ctx context.Context, in *CreateSessionRequest, opts ...grpc.CallOption) (*CreateSessionResponse, error)

+ GetNotifications func(ctx context.Context, in *NotificationsRequest, opts ...grpc.CallOption) (OxiaClient_GetNotificationsClient, error)

+ GetShardAssignments func(ctx context.Context, in *ShardAssignmentsRequest, opts ...grpc.CallOption) (OxiaClient_GetShardAssignmentsClient, error)

+ KeepAlive func(ctx context.Context, in *SessionHeartbeat, opts ...grpc.CallOption) (*KeepAliveResponse, error)

+ List func(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (OxiaClient_ListClient, error)

+ Read func(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (OxiaClient_ReadClient, error)

+ Write func(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)

+ func NewOxiaClientClient(cc grpc.ClientConnInterface) OxiaClientClient

+ type OxiaClientServer interface

+ CloseSession func(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)

+ CreateSession func(context.Context, *CreateSessionRequest) (*CreateSessionResponse, error)

+ GetNotifications func(*NotificationsRequest, OxiaClient_GetNotificationsServer) error

+ GetShardAssignments func(*ShardAssignmentsRequest, OxiaClient_GetShardAssignmentsServer) error

+ KeepAlive func(context.Context, *SessionHeartbeat) (*KeepAliveResponse, error)

+ List func(*ListRequest, OxiaClient_ListServer) error

+ Read func(*ReadRequest, OxiaClient_ReadServer) error

+ Write func(context.Context, *WriteRequest) (*WriteResponse, error)

+ type OxiaClient_GetNotificationsClient interface

+ Recv func() (*NotificationBatch, error)

+ type OxiaClient_GetNotificationsServer interface

+ Send func(*NotificationBatch) error

+ type OxiaClient_GetShardAssignmentsClient interface

+ Recv func() (*ShardAssignments, error)

+ type OxiaClient_GetShardAssignmentsServer interface

+ Send func(*ShardAssignments) error

+ type OxiaClient_ListClient interface

+ Recv func() (*ListResponse, error)

+ type OxiaClient_ListServer interface

+ Send func(*ListResponse) error

+ type OxiaClient_ReadClient interface

+ Recv func() (*ReadResponse, error)

+ type OxiaClient_ReadServer interface

+ Send func(*ReadResponse) error

+ type OxiaCoordinationClient interface

+ AddFollower func(ctx context.Context, in *AddFollowerRequest, opts ...grpc.CallOption) (*AddFollowerResponse, error)

+ BecomeLeader func(ctx context.Context, in *BecomeLeaderRequest, opts ...grpc.CallOption) (*BecomeLeaderResponse, error)

+ DeleteShard func(ctx context.Context, in *DeleteShardRequest, opts ...grpc.CallOption) (*DeleteShardResponse, error)

+ GetStatus func(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*GetStatusResponse, error)

+ NewTerm func(ctx context.Context, in *NewTermRequest, opts ...grpc.CallOption) (*NewTermResponse, error)

+ PushShardAssignments func(ctx context.Context, opts ...grpc.CallOption) (OxiaCoordination_PushShardAssignmentsClient, error)

+ func NewOxiaCoordinationClient(cc grpc.ClientConnInterface) OxiaCoordinationClient

+ type OxiaCoordinationServer interface

+ AddFollower func(context.Context, *AddFollowerRequest) (*AddFollowerResponse, error)

+ BecomeLeader func(context.Context, *BecomeLeaderRequest) (*BecomeLeaderResponse, error)

+ DeleteShard func(context.Context, *DeleteShardRequest) (*DeleteShardResponse, error)

+ GetStatus func(context.Context, *GetStatusRequest) (*GetStatusResponse, error)

+ NewTerm func(context.Context, *NewTermRequest) (*NewTermResponse, error)

+ PushShardAssignments func(OxiaCoordination_PushShardAssignmentsServer) error

+ type OxiaCoordination_PushShardAssignmentsClient interface

+ CloseAndRecv func() (*CoordinationShardAssignmentsResponse, error)

+ Send func(*ShardAssignments) error

+ type OxiaCoordination_PushShardAssignmentsServer interface

+ Recv func() (*ShardAssignments, error)

+ SendAndClose func(*CoordinationShardAssignmentsResponse) error

+ type OxiaLogReplicationClient interface

+ Replicate func(ctx context.Context, opts ...grpc.CallOption) (OxiaLogReplication_ReplicateClient, error)

+ SendSnapshot func(ctx context.Context, opts ...grpc.CallOption) (OxiaLogReplication_SendSnapshotClient, error)

+ Truncate func(ctx context.Context, in *TruncateRequest, opts ...grpc.CallOption) (*TruncateResponse, error)

+ func NewOxiaLogReplicationClient(cc grpc.ClientConnInterface) OxiaLogReplicationClient

+ type OxiaLogReplicationServer interface

+ Replicate func(OxiaLogReplication_ReplicateServer) error

+ SendSnapshot func(OxiaLogReplication_SendSnapshotServer) error

+ Truncate func(context.Context, *TruncateRequest) (*TruncateResponse, error)

+ type OxiaLogReplication_ReplicateClient interface

+ Recv func() (*Ack, error)

+ Send func(*Append) error

+ type OxiaLogReplication_ReplicateServer interface

+ Recv func() (*Append, error)

+ Send func(*Ack) error

+ type OxiaLogReplication_SendSnapshotClient interface

+ CloseAndRecv func() (*SnapshotResponse, error)

+ Send func(*SnapshotChunk) error

+ type OxiaLogReplication_SendSnapshotServer interface

+ Recv func() (*SnapshotChunk, error)

+ SendAndClose func(*SnapshotResponse) error

+ type PutRequest struct

+ ClientIdentity *string

+ ExpectedVersionId *int64

+ Key string

+ SessionId *int64

+ Value []byte

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

+ func (*PutRequest) ProtoMessage()

+ func (m *PutRequest) CloneMessageVT() proto.Message

+ func (m *PutRequest) CloneVT() *PutRequest

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

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

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

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

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

+ func (this *PutRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *PutRequest) EqualVT(that *PutRequest) bool

+ func (x *PutRequest) GetClientIdentity() string

+ func (x *PutRequest) GetExpectedVersionId() int64

+ func (x *PutRequest) GetKey() string

+ func (x *PutRequest) GetSessionId() int64

+ func (x *PutRequest) GetValue() []byte

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

+ func (x *PutRequest) Reset()

+ func (x *PutRequest) String() string

+ type PutResponse struct

+ Status Status

+ Version *Version

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

+ func (*PutResponse) ProtoMessage()

+ func (m *PutResponse) CloneMessageVT() proto.Message

+ func (m *PutResponse) CloneVT() *PutResponse

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

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

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

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

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

+ func (this *PutResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *PutResponse) EqualVT(that *PutResponse) bool

+ func (x *PutResponse) GetStatus() Status

+ func (x *PutResponse) GetVersion() *Version

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

+ func (x *PutResponse) Reset()

+ func (x *PutResponse) String() string

+ type ReadRequest struct

+ Gets []*GetRequest

+ ShardId *int64

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

+ func (*ReadRequest) ProtoMessage()

+ func (m *ReadRequest) CloneMessageVT() proto.Message

+ func (m *ReadRequest) CloneVT() *ReadRequest

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

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

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

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

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

+ func (this *ReadRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *ReadRequest) EqualVT(that *ReadRequest) bool

+ func (x *ReadRequest) GetGets() []*GetRequest

+ func (x *ReadRequest) GetShardId() int64

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

+ func (x *ReadRequest) Reset()

+ func (x *ReadRequest) String() string

+ type ReadResponse struct

+ Gets []*GetResponse

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

+ func (*ReadResponse) ProtoMessage()

+ func (m *ReadResponse) CloneMessageVT() proto.Message

+ func (m *ReadResponse) CloneVT() *ReadResponse

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

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

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

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

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

+ func (this *ReadResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *ReadResponse) EqualVT(that *ReadResponse) bool

+ func (x *ReadResponse) GetGets() []*GetResponse

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

+ func (x *ReadResponse) Reset()

+ func (x *ReadResponse) String() string

+ type ServingStatus int32

+ const ServingStatus_FENCED

+ const ServingStatus_FOLLOWER

+ const ServingStatus_LEADER

+ const ServingStatus_NOT_MEMBER

+ func (ServingStatus) Descriptor() protoreflect.EnumDescriptor

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

+ func (ServingStatus) Type() protoreflect.EnumType

+ func (x ServingStatus) Enum() *ServingStatus

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

+ func (x ServingStatus) String() string

+ type SessionHeartbeat struct

+ SessionId int64

+ ShardId int64

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

+ func (*SessionHeartbeat) ProtoMessage()

+ func (m *SessionHeartbeat) CloneMessageVT() proto.Message

+ func (m *SessionHeartbeat) CloneVT() *SessionHeartbeat

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

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

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

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

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

+ func (this *SessionHeartbeat) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *SessionHeartbeat) EqualVT(that *SessionHeartbeat) bool

+ func (x *SessionHeartbeat) GetSessionId() int64

+ func (x *SessionHeartbeat) GetShardId() int64

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

+ func (x *SessionHeartbeat) Reset()

+ func (x *SessionHeartbeat) String() string

+ type SessionMetadata struct

+ Identity string

+ TimeoutMs uint32

+ func SessionMetadataFromVTPool() *SessionMetadata

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

+ func (*SessionMetadata) ProtoMessage()

+ func (m *SessionMetadata) CloneMessageVT() proto.Message

+ func (m *SessionMetadata) CloneVT() *SessionMetadata

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

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

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

+ func (m *SessionMetadata) ResetVT()

+ func (m *SessionMetadata) ReturnToVTPool()

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

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

+ func (this *SessionMetadata) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *SessionMetadata) EqualVT(that *SessionMetadata) bool

+ func (x *SessionMetadata) GetIdentity() string

+ func (x *SessionMetadata) GetTimeoutMs() uint32

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

+ func (x *SessionMetadata) Reset()

+ func (x *SessionMetadata) String() string

+ type ShardAssignment struct

+ Leader string

+ ShardBoundaries isShardAssignment_ShardBoundaries

+ ShardId int64

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

+ func (*ShardAssignment) ProtoMessage()

+ func (m *ShardAssignment) CloneMessageVT() proto.Message

+ func (m *ShardAssignment) CloneVT() *ShardAssignment

+ func (m *ShardAssignment) GetShardBoundaries() isShardAssignment_ShardBoundaries

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

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

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

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

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

+ func (this *ShardAssignment) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *ShardAssignment) EqualVT(that *ShardAssignment) bool

+ func (x *ShardAssignment) GetInt32HashRange() *Int32HashRange

+ func (x *ShardAssignment) GetLeader() string

+ func (x *ShardAssignment) GetShardId() int64

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

+ func (x *ShardAssignment) Reset()

+ func (x *ShardAssignment) String() string

+ type ShardAssignment_Int32HashRange struct

+ Int32HashRange *Int32HashRange

+ func (m *ShardAssignment_Int32HashRange) CloneVT() isShardAssignment_ShardBoundaries

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

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

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

+ func (this *ShardAssignment_Int32HashRange) EqualVT(thatIface isShardAssignment_ShardBoundaries) bool

+ type ShardAssignments struct

+ Namespaces map[string]*NamespaceShardsAssignment

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

+ func (*ShardAssignments) ProtoMessage()

+ func (m *ShardAssignments) CloneMessageVT() proto.Message

+ func (m *ShardAssignments) CloneVT() *ShardAssignments

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

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

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

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

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

+ func (this *ShardAssignments) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *ShardAssignments) EqualVT(that *ShardAssignments) bool

+ func (x *ShardAssignments) GetNamespaces() map[string]*NamespaceShardsAssignment

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

+ func (x *ShardAssignments) Reset()

+ func (x *ShardAssignments) String() string

+ type ShardAssignmentsRequest struct

+ Namespace string

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

+ func (*ShardAssignmentsRequest) ProtoMessage()

+ func (m *ShardAssignmentsRequest) CloneMessageVT() proto.Message

+ func (m *ShardAssignmentsRequest) CloneVT() *ShardAssignmentsRequest

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

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

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

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

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

+ func (this *ShardAssignmentsRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *ShardAssignmentsRequest) EqualVT(that *ShardAssignmentsRequest) bool

+ func (x *ShardAssignmentsRequest) GetNamespace() string

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

+ func (x *ShardAssignmentsRequest) Reset()

+ func (x *ShardAssignmentsRequest) String() string

+ type ShardKeyRouter int32

+ const ShardKeyRouter_UNKNOWN

+ const ShardKeyRouter_XXHASH3

+ func (ShardKeyRouter) Descriptor() protoreflect.EnumDescriptor

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

+ func (ShardKeyRouter) Type() protoreflect.EnumType

+ func (x ShardKeyRouter) Enum() *ShardKeyRouter

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

+ func (x ShardKeyRouter) String() string

+ type SnapshotChunk struct

+ ChunkCount int32

+ ChunkIndex int32

+ Content []byte

+ Name string

+ Term int64

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

+ func (*SnapshotChunk) ProtoMessage()

+ func (m *SnapshotChunk) CloneMessageVT() proto.Message

+ func (m *SnapshotChunk) CloneVT() *SnapshotChunk

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

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

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

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

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

+ func (this *SnapshotChunk) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *SnapshotChunk) EqualVT(that *SnapshotChunk) bool

+ func (x *SnapshotChunk) GetChunkCount() int32

+ func (x *SnapshotChunk) GetChunkIndex() int32

+ func (x *SnapshotChunk) GetContent() []byte

+ func (x *SnapshotChunk) GetName() string

+ func (x *SnapshotChunk) GetTerm() int64

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

+ func (x *SnapshotChunk) Reset()

+ func (x *SnapshotChunk) String() string

+ type SnapshotResponse struct

+ AckOffset int64

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

+ func (*SnapshotResponse) ProtoMessage()

+ func (m *SnapshotResponse) CloneMessageVT() proto.Message

+ func (m *SnapshotResponse) CloneVT() *SnapshotResponse

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

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

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

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

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

+ func (this *SnapshotResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *SnapshotResponse) EqualVT(that *SnapshotResponse) bool

+ func (x *SnapshotResponse) GetAckOffset() int64

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

+ func (x *SnapshotResponse) Reset()

+ func (x *SnapshotResponse) String() string

+ type Status int32

+ const Status_KEY_NOT_FOUND

+ const Status_OK

+ const Status_SESSION_DOES_NOT_EXIST

+ const Status_UNEXPECTED_VERSION_ID

+ func (Status) Descriptor() protoreflect.EnumDescriptor

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

+ func (Status) Type() protoreflect.EnumType

+ func (x Status) Enum() *Status

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

+ func (x Status) String() string

+ type StorageEntry struct

+ ClientIdentity *string

+ CreationTimestamp uint64

+ ModificationTimestamp uint64

+ ModificationsCount int64

+ SessionId *int64

+ Value []byte

+ VersionId int64

+ func StorageEntryFromVTPool() *StorageEntry

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

+ func (*StorageEntry) ProtoMessage()

+ func (m *StorageEntry) CloneMessageVT() proto.Message

+ func (m *StorageEntry) CloneVT() *StorageEntry

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

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

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

+ func (m *StorageEntry) ResetVT()

+ func (m *StorageEntry) ReturnToVTPool()

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

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

+ func (this *StorageEntry) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *StorageEntry) EqualVT(that *StorageEntry) bool

+ func (x *StorageEntry) GetClientIdentity() string

+ func (x *StorageEntry) GetCreationTimestamp() uint64

+ func (x *StorageEntry) GetModificationTimestamp() uint64

+ func (x *StorageEntry) GetModificationsCount() int64

+ func (x *StorageEntry) GetSessionId() int64

+ func (x *StorageEntry) GetValue() []byte

+ func (x *StorageEntry) GetVersionId() int64

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

+ func (x *StorageEntry) Reset()

+ func (x *StorageEntry) String() string

+ type TruncateRequest struct

+ HeadEntryId *EntryId

+ Namespace string

+ ShardId int64

+ Term int64

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

+ func (*TruncateRequest) ProtoMessage()

+ func (m *TruncateRequest) CloneMessageVT() proto.Message

+ func (m *TruncateRequest) CloneVT() *TruncateRequest

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

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

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

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

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

+ func (this *TruncateRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *TruncateRequest) EqualVT(that *TruncateRequest) bool

+ func (x *TruncateRequest) GetHeadEntryId() *EntryId

+ func (x *TruncateRequest) GetNamespace() string

+ func (x *TruncateRequest) GetShardId() int64

+ func (x *TruncateRequest) GetTerm() int64

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

+ func (x *TruncateRequest) Reset()

+ func (x *TruncateRequest) String() string

+ type TruncateResponse struct

+ HeadEntryId *EntryId

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

+ func (*TruncateResponse) ProtoMessage()

+ func (m *TruncateResponse) CloneMessageVT() proto.Message

+ func (m *TruncateResponse) CloneVT() *TruncateResponse

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

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

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

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

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

+ func (this *TruncateResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *TruncateResponse) EqualVT(that *TruncateResponse) bool

+ func (x *TruncateResponse) GetHeadEntryId() *EntryId

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

+ func (x *TruncateResponse) Reset()

+ func (x *TruncateResponse) String() string

+ type UnimplementedOxiaClientServer struct

+ func (UnimplementedOxiaClientServer) CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)

+ func (UnimplementedOxiaClientServer) CreateSession(context.Context, *CreateSessionRequest) (*CreateSessionResponse, error)

+ func (UnimplementedOxiaClientServer) GetNotifications(*NotificationsRequest, OxiaClient_GetNotificationsServer) error

+ func (UnimplementedOxiaClientServer) GetShardAssignments(*ShardAssignmentsRequest, OxiaClient_GetShardAssignmentsServer) error

+ func (UnimplementedOxiaClientServer) KeepAlive(context.Context, *SessionHeartbeat) (*KeepAliveResponse, error)

+ func (UnimplementedOxiaClientServer) List(*ListRequest, OxiaClient_ListServer) error

+ func (UnimplementedOxiaClientServer) Read(*ReadRequest, OxiaClient_ReadServer) error

+ func (UnimplementedOxiaClientServer) Write(context.Context, *WriteRequest) (*WriteResponse, error)

+ type UnimplementedOxiaCoordinationServer struct

+ func (UnimplementedOxiaCoordinationServer) AddFollower(context.Context, *AddFollowerRequest) (*AddFollowerResponse, error)

+ func (UnimplementedOxiaCoordinationServer) BecomeLeader(context.Context, *BecomeLeaderRequest) (*BecomeLeaderResponse, error)

+ func (UnimplementedOxiaCoordinationServer) DeleteShard(context.Context, *DeleteShardRequest) (*DeleteShardResponse, error)

+ func (UnimplementedOxiaCoordinationServer) GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)

+ func (UnimplementedOxiaCoordinationServer) NewTerm(context.Context, *NewTermRequest) (*NewTermResponse, error)

+ func (UnimplementedOxiaCoordinationServer) PushShardAssignments(OxiaCoordination_PushShardAssignmentsServer) error

+ type UnimplementedOxiaLogReplicationServer struct

+ func (UnimplementedOxiaLogReplicationServer) Replicate(OxiaLogReplication_ReplicateServer) error

+ func (UnimplementedOxiaLogReplicationServer) SendSnapshot(OxiaLogReplication_SendSnapshotServer) error

+ func (UnimplementedOxiaLogReplicationServer) Truncate(context.Context, *TruncateRequest) (*TruncateResponse, error)

+ type UnsafeOxiaClientServer interface

+ type UnsafeOxiaCoordinationServer interface

+ type UnsafeOxiaLogReplicationServer interface

+ type Version struct

+ ClientIdentity *string

+ CreatedTimestamp uint64

+ ModificationsCount int64

+ ModifiedTimestamp uint64

+ SessionId *int64

+ VersionId int64

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

+ func (*Version) ProtoMessage()

+ func (m *Version) CloneMessageVT() proto.Message

+ func (m *Version) CloneVT() *Version

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

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

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

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

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

+ func (this *Version) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *Version) EqualVT(that *Version) bool

+ func (x *Version) GetClientIdentity() string

+ func (x *Version) GetCreatedTimestamp() uint64

+ func (x *Version) GetModificationsCount() int64

+ func (x *Version) GetModifiedTimestamp() uint64

+ func (x *Version) GetSessionId() int64

+ func (x *Version) GetVersionId() int64

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

+ func (x *Version) Reset()

+ func (x *Version) String() string

+ type WriteRequest struct

+ DeleteRanges []*DeleteRangeRequest

+ Deletes []*DeleteRequest

+ Puts []*PutRequest

+ ShardId *int64

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

+ func (*WriteRequest) ProtoMessage()

+ func (m *WriteRequest) CloneMessageVT() proto.Message

+ func (m *WriteRequest) CloneVT() *WriteRequest

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

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

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

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

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

+ func (this *WriteRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *WriteRequest) EqualVT(that *WriteRequest) bool

+ func (x *WriteRequest) GetDeleteRanges() []*DeleteRangeRequest

+ func (x *WriteRequest) GetDeletes() []*DeleteRequest

+ func (x *WriteRequest) GetPuts() []*PutRequest

+ func (x *WriteRequest) GetShardId() int64

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

+ func (x *WriteRequest) Reset()

+ func (x *WriteRequest) String() string

+ type WriteRequests struct

+ Writes []*WriteRequest

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

+ func (*WriteRequests) ProtoMessage()

+ func (m *WriteRequests) CloneMessageVT() proto.Message

+ func (m *WriteRequests) CloneVT() *WriteRequests

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

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

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

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

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

+ func (this *WriteRequests) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *WriteRequests) EqualVT(that *WriteRequests) bool

+ func (x *WriteRequests) GetWrites() []*WriteRequest

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

+ func (x *WriteRequests) Reset()

+ func (x *WriteRequests) String() string

+ type WriteResponse struct

+ DeleteRanges []*DeleteRangeResponse

+ Deletes []*DeleteResponse

+ Puts []*PutResponse

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

+ func (*WriteResponse) ProtoMessage()

+ func (m *WriteResponse) CloneMessageVT() proto.Message

+ func (m *WriteResponse) CloneVT() *WriteResponse

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

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

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

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

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

+ func (this *WriteResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *WriteResponse) EqualVT(that *WriteResponse) bool

+ func (x *WriteResponse) GetDeleteRanges() []*DeleteRangeResponse

+ func (x *WriteResponse) GetDeletes() []*DeleteResponse

+ func (x *WriteResponse) GetPuts() []*PutResponse

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

+ func (x *WriteResponse) Reset()

+ func (x *WriteResponse) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL