proto

package
v0.11.11 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 24, 2025 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ShardKeyRouter_name = map[int32]string{
		0: "UNKNOWN",
		1: "XXHASH3",
	}
	ShardKeyRouter_value = map[string]int32{
		"UNKNOWN": 0,
		"XXHASH3": 1,
	}
)

Enum value maps for ShardKeyRouter.

View Source 
var (
	KeyComparisonType_name = map[int32]string{
		0: "EQUAL",
		1: "FLOOR",
		2: "CEILING",
		3: "LOWER",
		4: "HIGHER",
	}
	KeyComparisonType_value = map[string]int32{
		"EQUAL":   0,
		"FLOOR":   1,
		"CEILING": 2,
		"LOWER":   3,
		"HIGHER":  4,
	}
)

Enum value maps for KeyComparisonType.

View Source 
var (
	Status_name = map[int32]string{
		0: "OK",
		1: "KEY_NOT_FOUND",
		2: "UNEXPECTED_VERSION_ID",
		3: "SESSION_DOES_NOT_EXIST",
	}
	Status_value = map[string]int32{
		"OK":                     0,
		"KEY_NOT_FOUND":          1,
		"UNEXPECTED_VERSION_ID":  2,
		"SESSION_DOES_NOT_EXIST": 3,
	}
)

Enum value maps for Status.

View Source 
var (
	NotificationType_name = map[int32]string{
		0: "KEY_CREATED",
		1: "KEY_MODIFIED",
		2: "KEY_DELETED",
		3: "KEY_RANGE_DELETED",
	}
	NotificationType_value = map[string]int32{
		"KEY_CREATED":       0,
		"KEY_MODIFIED":      1,
		"KEY_DELETED":       2,
		"KEY_RANGE_DELETED": 3,
	}
)

Enum value maps for NotificationType.

View Source 
var (
	ServingStatus_name = map[int32]string{
		0: "NOT_MEMBER",
		1: "FENCED",
		2: "FOLLOWER",
		3: "LEADER",
	}
	ServingStatus_value = map[string]int32{
		"NOT_MEMBER": 0,
		"FENCED":     1,
		"FOLLOWER":   2,
		"LEADER":     3,
	}
)

Enum value maps for ServingStatus.

View Source 
var (
	// optional bool mempool = 64101;
	E_Mempool = &file_storage_proto_extTypes[0]
)

Extension fields to descriptorpb.MessageOptions.

View Source 
var File_client_proto protoreflect.FileDescriptor
View Source 
var File_replication_proto protoreflect.FileDescriptor
View Source 
var File_storage_proto protoreflect.FileDescriptor
View Source 
var OxiaClient_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "io.streamnative.oxia.proto.OxiaClient",
	HandlerType: (*OxiaClientServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Write",
			Handler:    _OxiaClient_Write_Handler,
		},
		{
			MethodName: "CreateSession",
			Handler:    _OxiaClient_CreateSession_Handler,
		},
		{
			MethodName: "KeepAlive",
			Handler:    _OxiaClient_KeepAlive_Handler,
		},
		{
			MethodName: "CloseSession",
			Handler:    _OxiaClient_CloseSession_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetShardAssignments",
			Handler:       _OxiaClient_GetShardAssignments_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WriteStream",
			Handler:       _OxiaClient_WriteStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "Read",
			Handler:       _OxiaClient_Read_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "List",
			Handler:       _OxiaClient_List_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "RangeScan",
			Handler:       _OxiaClient_RangeScan_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetNotifications",
			Handler:       _OxiaClient_GetNotifications_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "client.proto",
}

OxiaClient_ServiceDesc is the grpc.ServiceDesc for OxiaClient service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var OxiaCoordination_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "replication.OxiaCoordination",
	HandlerType: (*OxiaCoordinationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NewTerm",
			Handler:    _OxiaCoordination_NewTerm_Handler,
		},
		{
			MethodName: "BecomeLeader",
			Handler:    _OxiaCoordination_BecomeLeader_Handler,
		},
		{
			MethodName: "AddFollower",
			Handler:    _OxiaCoordination_AddFollower_Handler,
		},
		{
			MethodName: "GetStatus",
			Handler:    _OxiaCoordination_GetStatus_Handler,
		},
		{
			MethodName: "DeleteShard",
			Handler:    _OxiaCoordination_DeleteShard_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PushShardAssignments",
			Handler:       _OxiaCoordination_PushShardAssignments_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "replication.proto",
}

OxiaCoordination_ServiceDesc is the grpc.ServiceDesc for OxiaCoordination service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var OxiaLogReplication_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "replication.OxiaLogReplication",
	HandlerType: (*OxiaLogReplicationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Truncate",
			Handler:    _OxiaLogReplication_Truncate_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Replicate",
			Handler:       _OxiaLogReplication_Replicate_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SendSnapshot",
			Handler:       _OxiaLogReplication_SendSnapshot_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "replication.proto",
}

OxiaLogReplication_ServiceDesc is the grpc.ServiceDesc for OxiaLogReplication service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterOxiaClientServer 

func RegisterOxiaClientServer(s grpc.ServiceRegistrar, srv OxiaClientServer)

func RegisterOxiaCoordinationServer 

func RegisterOxiaCoordinationServer(s grpc.ServiceRegistrar, srv OxiaCoordinationServer)

func RegisterOxiaLogReplicationServer 

func RegisterOxiaLogReplicationServer(s grpc.ServiceRegistrar, srv OxiaLogReplicationServer)

Types

type Ack 

type Ack struct {
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*Ack) CloneMessageVT 

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

func (*Ack) CloneVT 

func (m *Ack) CloneVT() *Ack

func (*Ack) Descriptor deprecated 

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

Deprecated: Use Ack.ProtoReflect.Descriptor instead.

func (*Ack) EqualMessageVT 

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

func (*Ack) EqualVT 

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

func (*Ack) GetOffset 

func (x *Ack) GetOffset() int64

func (*Ack) MarshalToSizedBufferVT 

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

func (*Ack) MarshalToVT 

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

func (*Ack) MarshalVT 

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

func (*Ack) ProtoMessage 

func (*Ack) ProtoMessage()

func (*Ack) ProtoReflect 

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

func (*Ack) Reset 

func (x *Ack) Reset()

func (*Ack) SizeVT 

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

func (*Ack) String 

func (x *Ack) String() string

func (*Ack) UnmarshalVT 

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

func (*Ack) UnmarshalVTUnsafe added in v0.5.0 

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

type AddFollowerRequest 

type AddFollowerRequest struct {
	Namespace           string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Shard               int64    `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"`
	Term                int64    `protobuf:"varint,3,opt,name=term,proto3" json:"term,omitempty"`
	FollowerName        string   `protobuf:"bytes,4,opt,name=follower_name,json=followerName,proto3" json:"follower_name,omitempty"`
	FollowerHeadEntryId *EntryId `protobuf:"bytes,5,opt,name=follower_head_entry_id,json=followerHeadEntryId,proto3" json:"follower_head_entry_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddFollowerRequest) CloneMessageVT 

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

func (*AddFollowerRequest) CloneVT 

func (m *AddFollowerRequest) CloneVT() *AddFollowerRequest

func (*AddFollowerRequest) Descriptor deprecated 

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

Deprecated: Use AddFollowerRequest.ProtoReflect.Descriptor instead.

func (*AddFollowerRequest) EqualMessageVT 

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

func (*AddFollowerRequest) EqualVT 

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

func (*AddFollowerRequest) GetFollowerHeadEntryId 

func (x *AddFollowerRequest) GetFollowerHeadEntryId() *EntryId

func (*AddFollowerRequest) GetFollowerName 

func (x *AddFollowerRequest) GetFollowerName() string

func (*AddFollowerRequest) GetNamespace 

func (x *AddFollowerRequest) GetNamespace() string

func (*AddFollowerRequest) GetShard added in v0.9.0 

func (x *AddFollowerRequest) GetShard() int64

func (*AddFollowerRequest) GetTerm 

func (x *AddFollowerRequest) GetTerm() int64

func (*AddFollowerRequest) MarshalToSizedBufferVT 

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

func (*AddFollowerRequest) MarshalToVT 

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

func (*AddFollowerRequest) MarshalVT 

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

func (*AddFollowerRequest) ProtoMessage 

func (*AddFollowerRequest) ProtoMessage()

func (*AddFollowerRequest) ProtoReflect 

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

func (*AddFollowerRequest) Reset 

func (x *AddFollowerRequest) Reset()

func (*AddFollowerRequest) SizeVT 

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

func (*AddFollowerRequest) String 

func (x *AddFollowerRequest) String() string

func (*AddFollowerRequest) UnmarshalVT 

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

func (*AddFollowerRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type AddFollowerResponse 

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

func (*AddFollowerResponse) CloneMessageVT 

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

func (*AddFollowerResponse) CloneVT 

func (m *AddFollowerResponse) CloneVT() *AddFollowerResponse

func (*AddFollowerResponse) Descriptor deprecated 

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

Deprecated: Use AddFollowerResponse.ProtoReflect.Descriptor instead.

func (*AddFollowerResponse) EqualMessageVT 

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

func (*AddFollowerResponse) EqualVT 

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

func (*AddFollowerResponse) MarshalToSizedBufferVT 

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

func (*AddFollowerResponse) MarshalToVT 

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

func (*AddFollowerResponse) MarshalVT 

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

func (*AddFollowerResponse) ProtoMessage 

func (*AddFollowerResponse) ProtoMessage()

func (*AddFollowerResponse) ProtoReflect 

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

func (*AddFollowerResponse) Reset 

func (x *AddFollowerResponse) Reset()

func (*AddFollowerResponse) SizeVT 

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

func (*AddFollowerResponse) String 

func (x *AddFollowerResponse) String() string

func (*AddFollowerResponse) UnmarshalVT 

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

func (*AddFollowerResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type Append 

type Append struct {
	Term         int64     `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
	Entry        *LogEntry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"`
	CommitOffset int64     `protobuf:"varint,3,opt,name=commit_offset,json=commitOffset,proto3" json:"commit_offset,omitempty"`
	// contains filtered or unexported fields
}

func (*Append) CloneMessageVT 

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

func (*Append) CloneVT 

func (m *Append) CloneVT() *Append

func (*Append) Descriptor deprecated 

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

Deprecated: Use Append.ProtoReflect.Descriptor instead.

func (*Append) EqualMessageVT 

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

func (*Append) EqualVT 

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

func (*Append) GetCommitOffset 

func (x *Append) GetCommitOffset() int64

func (*Append) GetEntry 

func (x *Append) GetEntry() *LogEntry

func (*Append) GetTerm 

func (x *Append) GetTerm() int64

func (*Append) MarshalToSizedBufferVT 

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

func (*Append) MarshalToVT 

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

func (*Append) MarshalVT 

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

func (*Append) ProtoMessage 

func (*Append) ProtoMessage()

func (*Append) ProtoReflect 

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

func (*Append) Reset 

func (x *Append) Reset()

func (*Append) SizeVT 

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

func (*Append) String 

func (x *Append) String() string

func (*Append) UnmarshalVT 

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

func (*Append) UnmarshalVTUnsafe added in v0.5.0 

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

type BecomeLeaderRequest 

