proto

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2024 License: Apache-2.0 Imports: 17 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 (
	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",
	}
	NotificationType_value = map[string]int32{
		"KEY_CREATED":  0,
		"KEY_MODIFIED": 1,
		"KEY_DELETED":  2,
	}
)

Enum value maps for NotificationType.

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
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:    "Read",
			Handler:       _OxiaClient_Read_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "List",
			Handler:       _OxiaClient_List_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

type AddFollowerRequest 

type AddFollowerRequest struct {
	Namespace           string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ShardId             int64    `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,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) GetShardId 

func (x *AddFollowerRequest) GetShardId() 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

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

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

type BecomeLeaderRequest 

type BecomeLeaderRequest struct {
	Namespace         string              `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ShardId           int64               `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,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) GetShardId 

func (x *BecomeLeaderRequest) GetShardId() 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

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

type CloseSessionRequest 

type CloseSessionRequest struct {
	ShardId   int64 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,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) GetShardId 

func (x *CloseSessionRequest) GetShardId() 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

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

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

type CreateSessionRequest 

type CreateSessionRequest struct {
	ShardId          int64  `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,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) GetShardId 

func (x *CreateSessionRequest) GetShardId() 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

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

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

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

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

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

type DeleteShardRequest 

type DeleteShardRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ShardId   int64  `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,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) GetShardId 

func (x *DeleteShardRequest) GetShardId() 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

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

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

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"`
	// 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) 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

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"`
	// 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) 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

type GetStatusRequest 

type GetStatusRequest struct {
	ShardId int64 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,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) GetShardId 

func (x *GetStatusRequest) GetShardId() 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

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

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

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

type ListRequest 

type ListRequest struct {

	// The shard id. This is optional allow for support for server-side hashing
	// and proxying in the future.
	ShardId *int64 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3,oneof" json:"shard_id,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"`
	// 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) GetShardId 

func (x *ListRequest) GetShardId() 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

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

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

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

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

type NewTermRequest 

type NewTermRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ShardId   int64  `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Term      int64  `protobuf:"varint,3,opt,name=term,proto3" json:"term,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) GetShardId 

func (x *NewTermRequest) GetShardId() 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

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

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"`
	// 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) 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

type NotificationBatch 

type NotificationBatch struct {
	ShardId       int64                    `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,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) GetShardId 

func (x *NotificationBatch) GetShardId() 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

type NotificationType 

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

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 {
	ShardId              int64  `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,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) GetShardId 

func (x *NotificationsRequest) GetShardId() 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

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.
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, 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.
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (OxiaClient_ListClient, 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.
	Write(context.Context, *WriteRequest) (*WriteResponse, 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.
	List(*ListRequest, OxiaClient_ListServer) 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_ReadClient 

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

type OxiaClient_ReadServer 

type OxiaClient_ReadServer interface {
	Send(*ReadResponse) 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"`
	// 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) 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

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"`
	// 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) 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

type ReadRequest 

type ReadRequest struct {

	// The shard id. This is optional allow for support for server-side hashing
	// and proxying in the future.
	ShardId *int64 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3,oneof" json:"shard_id,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) GetShardId 

func (x *ReadRequest) GetShardId() 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

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

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 {
	ShardId   int64 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,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) GetShardId 

func (x *SessionHeartbeat) GetShardId() 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

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

type ShardAssignment 

type ShardAssignment struct {

	// The shard id
	ShardId int64 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,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) GetShardBoundaries 

func (m *ShardAssignment) GetShardBoundaries() isShardAssignment_ShardBoundaries

func (*ShardAssignment) GetShardId 

func (x *ShardAssignment) GetShardId() int64

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

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

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

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

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

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"`
	// 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) 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

type TruncateRequest 

type TruncateRequest struct {
	Namespace   string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ShardId     int64    `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,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) GetShardId 

func (x *TruncateRequest) GetShardId() 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

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

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) Read 

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

func (UnimplementedOxiaClientServer) Write 

func (UnimplementedOxiaClientServer) Write(context.Context, *WriteRequest) (*WriteResponse, 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

type WriteRequest 

type WriteRequest struct {

	// The shard id. This is optional allow for support for server-side hashing
	// and proxying in the future.
	ShardId *int64 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3,oneof" json:"shard_id,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) GetShardId 

func (x *WriteRequest) GetShardId() 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

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

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

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.