type BecomeLeaderRequest struct {
	Namespace         string              `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Shard             int64               `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"`
	Term              int64               `protobuf:"varint,3,opt,name=term,proto3" json:"term,omitempty"`
	ReplicationFactor uint32              `protobuf:"varint,4,opt,name=replication_factor,json=replicationFactor,proto3" json:"replication_factor,omitempty"`
	FollowerMaps      map[string]*EntryId `` /* 185-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BecomeLeaderRequest) CloneMessageVT 

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

func (*BecomeLeaderRequest) CloneVT 

func (m *BecomeLeaderRequest) CloneVT() *BecomeLeaderRequest

func (*BecomeLeaderRequest) Descriptor deprecated 

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

Deprecated: Use BecomeLeaderRequest.ProtoReflect.Descriptor instead.

func (*BecomeLeaderRequest) EqualMessageVT 

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

func (*BecomeLeaderRequest) EqualVT 

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

func (*BecomeLeaderRequest) GetFollowerMaps 

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

func (*BecomeLeaderRequest) GetNamespace 

func (x *BecomeLeaderRequest) GetNamespace() string

func (*BecomeLeaderRequest) GetReplicationFactor 

func (x *BecomeLeaderRequest) GetReplicationFactor() uint32

func (*BecomeLeaderRequest) GetShard added in v0.9.0 

func (x *BecomeLeaderRequest) GetShard() int64

func (*BecomeLeaderRequest) GetTerm 

func (x *BecomeLeaderRequest) GetTerm() int64

func (*BecomeLeaderRequest) MarshalToSizedBufferVT 

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

func (*BecomeLeaderRequest) MarshalToVT 

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

func (*BecomeLeaderRequest) MarshalVT 

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

func (*BecomeLeaderRequest) ProtoMessage 

func (*BecomeLeaderRequest) ProtoMessage()

func (*BecomeLeaderRequest) ProtoReflect 

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

func (*BecomeLeaderRequest) Reset 

func (x *BecomeLeaderRequest) Reset()

func (*BecomeLeaderRequest) SizeVT 

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

func (*BecomeLeaderRequest) String 

func (x *BecomeLeaderRequest) String() string

func (*BecomeLeaderRequest) UnmarshalVT 

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

func (*BecomeLeaderRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type BecomeLeaderResponse 

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

func (*BecomeLeaderResponse) CloneMessageVT 

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

func (*BecomeLeaderResponse) CloneVT 

func (m *BecomeLeaderResponse) CloneVT() *BecomeLeaderResponse

func (*BecomeLeaderResponse) Descriptor deprecated 

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

Deprecated: Use BecomeLeaderResponse.ProtoReflect.Descriptor instead.

func (*BecomeLeaderResponse) EqualMessageVT 

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

func (*BecomeLeaderResponse) EqualVT 

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

func (*BecomeLeaderResponse) MarshalToSizedBufferVT 

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

func (*BecomeLeaderResponse) MarshalToVT 

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

func (*BecomeLeaderResponse) MarshalVT 

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

func (*BecomeLeaderResponse) ProtoMessage 

func (*BecomeLeaderResponse) ProtoMessage()

func (*BecomeLeaderResponse) ProtoReflect 

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

func (*BecomeLeaderResponse) Reset 

func (x *BecomeLeaderResponse) Reset()

func (*BecomeLeaderResponse) SizeVT 

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

func (*BecomeLeaderResponse) String 

func (x *BecomeLeaderResponse) String() string

func (*BecomeLeaderResponse) UnmarshalVT 

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

func (*BecomeLeaderResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type CloseSessionRequest 

type CloseSessionRequest struct {
	Shard     int64 `protobuf:"varint,1,opt,name=shard,proto3" json:"shard,omitempty"`
	SessionId int64 `protobuf:"varint,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseSessionRequest) CloneMessageVT 

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

func (*CloseSessionRequest) CloneVT 

func (m *CloseSessionRequest) CloneVT() *CloseSessionRequest

func (*CloseSessionRequest) Descriptor deprecated 

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

Deprecated: Use CloseSessionRequest.ProtoReflect.Descriptor instead.

func (*CloseSessionRequest) EqualMessageVT 

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

func (*CloseSessionRequest) EqualVT 

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

func (*CloseSessionRequest) GetSessionId 

func (x *CloseSessionRequest) GetSessionId() int64

func (*CloseSessionRequest) GetShard added in v0.9.0 

func (x *CloseSessionRequest) GetShard() int64

func (*CloseSessionRequest) MarshalToSizedBufferVT 

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

func (*CloseSessionRequest) MarshalToVT 

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

func (*CloseSessionRequest) MarshalVT 

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

func (*CloseSessionRequest) ProtoMessage 

func (*CloseSessionRequest) ProtoMessage()

func (*CloseSessionRequest) ProtoReflect 

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

func (*CloseSessionRequest) Reset 

func (x *CloseSessionRequest) Reset()

func (*CloseSessionRequest) SizeVT 

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

func (*CloseSessionRequest) String 

func (x *CloseSessionRequest) String() string

func (*CloseSessionRequest) UnmarshalVT 

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

func (*CloseSessionRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type CloseSessionResponse 

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

func (*CloseSessionResponse) CloneMessageVT 

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

func (*CloseSessionResponse) CloneVT 

func (m *CloseSessionResponse) CloneVT() *CloseSessionResponse

func (*CloseSessionResponse) Descriptor deprecated 

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

Deprecated: Use CloseSessionResponse.ProtoReflect.Descriptor instead.

func (*CloseSessionResponse) EqualMessageVT 

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

func (*CloseSessionResponse) EqualVT 

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

func (*CloseSessionResponse) MarshalToSizedBufferVT 

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

func (*CloseSessionResponse) MarshalToVT 

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

func (*CloseSessionResponse) MarshalVT 

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

func (*CloseSessionResponse) ProtoMessage 

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) ProtoReflect 

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

func (*CloseSessionResponse) Reset 

func (x *CloseSessionResponse) Reset()

func (*CloseSessionResponse) SizeVT 

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

func (*CloseSessionResponse) String 

func (x *CloseSessionResponse) String() string

func (*CloseSessionResponse) UnmarshalVT 

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

func (*CloseSessionResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type CoordinationShardAssignmentsResponse 

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

func (*CoordinationShardAssignmentsResponse) CloneMessageVT 

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

func (*CoordinationShardAssignmentsResponse) CloneVT 

func (m *CoordinationShardAssignmentsResponse) CloneVT() *CoordinationShardAssignmentsResponse

func (*CoordinationShardAssignmentsResponse) Descriptor deprecated 

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

Deprecated: Use CoordinationShardAssignmentsResponse.ProtoReflect.Descriptor instead.

func (*CoordinationShardAssignmentsResponse) EqualMessageVT 

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

func (*CoordinationShardAssignmentsResponse) EqualVT 

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

func (*CoordinationShardAssignmentsResponse) MarshalToSizedBufferVT 

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

func (*CoordinationShardAssignmentsResponse) MarshalToVT 

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

func (*CoordinationShardAssignmentsResponse) MarshalVT 

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

func (*CoordinationShardAssignmentsResponse) ProtoMessage 

func (*CoordinationShardAssignmentsResponse) ProtoMessage()

func (*CoordinationShardAssignmentsResponse) ProtoReflect 

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

func (*CoordinationShardAssignmentsResponse) Reset 

func (x *CoordinationShardAssignmentsResponse) Reset()

func (*CoordinationShardAssignmentsResponse) SizeVT 

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

func (*CoordinationShardAssignmentsResponse) String 

func (x *CoordinationShardAssignmentsResponse) String() string

func (*CoordinationShardAssignmentsResponse) UnmarshalVT 

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

func (*CoordinationShardAssignmentsResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type CreateSessionRequest 

type CreateSessionRequest struct {
	Shard            int64  `protobuf:"varint,1,opt,name=shard,proto3" json:"shard,omitempty"`
	SessionTimeoutMs uint32 `protobuf:"varint,2,opt,name=session_timeout_ms,json=sessionTimeoutMs,proto3" json:"session_timeout_ms,omitempty"`
	ClientIdentity   string `protobuf:"bytes,3,opt,name=client_identity,json=clientIdentity,proto3" json:"client_identity,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSessionRequest) CloneMessageVT 

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

func (*CreateSessionRequest) CloneVT 

func (m *CreateSessionRequest) CloneVT() *CreateSessionRequest

func (*CreateSessionRequest) Descriptor deprecated 

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

Deprecated: Use CreateSessionRequest.ProtoReflect.Descriptor instead.

func (*CreateSessionRequest) EqualMessageVT 

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

func (*CreateSessionRequest) EqualVT 

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

func (*CreateSessionRequest) GetClientIdentity 

func (x *CreateSessionRequest) GetClientIdentity() string

func (*CreateSessionRequest) GetSessionTimeoutMs 

func (x *CreateSessionRequest) GetSessionTimeoutMs() uint32

func (*CreateSessionRequest) GetShard added in v0.9.0 

func (x *CreateSessionRequest) GetShard() int64

func (*CreateSessionRequest) MarshalToSizedBufferVT 

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

func (*CreateSessionRequest) MarshalToVT 

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

func (*CreateSessionRequest) MarshalVT 

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

func (*CreateSessionRequest) ProtoMessage 

func (*CreateSessionRequest) ProtoMessage()

func (*CreateSessionRequest) ProtoReflect 

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

func (*CreateSessionRequest) Reset 

func (x *CreateSessionRequest) Reset()

func (*CreateSessionRequest) SizeVT 

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

func (*CreateSessionRequest) String 

func (x *CreateSessionRequest) String() string

func (*CreateSessionRequest) UnmarshalVT 

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

func (*CreateSessionRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type CreateSessionResponse 

type CreateSessionResponse struct {
	SessionId int64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSessionResponse) CloneMessageVT 

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

func (*CreateSessionResponse) CloneVT 

func (m *CreateSessionResponse) CloneVT() *CreateSessionResponse

func (*CreateSessionResponse) Descriptor deprecated 

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

Deprecated: Use CreateSessionResponse.ProtoReflect.Descriptor instead.

func (*CreateSessionResponse) EqualMessageVT 

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

func (*CreateSessionResponse) EqualVT 

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

func (*CreateSessionResponse) GetSessionId 

func (x *CreateSessionResponse) GetSessionId() int64

func (*CreateSessionResponse) MarshalToSizedBufferVT 

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

func (*CreateSessionResponse) MarshalToVT 

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

func (*CreateSessionResponse) MarshalVT 

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

func (*CreateSessionResponse) ProtoMessage 

func (*CreateSessionResponse) ProtoMessage()

func (*CreateSessionResponse) ProtoReflect 

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

func (*CreateSessionResponse) Reset 

func (x *CreateSessionResponse) Reset()

func (*CreateSessionResponse) SizeVT 

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

func (*CreateSessionResponse) String 

func (x *CreateSessionResponse) String() string

func (*CreateSessionResponse) UnmarshalVT 

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

func (*CreateSessionResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type DeleteRangeRequest 

type DeleteRangeRequest struct {

	// The start of the range, inclusive
	StartInclusive string `protobuf:"bytes,1,opt,name=start_inclusive,json=startInclusive,proto3" json:"start_inclusive,omitempty"`
	// The end of the range, exclusive
	EndExclusive string `protobuf:"bytes,2,opt,name=end_exclusive,json=endExclusive,proto3" json:"end_exclusive,omitempty"`
	// contains filtered or unexported fields
}

* Input to a delete range request. Key ranges assume a UTF-8 byte sort order.

func (*DeleteRangeRequest) CloneMessageVT 

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

func (*DeleteRangeRequest) CloneVT 

func (m *DeleteRangeRequest) CloneVT() *DeleteRangeRequest

func (*DeleteRangeRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRangeRequest.ProtoReflect.Descriptor instead.

func (*DeleteRangeRequest) EqualMessageVT 

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

func (*DeleteRangeRequest) EqualVT 

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

func (*DeleteRangeRequest) GetEndExclusive 

func (x *DeleteRangeRequest) GetEndExclusive() string

func (*DeleteRangeRequest) GetStartInclusive 

func (x *DeleteRangeRequest) GetStartInclusive() string

func (*DeleteRangeRequest) MarshalToSizedBufferVT 

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

func (*DeleteRangeRequest) MarshalToVT 

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

func (*DeleteRangeRequest) MarshalVT 

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

func (*DeleteRangeRequest) ProtoMessage 

func (*DeleteRangeRequest) ProtoMessage()

func (*DeleteRangeRequest) ProtoReflect 

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

func (*DeleteRangeRequest) Reset 

func (x *DeleteRangeRequest) Reset()

func (*DeleteRangeRequest) SizeVT 

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

func (*DeleteRangeRequest) String 

func (x *DeleteRangeRequest) String() string

func (*DeleteRangeRequest) UnmarshalVT 

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

func (*DeleteRangeRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type DeleteRangeResponse 

type DeleteRangeResponse struct {

	// Includes the error or OK
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=io.streamnative.oxia.proto.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

* The response for a delete range request.

func (*DeleteRangeResponse) CloneMessageVT 

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

func (*DeleteRangeResponse) CloneVT 

func (m *DeleteRangeResponse) CloneVT() *DeleteRangeResponse

func (*DeleteRangeResponse) Descriptor deprecated 

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

Deprecated: Use DeleteRangeResponse.ProtoReflect.Descriptor instead.

func (*DeleteRangeResponse) EqualMessageVT 

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

func (*DeleteRangeResponse) EqualVT 

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

func (*DeleteRangeResponse) GetStatus 

func (x *DeleteRangeResponse) GetStatus() Status

func (*DeleteRangeResponse) MarshalToSizedBufferVT 

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

func (*DeleteRangeResponse) MarshalToVT 

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

func (*DeleteRangeResponse) MarshalVT 

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

func (*DeleteRangeResponse) ProtoMessage 

func (*DeleteRangeResponse) ProtoMessage()

func (*DeleteRangeResponse) ProtoReflect 

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

func (*DeleteRangeResponse) Reset 

func (x *DeleteRangeResponse) Reset()

func (*DeleteRangeResponse) SizeVT 

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

func (*DeleteRangeResponse) String 

func (x *DeleteRangeResponse) String() string

func (*DeleteRangeResponse) UnmarshalVT 

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

func (*DeleteRangeResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type DeleteRequest 

type DeleteRequest struct {

	// The key
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// An optional expected version_id. The delete will fail if the server's current version_id
	// does not match
	ExpectedVersionId *int64 `protobuf:"varint,2,opt,name=expected_version_id,json=expectedVersionId,proto3,oneof" json:"expected_version_id,omitempty"`
	// contains filtered or unexported fields
}

* A delete request. Deletes the specified key.

func (*DeleteRequest) CloneMessageVT 

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

func (*DeleteRequest) CloneVT 

func (m *DeleteRequest) CloneVT() *DeleteRequest

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) EqualMessageVT 

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

func (*DeleteRequest) EqualVT 

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

func (*DeleteRequest) GetExpectedVersionId 

func (x *DeleteRequest) GetExpectedVersionId() int64

func (*DeleteRequest) GetKey 

func (x *DeleteRequest) GetKey() string

func (*DeleteRequest) MarshalToSizedBufferVT 

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

func (*DeleteRequest) MarshalToVT 

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

func (*DeleteRequest) MarshalVT 

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

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

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

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) SizeVT 

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

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

func (*DeleteRequest) UnmarshalVT 

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

func (*DeleteRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type DeleteResponse 

type DeleteResponse struct {

	// Includes the error or OK
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=io.streamnative.oxia.proto.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

* The response to a delete request or an item in a response to the delete range request.

func (*DeleteResponse) CloneMessageVT 

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

func (*DeleteResponse) CloneVT 

func (m *DeleteResponse) CloneVT() *DeleteResponse

func (*DeleteResponse) Descriptor deprecated 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) EqualMessageVT 

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

func (*DeleteResponse) EqualVT 

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

func (*DeleteResponse) GetStatus 

func (x *DeleteResponse) GetStatus() Status

func (*DeleteResponse) MarshalToSizedBufferVT 

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

func (*DeleteResponse) MarshalToVT 

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

func (*DeleteResponse) MarshalVT 

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

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

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

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) SizeVT 

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

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

func (*DeleteResponse) UnmarshalVT 

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

func (*DeleteResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type DeleteShardRequest 

type DeleteShardRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Shard     int64  `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"`
	Term      int64  `protobuf:"varint,3,opt,name=term,proto3" json:"term,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteShardRequest) CloneMessageVT 

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

func (*DeleteShardRequest) CloneVT 

func (m *DeleteShardRequest) CloneVT() *DeleteShardRequest

func (*DeleteShardRequest) Descriptor deprecated 

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

Deprecated: Use DeleteShardRequest.ProtoReflect.Descriptor instead.

func (*DeleteShardRequest) EqualMessageVT 

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

func (*DeleteShardRequest) EqualVT 

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

func (*DeleteShardRequest) GetNamespace 

func (x *DeleteShardRequest) GetNamespace() string

func (*DeleteShardRequest) GetShard added in v0.9.0 

func (x *DeleteShardRequest) GetShard() int64

func (*DeleteShardRequest) GetTerm 

func (x *DeleteShardRequest) GetTerm() int64

func (*DeleteShardRequest) MarshalToSizedBufferVT 

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

func (*DeleteShardRequest) MarshalToVT 

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

func (*DeleteShardRequest) MarshalVT 

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

func (*DeleteShardRequest) ProtoMessage 

func (*DeleteShardRequest) ProtoMessage()

func (*DeleteShardRequest) ProtoReflect 

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

func (*DeleteShardRequest) Reset 

func (x *DeleteShardRequest) Reset()

func (*DeleteShardRequest) SizeVT 

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

func (*DeleteShardRequest) String 

func (x *DeleteShardRequest) String() string

func (*DeleteShardRequest) UnmarshalVT 

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

func (*DeleteShardRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type DeleteShardResponse 

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

func (*DeleteShardResponse) CloneMessageVT 

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

func (*DeleteShardResponse) CloneVT 

func (m *DeleteShardResponse) CloneVT() *DeleteShardResponse

func (*DeleteShardResponse) Descriptor deprecated 

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

Deprecated: Use DeleteShardResponse.ProtoReflect.Descriptor instead.

func (*DeleteShardResponse) EqualMessageVT 

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

func (*DeleteShardResponse) EqualVT 

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

func (*DeleteShardResponse) MarshalToSizedBufferVT 

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

func (*DeleteShardResponse) MarshalToVT 

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

func (*DeleteShardResponse) MarshalVT 

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

func (*DeleteShardResponse) ProtoMessage 

func (*DeleteShardResponse) ProtoMessage()

func (*DeleteShardResponse) ProtoReflect 

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

func (*DeleteShardResponse) Reset 

func (x *DeleteShardResponse) Reset()

func (*DeleteShardResponse) SizeVT 

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

func (*DeleteShardResponse) String 

func (x *DeleteShardResponse) String() string

func (*DeleteShardResponse) UnmarshalVT 

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

func (*DeleteShardResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type EntryId 

type EntryId struct {
	Term   int64 `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
	Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*EntryId) CloneMessageVT 

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

func (*EntryId) CloneVT 

func (m *EntryId) CloneVT() *EntryId

func (*EntryId) Descriptor deprecated 

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

Deprecated: Use EntryId.ProtoReflect.Descriptor instead.

func (*EntryId) EqualMessageVT 

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

func (*EntryId) EqualVT 

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

func (*EntryId) GetOffset 

func (x *EntryId) GetOffset() int64

func (*EntryId) GetTerm 

func (x *EntryId) GetTerm() int64

func (*EntryId) MarshalToSizedBufferVT 

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

func (*EntryId) MarshalToVT 

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

func (*EntryId) MarshalVT 

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

func (*EntryId) ProtoMessage 

func (*EntryId) ProtoMessage()

func (*EntryId) ProtoReflect 

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

func (*EntryId) Reset 

func (x *EntryId) Reset()

func (*EntryId) SizeVT 

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

func (*EntryId) String 

func (x *EntryId) String() string

func (*EntryId) UnmarshalVT 

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

func (*EntryId) UnmarshalVTUnsafe added in v0.5.0 

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

type GetRequest 

type GetRequest struct {

	// The key
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Specifies whether the response should include the value
	IncludeValue   bool              `protobuf:"varint,2,opt,name=include_value,json=includeValue,proto3" json:"include_value,omitempty"`
	ComparisonType KeyComparisonType `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

* A get request. Gets the stat and optionally the value for the specified key.

func (*GetRequest) CloneMessageVT 

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

func (*GetRequest) CloneVT 

func (m *GetRequest) CloneVT() *GetRequest

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) EqualMessageVT 

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

func (*GetRequest) EqualVT 

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

func (*GetRequest) GetComparisonType added in v0.5.0 

func (x *GetRequest) GetComparisonType() KeyComparisonType

func (*GetRequest) GetIncludeValue 

func (x *GetRequest) GetIncludeValue() bool

func (*GetRequest) GetKey 

func (x *GetRequest) GetKey() string

func (*GetRequest) MarshalToSizedBufferVT 

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

func (*GetRequest) MarshalToVT 

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

func (*GetRequest) MarshalVT 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) SizeVT 

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

func (*GetRequest) String 

func (x *GetRequest) String() string

func (*GetRequest) UnmarshalVT 

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

func (*GetRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type GetResponse 

type GetResponse struct {

	// Includes the error or OK
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=io.streamnative.oxia.proto.Status" json:"status,omitempty"`
	// The version of the record
	Version *Version `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// The value, if it was requested and there was no error
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3,oneof" json:"value,omitempty"`
	// In case of non-exact queries (eg. floor, ceiling) the found key will be
	// returned in the GetResponse.
	Key *string `protobuf:"bytes,4,opt,name=key,proto3,oneof" json:"key,omitempty"`
	// contains filtered or unexported fields
}

* The response to a get request.

func (*GetResponse) CloneMessageVT 

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

func (*GetResponse) CloneVT 

func (m *GetResponse) CloneVT() *GetResponse

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) EqualMessageVT 

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

func (*GetResponse) EqualVT 

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

func (*GetResponse) GetKey added in v0.5.0 

func (x *GetResponse) GetKey() string

func (*GetResponse) GetStatus 

func (x *GetResponse) GetStatus() Status

func (*GetResponse) GetValue 

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

func (*GetResponse) GetVersion 

func (x *GetResponse) GetVersion() *Version

func (*GetResponse) MarshalToSizedBufferVT 

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

func (*GetResponse) MarshalToVT 

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

func (*GetResponse) MarshalVT 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

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

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) SizeVT 

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

func (*GetResponse) String 

func (x *GetResponse) String() string

func (*GetResponse) UnmarshalVT 

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

func (*GetResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type GetStatusRequest 

type GetStatusRequest struct {
	Shard int64 `protobuf:"varint,1,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatusRequest) CloneMessageVT 

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

func (*GetStatusRequest) CloneVT 

func (m *GetStatusRequest) CloneVT() *GetStatusRequest

func (*GetStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetStatusRequest.ProtoReflect.Descriptor instead.

func (*GetStatusRequest) EqualMessageVT 

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

func (*GetStatusRequest) EqualVT 

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

func (*GetStatusRequest) GetShard added in v0.9.0 

func (x *GetStatusRequest) GetShard() int64

func (*GetStatusRequest) MarshalToSizedBufferVT 

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

func (*GetStatusRequest) MarshalToVT 

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

func (*GetStatusRequest) MarshalVT 

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

func (*GetStatusRequest) ProtoMessage 

func (*GetStatusRequest) ProtoMessage()

func (*GetStatusRequest) ProtoReflect 

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

func (*GetStatusRequest) Reset 

func (x *GetStatusRequest) Reset()

func (*GetStatusRequest) SizeVT 

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

func (*GetStatusRequest) String 

func (x *GetStatusRequest) String() string

func (*GetStatusRequest) UnmarshalVT 

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

func (*GetStatusRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type GetStatusResponse 

type GetStatusResponse struct {
	Term         int64         `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
	Status       ServingStatus `protobuf:"varint,2,opt,name=status,proto3,enum=replication.ServingStatus" json:"status,omitempty"`
	HeadOffset   int64         `protobuf:"varint,3,opt,name=head_offset,json=headOffset,proto3" json:"head_offset,omitempty"`
	CommitOffset int64         `protobuf:"varint,4,opt,name=commit_offset,json=commitOffset,proto3" json:"commit_offset,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatusResponse) CloneMessageVT 

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

func (*GetStatusResponse) CloneVT 

func (m *GetStatusResponse) CloneVT() *GetStatusResponse

func (*GetStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetStatusResponse.ProtoReflect.Descriptor instead.

func (*GetStatusResponse) EqualMessageVT 

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

func (*GetStatusResponse) EqualVT 

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

func (*GetStatusResponse) GetCommitOffset 

func (x *GetStatusResponse) GetCommitOffset() int64

func (*GetStatusResponse) GetHeadOffset 

func (x *GetStatusResponse) GetHeadOffset() int64

func (*GetStatusResponse) GetStatus 

func (x *GetStatusResponse) GetStatus() ServingStatus

func (*GetStatusResponse) GetTerm 

func (x *GetStatusResponse) GetTerm() int64

func (*GetStatusResponse) MarshalToSizedBufferVT 

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

func (*GetStatusResponse) MarshalToVT 

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

func (*GetStatusResponse) MarshalVT 

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

func (*GetStatusResponse) ProtoMessage 

func (*GetStatusResponse) ProtoMessage()

func (*GetStatusResponse) ProtoReflect 

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

func (*GetStatusResponse) Reset 

func (x *GetStatusResponse) Reset()

func (*GetStatusResponse) SizeVT 

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

func (*GetStatusResponse) String 

func (x *GetStatusResponse) String() string

func (*GetStatusResponse) UnmarshalVT 

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

func (*GetStatusResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type Int32HashRange 

type Int32HashRange struct {

	// The minimum inclusive hash that the shard can contain
	MinHashInclusive uint32 `protobuf:"fixed32,1,opt,name=min_hash_inclusive,json=minHashInclusive,proto3" json:"min_hash_inclusive,omitempty"`
	// The maximum inclusive hash that the shard can contain
	MaxHashInclusive uint32 `protobuf:"fixed32,2,opt,name=max_hash_inclusive,json=maxHashInclusive,proto3" json:"max_hash_inclusive,omitempty"`
	// contains filtered or unexported fields
}

* Represents a range of hash values [min, max)

func (*Int32HashRange) CloneMessageVT 

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

func (*Int32HashRange) CloneVT 

func (m *Int32HashRange) CloneVT() *Int32HashRange

func (*Int32HashRange) Descriptor deprecated 

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

Deprecated: Use Int32HashRange.ProtoReflect.Descriptor instead.

func (*Int32HashRange) EqualMessageVT 

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

func (*Int32HashRange) EqualVT 

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

func (*Int32HashRange) GetMaxHashInclusive 

func (x *Int32HashRange) GetMaxHashInclusive() uint32

func (*Int32HashRange) GetMinHashInclusive 

func (x *Int32HashRange) GetMinHashInclusive() uint32

func (*Int32HashRange) MarshalToSizedBufferVT 

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

func (*Int32HashRange) MarshalToVT 

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

func (*Int32HashRange) MarshalVT 

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

func (*Int32HashRange) ProtoMessage 

func (*Int32HashRange) ProtoMessage()

func (*Int32HashRange) ProtoReflect 

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

func (*Int32HashRange) Reset 

func (x *Int32HashRange) Reset()

func (*Int32HashRange) SizeVT 

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

func (*Int32HashRange) String 

func (x *Int32HashRange) String() string

func (*Int32HashRange) UnmarshalVT 

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

func (*Int32HashRange) UnmarshalVTUnsafe added in v0.5.0 

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

type KeepAliveResponse 

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

func (*KeepAliveResponse) CloneMessageVT 

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

func (*KeepAliveResponse) CloneVT 

func (m *KeepAliveResponse) CloneVT() *KeepAliveResponse

func (*KeepAliveResponse) Descriptor deprecated 

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

Deprecated: Use KeepAliveResponse.ProtoReflect.Descriptor instead.

func (*KeepAliveResponse) EqualMessageVT 

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

func (*KeepAliveResponse) EqualVT 

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

func (*KeepAliveResponse) MarshalToSizedBufferVT 

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

func (*KeepAliveResponse) MarshalToVT 

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

func (*KeepAliveResponse) MarshalVT 

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

func (*KeepAliveResponse) ProtoMessage 

func (*KeepAliveResponse) ProtoMessage()

func (*KeepAliveResponse) ProtoReflect 

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

func (*KeepAliveResponse) Reset 

func (x *KeepAliveResponse) Reset()

func (*KeepAliveResponse) SizeVT 

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

func (*KeepAliveResponse) String 

func (x *KeepAliveResponse) String() string

func (*KeepAliveResponse) UnmarshalVT 

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

func (*KeepAliveResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type KeyComparisonType added in v0.5.0 

type KeyComparisonType int32

* The type of key comparison to apply in a get() request 

const (
	// The stored key must be equal to the requested key
	KeyComparisonType_EQUAL KeyComparisonType = 0
	// Search for a key that is the highest key that is <= to the requested key
	KeyComparisonType_FLOOR KeyComparisonType = 1
	// Search for a key that is the lowest key that is >= to the requested key
	KeyComparisonType_CEILING KeyComparisonType = 2
	// Search for a key that is the highest key that is < to the requested key
	KeyComparisonType_LOWER KeyComparisonType = 3
	// Search for a key that is the lowest key that is > to the requested key
	KeyComparisonType_HIGHER KeyComparisonType = 4
)

func (KeyComparisonType) Descriptor added in v0.5.0 

func (KeyComparisonType) Descriptor() protoreflect.EnumDescriptor

func (KeyComparisonType) Enum added in v0.5.0 

func (x KeyComparisonType) Enum() *KeyComparisonType

func (KeyComparisonType) EnumDescriptor deprecated added in v0.5.0 

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

Deprecated: Use KeyComparisonType.Descriptor instead.

func (KeyComparisonType) Number added in v0.5.0 

func (x KeyComparisonType) Number() protoreflect.EnumNumber

func (KeyComparisonType) String added in v0.5.0 

func (x KeyComparisonType) String() string

func (KeyComparisonType) Type added in v0.5.0 

func (KeyComparisonType) Type() protoreflect.EnumType

type ListRequest 

type ListRequest struct {

	// The shard id. This is optional allow for support for server-side hashing
	// and proxying in the future.
	Shard *int64 `protobuf:"varint,1,opt,name=shard,proto3,oneof" json:"shard,omitempty"`
	// The start of the range, inclusive
	StartInclusive string `protobuf:"bytes,2,opt,name=start_inclusive,json=startInclusive,proto3" json:"start_inclusive,omitempty"`
	// The end of the range, exclusive
	EndExclusive       string  `protobuf:"bytes,3,opt,name=end_exclusive,json=endExclusive,proto3" json:"end_exclusive,omitempty"`
	SecondaryIndexName *string `protobuf:"bytes,4,opt,name=secondary_index_name,json=secondaryIndexName,proto3,oneof" json:"secondary_index_name,omitempty"`
	// contains filtered or unexported fields
}

* Input to a list request. Key ranges assume a UTF-8 byte sort order.

func (*ListRequest) CloneMessageVT 

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

func (*ListRequest) CloneVT 

func (m *ListRequest) CloneVT() *ListRequest

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) EqualMessageVT 

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

func (*ListRequest) EqualVT 

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

func (*ListRequest) GetEndExclusive 

func (x *ListRequest) GetEndExclusive() string

func (*ListRequest) GetSecondaryIndexName added in v0.11.0 

func (x *ListRequest) GetSecondaryIndexName() string

func (*ListRequest) GetShard added in v0.9.0 

func (x *ListRequest) GetShard() int64

func (*ListRequest) GetStartInclusive 

func (x *ListRequest) GetStartInclusive() string

func (*ListRequest) MarshalToSizedBufferVT 

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

func (*ListRequest) MarshalToVT 

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

func (*ListRequest) MarshalVT 

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

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) SizeVT 

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

func (*ListRequest) String 

func (x *ListRequest) String() string

func (*ListRequest) UnmarshalVT 

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

func (*ListRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type ListResponse 

type ListResponse struct {

	// A portion of the keys found within the specified range
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

* The response to a list request.

func (*ListResponse) CloneMessageVT 

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

func (*ListResponse) CloneVT 

func (m *ListResponse) CloneVT() *ListResponse

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) EqualMessageVT 

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

func (*ListResponse) EqualVT 

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

func (*ListResponse) GetKeys 

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

func (*ListResponse) MarshalToSizedBufferVT 

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

func (*ListResponse) MarshalToVT 

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

func (*ListResponse) MarshalVT 

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

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

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

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) SizeVT 

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

func (*ListResponse) String 

func (x *ListResponse) String() string

func (*ListResponse) UnmarshalVT 

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

func (*ListResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type LogEntry 

type LogEntry struct {
	Term      int64  `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
	Offset    int64  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Value     []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp uint64 `protobuf:"fixed64,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEntry) CloneMessageVT 

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

func (*LogEntry) CloneVT 

func (m *LogEntry) CloneVT() *LogEntry

func (*LogEntry) Descriptor deprecated 

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

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) EqualMessageVT 

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

func (*LogEntry) EqualVT 

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

func (*LogEntry) GetOffset 

func (x *LogEntry) GetOffset() int64

func (*LogEntry) GetTerm 

func (x *LogEntry) GetTerm() int64

func (*LogEntry) GetTimestamp 

func (x *LogEntry) GetTimestamp() uint64

func (*LogEntry) GetValue 

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

func (*LogEntry) MarshalToSizedBufferVT 

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

func (*LogEntry) MarshalToVT 

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

func (*LogEntry) MarshalVT 

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

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect 

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

func (*LogEntry) Reset 

func (x *LogEntry) Reset()

func (*LogEntry) SizeVT 

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

func (*LogEntry) String 

func (x *LogEntry) String() string

func (*LogEntry) UnmarshalVT 

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

func (*LogEntry) UnmarshalVTUnsafe added in v0.5.0 

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

type LogEntryValue 

type LogEntryValue struct {

	// Types that are assignable to Value:
	//
	//	*LogEntryValue_Requests
	Value isLogEntryValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func LogEntryValueFromVTPool 

func LogEntryValueFromVTPool() *LogEntryValue

func (*LogEntryValue) CloneMessageVT 

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

func (*LogEntryValue) CloneVT 

func (m *LogEntryValue) CloneVT() *LogEntryValue

func (*LogEntryValue) Descriptor deprecated 

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

Deprecated: Use LogEntryValue.ProtoReflect.Descriptor instead.

func (*LogEntryValue) EqualMessageVT 

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

func (*LogEntryValue) EqualVT 

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

func (*LogEntryValue) GetRequests 

func (x *LogEntryValue) GetRequests() *WriteRequests

func (*LogEntryValue) GetValue 

func (m *LogEntryValue) GetValue() isLogEntryValue_Value

func (*LogEntryValue) MarshalToSizedBufferVT 

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

func (*LogEntryValue) MarshalToVT 

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

func (*LogEntryValue) MarshalVT 

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

func (*LogEntryValue) ProtoMessage 

func (*LogEntryValue) ProtoMessage()

func (*LogEntryValue) ProtoReflect 

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

func (*LogEntryValue) Reset 

func (x *LogEntryValue) Reset()

func (*LogEntryValue) ResetVT 

func (m *LogEntryValue) ResetVT()

func (*LogEntryValue) ReturnToVTPool 

func (m *LogEntryValue) ReturnToVTPool()

func (*LogEntryValue) SizeVT 

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

func (*LogEntryValue) String 

func (x *LogEntryValue) String() string

func (*LogEntryValue) UnmarshalVT 

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

func (*LogEntryValue) UnmarshalVTUnsafe added in v0.5.0 

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

type LogEntryValue_Requests 

type LogEntryValue_Requests struct {
	Requests *WriteRequests `protobuf:"bytes,1,opt,name=requests,proto3,oneof"`
}

func (*LogEntryValue_Requests) CloneVT 

func (m *LogEntryValue_Requests) CloneVT() isLogEntryValue_Value

func (*LogEntryValue_Requests) EqualVT 

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

func (*LogEntryValue_Requests) MarshalToSizedBufferVT 

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

func (*LogEntryValue_Requests) MarshalToVT 

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

func (*LogEntryValue_Requests) SizeVT 

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

type NamespaceShardsAssignment 

type NamespaceShardsAssignment struct {

	// All assignments in the response stream will contain all the
	// assignments to bring the client up to date. For example, if a shard is
	// split, the stream will return a single response containing all the new
	// shard assignments as opposed to multiple stream responses, each containing
	// a single shard assignment.
	Assignments []*ShardAssignment `protobuf:"bytes,1,rep,name=assignments,proto3" json:"assignments,omitempty"`
	// Indicates the mechanism by which the keys are assigned to the individual
	// shards.
	ShardKeyRouter ShardKeyRouter `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

* The shards assignments for a given namespace

func (*NamespaceShardsAssignment) CloneMessageVT 

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

func (*NamespaceShardsAssignment) CloneVT 

func (m *NamespaceShardsAssignment) CloneVT() *NamespaceShardsAssignment

func (*NamespaceShardsAssignment) Descriptor deprecated 

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

Deprecated: Use NamespaceShardsAssignment.ProtoReflect.Descriptor instead.

func (*NamespaceShardsAssignment) EqualMessageVT 

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

func (*NamespaceShardsAssignment) EqualVT 

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

func (*NamespaceShardsAssignment) GetAssignments 

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

func (*NamespaceShardsAssignment) GetShardKeyRouter 

func (x *NamespaceShardsAssignment) GetShardKeyRouter() ShardKeyRouter

func (*NamespaceShardsAssignment) MarshalToSizedBufferVT 

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

func (*NamespaceShardsAssignment) MarshalToVT 

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

func (*NamespaceShardsAssignment) MarshalVT 

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

func (*NamespaceShardsAssignment) ProtoMessage 

func (*NamespaceShardsAssignment) ProtoMessage()

func (*NamespaceShardsAssignment) ProtoReflect 

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

func (*NamespaceShardsAssignment) Reset 

func (x *NamespaceShardsAssignment) Reset()

func (*NamespaceShardsAssignment) SizeVT 

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

func (*NamespaceShardsAssignment) String 

func (x *NamespaceShardsAssignment) String() string

func (*NamespaceShardsAssignment) UnmarshalVT 

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

func (*NamespaceShardsAssignment) UnmarshalVTUnsafe added in v0.5.0 

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

type NewTermOptions added in v0.10.0 

type NewTermOptions struct {
	EnableNotifications bool `protobuf:"varint,1,opt,name=enable_notifications,json=enableNotifications,proto3" json:"enable_notifications,omitempty"`
	// contains filtered or unexported fields
}

func (*NewTermOptions) CloneMessageVT added in v0.10.0 

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

func (*NewTermOptions) CloneVT added in v0.10.0 

func (m *NewTermOptions) CloneVT() *NewTermOptions

func (*NewTermOptions) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use NewTermOptions.ProtoReflect.Descriptor instead.

func (*NewTermOptions) EqualMessageVT added in v0.10.0 

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

func (*NewTermOptions) EqualVT added in v0.10.0 

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

func (*NewTermOptions) GetEnableNotifications added in v0.10.0 

func (x *NewTermOptions) GetEnableNotifications() bool

func (*NewTermOptions) MarshalToSizedBufferVT added in v0.10.0 

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

func (*NewTermOptions) MarshalToVT added in v0.10.0 

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

func (*NewTermOptions) MarshalVT added in v0.10.0 

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

func (*NewTermOptions) ProtoMessage added in v0.10.0 

func (*NewTermOptions) ProtoMessage()

func (*NewTermOptions) ProtoReflect added in v0.10.0 

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

func (*NewTermOptions) Reset added in v0.10.0 

func (x *NewTermOptions) Reset()

func (*NewTermOptions) SizeVT added in v0.10.0 

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

func (*NewTermOptions) String added in v0.10.0 

func (x *NewTermOptions) String() string

func (*NewTermOptions) UnmarshalVT added in v0.10.0 

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

func (*NewTermOptions) UnmarshalVTUnsafe added in v0.10.0 

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

type NewTermRequest 

type NewTermRequest struct {
	Namespace string          `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Shard     int64           `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"`
	Term      int64           `protobuf:"varint,3,opt,name=term,proto3" json:"term,omitempty"`
	Options   *NewTermOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*NewTermRequest) CloneMessageVT 

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

func (*NewTermRequest) CloneVT 

func (m *NewTermRequest) CloneVT() *NewTermRequest

func (*NewTermRequest) Descriptor deprecated 

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

Deprecated: Use NewTermRequest.ProtoReflect.Descriptor instead.

func (*NewTermRequest) EqualMessageVT 

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

func (*NewTermRequest) EqualVT 

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

func (*NewTermRequest) GetNamespace 

func (x *NewTermRequest) GetNamespace() string

func (*NewTermRequest) GetOptions added in v0.10.0 

func (x *NewTermRequest) GetOptions() *NewTermOptions

func (*NewTermRequest) GetShard added in v0.9.0 

func (x *NewTermRequest) GetShard() int64

func (*NewTermRequest) GetTerm 

func (x *NewTermRequest) GetTerm() int64

func (*NewTermRequest) MarshalToSizedBufferVT 

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

func (*NewTermRequest) MarshalToVT 

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

func (*NewTermRequest) MarshalVT 

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

func (*NewTermRequest) ProtoMessage 

func (*NewTermRequest) ProtoMessage()

func (*NewTermRequest) ProtoReflect 

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

func (*NewTermRequest) Reset 

func (x *NewTermRequest) Reset()

func (*NewTermRequest) SizeVT 

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

func (*NewTermRequest) String 

func (x *NewTermRequest) String() string

func (*NewTermRequest) UnmarshalVT 

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

func (*NewTermRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type NewTermResponse 

type NewTermResponse struct {
	HeadEntryId *EntryId `protobuf:"bytes,1,opt,name=head_entry_id,json=headEntryId,proto3" json:"head_entry_id,omitempty"`
	// contains filtered or unexported fields
}

func (*NewTermResponse) CloneMessageVT 

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

func (*NewTermResponse) CloneVT 

func (m *NewTermResponse) CloneVT() *NewTermResponse

func (*NewTermResponse) Descriptor deprecated 

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

Deprecated: Use NewTermResponse.ProtoReflect.Descriptor instead.

func (*NewTermResponse) EqualMessageVT 

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

func (*NewTermResponse) EqualVT 

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

func (*NewTermResponse) GetHeadEntryId 

func (x *NewTermResponse) GetHeadEntryId() *EntryId

func (*NewTermResponse) MarshalToSizedBufferVT 

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

func (*NewTermResponse) MarshalToVT 

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

func (*NewTermResponse) MarshalVT 

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

func (*NewTermResponse) ProtoMessage 

func (*NewTermResponse) ProtoMessage()

func (*NewTermResponse) ProtoReflect 

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

func (*NewTermResponse) Reset 

func (x *NewTermResponse) Reset()

func (*NewTermResponse) SizeVT 

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

func (*NewTermResponse) String 

func (x *NewTermResponse) String() string

func (*NewTermResponse) UnmarshalVT 

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

func (*NewTermResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type Notification 

type Notification struct {
	Type         NotificationType `protobuf:"varint,1,opt,name=type,proto3,enum=io.streamnative.oxia.proto.NotificationType" json:"type,omitempty"`
	VersionId    *int64           `protobuf:"varint,2,opt,name=version_id,json=versionId,proto3,oneof" json:"version_id,omitempty"`
	KeyRangeLast *string          `protobuf:"bytes,3,opt,name=key_range_last,json=keyRangeLast,proto3,oneof" json:"key_range_last,omitempty"`
	// contains filtered or unexported fields
}

func (*Notification) CloneMessageVT 

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

func (*Notification) CloneVT 

func (m *Notification) CloneVT() *Notification

func (*Notification) Descriptor deprecated 

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

Deprecated: Use Notification.ProtoReflect.Descriptor instead.

func (*Notification) EqualMessageVT 

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

func (*Notification) EqualVT 

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

func (*Notification) GetKeyRangeLast added in v0.10.0 

func (x *Notification) GetKeyRangeLast() string

func (*Notification) GetType 

func (x *Notification) GetType() NotificationType

func (*Notification) GetVersionId 

func (x *Notification) GetVersionId() int64

func (*Notification) MarshalToSizedBufferVT 

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

func (*Notification) MarshalToVT 

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

func (*Notification) MarshalVT 

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

func (*Notification) ProtoMessage 

func (*Notification) ProtoMessage()

func (*Notification) ProtoReflect 

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

func (*Notification) Reset 

func (x *Notification) Reset()

func (*Notification) SizeVT 

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

func (*Notification) String 

func (x *Notification) String() string

func (*Notification) UnmarshalVT 

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

func (*Notification) UnmarshalVTUnsafe added in v0.5.0 

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

type NotificationBatch 

type NotificationBatch struct {
	Shard         int64                    `protobuf:"varint,1,opt,name=shard,proto3" json:"shard,omitempty"`
	Offset        int64                    `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Timestamp     uint64                   `protobuf:"fixed64,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Notifications map[string]*Notification `` /* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NotificationBatch) CloneMessageVT 

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

func (*NotificationBatch) CloneVT 

func (m *NotificationBatch) CloneVT() *NotificationBatch

func (*NotificationBatch) Descriptor deprecated 

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

Deprecated: Use NotificationBatch.ProtoReflect.Descriptor instead.

func (*NotificationBatch) EqualMessageVT 

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

func (*NotificationBatch) EqualVT 

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

func (*NotificationBatch) GetNotifications 

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

func (*NotificationBatch) GetOffset 

func (x *NotificationBatch) GetOffset() int64

func (*NotificationBatch) GetShard added in v0.9.0 

func (x *NotificationBatch) GetShard() int64

func (*NotificationBatch) GetTimestamp 

func (x *NotificationBatch) GetTimestamp() uint64

func (*NotificationBatch) MarshalToSizedBufferVT 

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

func (*NotificationBatch) MarshalToVT 

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

func (*NotificationBatch) MarshalVT 

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

func (*NotificationBatch) ProtoMessage 

func (*NotificationBatch) ProtoMessage()

func (*NotificationBatch) ProtoReflect 

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

func (*NotificationBatch) Reset 

func (x *NotificationBatch) Reset()

func (*NotificationBatch) SizeVT 

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

func (*NotificationBatch) String 

func (x *NotificationBatch) String() string

func (*NotificationBatch) UnmarshalVT 

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

func (*NotificationBatch) UnmarshalVTUnsafe added in v0.5.0 

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

type NotificationType 

type NotificationType int32
const (
	NotificationType_KEY_CREATED       NotificationType = 0
	NotificationType_KEY_MODIFIED      NotificationType = 1
	NotificationType_KEY_DELETED       NotificationType = 2
	NotificationType_KEY_RANGE_DELETED NotificationType = 3
)

func (NotificationType) Descriptor 

func (NotificationType) Descriptor() protoreflect.EnumDescriptor

func (NotificationType) Enum 

func (x NotificationType) Enum() *NotificationType

func (NotificationType) EnumDescriptor deprecated 

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

Deprecated: Use NotificationType.Descriptor instead.

func (NotificationType) Number 

func (x NotificationType) Number() protoreflect.EnumNumber

func (NotificationType) String 

func (x NotificationType) String() string

func (NotificationType) Type 

func (NotificationType) Type() protoreflect.EnumType

type NotificationsRequest 

type NotificationsRequest struct {
	Shard                int64  `protobuf:"varint,1,opt,name=shard,proto3" json:"shard,omitempty"`
	StartOffsetExclusive *int64 `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NotificationsRequest) CloneMessageVT 

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

func (*NotificationsRequest) CloneVT 

func (m *NotificationsRequest) CloneVT() *NotificationsRequest

func (*NotificationsRequest) Descriptor deprecated 

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

Deprecated: Use NotificationsRequest.ProtoReflect.Descriptor instead.

func (*NotificationsRequest) EqualMessageVT 

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

func (*NotificationsRequest) EqualVT 

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

func (*NotificationsRequest) GetShard added in v0.9.0 

func (x *NotificationsRequest) GetShard() int64

func (*NotificationsRequest) GetStartOffsetExclusive 

func (x *NotificationsRequest) GetStartOffsetExclusive() int64

func (*NotificationsRequest) MarshalToSizedBufferVT 

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

func (*NotificationsRequest) MarshalToVT 

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

func (*NotificationsRequest) MarshalVT 

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

func (*NotificationsRequest) ProtoMessage 

func (*NotificationsRequest) ProtoMessage()

func (*NotificationsRequest) ProtoReflect 

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

func (*NotificationsRequest) Reset 

func (x *NotificationsRequest) Reset()

func (*NotificationsRequest) SizeVT 

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

func (*NotificationsRequest) String 

func (x *NotificationsRequest) String() string

func (*NotificationsRequest) UnmarshalVT 

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

func (*NotificationsRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type OxiaClientClient 

type OxiaClientClient interface {
	// *
	// Gets all shard-to-server assignments as a stream. Each set of assignments
	// in the response stream will contain all the assignments to bring the client
	// up to date. For example, if a shard is split, the stream will return a
	// single response containing all the new shard assignments as opposed to
	// multiple stream responses, each containing a single shard assignment.
	//
	// Clients should connect to a single random server which will stream the
	// assignments for all shards on all servers.
	GetShardAssignments(ctx context.Context, in *ShardAssignmentsRequest, opts ...grpc.CallOption) (OxiaClient_GetShardAssignmentsClient, error)
	// *
	// Batches put, delete and delete_range requests.
	//
	// Clients should send this request to the shard leader. In the future,
	// this may be handled server-side in a proxy layer.
	//
	// Deprecated
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
	// *
	// Batches put, delete and delete_range requests.
	//
	// Clients should send this request to the shard leader. In the future,
	// this may be handled server-side in a proxy layer.
	WriteStream(ctx context.Context, opts ...grpc.CallOption) (OxiaClient_WriteStreamClient, error)
	// *
	// Batches get requests.
	//
	// Clients should send this request to the shard leader. In the future,
	// this may be handled server-side in a proxy layer.
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (OxiaClient_ReadClient, error)
	// *
	// Requests all the keys between a range of keys.
	//
	// Clients should send an equivalent request to all respective shards,
	// unless a particular partition key was specified.
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (OxiaClient_ListClient, error)
	// *
	// Requests all the records between a range of keys.
	//
	// Clients should send an equivalent request to all respective shards,
	// unless a particular partition key was specified.
	RangeScan(ctx context.Context, in *RangeScanRequest, opts ...grpc.CallOption) (OxiaClient_RangeScanClient, error)
	GetNotifications(ctx context.Context, in *NotificationsRequest, opts ...grpc.CallOption) (OxiaClient_GetNotificationsClient, error)
	// Creates a new client session. Sessions are kept alive by regularly sending
	// heartbeats via the KeepAlive rpc.
	CreateSession(ctx context.Context, in *CreateSessionRequest, opts ...grpc.CallOption) (*CreateSessionResponse, error)
	// Sends a heartbeat to prevent the session from timing out.
	KeepAlive(ctx context.Context, in *SessionHeartbeat, opts ...grpc.CallOption) (*KeepAliveResponse, error)
	// Closes a session and removes all ephemeral values associated with it.
	CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)
}

OxiaClientClient is the client API for OxiaClient service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewOxiaClientClient 

func NewOxiaClientClient(cc grpc.ClientConnInterface) OxiaClientClient

type OxiaClientServer 

type OxiaClientServer interface {
	// *
	// Gets all shard-to-server assignments as a stream. Each set of assignments
	// in the response stream will contain all the assignments to bring the client
	// up to date. For example, if a shard is split, the stream will return a
	// single response containing all the new shard assignments as opposed to
	// multiple stream responses, each containing a single shard assignment.
	//
	// Clients should connect to a single random server which will stream the
	// assignments for all shards on all servers.
	GetShardAssignments(*ShardAssignmentsRequest, OxiaClient_GetShardAssignmentsServer) error
	// *
	// Batches put, delete and delete_range requests.
	//
	// Clients should send this request to the shard leader. In the future,
	// this may be handled server-side in a proxy layer.
	//
	// Deprecated
	Write(context.Context, *WriteRequest) (*WriteResponse, error)
	// *
	// Batches put, delete and delete_range requests.
	//
	// Clients should send this request to the shard leader. In the future,
	// this may be handled server-side in a proxy layer.
	WriteStream(OxiaClient_WriteStreamServer) error
	// *
	// Batches get requests.
	//
	// Clients should send this request to the shard leader. In the future,
	// this may be handled server-side in a proxy layer.
	Read(*ReadRequest, OxiaClient_ReadServer) error
	// *
	// Requests all the keys between a range of keys.
	//
	// Clients should send an equivalent request to all respective shards,
	// unless a particular partition key was specified.
	List(*ListRequest, OxiaClient_ListServer) error
	// *
	// Requests all the records between a range of keys.
	//
	// Clients should send an equivalent request to all respective shards,
	// unless a particular partition key was specified.
	RangeScan(*RangeScanRequest, OxiaClient_RangeScanServer) error
	GetNotifications(*NotificationsRequest, OxiaClient_GetNotificationsServer) error
	// Creates a new client session. Sessions are kept alive by regularly sending
	// heartbeats via the KeepAlive rpc.
	CreateSession(context.Context, *CreateSessionRequest) (*CreateSessionResponse, error)
	// Sends a heartbeat to prevent the session from timing out.
	KeepAlive(context.Context, *SessionHeartbeat) (*KeepAliveResponse, error)
	// Closes a session and removes all ephemeral values associated with it.
	CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
	// contains filtered or unexported methods
}

OxiaClientServer is the server API for OxiaClient service. All implementations must embed UnimplementedOxiaClientServer for forward compatibility

type OxiaClient_GetNotificationsClient 

type OxiaClient_GetNotificationsClient interface {
	Recv() (*NotificationBatch, error)
	grpc.ClientStream
}

type OxiaClient_GetNotificationsServer 

type OxiaClient_GetNotificationsServer interface {
	Send(*NotificationBatch) error
	grpc.ServerStream
}

type OxiaClient_GetShardAssignmentsClient 

type OxiaClient_GetShardAssignmentsClient interface {
	Recv() (*ShardAssignments, error)
	grpc.ClientStream
}

type OxiaClient_GetShardAssignmentsServer 

type OxiaClient_GetShardAssignmentsServer interface {
	Send(*ShardAssignments) error
	grpc.ServerStream
}

type OxiaClient_ListClient 

type OxiaClient_ListClient interface {
	Recv() (*ListResponse, error)
	grpc.ClientStream
}

type OxiaClient_ListServer 

type OxiaClient_ListServer interface {
	Send(*ListResponse) error
	grpc.ServerStream
}

type OxiaClient_RangeScanClient added in v0.5.0 

type OxiaClient_RangeScanClient interface {
	Recv() (*RangeScanResponse, error)
	grpc.ClientStream
}

type OxiaClient_RangeScanServer added in v0.5.0 

type OxiaClient_RangeScanServer interface {
	Send(*RangeScanResponse) error
	grpc.ServerStream
}

type OxiaClient_ReadClient 

type OxiaClient_ReadClient interface {
	Recv() (*ReadResponse, error)
	grpc.ClientStream
}

type OxiaClient_ReadServer 

type OxiaClient_ReadServer interface {
	Send(*ReadResponse) error
	grpc.ServerStream
}

type OxiaClient_WriteStreamClient added in v0.7.0 

type OxiaClient_WriteStreamClient interface {
	Send(*WriteRequest) error
	Recv() (*WriteResponse, error)
	grpc.ClientStream
}

type OxiaClient_WriteStreamServer added in v0.7.0 

type OxiaClient_WriteStreamServer interface {
	Send(*WriteResponse) error
	Recv() (*WriteRequest, error)
	grpc.ServerStream
}

type OxiaCoordinationClient 

type OxiaCoordinationClient interface {
	PushShardAssignments(ctx context.Context, opts ...grpc.CallOption) (OxiaCoordination_PushShardAssignmentsClient, error)
	NewTerm(ctx context.Context, in *NewTermRequest, opts ...grpc.CallOption) (*NewTermResponse, error)
	BecomeLeader(ctx context.Context, in *BecomeLeaderRequest, opts ...grpc.CallOption) (*BecomeLeaderResponse, error)
	AddFollower(ctx context.Context, in *AddFollowerRequest, opts ...grpc.CallOption) (*AddFollowerResponse, error)
	GetStatus(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*GetStatusResponse, error)
	DeleteShard(ctx context.Context, in *DeleteShardRequest, opts ...grpc.CallOption) (*DeleteShardResponse, error)
}

OxiaCoordinationClient is the client API for OxiaCoordination service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewOxiaCoordinationClient 

func NewOxiaCoordinationClient(cc grpc.ClientConnInterface) OxiaCoordinationClient

type OxiaCoordinationServer 

type OxiaCoordinationServer interface {
	PushShardAssignments(OxiaCoordination_PushShardAssignmentsServer) error
	NewTerm(context.Context, *NewTermRequest) (*NewTermResponse, error)
	BecomeLeader(context.Context, *BecomeLeaderRequest) (*BecomeLeaderResponse, error)
	AddFollower(context.Context, *AddFollowerRequest) (*AddFollowerResponse, error)
	GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)
	DeleteShard(context.Context, *DeleteShardRequest) (*DeleteShardResponse, error)
	// contains filtered or unexported methods
}

OxiaCoordinationServer is the server API for OxiaCoordination service. All implementations must embed UnimplementedOxiaCoordinationServer for forward compatibility

type OxiaCoordination_PushShardAssignmentsClient 

type OxiaCoordination_PushShardAssignmentsClient interface {
	Send(*ShardAssignments) error
	CloseAndRecv() (*CoordinationShardAssignmentsResponse, error)
	grpc.ClientStream
}

type OxiaCoordination_PushShardAssignmentsServer 

type OxiaCoordination_PushShardAssignmentsServer interface {
	SendAndClose(*CoordinationShardAssignmentsResponse) error
	Recv() (*ShardAssignments, error)
	grpc.ServerStream
}

type OxiaLogReplicationClient 

type OxiaLogReplicationClient interface {
	Truncate(ctx context.Context, in *TruncateRequest, opts ...grpc.CallOption) (*TruncateResponse, error)
	Replicate(ctx context.Context, opts ...grpc.CallOption) (OxiaLogReplication_ReplicateClient, error)
	SendSnapshot(ctx context.Context, opts ...grpc.CallOption) (OxiaLogReplication_SendSnapshotClient, error)
}

OxiaLogReplicationClient is the client API for OxiaLogReplication service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewOxiaLogReplicationClient 

func NewOxiaLogReplicationClient(cc grpc.ClientConnInterface) OxiaLogReplicationClient

type OxiaLogReplicationServer 

type OxiaLogReplicationServer interface {
	Truncate(context.Context, *TruncateRequest) (*TruncateResponse, error)
	Replicate(OxiaLogReplication_ReplicateServer) error
	SendSnapshot(OxiaLogReplication_SendSnapshotServer) error
	// contains filtered or unexported methods
}

OxiaLogReplicationServer is the server API for OxiaLogReplication service. All implementations must embed UnimplementedOxiaLogReplicationServer for forward compatibility

type OxiaLogReplication_ReplicateClient 

type OxiaLogReplication_ReplicateClient interface {
	Send(*Append) error
	Recv() (*Ack, error)
	grpc.ClientStream
}

type OxiaLogReplication_ReplicateServer 

type OxiaLogReplication_ReplicateServer interface {
	Send(*Ack) error
	Recv() (*Append, error)
	grpc.ServerStream
}

type OxiaLogReplication_SendSnapshotClient 

type OxiaLogReplication_SendSnapshotClient interface {
	Send(*SnapshotChunk) error
	CloseAndRecv() (*SnapshotResponse, error)
	grpc.ClientStream
}

type OxiaLogReplication_SendSnapshotServer 

type OxiaLogReplication_SendSnapshotServer interface {
	SendAndClose(*SnapshotResponse) error
	Recv() (*SnapshotChunk, error)
	grpc.ServerStream
}

type PutRequest 

type PutRequest struct {

	// The key
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The value
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// An optional expected version_id. The put will fail if the server's current version_id
	// does not match
	ExpectedVersionId *int64 `protobuf:"varint,3,opt,name=expected_version_id,json=expectedVersionId,proto3,oneof" json:"expected_version_id,omitempty"`
	// Optional. Associate the new record with the session (i.e. ephemeral record).
	// When the session expires or is explicitly closed, the record will be automatically
	// removed
	SessionId *int64 `protobuf:"varint,4,opt,name=session_id,json=sessionId,proto3,oneof" json:"session_id,omitempty"`
	// Client identifier used to track the client that last modified an
	// ephemeral record.
	ClientIdentity *string `protobuf:"bytes,5,opt,name=client_identity,json=clientIdentity,proto3,oneof" json:"client_identity,omitempty"`
	// If a partition key is present, it supersedes the regular record key in determining the routing of
	// a record to a particular shard. It is passed to the server because it needs to be persisted as
	// part of the record. We would need the partition_key if we're going to do a split of the shards.
	PartitionKey *string `protobuf:"bytes,6,opt,name=partition_key,json=partitionKey,proto3,oneof" json:"partition_key,omitempty"`
	// If one or more sequence key are specified. The key will get added suffixes
	// based on adding the delta to the current highest key with the same prefix
	SequenceKeyDelta []uint64          `protobuf:"varint,7,rep,packed,name=sequence_key_delta,json=sequenceKeyDelta,proto3" json:"sequence_key_delta,omitempty"`
	SecondaryIndexes []*SecondaryIndex `protobuf:"bytes,8,rep,name=secondary_indexes,json=secondaryIndexes,proto3" json:"secondary_indexes,omitempty"`
	// contains filtered or unexported fields
}

* A put request. Persists the specified key and value

func (*PutRequest) CloneMessageVT 

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

func (*PutRequest) CloneVT 

func (m *PutRequest) CloneVT() *PutRequest

func (*PutRequest) Descriptor deprecated 

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) EqualMessageVT 

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

func (*PutRequest) EqualVT 

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

func (*PutRequest) GetClientIdentity 

func (x *PutRequest) GetClientIdentity() string

func (*PutRequest) GetExpectedVersionId 

func (x *PutRequest) GetExpectedVersionId() int64

func (*PutRequest) GetKey 

func (x *PutRequest) GetKey() string

func (*PutRequest) GetPartitionKey added in v0.5.0 

func (x *PutRequest) GetPartitionKey() string

func (*PutRequest) GetSecondaryIndexes added in v0.11.0 

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

func (*PutRequest) GetSequenceKeyDelta added in v0.5.0 

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

func (*PutRequest) GetSessionId 

func (x *PutRequest) GetSessionId() int64

func (*PutRequest) GetValue 

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

func (*PutRequest) MarshalToSizedBufferVT 

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

func (*PutRequest) MarshalToVT 

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

func (*PutRequest) MarshalVT 

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

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect 

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

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) SizeVT 

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

func (*PutRequest) String 

func (x *PutRequest) String() string

func (*PutRequest) UnmarshalVT 

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

func (*PutRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type PutResponse 

type PutResponse struct {

	// Includes the error or OK
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=io.streamnative.oxia.proto.Status" json:"status,omitempty"`
	// The version if the put was successful
	Version *Version `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// If the key was generated by Oxia, it will be returned as part
	// of the response
	Key *string `protobuf:"bytes,3,opt,name=key,proto3,oneof" json:"key,omitempty"`
	// contains filtered or unexported fields
}

* The response to a put request.

func (*PutResponse) CloneMessageVT 

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

func (*PutResponse) CloneVT 

func (m *PutResponse) CloneVT() *PutResponse

func (*PutResponse) Descriptor deprecated 

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

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) EqualMessageVT 

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

func (*PutResponse) EqualVT 

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

func (*PutResponse) GetKey added in v0.5.0 

func (x *PutResponse) GetKey() string

func (*PutResponse) GetStatus 

func (x *PutResponse) GetStatus() Status

func (*PutResponse) GetVersion 

func (x *PutResponse) GetVersion() *Version

func (*PutResponse) MarshalToSizedBufferVT 

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

func (*PutResponse) MarshalToVT 

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

func (*PutResponse) MarshalVT 

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

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect 

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

func (*PutResponse) Reset 

func (x *PutResponse) Reset()

func (*PutResponse) SizeVT 

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

func (*PutResponse) String 

func (x *PutResponse) String() string

func (*PutResponse) UnmarshalVT 

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

func (*PutResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type RangeScanRequest added in v0.5.0 

type RangeScanRequest struct {

	// The shard id. This is optional allow for support for server-side hashing
	// and proxying in the future.
	Shard *int64 `protobuf:"varint,1,opt,name=shard,proto3,oneof" json:"shard,omitempty"`
	// The start of the range, inclusive
	StartInclusive string `protobuf:"bytes,2,opt,name=start_inclusive,json=startInclusive,proto3" json:"start_inclusive,omitempty"`
	// The end of the range, exclusive
	EndExclusive       string  `protobuf:"bytes,3,opt,name=end_exclusive,json=endExclusive,proto3" json:"end_exclusive,omitempty"`
	SecondaryIndexName *string `protobuf:"bytes,4,opt,name=secondary_index_name,json=secondaryIndexName,proto3,oneof" json:"secondary_index_name,omitempty"`
	// contains filtered or unexported fields
}

* Input to a range-scan request

func (*RangeScanRequest) CloneMessageVT added in v0.5.0 

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

func (*RangeScanRequest) CloneVT added in v0.5.0 

func (m *RangeScanRequest) CloneVT() *RangeScanRequest

func (*RangeScanRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use RangeScanRequest.ProtoReflect.Descriptor instead.

func (*RangeScanRequest) EqualMessageVT added in v0.5.0 

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

func (*RangeScanRequest) EqualVT added in v0.5.0 

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

func (*RangeScanRequest) GetEndExclusive added in v0.5.0 

func (x *RangeScanRequest) GetEndExclusive() string

func (*RangeScanRequest) GetSecondaryIndexName added in v0.11.0 

func (x *RangeScanRequest) GetSecondaryIndexName() string

func (*RangeScanRequest) GetShard added in v0.9.0 

func (x *RangeScanRequest) GetShard() int64

func (*RangeScanRequest) GetStartInclusive added in v0.5.0 

func (x *RangeScanRequest) GetStartInclusive() string

func (*RangeScanRequest) MarshalToSizedBufferVT added in v0.5.0 

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

func (*RangeScanRequest) MarshalToVT added in v0.5.0 

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

func (*RangeScanRequest) MarshalVT added in v0.5.0 

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

func (*RangeScanRequest) ProtoMessage added in v0.5.0 

func (*RangeScanRequest) ProtoMessage()

func (*RangeScanRequest) ProtoReflect added in v0.5.0 

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

func (*RangeScanRequest) Reset added in v0.5.0 

func (x *RangeScanRequest) Reset()

func (*RangeScanRequest) SizeVT added in v0.5.0 

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

func (*RangeScanRequest) String added in v0.5.0 

func (x *RangeScanRequest) String() string

func (*RangeScanRequest) UnmarshalVT added in v0.5.0 

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

func (*RangeScanRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type RangeScanResponse added in v0.5.0 

type RangeScanResponse struct {

	// A portion of the records found within the specified range
	Records []*GetResponse `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

* The response to a range-scan request.

func (*RangeScanResponse) CloneMessageVT added in v0.5.0 

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

func (*RangeScanResponse) CloneVT added in v0.5.0 

func (m *RangeScanResponse) CloneVT() *RangeScanResponse

func (*RangeScanResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use RangeScanResponse.ProtoReflect.Descriptor instead.

func (*RangeScanResponse) EqualMessageVT added in v0.5.0 

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

func (*RangeScanResponse) EqualVT added in v0.5.0 

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

func (*RangeScanResponse) GetRecords added in v0.5.0 

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

func (*RangeScanResponse) MarshalToSizedBufferVT added in v0.5.0 

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

func (*RangeScanResponse) MarshalToVT added in v0.5.0 

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

func (*RangeScanResponse) MarshalVT added in v0.5.0 

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

func (*RangeScanResponse) ProtoMessage added in v0.5.0 

func (*RangeScanResponse) ProtoMessage()

func (*RangeScanResponse) ProtoReflect added in v0.5.0 

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

func (*RangeScanResponse) Reset added in v0.5.0 

func (x *RangeScanResponse) Reset()

func (*RangeScanResponse) SizeVT added in v0.5.0 

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

func (*RangeScanResponse) String added in v0.5.0 

func (x *RangeScanResponse) String() string

func (*RangeScanResponse) UnmarshalVT added in v0.5.0 

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

func (*RangeScanResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type ReadRequest 

type ReadRequest struct {

	// The shard id. This is optional allow for support for server-side hashing
	// and proxying in the future.
	Shard *int64 `protobuf:"varint,1,opt,name=shard,proto3,oneof" json:"shard,omitempty"`
	// The get requests
	Gets []*GetRequest `protobuf:"bytes,2,rep,name=gets,proto3" json:"gets,omitempty"`
	// contains filtered or unexported fields
}

* A batch read request. Applies the batches of requests.

func (*ReadRequest) CloneMessageVT 

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

func (*ReadRequest) CloneVT 

func (m *ReadRequest) CloneVT() *ReadRequest

func (*ReadRequest) Descriptor deprecated 

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

Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.

func (*ReadRequest) EqualMessageVT 

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

func (*ReadRequest) EqualVT 

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

func (*ReadRequest) GetGets 

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

func (*ReadRequest) GetShard added in v0.9.0 

func (x *ReadRequest) GetShard() int64

func (*ReadRequest) MarshalToSizedBufferVT 

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

func (*ReadRequest) MarshalToVT 

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

func (*ReadRequest) MarshalVT 

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

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) ProtoReflect 

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

func (*ReadRequest) Reset 

func (x *ReadRequest) Reset()

func (*ReadRequest) SizeVT 

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

func (*ReadRequest) String 

func (x *ReadRequest) String() string

func (*ReadRequest) UnmarshalVT 

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

func (*ReadRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type ReadResponse 

type ReadResponse struct {

	// The get responses
	Gets []*GetResponse `protobuf:"bytes,1,rep,name=gets,proto3" json:"gets,omitempty"`
	// contains filtered or unexported fields
}

* The response to a batch read request. Responses of each type respect the order of the original requests.

func (*ReadResponse) CloneMessageVT 

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

func (*ReadResponse) CloneVT 

func (m *ReadResponse) CloneVT() *ReadResponse

func (*ReadResponse) Descriptor deprecated 

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

Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.

func (*ReadResponse) EqualMessageVT 

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

func (*ReadResponse) EqualVT 

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

func (*ReadResponse) GetGets 

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

func (*ReadResponse) MarshalToSizedBufferVT 

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

func (*ReadResponse) MarshalToVT 

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

func (*ReadResponse) MarshalVT 

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

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) ProtoReflect 

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

func (*ReadResponse) Reset 

func (x *ReadResponse) Reset()

func (*ReadResponse) SizeVT 

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

func (*ReadResponse) String 

func (x *ReadResponse) String() string

func (*ReadResponse) UnmarshalVT 

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

func (*ReadResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type SecondaryIndex added in v0.11.0 

type SecondaryIndex struct {
	IndexName    string `protobuf:"bytes,1,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	SecondaryKey string `protobuf:"bytes,2,opt,name=secondary_key,json=secondaryKey,proto3" json:"secondary_key,omitempty"`
	// contains filtered or unexported fields
}

func (*SecondaryIndex) CloneMessageVT added in v0.11.0 

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

func (*SecondaryIndex) CloneVT added in v0.11.0 

func (m *SecondaryIndex) CloneVT() *SecondaryIndex

func (*SecondaryIndex) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use SecondaryIndex.ProtoReflect.Descriptor instead.

func (*SecondaryIndex) EqualMessageVT added in v0.11.0 

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

func (*SecondaryIndex) EqualVT added in v0.11.0 

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

func (*SecondaryIndex) GetIndexName added in v0.11.0 

func (x *SecondaryIndex) GetIndexName() string

func (*SecondaryIndex) GetSecondaryKey added in v0.11.0 

func (x *SecondaryIndex) GetSecondaryKey() string

func (*SecondaryIndex) MarshalToSizedBufferVT added in v0.11.0 

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

func (*SecondaryIndex) MarshalToVT added in v0.11.0 

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

func (*SecondaryIndex) MarshalVT added in v0.11.0 

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

func (*SecondaryIndex) ProtoMessage added in v0.11.0 

func (*SecondaryIndex) ProtoMessage()

func (*SecondaryIndex) ProtoReflect added in v0.11.0 

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

func (*SecondaryIndex) Reset added in v0.11.0 

func (x *SecondaryIndex) Reset()

func (*SecondaryIndex) SizeVT added in v0.11.0 

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

func (*SecondaryIndex) String added in v0.11.0 

func (x *SecondaryIndex) String() string

func (*SecondaryIndex) UnmarshalVT added in v0.11.0 

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

func (*SecondaryIndex) UnmarshalVTUnsafe added in v0.11.0 

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

type ServingStatus 

type ServingStatus int32
const (
	ServingStatus_NOT_MEMBER ServingStatus = 0
	ServingStatus_FENCED     ServingStatus = 1
	ServingStatus_FOLLOWER   ServingStatus = 2
	ServingStatus_LEADER     ServingStatus = 3
)

func (ServingStatus) Descriptor 

func (ServingStatus) Descriptor() protoreflect.EnumDescriptor

func (ServingStatus) Enum 

func (x ServingStatus) Enum() *ServingStatus

func (ServingStatus) EnumDescriptor deprecated 

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

Deprecated: Use ServingStatus.Descriptor instead.

func (ServingStatus) Number 

func (x ServingStatus) Number() protoreflect.EnumNumber

func (ServingStatus) String 

func (x ServingStatus) String() string

func (ServingStatus) Type 

func (ServingStatus) Type() protoreflect.EnumType

type SessionHeartbeat 

type SessionHeartbeat struct {
	Shard     int64 `protobuf:"varint,1,opt,name=shard,proto3" json:"shard,omitempty"`
	SessionId int64 `protobuf:"varint,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionHeartbeat) CloneMessageVT 

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

func (*SessionHeartbeat) CloneVT 

func (m *SessionHeartbeat) CloneVT() *SessionHeartbeat

func (*SessionHeartbeat) Descriptor deprecated 

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

Deprecated: Use SessionHeartbeat.ProtoReflect.Descriptor instead.

func (*SessionHeartbeat) EqualMessageVT 

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

func (*SessionHeartbeat) EqualVT 

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

func (*SessionHeartbeat) GetSessionId 

func (x *SessionHeartbeat) GetSessionId() int64

func (*SessionHeartbeat) GetShard added in v0.9.0 

func (x *SessionHeartbeat) GetShard() int64

func (*SessionHeartbeat) MarshalToSizedBufferVT 

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

func (*SessionHeartbeat) MarshalToVT 

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

func (*SessionHeartbeat) MarshalVT 

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

func (*SessionHeartbeat) ProtoMessage 

func (*SessionHeartbeat) ProtoMessage()

func (*SessionHeartbeat) ProtoReflect 

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

func (*SessionHeartbeat) Reset 

func (x *SessionHeartbeat) Reset()

func (*SessionHeartbeat) SizeVT 

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

func (*SessionHeartbeat) String 

func (x *SessionHeartbeat) String() string

func (*SessionHeartbeat) UnmarshalVT 

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

func (*SessionHeartbeat) UnmarshalVTUnsafe added in v0.5.0 

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

type SessionMetadata 

type SessionMetadata struct {
	TimeoutMs uint32 `protobuf:"varint,1,opt,name=timeout_ms,json=timeoutMs,proto3" json:"timeout_ms,omitempty"`
	Identity  string `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
	// contains filtered or unexported fields
}

func SessionMetadataFromVTPool 

func SessionMetadataFromVTPool() *SessionMetadata

func (*SessionMetadata) CloneMessageVT 

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

func (*SessionMetadata) CloneVT 

func (m *SessionMetadata) CloneVT() *SessionMetadata

func (*SessionMetadata) Descriptor deprecated 

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

Deprecated: Use SessionMetadata.ProtoReflect.Descriptor instead.

func (*SessionMetadata) EqualMessageVT 

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

func (*SessionMetadata) EqualVT 

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

func (*SessionMetadata) GetIdentity 

func (x *SessionMetadata) GetIdentity() string

func (*SessionMetadata) GetTimeoutMs 

func (x *SessionMetadata) GetTimeoutMs() uint32

func (*SessionMetadata) MarshalToSizedBufferVT 

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

func (*SessionMetadata) MarshalToVT 

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

func (*SessionMetadata) MarshalVT 

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

func (*SessionMetadata) ProtoMessage 

func (*SessionMetadata) ProtoMessage()

func (*SessionMetadata) ProtoReflect 

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

func (*SessionMetadata) Reset 

func (x *SessionMetadata) Reset()

func (*SessionMetadata) ResetVT 

func (m *SessionMetadata) ResetVT()

func (*SessionMetadata) ReturnToVTPool 

func (m *SessionMetadata) ReturnToVTPool()

func (*SessionMetadata) SizeVT 

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

func (*SessionMetadata) String 

func (x *SessionMetadata) String() string

func (*SessionMetadata) UnmarshalVT 

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

func (*SessionMetadata) UnmarshalVTUnsafe added in v0.5.0 

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

type ShardAssignment 

type ShardAssignment struct {

	// The shard id
	Shard int64 `protobuf:"varint,1,opt,name=shard,proto3" json:"shard,omitempty"`
	// The shard leader, e.g. `host:port`
	Leader string `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
	// There could be multiple ways to describe the boundaries of a shard
	//
	// Types that are assignable to ShardBoundaries:
	//
	//	*ShardAssignment_Int32HashRange
	ShardBoundaries isShardAssignment_ShardBoundaries `protobuf_oneof:"shard_boundaries"`
	// contains filtered or unexported fields
}

* The assignment of a shard to a server.

func (*ShardAssignment) CloneMessageVT 

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

func (*ShardAssignment) CloneVT 

func (m *ShardAssignment) CloneVT() *ShardAssignment

func (*ShardAssignment) Descriptor deprecated 

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

Deprecated: Use ShardAssignment.ProtoReflect.Descriptor instead.

func (*ShardAssignment) EqualMessageVT 

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

func (*ShardAssignment) EqualVT 

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

func (*ShardAssignment) GetInt32HashRange 

func (x *ShardAssignment) GetInt32HashRange() *Int32HashRange

func (*ShardAssignment) GetLeader 

func (x *ShardAssignment) GetLeader() string

func (*ShardAssignment) GetShard added in v0.9.0 

func (x *ShardAssignment) GetShard() int64

func (*ShardAssignment) GetShardBoundaries 

func (m *ShardAssignment) GetShardBoundaries() isShardAssignment_ShardBoundaries

func (*ShardAssignment) MarshalToSizedBufferVT 

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

func (*ShardAssignment) MarshalToVT 

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

func (*ShardAssignment) MarshalVT 

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

func (*ShardAssignment) ProtoMessage 

func (*ShardAssignment) ProtoMessage()

func (*ShardAssignment) ProtoReflect 

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

func (*ShardAssignment) Reset 

func (x *ShardAssignment) Reset()

func (*ShardAssignment) SizeVT 

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

func (*ShardAssignment) String 

func (x *ShardAssignment) String() string

func (*ShardAssignment) UnmarshalVT 

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

func (*ShardAssignment) UnmarshalVTUnsafe added in v0.5.0 

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

type ShardAssignment_Int32HashRange 

type ShardAssignment_Int32HashRange struct {
	Int32HashRange *Int32HashRange `protobuf:"bytes,3,opt,name=int32_hash_range,json=int32HashRange,proto3,oneof"`
}

func (*ShardAssignment_Int32HashRange) CloneVT 

func (m *ShardAssignment_Int32HashRange) CloneVT() isShardAssignment_ShardBoundaries

func (*ShardAssignment_Int32HashRange) EqualVT 

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

func (*ShardAssignment_Int32HashRange) MarshalToSizedBufferVT 

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

func (*ShardAssignment_Int32HashRange) MarshalToVT 

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

func (*ShardAssignment_Int32HashRange) SizeVT 

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

type ShardAssignments 

type ShardAssignments struct {
	Namespaces map[string]*NamespaceShardsAssignment `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

* The response to a shard assignments request.

func (*ShardAssignments) CloneMessageVT 

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

func (*ShardAssignments) CloneVT 

func (m *ShardAssignments) CloneVT() *ShardAssignments

func (*ShardAssignments) Descriptor deprecated 

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

Deprecated: Use ShardAssignments.ProtoReflect.Descriptor instead.

func (*ShardAssignments) EqualMessageVT 

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

func (*ShardAssignments) EqualVT 

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

func (*ShardAssignments) GetNamespaces 

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

func (*ShardAssignments) MarshalToSizedBufferVT 

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

func (*ShardAssignments) MarshalToVT 

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

func (*ShardAssignments) MarshalVT 

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

func (*ShardAssignments) ProtoMessage 

func (*ShardAssignments) ProtoMessage()

func (*ShardAssignments) ProtoReflect 

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

func (*ShardAssignments) Reset 

func (x *ShardAssignments) Reset()

func (*ShardAssignments) SizeVT 

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

func (*ShardAssignments) String 

func (x *ShardAssignments) String() string

func (*ShardAssignments) UnmarshalVT 

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

func (*ShardAssignments) UnmarshalVTUnsafe added in v0.5.0 

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

type ShardAssignmentsRequest 

type ShardAssignmentsRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

* A shard assignments request. Gets all shard-to-server assignments as a stream. Each set of assignments in the response stream will contain all the assignments to bring the client up to date. For example, if a shard is split, the stream will return a single response containing all the new shard assignments as opposed to multiple stream responses, each containing a single shard assignment.

func (*ShardAssignmentsRequest) CloneMessageVT 

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

func (*ShardAssignmentsRequest) CloneVT 

func (m *ShardAssignmentsRequest) CloneVT() *ShardAssignmentsRequest

func (*ShardAssignmentsRequest) Descriptor deprecated 

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

Deprecated: Use ShardAssignmentsRequest.ProtoReflect.Descriptor instead.

func (*ShardAssignmentsRequest) EqualMessageVT 

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

func (*ShardAssignmentsRequest) EqualVT 

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

func (*ShardAssignmentsRequest) GetNamespace 

func (x *ShardAssignmentsRequest) GetNamespace() string

func (*ShardAssignmentsRequest) MarshalToSizedBufferVT 

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

func (*ShardAssignmentsRequest) MarshalToVT 

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

func (*ShardAssignmentsRequest) MarshalVT 

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

func (*ShardAssignmentsRequest) ProtoMessage 

func (*ShardAssignmentsRequest) ProtoMessage()

func (*ShardAssignmentsRequest) ProtoReflect 

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

func (*ShardAssignmentsRequest) Reset 

func (x *ShardAssignmentsRequest) Reset()

func (*ShardAssignmentsRequest) SizeVT 

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

func (*ShardAssignmentsRequest) String 

func (x *ShardAssignmentsRequest) String() string

func (*ShardAssignmentsRequest) UnmarshalVT 

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

func (*ShardAssignmentsRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type ShardKeyRouter 

type ShardKeyRouter int32
const (
	ShardKeyRouter_UNKNOWN ShardKeyRouter = 0
	ShardKeyRouter_XXHASH3 ShardKeyRouter = 1
)

func (ShardKeyRouter) Descriptor 

func (ShardKeyRouter) Descriptor() protoreflect.EnumDescriptor

func (ShardKeyRouter) Enum 

func (x ShardKeyRouter) Enum() *ShardKeyRouter

func (ShardKeyRouter) EnumDescriptor deprecated 

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

Deprecated: Use ShardKeyRouter.Descriptor instead.

func (ShardKeyRouter) Number 

func (x ShardKeyRouter) Number() protoreflect.EnumNumber

func (ShardKeyRouter) String 

func (x ShardKeyRouter) String() string

func (ShardKeyRouter) Type 

func (ShardKeyRouter) Type() protoreflect.EnumType

type SnapshotChunk 

type SnapshotChunk struct {
	Term       int64  `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
	Name       string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Content    []byte `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	ChunkIndex int32  `protobuf:"varint,4,opt,name=chunk_index,json=chunkIndex,proto3" json:"chunk_index,omitempty"`
	ChunkCount int32  `protobuf:"varint,5,opt,name=chunk_count,json=chunkCount,proto3" json:"chunk_count,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotChunk) CloneMessageVT 

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

func (*SnapshotChunk) CloneVT 

func (m *SnapshotChunk) CloneVT() *SnapshotChunk

func (*SnapshotChunk) Descriptor deprecated 

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

Deprecated: Use SnapshotChunk.ProtoReflect.Descriptor instead.

func (*SnapshotChunk) EqualMessageVT 

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

func (*SnapshotChunk) EqualVT 

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

func (*SnapshotChunk) GetChunkCount 

func (x *SnapshotChunk) GetChunkCount() int32

func (*SnapshotChunk) GetChunkIndex 

func (x *SnapshotChunk) GetChunkIndex() int32

func (*SnapshotChunk) GetContent 

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

func (*SnapshotChunk) GetName 

func (x *SnapshotChunk) GetName() string

func (*SnapshotChunk) GetTerm 

func (x *SnapshotChunk) GetTerm() int64

func (*SnapshotChunk) MarshalToSizedBufferVT 

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

func (*SnapshotChunk) MarshalToVT 

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

func (*SnapshotChunk) MarshalVT 

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

func (*SnapshotChunk) ProtoMessage 

func (*SnapshotChunk) ProtoMessage()

func (*SnapshotChunk) ProtoReflect 

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

func (*SnapshotChunk) Reset 

func (x *SnapshotChunk) Reset()

func (*SnapshotChunk) SizeVT 

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

func (*SnapshotChunk) String 

func (x *SnapshotChunk) String() string

func (*SnapshotChunk) UnmarshalVT 

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

func (*SnapshotChunk) UnmarshalVTUnsafe added in v0.5.0 

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

type SnapshotResponse 

type SnapshotResponse struct {
	AckOffset int64 `protobuf:"varint,1,opt,name=ack_offset,json=ackOffset,proto3" json:"ack_offset,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotResponse) CloneMessageVT 

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

func (*SnapshotResponse) CloneVT 

func (m *SnapshotResponse) CloneVT() *SnapshotResponse

func (*SnapshotResponse) Descriptor deprecated 

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

Deprecated: Use SnapshotResponse.ProtoReflect.Descriptor instead.

func (*SnapshotResponse) EqualMessageVT 

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

func (*SnapshotResponse) EqualVT 

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

func (*SnapshotResponse) GetAckOffset 

func (x *SnapshotResponse) GetAckOffset() int64

func (*SnapshotResponse) MarshalToSizedBufferVT 

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

func (*SnapshotResponse) MarshalToVT 

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

func (*SnapshotResponse) MarshalVT 

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

func (*SnapshotResponse) ProtoMessage 

func (*SnapshotResponse) ProtoMessage()

func (*SnapshotResponse) ProtoReflect 

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

func (*SnapshotResponse) Reset 

func (x *SnapshotResponse) Reset()

func (*SnapshotResponse) SizeVT 

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

func (*SnapshotResponse) String 

func (x *SnapshotResponse) String() string

func (*SnapshotResponse) UnmarshalVT 

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

func (*SnapshotResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type Status 

type Status int32

* Represents all the possible status. 

const (
	// Operation was successful
	Status_OK Status = 0
	// The key was not found
	Status_KEY_NOT_FOUND Status = 1
	// The existing version does not match the expected version
	Status_UNEXPECTED_VERSION_ID Status = 2
	// The session that the put request referred to is not alive
	Status_SESSION_DOES_NOT_EXIST Status = 3
)

func (Status) Descriptor 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated 

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

Deprecated: Use Status.Descriptor instead.

func (Status) Number 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String 

func (x Status) String() string

func (Status) Type 

func (Status) Type() protoreflect.EnumType

type StorageEntry 

type StorageEntry struct {
	Value                 []byte            `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	VersionId             int64             `protobuf:"varint,2,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"`
	ModificationsCount    int64             `protobuf:"varint,3,opt,name=modifications_count,json=modificationsCount,proto3" json:"modifications_count,omitempty"`
	CreationTimestamp     uint64            `protobuf:"fixed64,4,opt,name=creation_timestamp,json=creationTimestamp,proto3" json:"creation_timestamp,omitempty"`
	ModificationTimestamp uint64            `` /* 126-byte string literal not displayed */
	SessionId             *int64            `protobuf:"varint,6,opt,name=session_id,json=sessionId,proto3,oneof" json:"session_id,omitempty"`
	ClientIdentity        *string           `protobuf:"bytes,7,opt,name=client_identity,json=clientIdentity,proto3,oneof" json:"client_identity,omitempty"`
	PartitionKey          *string           `protobuf:"bytes,8,opt,name=partition_key,json=partitionKey,proto3,oneof" json:"partition_key,omitempty"`
	SecondaryIndexes      []*SecondaryIndex `protobuf:"bytes,9,rep,name=secondary_indexes,json=secondaryIndexes,proto3" json:"secondary_indexes,omitempty"`
	// contains filtered or unexported fields
}

func StorageEntryFromVTPool 

func StorageEntryFromVTPool() *StorageEntry

func (*StorageEntry) CloneMessageVT 

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

func (*StorageEntry) CloneVT 

func (m *StorageEntry) CloneVT() *StorageEntry

func (*StorageEntry) Descriptor deprecated 

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

Deprecated: Use StorageEntry.ProtoReflect.Descriptor instead.

func (*StorageEntry) EqualMessageVT 

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

func (*StorageEntry) EqualVT 

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

func (*StorageEntry) GetClientIdentity 

func (x *StorageEntry) GetClientIdentity() string

func (*StorageEntry) GetCreationTimestamp 

func (x *StorageEntry) GetCreationTimestamp() uint64

func (*StorageEntry) GetModificationTimestamp 

func (x *StorageEntry) GetModificationTimestamp() uint64

func (*StorageEntry) GetModificationsCount 

func (x *StorageEntry) GetModificationsCount() int64

func (*StorageEntry) GetPartitionKey added in v0.5.0 

func (x *StorageEntry) GetPartitionKey() string

func (*StorageEntry) GetSecondaryIndexes added in v0.11.0 

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

func (*StorageEntry) GetSessionId 

func (x *StorageEntry) GetSessionId() int64

func (*StorageEntry) GetValue 

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

func (*StorageEntry) GetVersionId 

func (x *StorageEntry) GetVersionId() int64

func (*StorageEntry) MarshalToSizedBufferVT 

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

func (*StorageEntry) MarshalToVT 

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

func (*StorageEntry) MarshalVT 

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

func (*StorageEntry) ProtoMessage 

func (*StorageEntry) ProtoMessage()

func (*StorageEntry) ProtoReflect 

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

func (*StorageEntry) Reset 

func (x *StorageEntry) Reset()

func (*StorageEntry) ResetVT 

func (m *StorageEntry) ResetVT()

func (*StorageEntry) ReturnToVTPool 

func (m *StorageEntry) ReturnToVTPool()

func (*StorageEntry) SizeVT 

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

func (*StorageEntry) String 

func (x *StorageEntry) String() string

func (*StorageEntry) UnmarshalVT 

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

func (*StorageEntry) UnmarshalVTUnsafe added in v0.5.0 

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

type TruncateRequest 

type TruncateRequest struct {
	Namespace   string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Shard       int64    `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"`
	Term        int64    `protobuf:"varint,3,opt,name=term,proto3" json:"term,omitempty"`
	HeadEntryId *EntryId `protobuf:"bytes,4,opt,name=head_entry_id,json=headEntryId,proto3" json:"head_entry_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TruncateRequest) CloneMessageVT 

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

func (*TruncateRequest) CloneVT 

func (m *TruncateRequest) CloneVT() *TruncateRequest

func (*TruncateRequest) Descriptor deprecated 

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

Deprecated: Use TruncateRequest.ProtoReflect.Descriptor instead.

func (*TruncateRequest) EqualMessageVT 

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

func (*TruncateRequest) EqualVT 

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

func (*TruncateRequest) GetHeadEntryId 

func (x *TruncateRequest) GetHeadEntryId() *EntryId

func (*TruncateRequest) GetNamespace 

func (x *TruncateRequest) GetNamespace() string

func (*TruncateRequest) GetShard added in v0.9.0 

func (x *TruncateRequest) GetShard() int64

func (*TruncateRequest) GetTerm 

func (x *TruncateRequest) GetTerm() int64

func (*TruncateRequest) MarshalToSizedBufferVT 

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

func (*TruncateRequest) MarshalToVT 

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

func (*TruncateRequest) MarshalVT 

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

func (*TruncateRequest) ProtoMessage 

func (*TruncateRequest) ProtoMessage()

func (*TruncateRequest) ProtoReflect 

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

func (*TruncateRequest) Reset 

func (x *TruncateRequest) Reset()

func (*TruncateRequest) SizeVT 

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

func (*TruncateRequest) String 

func (x *TruncateRequest) String() string

func (*TruncateRequest) UnmarshalVT 

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

func (*TruncateRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type TruncateResponse 

type TruncateResponse struct {
	HeadEntryId *EntryId `protobuf:"bytes,1,opt,name=head_entry_id,json=headEntryId,proto3" json:"head_entry_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TruncateResponse) CloneMessageVT 

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

func (*TruncateResponse) CloneVT 

func (m *TruncateResponse) CloneVT() *TruncateResponse

func (*TruncateResponse) Descriptor deprecated 

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

Deprecated: Use TruncateResponse.ProtoReflect.Descriptor instead.

func (*TruncateResponse) EqualMessageVT 

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

func (*TruncateResponse) EqualVT 

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

func (*TruncateResponse) GetHeadEntryId 

func (x *TruncateResponse) GetHeadEntryId() *EntryId

func (*TruncateResponse) MarshalToSizedBufferVT 

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

func (*TruncateResponse) MarshalToVT 

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

func (*TruncateResponse) MarshalVT 

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

func (*TruncateResponse) ProtoMessage 

func (*TruncateResponse) ProtoMessage()

func (*TruncateResponse) ProtoReflect 

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

func (*TruncateResponse) Reset 

func (x *TruncateResponse) Reset()

func (*TruncateResponse) SizeVT 

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

func (*TruncateResponse) String 

func (x *TruncateResponse) String() string

func (*TruncateResponse) UnmarshalVT 

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

func (*TruncateResponse) UnmarshalVTUnsafe added in v0.5.0 

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

type UnimplementedOxiaClientServer 

type UnimplementedOxiaClientServer struct {
}

UnimplementedOxiaClientServer must be embedded to have forward compatible implementations.

func (UnimplementedOxiaClientServer) CloseSession 

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

func (UnimplementedOxiaClientServer) CreateSession 

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

func (UnimplementedOxiaClientServer) GetNotifications 

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

func (UnimplementedOxiaClientServer) GetShardAssignments 

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

func (UnimplementedOxiaClientServer) KeepAlive 

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

func (UnimplementedOxiaClientServer) List 

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

func (UnimplementedOxiaClientServer) RangeScan added in v0.5.0 

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

func (UnimplementedOxiaClientServer) Read 

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

func (UnimplementedOxiaClientServer) Write 

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

func (UnimplementedOxiaClientServer) WriteStream added in v0.7.0 

func (UnimplementedOxiaClientServer) WriteStream(OxiaClient_WriteStreamServer) error

type UnimplementedOxiaCoordinationServer 

type UnimplementedOxiaCoordinationServer struct {
}

UnimplementedOxiaCoordinationServer must be embedded to have forward compatible implementations.

func (UnimplementedOxiaCoordinationServer) AddFollower 

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

func (UnimplementedOxiaCoordinationServer) BecomeLeader 

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

func (UnimplementedOxiaCoordinationServer) DeleteShard 

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

func (UnimplementedOxiaCoordinationServer) GetStatus 

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

func (UnimplementedOxiaCoordinationServer) NewTerm 

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

func (UnimplementedOxiaCoordinationServer) PushShardAssignments 

func (UnimplementedOxiaCoordinationServer) PushShardAssignments(OxiaCoordination_PushShardAssignmentsServer) error

type UnimplementedOxiaLogReplicationServer 

type UnimplementedOxiaLogReplicationServer struct {
}

UnimplementedOxiaLogReplicationServer must be embedded to have forward compatible implementations.

func (UnimplementedOxiaLogReplicationServer) Replicate 

func (UnimplementedOxiaLogReplicationServer) Replicate(OxiaLogReplication_ReplicateServer) error

func (UnimplementedOxiaLogReplicationServer) SendSnapshot 

func (UnimplementedOxiaLogReplicationServer) SendSnapshot(OxiaLogReplication_SendSnapshotServer) error

func (UnimplementedOxiaLogReplicationServer) Truncate 

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

type UnsafeOxiaClientServer 

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

UnsafeOxiaClientServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OxiaClientServer will result in compilation errors.

type UnsafeOxiaCoordinationServer 

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

UnsafeOxiaCoordinationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OxiaCoordinationServer will result in compilation errors.

type UnsafeOxiaLogReplicationServer 

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

UnsafeOxiaLogReplicationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OxiaLogReplicationServer will result in compilation errors.

type Version 

type Version struct {

	// The version identifier of the record
	VersionId int64 `protobuf:"varint,1,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"`
	// The number of modifications made to the record since
	// it was created
	ModificationsCount int64 `protobuf:"varint,2,opt,name=modifications_count,json=modificationsCount,proto3" json:"modifications_count,omitempty"`
	// The creation timestamp of the first version of the record
	CreatedTimestamp uint64 `protobuf:"fixed64,3,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"`
	// The modified timestamp of the current version of the record
	ModifiedTimestamp uint64 `protobuf:"fixed64,4,opt,name=modified_timestamp,json=modifiedTimestamp,proto3" json:"modified_timestamp,omitempty"`
	// Identifier of the session if the record is ephemeral
	SessionId      *int64  `protobuf:"varint,5,opt,name=session_id,json=sessionId,proto3,oneof" json:"session_id,omitempty"`
	ClientIdentity *string `protobuf:"bytes,6,opt,name=client_identity,json=clientIdentity,proto3,oneof" json:"client_identity,omitempty"`
	// contains filtered or unexported fields
}

* Version contains info about the state of a record.

func (*Version) CloneMessageVT 

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

func (*Version) CloneVT 

func (m *Version) CloneVT() *Version

func (*Version) Descriptor deprecated 

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

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) EqualMessageVT 

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

func (*Version) EqualVT 

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

func (*Version) GetClientIdentity 

func (x *Version) GetClientIdentity() string

func (*Version) GetCreatedTimestamp 

func (x *Version) GetCreatedTimestamp() uint64

func (*Version) GetModificationsCount 

func (x *Version) GetModificationsCount() int64

func (*Version) GetModifiedTimestamp 

func (x *Version) GetModifiedTimestamp() uint64

func (*Version) GetSessionId 

func (x *Version) GetSessionId() int64

func (*Version) GetVersionId 

func (x *Version) GetVersionId() int64

func (*Version) MarshalToSizedBufferVT 

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

func (*Version) MarshalToVT 

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

func (*Version) MarshalVT 

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

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) ProtoReflect 

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

func (*Version) Reset 

func (x *Version) Reset()

func (*Version) SizeVT 

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

func (*Version) String 

func (x *Version) String() string

func (*Version) UnmarshalVT 

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

func (*Version) UnmarshalVTUnsafe added in v0.5.0 

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

type WriteRequest 

type WriteRequest struct {

	// The shard id. This is optional allow for support for server-side hashing
	// and proxying in the future.
	Shard *int64 `protobuf:"varint,1,opt,name=shard,proto3,oneof" json:"shard,omitempty"`
	// The put requests
	Puts []*PutRequest `protobuf:"bytes,2,rep,name=puts,proto3" json:"puts,omitempty"`
	// The delete requests
	Deletes []*DeleteRequest `protobuf:"bytes,3,rep,name=deletes,proto3" json:"deletes,omitempty"`
	// The delete range requests
	DeleteRanges []*DeleteRangeRequest `protobuf:"bytes,4,rep,name=delete_ranges,json=deleteRanges,proto3" json:"delete_ranges,omitempty"`
	// contains filtered or unexported fields
}

* A batch write request. Applies the batches of requests. Requests are processed in positional order within batches and the batch types are processed in the following order: puts, deletes, delete_ranges.

func (*WriteRequest) CloneMessageVT 

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

func (*WriteRequest) CloneVT 

func (m *WriteRequest) CloneVT() *WriteRequest

func (*WriteRequest) Descriptor deprecated 

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

Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.

func (*WriteRequest) EqualMessageVT 

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

func (*WriteRequest) EqualVT 

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

func (*WriteRequest) GetDeleteRanges 

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

func (*WriteRequest) GetDeletes 

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

func (*WriteRequest) GetPuts 

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

func (*WriteRequest) GetShard added in v0.9.0 

func (x *WriteRequest) GetShard() int64

func (*WriteRequest) MarshalToSizedBufferVT 

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

func (*WriteRequest) MarshalToVT 

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

func (*WriteRequest) MarshalVT 

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

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) ProtoReflect 

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

func (*WriteRequest) Reset 

func (x *WriteRequest) Reset()

func (*WriteRequest) SizeVT 

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

func (*WriteRequest) String 

func (x *WriteRequest) String() string

func (*WriteRequest) UnmarshalVT 

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

func (*WriteRequest) UnmarshalVTUnsafe added in v0.5.0 

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

type WriteRequests 

type WriteRequests struct {
	Writes []*WriteRequest `protobuf:"bytes,1,rep,name=writes,proto3" json:"writes,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteRequests) CloneMessageVT 

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

func (*WriteRequests) CloneVT 

func (m *WriteRequests) CloneVT() *WriteRequests

func (*WriteRequests) Descriptor deprecated 

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

Deprecated: Use WriteRequests.ProtoReflect.Descriptor instead.

func (*WriteRequests) EqualMessageVT 

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

func (*WriteRequests) EqualVT 

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

func (*WriteRequests) GetWrites 

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

func (*WriteRequests) MarshalToSizedBufferVT 

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

func (*WriteRequests) MarshalToVT 

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

func (*WriteRequests) MarshalVT 

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

func (*WriteRequests) ProtoMessage 

func (*WriteRequests) ProtoMessage()

func (*WriteRequests) ProtoReflect 

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

func (*WriteRequests) Reset 

func (x *WriteRequests) Reset()

func (*WriteRequests) SizeVT 

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

func (*WriteRequests) String 

func (x *WriteRequests) String() string

func (*WriteRequests) UnmarshalVT 

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

func (*WriteRequests) UnmarshalVTUnsafe added in v0.5.0 

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

type WriteResponse 

type WriteResponse struct {

	// The put responses
	Puts []*PutResponse `protobuf:"bytes,1,rep,name=puts,proto3" json:"puts,omitempty"`
	// The delete responses
	Deletes []*DeleteResponse `protobuf:"bytes,2,rep,name=deletes,proto3" json:"deletes,omitempty"`
	// The delete range responses
	DeleteRanges []*DeleteRangeResponse `protobuf:"bytes,3,rep,name=delete_ranges,json=deleteRanges,proto3" json:"delete_ranges,omitempty"`
	// contains filtered or unexported fields
}

* The response to a batch write request. Responses of each type respect the order of the original requests.

func (*WriteResponse) CloneMessageVT 

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

func (*WriteResponse) CloneVT 

func (m *WriteResponse) CloneVT() *WriteResponse

func (*WriteResponse) Descriptor deprecated 

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

Deprecated: Use WriteResponse.ProtoReflect.Descriptor instead.

func (*WriteResponse) EqualMessageVT 

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

func (*WriteResponse) EqualVT 

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

func (*WriteResponse) GetDeleteRanges 

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

func (*WriteResponse) GetDeletes 

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

func (*WriteResponse) GetPuts 

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

func (*WriteResponse) MarshalToSizedBufferVT 

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

func (*WriteResponse) MarshalToVT 

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

func (*WriteResponse) MarshalVT 

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

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) ProtoReflect 

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

func (*WriteResponse) Reset 

func (x *WriteResponse) Reset()

func (*WriteResponse) SizeVT 

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

func (*WriteResponse) String 

func (x *WriteResponse) String() string

func (*WriteResponse) UnmarshalVT 

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

func (*WriteResponse) UnmarshalVTUnsafe added in v0.5.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.