regattapb

package
v0.4.3 Latest Latest
Warning

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

 Go to latest Published: Jun 11, 2024 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Maintenance_Backup_FullMethodName  = "/maintenance.v1.Maintenance/Backup"
	Maintenance_Restore_FullMethodName = "/maintenance.v1.Maintenance/Restore"
	Maintenance_Reset_FullMethodName   = "/maintenance.v1.Maintenance/Reset"
)
View Source 
const (
	KV_Range_FullMethodName        = "/regatta.v1.KV/Range"
	KV_IterateRange_FullMethodName = "/regatta.v1.KV/IterateRange"
	KV_Put_FullMethodName          = "/regatta.v1.KV/Put"
	KV_DeleteRange_FullMethodName  = "/regatta.v1.KV/DeleteRange"
	KV_Txn_FullMethodName          = "/regatta.v1.KV/Txn"
)
View Source 
const (
	Cluster_MemberList_FullMethodName = "/regatta.v1.Cluster/MemberList"
	Cluster_Status_FullMethodName     = "/regatta.v1.Cluster/Status"
)
View Source 
const (
	Tables_Create_FullMethodName = "/regatta.v1.Tables/Create"
	Tables_Delete_FullMethodName = "/regatta.v1.Tables/Delete"
	Tables_List_FullMethodName   = "/regatta.v1.Tables/List"
)
View Source 
const (
	Log_Replicate_FullMethodName = "/replication.v1.Log/Replicate"
)
View Source 
const (
	Metadata_Get_FullMethodName = "/replication.v1.Metadata/Get"
)
View Source 
const (
	Snapshot_Stream_FullMethodName = "/replication.v1.Snapshot/Stream"
)

Variables

View Source 
var (
	Command_CommandType_name = map[int32]string{
		0: "PUT",
		1: "DELETE",
		2: "DUMMY",
		3: "PUT_BATCH",
		4: "DELETE_BATCH",
		5: "TXN",
		6: "SEQUENCE",
	}
	Command_CommandType_value = map[string]int32{
		"PUT":          0,
		"DELETE":       1,
		"DUMMY":        2,
		"PUT_BATCH":    3,
		"DELETE_BATCH": 4,
		"TXN":          5,
		"SEQUENCE":     6,
	}
)

Enum value maps for Command_CommandType.

View Source 
var (
	Compare_CompareResult_name = map[int32]string{
		0: "EQUAL",
		1: "GREATER",
		2: "LESS",
		3: "NOT_EQUAL",
	}
	Compare_CompareResult_value = map[string]int32{
		"EQUAL":     0,
		"GREATER":   1,
		"LESS":      2,
		"NOT_EQUAL": 3,
	}
)

Enum value maps for Compare_CompareResult.

View Source 
var (
	Compare_CompareTarget_name = map[int32]string{
		0: "VALUE",
	}
	Compare_CompareTarget_value = map[string]int32{
		"VALUE": 0,
	}
)

Enum value maps for Compare_CompareTarget.

View Source 
var (
	ReplicateError_name = map[int32]string{
		0: "USE_SNAPSHOT",
		1: "LEADER_BEHIND",
	}
	ReplicateError_value = map[string]int32{
		"USE_SNAPSHOT":  0,
		"LEADER_BEHIND": 1,
	}
)

Enum value maps for ReplicateError.

View Source 
var (
	Table_Type_name = map[int32]string{
		0: "REPLICATED",
		1: "LOCAL",
	}
	Table_Type_value = map[string]int32{
		"REPLICATED": 0,
		"LOCAL":      1,
	}
)

Enum value maps for Table_Type.

View Source 
var Cluster_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "regatta.v1.Cluster",
	HandlerType: (*ClusterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "MemberList",
			Handler:    _Cluster_MemberList_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _Cluster_Status_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "regatta.proto",
}

Cluster_ServiceDesc is the grpc.ServiceDesc for Cluster 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 File_maintenance_proto protoreflect.FileDescriptor
View Source 
var File_mvcc_proto protoreflect.FileDescriptor
View Source 
var File_regatta_proto protoreflect.FileDescriptor
View Source 
var File_replication_proto protoreflect.FileDescriptor
View Source 
var KV_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "regatta.v1.KV",
	HandlerType: (*KVServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Range",
			Handler:    _KV_Range_Handler,
		},
		{
			MethodName: "Put",
			Handler:    _KV_Put_Handler,
		},
		{
			MethodName: "DeleteRange",
			Handler:    _KV_DeleteRange_Handler,
		},
		{
			MethodName: "Txn",
			Handler:    _KV_Txn_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "IterateRange",
			Handler:       _KV_IterateRange_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "regatta.proto",
}

KV_ServiceDesc is the grpc.ServiceDesc for KV 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 Log_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "replication.v1.Log",
	HandlerType: (*LogServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Replicate",
			Handler:       _Log_Replicate_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "replication.proto",
}

Log_ServiceDesc is the grpc.ServiceDesc for Log 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 Maintenance_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "maintenance.v1.Maintenance",
	HandlerType: (*MaintenanceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Reset",
			Handler:    _Maintenance_Reset_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Backup",
			Handler:       _Maintenance_Backup_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Restore",
			Handler:       _Maintenance_Restore_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "maintenance.proto",
}

Maintenance_ServiceDesc is the grpc.ServiceDesc for Maintenance 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 Metadata_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "replication.v1.Metadata",
	HandlerType: (*MetadataServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _Metadata_Get_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "replication.proto",
}

Metadata_ServiceDesc is the grpc.ServiceDesc for Metadata 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 Snapshot_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "replication.v1.Snapshot",
	HandlerType: (*SnapshotServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Stream",
			Handler:       _Snapshot_Stream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "replication.proto",
}

Snapshot_ServiceDesc is the grpc.ServiceDesc for Snapshot 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 Tables_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "regatta.v1.Tables",
	HandlerType: (*TablesServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _Tables_Create_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Tables_Delete_Handler,
		},
		{
			MethodName: "List",
			Handler:    _Tables_List_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "regatta.proto",
}

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

Functions

func RegisterClusterServer 

func RegisterClusterServer(s grpc.ServiceRegistrar, srv ClusterServer)

func RegisterKVServer 

func RegisterKVServer(s grpc.ServiceRegistrar, srv KVServer)

func RegisterLogServer 

func RegisterLogServer(s grpc.ServiceRegistrar, srv LogServer)

func RegisterMaintenanceServer 

func RegisterMaintenanceServer(s grpc.ServiceRegistrar, srv MaintenanceServer)

func RegisterMetadataServer 

func RegisterMetadataServer(s grpc.ServiceRegistrar, srv MetadataServer)

func RegisterSnapshotServer 

func RegisterSnapshotServer(s grpc.ServiceRegistrar, srv SnapshotServer)

func RegisterTablesServer added in v0.4.0 

func RegisterTablesServer(s grpc.ServiceRegistrar, srv TablesServer)

Types

type BackupRequest 

type BackupRequest struct {

	// table is name of the table to stream.
	Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

BackupRequest requests and opens a stream with backup data.

func (*BackupRequest) Descriptor deprecated 

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

Deprecated: Use BackupRequest.ProtoReflect.Descriptor instead.

func (*BackupRequest) GetTable 

func (x *BackupRequest) GetTable() []byte

func (*BackupRequest) MarshalToSizedBufferVT 

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

func (*BackupRequest) MarshalToVT 

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

func (*BackupRequest) MarshalVT 

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

func (*BackupRequest) ProtoMessage 

func (*BackupRequest) ProtoMessage()

func (*BackupRequest) ProtoReflect 

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

func (*BackupRequest) Reset 

func (x *BackupRequest) Reset()

func (*BackupRequest) SizeVT 

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

func (*BackupRequest) String 

func (x *BackupRequest) String() string

func (*BackupRequest) UnmarshalVT 

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

func (*BackupRequest) UnmarshalVTUnsafe added in v0.4.0 

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

type ClusterClient 

type ClusterClient interface {
	// MemberList lists all the members in the cluster.
	MemberList(ctx context.Context, in *MemberListRequest, opts ...grpc.CallOption) (*MemberListResponse, error)
	// Status gets the status of the member.
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

ClusterClient is the client API for Cluster 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 NewClusterClient 

func NewClusterClient(cc grpc.ClientConnInterface) ClusterClient

type ClusterServer 

type ClusterServer interface {
	// MemberList lists all the members in the cluster.
	MemberList(context.Context, *MemberListRequest) (*MemberListResponse, error)
	// Status gets the status of the member.
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	// contains filtered or unexported methods
}

ClusterServer is the server API for Cluster service. All implementations must embed UnimplementedClusterServer for forward compatibility

type Command 

type Command struct {

	// table name of the table
	Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// type is the kind of event. If type is a PUT, it indicates
	// new data has been stored to the key. If type is a DELETE,
	// it indicates the key was deleted.
	Type Command_CommandType `protobuf:"varint,2,opt,name=type,proto3,enum=mvcc.v1.Command_CommandType" json:"type,omitempty"`
	// kv holds the KeyValue for the event.
	// A PUT event contains current kv pair.
	// A PUT event with kv.Version=1 indicates the creation of a key.
	// A DELETE/EXPIRE event contains the deleted key with
	// its modification revision set to the revision of deletion.
	Kv *KeyValue `protobuf:"bytes,3,opt,name=kv,proto3" json:"kv,omitempty"`
	// leader_index holds the value of the log index of a leader cluster from which this command was replicated from.
	LeaderIndex *uint64 `protobuf:"varint,5,opt,name=leader_index,json=leaderIndex,proto3,oneof" json:"leader_index,omitempty"`
	// batch is an atomic batch of KVs to either PUT or DELETE. (faster, no read, no mix of types, no conditions).
	Batch []*KeyValue `protobuf:"bytes,6,rep,name=batch,proto3" json:"batch,omitempty"`
	// txn is an atomic transaction (slow, supports reads and conditions).
	Txn *Txn `protobuf:"bytes,7,opt,name=txn,proto3,oneof" json:"txn,omitempty"`
	// range_end is the key following the last key to affect for the range [kv.key, range_end).
	// If range_end is not given, the range is defined to contain only the kv.key argument.
	// If range_end is one bit larger than the given kv.key, then the range is all the keys
	// with the prefix (the given key).
	// If range_end is '\0', the range is all keys greater than or equal to the key argument.
	RangeEnd []byte `protobuf:"bytes,8,opt,name=range_end,json=rangeEnd,proto3,oneof" json:"range_end,omitempty"`
	// prev_kvs if to fetch previous KVs.
	PrevKvs bool `protobuf:"varint,9,opt,name=prev_kvs,json=prevKvs,proto3" json:"prev_kvs,omitempty"`
	// sequence is the sequence of commands to be applied as a single FSM step.
	Sequence []*Command `protobuf:"bytes,10,rep,name=sequence,proto3" json:"sequence,omitempty"`
	// count if to count number of records affected by a command.
	Count bool `protobuf:"varint,11,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func CommandFromVTPool 

func CommandFromVTPool() *Command

func (*Command) Descriptor deprecated 

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

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetBatch 

func (x *Command) GetBatch() []*KeyValue

func (*Command) GetCount 

func (x *Command) GetCount() bool

func (*Command) GetKv 

func (x *Command) GetKv() *KeyValue

func (*Command) GetLeaderIndex 

func (x *Command) GetLeaderIndex() uint64

func (*Command) GetPrevKvs 

func (x *Command) GetPrevKvs() bool

func (*Command) GetRangeEnd 

func (x *Command) GetRangeEnd() []byte

func (*Command) GetSequence 

func (x *Command) GetSequence() []*Command

func (*Command) GetTable 

func (x *Command) GetTable() []byte

func (*Command) GetTxn 

func (x *Command) GetTxn() *Txn

func (*Command) GetType 

func (x *Command) GetType() Command_CommandType

func (*Command) MarshalToSizedBufferVT 

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

func (*Command) MarshalToVT 

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

func (*Command) MarshalVT 

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

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) ProtoReflect 

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

func (*Command) Reset 

func (x *Command) Reset()

func (*Command) ResetVT 

func (m *Command) ResetVT()

func (*Command) ReturnToVTPool 

func (m *Command) ReturnToVTPool()

func (*Command) SizeVT 

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

func (*Command) String 

func (x *Command) String() string

func (*Command) UnmarshalVT 

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

func (*Command) UnmarshalVTUnsafe added in v0.4.0 

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

type CommandResult 

type CommandResult struct {

	// responses are the responses (if any) in order of application.
	Responses []*ResponseOp `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// revision is the key-value store revision when the request was applied.
	Revision uint64 `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandResult) Descriptor deprecated 

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

Deprecated: Use CommandResult.ProtoReflect.Descriptor instead.

func (*CommandResult) GetResponses 

func (x *CommandResult) GetResponses() []*ResponseOp

func (*CommandResult) GetRevision 

func (x *CommandResult) GetRevision() uint64

func (*CommandResult) MarshalToSizedBufferVT 

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

func (*CommandResult) MarshalToVT 

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

func (*CommandResult) MarshalVT 

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

func (*CommandResult) ProtoMessage 

func (*CommandResult) ProtoMessage()

func (*CommandResult) ProtoReflect 

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

func (*CommandResult) Reset 

func (x *CommandResult) Reset()

func (*CommandResult) SizeVT 

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

func (*CommandResult) String 

func (x *CommandResult) String() string

func (*CommandResult) UnmarshalVT 

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

func (*CommandResult) UnmarshalVTUnsafe added in v0.4.0 

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

type Command_CommandType 

type Command_CommandType int32
const (
	Command_PUT          Command_CommandType = 0
	Command_DELETE       Command_CommandType = 1
	Command_DUMMY        Command_CommandType = 2
	Command_PUT_BATCH    Command_CommandType = 3
	Command_DELETE_BATCH Command_CommandType = 4
	Command_TXN          Command_CommandType = 5
	Command_SEQUENCE     Command_CommandType = 6
)

func (Command_CommandType) Descriptor 

func (Command_CommandType) Descriptor() protoreflect.EnumDescriptor

func (Command_CommandType) Enum 

func (x Command_CommandType) Enum() *Command_CommandType

func (Command_CommandType) EnumDescriptor deprecated 

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

Deprecated: Use Command_CommandType.Descriptor instead.

func (Command_CommandType) Number 

func (x Command_CommandType) Number() protoreflect.EnumNumber

func (Command_CommandType) String 

func (x Command_CommandType) String() string

func (Command_CommandType) Type 

func (Command_CommandType) Type() protoreflect.EnumType

type Compare 

type Compare struct {

	// result is logical comparison operation for this comparison.
	Result Compare_CompareResult `protobuf:"varint,1,opt,name=result,proto3,enum=mvcc.v1.Compare_CompareResult" json:"result,omitempty"`
	// target is the key-value field to inspect for the comparison.
	Target Compare_CompareTarget `protobuf:"varint,2,opt,name=target,proto3,enum=mvcc.v1.Compare_CompareTarget" json:"target,omitempty"`
	// key is the subject key for the comparison operation.
	Key []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are assignable to TargetUnion:
	//
	//	*Compare_Value
	TargetUnion isCompare_TargetUnion `protobuf_oneof:"target_union"`
	// range_end compares the given target to all keys in the range [key, range_end).
	// See RangeRequest for more details on key ranges.
	RangeEnd []byte `protobuf:"bytes,64,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"` // TODO: fill out with most of the rest of RangeRequest fields when needed.
	// contains filtered or unexported fields
}

Compare property `target` for every KV from DB in [key, range_end) with target_union using the operation `result`. e.g. `DB[key].target result target_union.target`, that means that for asymmetric operations LESS and GREATER the target property of the key from the DB is the left-hand side of the comparison. Examples: * `DB[key][value] EQUAL target_union.value` * `DB[key][value] GREATER target_union.value` * `DB[key...range_end][value] GREATER target_union.value` * `DB[key][value] LESS target_union.value`

func (*Compare) Descriptor deprecated 

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

Deprecated: Use Compare.ProtoReflect.Descriptor instead.

func (*Compare) GetKey 

func (x *Compare) GetKey() []byte

func (*Compare) GetRangeEnd 

func (x *Compare) GetRangeEnd() []byte

func (*Compare) GetResult 

func (x *Compare) GetResult() Compare_CompareResult

func (*Compare) GetTarget 

func (x *Compare) GetTarget() Compare_CompareTarget

func (*Compare) GetTargetUnion 

func (m *Compare) GetTargetUnion() isCompare_TargetUnion

func (*Compare) GetValue 

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

func (*Compare) MarshalToSizedBufferVT 

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

func (*Compare) MarshalToVT 

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

func (*Compare) MarshalVT 

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

func (*Compare) ProtoMessage 

func (*Compare) ProtoMessage()

func (*Compare) ProtoReflect 

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

func (*Compare) Reset 

func (x *Compare) Reset()

func (*Compare) SizeVT 

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

func (*Compare) String 

func (x *Compare) String() string

func (*Compare) UnmarshalVT 

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

func (*Compare) UnmarshalVTUnsafe added in v0.4.0 

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

type Compare_CompareResult 

type Compare_CompareResult int32
const (
	Compare_EQUAL     Compare_CompareResult = 0
	Compare_GREATER   Compare_CompareResult = 1
	Compare_LESS      Compare_CompareResult = 2
	Compare_NOT_EQUAL Compare_CompareResult = 3
)

func (Compare_CompareResult) Descriptor 

func (Compare_CompareResult) Descriptor() protoreflect.EnumDescriptor

func (Compare_CompareResult) Enum 

func (x Compare_CompareResult) Enum() *Compare_CompareResult

func (Compare_CompareResult) EnumDescriptor deprecated 

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

Deprecated: Use Compare_CompareResult.Descriptor instead.

func (Compare_CompareResult) Number 

func (x Compare_CompareResult) Number() protoreflect.EnumNumber

func (Compare_CompareResult) String 

func (x Compare_CompareResult) String() string

func (Compare_CompareResult) Type 

func (Compare_CompareResult) Type() protoreflect.EnumType

type Compare_CompareTarget 

type Compare_CompareTarget int32
const (
	Compare_VALUE Compare_CompareTarget = 0
)

func (Compare_CompareTarget) Descriptor 

func (Compare_CompareTarget) Descriptor() protoreflect.EnumDescriptor

func (Compare_CompareTarget) Enum 

func (x Compare_CompareTarget) Enum() *Compare_CompareTarget

func (Compare_CompareTarget) EnumDescriptor deprecated 

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

Deprecated: Use Compare_CompareTarget.Descriptor instead.

func (Compare_CompareTarget) Number 

func (x Compare_CompareTarget) Number() protoreflect.EnumNumber

func (Compare_CompareTarget) String 

func (x Compare_CompareTarget) String() string

func (Compare_CompareTarget) Type 

func (Compare_CompareTarget) Type() protoreflect.EnumType

type Compare_Value 

type Compare_Value struct {
	// value is the value of the given key, in bytes.
	Value []byte `protobuf:"bytes,4,opt,name=value,proto3,oneof"`
}

func (*Compare_Value) MarshalToSizedBufferVT 

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

func (*Compare_Value) MarshalToVT 

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

func (*Compare_Value) SizeVT 

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

type CreateTableRequest added in v0.4.0 

type CreateTableRequest struct {

	// Name of the table to be created.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// config the table configuration values.
	Config *structpb.Struct `protobuf:"bytes,5,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

CreateTableRequest describes the table to be created.

func (*CreateTableRequest) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use CreateTableRequest.ProtoReflect.Descriptor instead.

func (*CreateTableRequest) GetConfig added in v0.4.0 

func (x *CreateTableRequest) GetConfig() *structpb.Struct

func (*CreateTableRequest) GetName added in v0.4.0 

func (x *CreateTableRequest) GetName() string

func (*CreateTableRequest) MarshalToSizedBufferVT added in v0.4.0 

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

func (*CreateTableRequest) MarshalToVT added in v0.4.0 

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

func (*CreateTableRequest) MarshalVT added in v0.4.0 

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

func (*CreateTableRequest) ProtoMessage added in v0.4.0 

func (*CreateTableRequest) ProtoMessage()

func (*CreateTableRequest) ProtoReflect added in v0.4.0 

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

func (*CreateTableRequest) Reset added in v0.4.0 

func (x *CreateTableRequest) Reset()

func (*CreateTableRequest) SizeVT added in v0.4.0 

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

func (*CreateTableRequest) String added in v0.4.0 

func (x *CreateTableRequest) String() string

func (*CreateTableRequest) UnmarshalVT added in v0.4.0 

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

func (*CreateTableRequest) UnmarshalVTUnsafe added in v0.4.0 

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

type CreateTableResponse added in v0.4.0 

type CreateTableResponse struct {

	// id the created table.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

CreateTableResponse describes the newly created table.

func (*CreateTableResponse) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use CreateTableResponse.ProtoReflect.Descriptor instead.

func (*CreateTableResponse) GetId added in v0.4.0 

func (x *CreateTableResponse) GetId() string

func (*CreateTableResponse) MarshalToSizedBufferVT added in v0.4.0 

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

func (*CreateTableResponse) MarshalToVT added in v0.4.0 

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

func (*CreateTableResponse) MarshalVT added in v0.4.0 

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

func (*CreateTableResponse) ProtoMessage added in v0.4.0 

func (*CreateTableResponse) ProtoMessage()

func (*CreateTableResponse) ProtoReflect added in v0.4.0 

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

func (*CreateTableResponse) Reset added in v0.4.0 

func (x *CreateTableResponse) Reset()

func (*CreateTableResponse) SizeVT added in v0.4.0 

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

func (*CreateTableResponse) String added in v0.4.0 

func (x *CreateTableResponse) String() string

func (*CreateTableResponse) UnmarshalVT added in v0.4.0 

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

func (*CreateTableResponse) UnmarshalVTUnsafe added in v0.4.0 

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

type DeleteRangeRequest 

type DeleteRangeRequest struct {

	// table name of the table
	Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// key is the first key to delete in the range.
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// range_end is the key following the last key to delete for the range [key, range_end).
	// If range_end is not given, the range is defined to contain only the key argument.
	// If range_end is one bit larger than the given key, then the range is all the keys
	// with the prefix (the given key).
	// If range_end is '\0', the range is all keys greater than or equal to the key argument.
	RangeEnd []byte `protobuf:"bytes,3,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
	// If prev_kv is set, regatta gets the previous key-value pairs before deleting it.
	// The previous key-value pairs will be returned in the delete response.
	// Beware that getting previous records could have serious performance impact on a delete range spanning a large dataset.
	PrevKv bool `protobuf:"varint,4,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// If count is set, regatta gets the count of previous key-value pairs before deleting it.
	// The deleted field will be set to number of deleted key-value pairs in the response.
	// Beware that counting records could have serious performance impact on a delete range spanning a large dataset.
	Count bool `protobuf:"varint,5,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRangeRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRangeRequest.ProtoReflect.Descriptor instead.

func (*DeleteRangeRequest) GetCount 

func (x *DeleteRangeRequest) GetCount() bool

func (*DeleteRangeRequest) GetKey 

func (x *DeleteRangeRequest) GetKey() []byte

func (*DeleteRangeRequest) GetPrevKv 

func (x *DeleteRangeRequest) GetPrevKv() bool

func (*DeleteRangeRequest) GetRangeEnd 

func (x *DeleteRangeRequest) GetRangeEnd() []byte

func (*DeleteRangeRequest) GetTable 

func (x *DeleteRangeRequest) GetTable() []byte

func (*DeleteRangeRequest) MarshalToSizedBufferVT 

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

func (*DeleteRangeRequest) MarshalToVT 

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

func (*DeleteRangeRequest) MarshalVT 

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

func (*DeleteRangeRequest) ProtoMessage 

func (*DeleteRangeRequest) ProtoMessage()

func (*DeleteRangeRequest) ProtoReflect 

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

func (*DeleteRangeRequest) Reset 

func (x *DeleteRangeRequest) Reset()

func (*DeleteRangeRequest) SizeVT 

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

func (*DeleteRangeRequest) String 

func (x *DeleteRangeRequest) String() string

func (*DeleteRangeRequest) UnmarshalVT 

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

func (*DeleteRangeRequest) UnmarshalVTUnsafe added in v0.4.0 

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

type DeleteRangeResponse 

type DeleteRangeResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// deleted is the number of keys deleted by the delete range request.
	Deleted int64 `protobuf:"varint,2,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// if prev_kv is set in the request, the previous key-value pairs will be returned.
	PrevKvs []*KeyValue `protobuf:"bytes,3,rep,name=prev_kvs,json=prevKvs,proto3" json:"prev_kvs,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRangeResponse) Descriptor deprecated 

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

Deprecated: Use DeleteRangeResponse.ProtoReflect.Descriptor instead.

func (*DeleteRangeResponse) GetDeleted 

func (x *DeleteRangeResponse) GetDeleted() int64

func (*DeleteRangeResponse) GetHeader 

func (x *DeleteRangeResponse) GetHeader() *ResponseHeader

func (*DeleteRangeResponse) GetPrevKvs 

func (x *DeleteRangeResponse) GetPrevKvs() []*KeyValue

func (*DeleteRangeResponse) MarshalToSizedBufferVT 

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

func (*DeleteRangeResponse) MarshalToVT 

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

func (*DeleteRangeResponse) MarshalVT 

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

func (*DeleteRangeResponse) ProtoMessage 

func (*DeleteRangeResponse) ProtoMessage()

func (*DeleteRangeResponse) ProtoReflect 

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

func (*DeleteRangeResponse) Reset 

func (x *DeleteRangeResponse) Reset()

func (*DeleteRangeResponse) SizeVT 

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

func (*DeleteRangeResponse) String 

func (x *DeleteRangeResponse) String() string

func (*DeleteRangeResponse) UnmarshalVT 

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

func (*DeleteRangeResponse) UnmarshalVTUnsafe added in v0.4.0 

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

type DeleteTableRequest added in v0.4.0 

type DeleteTableRequest struct {

	// name of the table to be deleted.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

DeleteTableRequest describes the table to be deleted.

func (*DeleteTableRequest) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use DeleteTableRequest.ProtoReflect.Descriptor instead.

func (*DeleteTableRequest) GetName added in v0.4.0 

func (x *DeleteTableRequest) GetName() string

func (*DeleteTableRequest) MarshalToSizedBufferVT added in v0.4.0 

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

func (*DeleteTableRequest) MarshalToVT added in v0.4.0 

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

func (*DeleteTableRequest) MarshalVT added in v0.4.0 

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

func (*DeleteTableRequest) ProtoMessage added in v0.4.0 

func (*DeleteTableRequest) ProtoMessage()

func (*DeleteTableRequest) ProtoReflect added in v0.4.0 

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

func (*DeleteTableRequest) Reset added in v0.4.0 

func (x *DeleteTableRequest) Reset()

func (*DeleteTableRequest) SizeVT added in v0.4.0 

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

func (*DeleteTableRequest) String added in v0.4.0 

func (x *DeleteTableRequest) String() string

func (*DeleteTableRequest) UnmarshalVT added in v0.4.0 

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

func (*DeleteTableRequest) UnmarshalVTUnsafe added in v0.4.0 

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

type DeleteTableResponse added in v0.4.0 

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

DeleteTableResponse when the table was successfully deleted.

func (*DeleteTableResponse) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use DeleteTableResponse.ProtoReflect.Descriptor instead.

func (*DeleteTableResponse) MarshalToSizedBufferVT added in v0.4.0 

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

func (*DeleteTableResponse) MarshalToVT added in v0.4.0 

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

func (*DeleteTableResponse) MarshalVT added in v0.4.0 

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

func (*DeleteTableResponse) ProtoMessage added in v0.4.0 

func (*DeleteTableResponse) ProtoMessage()

func (*DeleteTableResponse) ProtoReflect added in v0.4.0 

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

func (*DeleteTableResponse) Reset added in v0.4.0 

func (x *DeleteTableResponse) Reset()

func (*DeleteTableResponse) SizeVT added in v0.4.0 

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

func (*DeleteTableResponse) String added in v0.4.0 

func (x *DeleteTableResponse) String() string

func (*DeleteTableResponse) UnmarshalVT added in v0.4.0 

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

func (*DeleteTableResponse) UnmarshalVTUnsafe added in v0.4.0 

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

type KVClient 

type KVClient interface {
	// Range gets the keys in the range from the key-value store.
	Range(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (*RangeResponse, error)
	// IterateRange gets the keys in the range from the key-value store.
	IterateRange(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (KV_IterateRangeClient, error)
	// Put puts the given key into the key-value store.
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	// DeleteRange deletes the given range from the key-value store.
	DeleteRange(ctx context.Context, in *DeleteRangeRequest, opts ...grpc.CallOption) (*DeleteRangeResponse, error)
	// Txn processes multiple requests in a single transaction.
	// A txn request increments the revision of the key-value store
	// and generates events with the same revision for every completed request.
	// It is allowed to modify the same key several times within one txn (the result will be the last Op that modified the key).
	Txn(ctx context.Context, in *TxnRequest, opts ...grpc.CallOption) (*TxnResponse, error)
}

KVClient is the client API for KV 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 NewKVClient 

func NewKVClient(cc grpc.ClientConnInterface) KVClient

type KVServer 

type KVServer interface {
	// Range gets the keys in the range from the key-value store.
	Range(context.Context, *RangeRequest) (*RangeResponse, error)
	// IterateRange gets the keys in the range from the key-value store.
	IterateRange(*RangeRequest, KV_IterateRangeServer) error
	// Put puts the given key into the key-value store.
	Put(context.Context, *PutRequest) (*PutResponse, error)
	// DeleteRange deletes the given range from the key-value store.
	DeleteRange(context.Context, *DeleteRangeRequest) (*DeleteRangeResponse, error)
	// Txn processes multiple requests in a single transaction.
	// A txn request increments the revision of the key-value store
	// and generates events with the same revision for every completed request.
	// It is allowed to modify the same key several times within one txn (the result will be the last Op that modified the key).
	Txn(context.Context, *TxnRequest) (*TxnResponse, error)
	// contains filtered or unexported methods
}

KVServer is the server API for KV service. All implementations must embed UnimplementedKVServer for forward compatibility

type KV_IterateRangeClient added in v0.3.0 

type KV_IterateRangeClient interface {
	Recv() (*RangeResponse, error)
	grpc.ClientStream
}

type KV_IterateRangeServer added in v0.3.0 

type KV_IterateRangeServer interface {
	Send(*RangeResponse) error
	grpc.ServerStream
}

type KeyValue 

type KeyValue struct {

	// key is the key in bytes. An empty key is not allowed.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// create_revision is the revision of last creation on this key.
	CreateRevision int64 `protobuf:"varint,2,opt,name=create_revision,json=createRevision,proto3" json:"create_revision,omitempty"`
	// mod_revision is the revision of last modification on this key.
	ModRevision int64 `protobuf:"varint,3,opt,name=mod_revision,json=modRevision,proto3" json:"mod_revision,omitempty"`
	// value is the value held by the key, in bytes.
	Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyValue) Descriptor deprecated 

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

Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.

func (*KeyValue) GetCreateRevision 

func (x *KeyValue) GetCreateRevision() int64

func (*KeyValue) GetKey 

func (x *KeyValue) GetKey() []byte

func (*KeyValue) GetModRevision 

func (x *KeyValue) GetModRevision() int64

func (*KeyValue) GetValue 

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

func (*KeyValue) MarshalToSizedBufferVT 

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

func (*KeyValue) MarshalToVT 

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

func (*KeyValue) MarshalVT 

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

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) ProtoReflect 

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

func (*KeyValue) Reset 

func (x *KeyValue) Reset()

func (*KeyValue) SizeVT 

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

func (*KeyValue) String 

func (x *KeyValue) String() string

func (*KeyValue) UnmarshalVT 

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

func (*KeyValue) UnmarshalVTUnsafe added in v0.4.0 

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

type ListTablesRequest added in v0.4.0 

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

ListTablesRequest requests the list of currently registered tables.

func (*ListTablesRequest) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use ListTablesRequest.ProtoReflect.Descriptor instead.

func (*ListTablesRequest) MarshalToSizedBufferVT added in v0.4.0 

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

func (*ListTablesRequest) MarshalToVT added in v0.4.0 

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

func (*ListTablesRequest) MarshalVT added in v0.4.0 

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

func (*ListTablesRequest) ProtoMessage added in v0.4.0 

func (*ListTablesRequest) ProtoMessage()

func (*ListTablesRequest) ProtoReflect added in v0.4.0 

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

func (*ListTablesRequest) Reset added in v0.4.0 

func (x *ListTablesRequest) Reset()

func (*ListTablesRequest) SizeVT added in v0.4.0 

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

func (*ListTablesRequest) String added in v0.4.0 

func (x *ListTablesRequest) String() string

func (*ListTablesRequest) UnmarshalVT added in v0.4.0 

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

func (*ListTablesRequest) UnmarshalVTUnsafe added in v0.4.0 

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

type ListTablesResponse added in v0.4.0 

type ListTablesResponse struct {
	Tables []*TableInfo `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

FollowerGetTablesResponse contains information about tables stored in the cluster.

func (*ListTablesResponse) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use ListTablesResponse.ProtoReflect.Descriptor instead.

func (*ListTablesResponse) GetTables added in v0.4.0 

func (x *ListTablesResponse) GetTables() []*TableInfo

func (*ListTablesResponse) MarshalToSizedBufferVT added in v0.4.0 

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

func (*ListTablesResponse) MarshalToVT added in v0.4.0 

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

func (*ListTablesResponse) MarshalVT added in v0.4.0 

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

func (*ListTablesResponse) ProtoMessage added in v0.4.0 

func (*ListTablesResponse) ProtoMessage()

func (*ListTablesResponse) ProtoReflect added in v0.4.0 

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

func (*ListTablesResponse) Reset added in v0.4.0 

func (x *ListTablesResponse) Reset()

func (*ListTablesResponse) SizeVT added in v0.4.0 

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

func (*ListTablesResponse) String added in v0.4.0 

func (x *ListTablesResponse) String() string

func (*ListTablesResponse) UnmarshalVT added in v0.4.0 

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

func (*ListTablesResponse) UnmarshalVTUnsafe added in v0.4.0 

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

type LogClient 

type LogClient interface {
	// Replicate is method to ask for data of specified table from the specified index.
	Replicate(ctx context.Context, in *ReplicateRequest, opts ...grpc.CallOption) (Log_ReplicateClient, error)
}

LogClient is the client API for Log 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 NewLogClient 

func NewLogClient(cc grpc.ClientConnInterface) LogClient

type LogServer 

type LogServer interface {
	// Replicate is method to ask for data of specified table from the specified index.
	Replicate(*ReplicateRequest, Log_ReplicateServer) error
	// contains filtered or unexported methods
}

LogServer is the server API for Log service. All implementations must embed UnimplementedLogServer for forward compatibility

type Log_ReplicateClient 

type Log_ReplicateClient interface {
	Recv() (*ReplicateResponse, error)
	grpc.ClientStream
}

type Log_ReplicateServer 

type Log_ReplicateServer interface {
	Send(*ReplicateResponse) error
	grpc.ServerStream
}

type MaintenanceClient 

type MaintenanceClient interface {
	Backup(ctx context.Context, in *BackupRequest, opts ...grpc.CallOption) (Maintenance_BackupClient, error)
	Restore(ctx context.Context, opts ...grpc.CallOption) (Maintenance_RestoreClient, error)
	Reset(ctx context.Context, in *ResetRequest, opts ...grpc.CallOption) (*ResetResponse, error)
}

MaintenanceClient is the client API for Maintenance 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 NewMaintenanceClient 

func NewMaintenanceClient(cc grpc.ClientConnInterface) MaintenanceClient

type MaintenanceServer 

type MaintenanceServer interface {
	Backup(*BackupRequest, Maintenance_BackupServer) error
	Restore(Maintenance_RestoreServer) error
	Reset(context.Context, *ResetRequest) (*ResetResponse, error)
	// contains filtered or unexported methods
}

MaintenanceServer is the server API for Maintenance service. All implementations must embed UnimplementedMaintenanceServer for forward compatibility

type Maintenance_BackupClient 

type Maintenance_BackupClient interface {
	Recv() (*SnapshotChunk, error)
	grpc.ClientStream
}

type Maintenance_BackupServer 

type Maintenance_BackupServer interface {
	Send(*SnapshotChunk) error
	grpc.ServerStream
}

type Maintenance_RestoreClient 

type Maintenance_RestoreClient interface {
	Send(*RestoreMessage) error
	CloseAndRecv() (*RestoreResponse, error)
	grpc.ClientStream
}

type Maintenance_RestoreServer 

type Maintenance_RestoreServer interface {
	SendAndClose(*RestoreResponse) error
	Recv() (*RestoreMessage, error)
	grpc.ServerStream
}

type Member 

type Member struct {

	// id is the member ID of this member.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// name is the human-readable name of the member. If the member is not started, the name will be an empty string.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// peerURLs is the list of URLs the member exposes to the cluster for communication.
	PeerURLs []string `protobuf:"bytes,3,rep,name=peerURLs,proto3" json:"peerURLs,omitempty"`
	// clientURLs is the list of URLs the member exposes to clients for communication. If the member is not started, clientURLs will be empty.
	ClientURLs []string `protobuf:"bytes,4,rep,name=clientURLs,proto3" json:"clientURLs,omitempty"`
	// contains filtered or unexported fields
}

func (*Member) Descriptor deprecated 

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

Deprecated: Use Member.ProtoReflect.Descriptor instead.

func (*Member) GetClientURLs 

func (x *Member) GetClientURLs() []string

func (*Member) GetId added in v0.2.0 

func (x *Member) GetId() string

func (*Member) GetName 

func (x *Member) GetName() string

func (*Member) GetPeerURLs 

func (x *Member) GetPeerURLs() []string

func (*Member) MarshalToSizedBufferVT 

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

func (*Member) MarshalToVT 

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

func (*Member) MarshalVT 

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

func (*Member) ProtoMessage 

func (*Member) ProtoMessage()

func (*Member) ProtoReflect 

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

func (*Member) Reset 

func (x *Member) Reset()

func (*Member) SizeVT 

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

func (*Member) String 

func (x *Member) String() string

func (*Member) UnmarshalVT 

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

func (*Member) UnmarshalVTUnsafe added in v0.4.0 

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

type MemberListRequest 

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

func (*MemberListRequest) Descriptor deprecated 

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

Deprecated: Use MemberListRequest.ProtoReflect.Descriptor instead.

func (*MemberListRequest) MarshalToSizedBufferVT 

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

func (*MemberListRequest) MarshalToVT 

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

func (*MemberListRequest) MarshalVT 

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

func (*MemberListRequest) ProtoMessage 

func (*MemberListRequest) ProtoMessage()

func (*MemberListRequest) ProtoReflect 

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

func (*MemberListRequest) Reset 

func (x *MemberListRequest) Reset()

func (*MemberListRequest) SizeVT 

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

func (*MemberListRequest) String 

func (x *MemberListRequest) String() string

func (*MemberListRequest) UnmarshalVT 

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

func (*MemberListRequest) UnmarshalVTUnsafe added in v0.4.0 

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

type MemberListResponse 

type MemberListResponse struct {

	// cluster is a name of the cluster.
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// members is a list of all members associated with the cluster.
	Members []*Member `protobuf:"bytes,2,rep,name=members,proto3" json:"members,omitempty"`
	// contains filtered or unexported fields
}

func (*MemberListResponse) Descriptor deprecated 

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

Deprecated: Use MemberListResponse.ProtoReflect.Descriptor instead.

func (*MemberListResponse) GetCluster added in v0.3.0 

func (x *MemberListResponse) GetCluster() string

func (*MemberListResponse) GetMembers 

func (x *MemberListResponse) GetMembers() []*Member

func (*MemberListResponse) MarshalToSizedBufferVT 

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

func (*MemberListResponse) MarshalToVT 

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

func (*MemberListResponse) MarshalVT 

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

func (*MemberListResponse) ProtoMessage 

func (*MemberListResponse) ProtoMessage()

func (*MemberListResponse) ProtoReflect 

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

func (*MemberListResponse) Reset 

func (x *MemberListResponse) Reset()

func (*MemberListResponse) SizeVT 

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

func (*MemberListResponse) String 

func (x *MemberListResponse) String() string

func (*MemberListResponse) UnmarshalVT 

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

func (*MemberListResponse) UnmarshalVTUnsafe added in v0.4.0 

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

type MetadataClient 

type MetadataClient interface {
	Get(ctx context.Context, in *MetadataRequest, opts ...grpc.CallOption) (*MetadataResponse, error)
}

MetadataClient is the client API for Metadata 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 NewMetadataClient 

func NewMetadataClient(cc grpc.ClientConnInterface) MetadataClient

type MetadataRequest 

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

func (*MetadataRequest) Descriptor deprecated 

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

Deprecated: Use MetadataRequest.ProtoReflect.Descriptor instead.

func (*MetadataRequest) MarshalToSizedBufferVT 

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

func (*MetadataRequest) MarshalToVT 

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

func (*MetadataRequest) MarshalVT 

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

func (*MetadataRequest) ProtoMessage 

func (*MetadataRequest) ProtoMessage()

func (*MetadataRequest) ProtoReflect 

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

func (*MetadataRequest) Reset 

func (x *MetadataRequest) Reset()

func (*MetadataRequest) SizeVT 

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

func (*MetadataRequest) String 

func (x *MetadataRequest) String() string

func (*MetadataRequest) UnmarshalVT 

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

func (*MetadataRequest) UnmarshalVTUnsafe added in v0.4.0 

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

type MetadataResponse 

type MetadataResponse struct {
	Tables []*Table `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

func (*MetadataResponse) Descriptor deprecated 

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

Deprecated: Use MetadataResponse.ProtoReflect.Descriptor instead.

func (*MetadataResponse) GetTables 

func (x *MetadataResponse) GetTables() []*Table

func (*MetadataResponse) MarshalToSizedBufferVT 

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

func (*MetadataResponse) MarshalToVT 

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

func (*MetadataResponse) MarshalVT 

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

func (*MetadataResponse) ProtoMessage 

func (*MetadataResponse) ProtoMessage()

func (*MetadataResponse) ProtoReflect 

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

func (*MetadataResponse) Reset 

func (x *MetadataResponse) Reset()

func (*MetadataResponse) SizeVT 

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

func (*MetadataResponse) String 

func (x *MetadataResponse) String() string

func (*MetadataResponse) UnmarshalVT 

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

func (*MetadataResponse) UnmarshalVTUnsafe added in v0.4.0 

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

type MetadataServer 

type MetadataServer interface {
	Get(context.Context, *MetadataRequest) (*MetadataResponse, error)
	// contains filtered or unexported methods
}

MetadataServer is the server API for Metadata service. All implementations must embed UnimplementedMetadataServer for forward compatibility

type PutRequest 

type PutRequest struct {

	// table name of the table
	Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// key is the key, in bytes, to put into the key-value store.
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// value is the value, in bytes, to associate with the key in the key-value store.
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// prev_kv if true the previous key-value pair will be returned in the put response.
	PrevKv bool `protobuf:"varint,4,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) Descriptor deprecated 

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetKey 

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

func (*PutRequest) GetPrevKv 

func (x *PutRequest) GetPrevKv() bool

func (*PutRequest) GetTable 

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

func (*PutRequest) GetValue 

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

func (*PutRequest) MarshalToSizedBufferVT 

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

func (*PutRequest) MarshalToVT 

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

func (*PutRequest) MarshalVT 

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

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect 

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

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) SizeVT 

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

func (*PutRequest) String 

func (x *PutRequest) String() string

func (*PutRequest) UnmarshalVT 

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

func (*PutRequest) UnmarshalVTUnsafe added in v0.4.0 

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

type PutResponse 

type PutResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// if prev_kv is set in the request, the previous key-value pair will be returned.
	PrevKv *KeyValue `protobuf:"bytes,2,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// contains filtered or unexported fields
}

func (*PutResponse) Descriptor deprecated 

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

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) GetHeader 

func (x *PutResponse) GetHeader() *ResponseHeader

func (*PutResponse) GetPrevKv 

func (x *PutResponse) GetPrevKv() *KeyValue

func (*PutResponse) MarshalToSizedBufferVT 

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

func (*PutResponse) MarshalToVT 

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

func (*PutResponse) MarshalVT 

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

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect 

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

func (*PutResponse) Reset 

func (x *PutResponse) Reset()

func (*PutResponse) SizeVT 

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

func (*PutResponse) String 

func (x *PutResponse) String() string

func (*PutResponse) UnmarshalVT 

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

func (*PutResponse) UnmarshalVTUnsafe added in v0.4.0 

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

type RangeRequest 

type RangeRequest struct {

	// table name of the table
	Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// key is the first key for the range. If range_end is not given, the request only looks up key.
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// range_end is the upper bound on the requested range [key, range_end).
	// If range_end is '\0', the range is all keys >= key.
	// If range_end is key plus one (e.g., "aa"+1 == "ab", "a\xff"+1 == "b"),
	// then the range request gets all keys prefixed with key.
	// If both key and range_end are '\0', then the range request returns all keys.
	RangeEnd []byte `protobuf:"bytes,3,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
	// limit is a limit on the number of keys returned for the request. When limit is set to 0,
	// it is treated as no limit.
	Limit int64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// linearizable sets the range request to use linearizable read. Linearizable requests
	// have higher latency and lower throughput than serializable requests but reflect the current
	// consensus of the cluster. For better performance, in exchange for possible stale reads,
	// a serializable range request is served locally without needing to reach consensus
	// with other nodes in the cluster. The serializable request is default option.
	Linearizable bool `protobuf:"varint,5,opt,name=linearizable,proto3" json:"linearizable,omitempty"`
	// keys_only when set returns only the keys and not the values.
	KeysOnly bool `protobuf:"varint,6,opt,name=keys_only,json=keysOnly,proto3" json:"keys_only,omitempty"`
	// count_only when set returns only the count of the keys in the range.
	CountOnly bool `protobuf:"varint,7,opt,name=count_only,json=countOnly,proto3" json:"count_only,omitempty"`
	// min_mod_revision is the lower bound for returned key mod revisions; all keys with
	// lesser mod revisions will be filtered away.
	MinModRevision int64 `protobuf:"varint,8,opt,name=min_mod_revision,json=minModRevision,proto3" json:"min_mod_revision,omitempty"`
	// max_mod_revision is the upper bound for returned key mod revisions; all keys with
	// greater mod revisions will be filtered away.
	MaxModRevision int64 `protobuf:"varint,9,opt,name=max_mod_revision,json=maxModRevision,proto3" json:"max_mod_revision,omitempty"`
	// min_create_revision is the lower bound for returned key create revisions; all keys with
	// lesser create revisions will be filtered away.
	MinCreateRevision int64 `protobuf:"varint,10,opt,name=min_create_revision,json=minCreateRevision,proto3" json:"min_create_revision,omitempty"`
	// max_create_revision is the upper bound for returned key create revisions; all keys with
	// greater create revisions will be filtered away.
	MaxCreateRevision int64 `protobuf:"varint,11,opt,name=max_create_revision,json=maxCreateRevision,proto3" json:"max_create_revision,omitempty"`
	// contains filtered or unexported fields
}

func (*RangeRequest) Descriptor deprecated 

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

Deprecated: Use RangeRequest.ProtoReflect.Descriptor instead.

func (*RangeRequest) GetCountOnly 

func (x *RangeRequest) GetCountOnly() bool

func (*RangeRequest) GetKey 

func (x *RangeRequest) GetKey() []byte

func (*RangeRequest) GetKeysOnly 

func (x *RangeRequest) GetKeysOnly() bool

func (*RangeRequest) GetLimit 

func (x *RangeRequest) GetLimit() int64

func (*RangeRequest) GetLinearizable 

func (x *RangeRequest) GetLinearizable() bool

func (*RangeRequest) GetMaxCreateRevision 

func (x *RangeRequest) GetMaxCreateRevision() int64

func (*RangeRequest) GetMaxModRevision 

func (x *RangeRequest) GetMaxModRevision() int64

func (*RangeRequest) GetMinCreateRevision 

func (x *RangeRequest) GetMinCreateRevision() int64

func (*RangeRequest) GetMinModRevision 

func (x *RangeRequest) GetMinModRevision() int64

func (*RangeRequest) GetRangeEnd 

func (x *RangeRequest) GetRangeEnd() []byte

func (*RangeRequest) GetTable 

func (x *RangeRequest) GetTable() []byte

func (*RangeRequest) MarshalToSizedBufferVT 

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

func (*RangeRequest) MarshalToVT 

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

func (*RangeRequest) MarshalVT 

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

func (*RangeRequest) ProtoMessage 

func (*RangeRequest) ProtoMessage()

func (*RangeRequest) ProtoReflect 

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

func (*RangeRequest) Reset 

func (x *RangeRequest) Reset()

func (*RangeRequest) SizeVT 

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

func (*RangeRequest) String 

func (x *RangeRequest) String() string

func (*RangeRequest) UnmarshalVT 

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

func (*RangeRequest) UnmarshalVTUnsafe added in v0.4.0 

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

type RangeResponse 

type RangeResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// kvs is the list of key-value pairs matched by the range request.
	// kvs is empty when count is requested.
	Kvs []*KeyValue `protobuf:"bytes,3,rep,name=kvs,proto3" json:"kvs,omitempty"`
	// more indicates if there are more keys to return in the requested range.
	More bool `protobuf:"varint,4,opt,name=more,proto3" json:"more,omitempty"`
	// count is set to the number of keys within the range when requested.
	Count int64 `protobuf:"varint,5,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*RangeResponse) Descriptor deprecated 

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

Deprecated: Use RangeResponse.ProtoReflect.Descriptor instead.

func (*RangeResponse) GetCount 

func (x *RangeResponse) GetCount() int64

func (*RangeResponse) GetHeader 

func (x *RangeResponse) GetHeader() *ResponseHeader

func (*RangeResponse) GetKvs 

func (x *RangeResponse) GetKvs() []*KeyValue

func (*RangeResponse) GetMore 

func (x *RangeResponse) GetMore() bool

func (*RangeResponse) MarshalToSizedBufferVT 

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

func (*RangeResponse) MarshalToVT 

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

func (*RangeResponse) MarshalVT 

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

func (*RangeResponse) ProtoMessage 

func (*RangeResponse) ProtoMessage()

func (*RangeResponse) ProtoReflect 

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

func (*RangeResponse) Reset 

func (x *RangeResponse) Reset()

func (*RangeResponse) SizeVT 

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

func (*RangeResponse) String 

func (x *RangeResponse) String() string

func (*RangeResponse) UnmarshalVT 

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

func (*RangeResponse) UnmarshalVTUnsafe added in v0.4.0 

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

type ReplicateCommand 

type ReplicateCommand struct {

	// leaderIndex represents the leader raft index of the given command
	LeaderIndex uint64 `protobuf:"varint,1,opt,name=leader_index,json=leaderIndex,proto3" json:"leader_index,omitempty"`
	// command holds the leader raft log command at leaderIndex
	Command *Command `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicateCommand) Descriptor deprecated 

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

Deprecated: Use ReplicateCommand.ProtoReflect.Descriptor instead.

func (*ReplicateCommand) GetCommand 

func (x *ReplicateCommand) GetCommand() *Command

func (*ReplicateCommand) GetLeaderIndex 

func (x *ReplicateCommand) GetLeaderIndex() uint64

func (*ReplicateCommand) MarshalToSizedBufferVT 

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

func (*ReplicateCommand) MarshalToVT 

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

func (*ReplicateCommand) MarshalVT 

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

func (*ReplicateCommand) ProtoMessage 

func (*ReplicateCommand) ProtoMessage()

func (*ReplicateCommand) ProtoReflect 

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

func (*ReplicateCommand) Reset 

func (x *ReplicateCommand) Reset()

func (*ReplicateCommand) SizeVT 

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

func (*ReplicateCommand) String 

func (x *ReplicateCommand) String() string

func (*ReplicateCommand) UnmarshalVT 

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

func (*ReplicateCommand) UnmarshalVTUnsafe added in v0.4.0 

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

type ReplicateCommandsResponse 

type ReplicateCommandsResponse struct {

	// commands represent the
	Commands []*ReplicateCommand `protobuf:"bytes,1,rep,name=commands,proto3" json:"commands,omitempty"`
	// contains filtered or unexported fields
}

ReplicateCommandsResponse sequence of replication commands

func (*ReplicateCommandsResponse) Descriptor deprecated 

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

Deprecated: Use ReplicateCommandsResponse.ProtoReflect.Descriptor instead.

func (*ReplicateCommandsResponse) GetCommands 

func (x *ReplicateCommandsResponse) GetCommands() []*ReplicateCommand

func (*ReplicateCommandsResponse) MarshalToSizedBufferVT 

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

func (*ReplicateCommandsResponse) MarshalToVT 

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

func (*ReplicateCommandsResponse) MarshalVT 

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

func (*ReplicateCommandsResponse) ProtoMessage 

func (*ReplicateCommandsResponse) ProtoMessage()

func (*ReplicateCommandsResponse) ProtoReflect 

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

func (*ReplicateCommandsResponse) Reset 

func (x *ReplicateCommandsResponse) Reset()

func (*ReplicateCommandsResponse) SizeVT 

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

func (*ReplicateCommandsResponse) String 

func (x *ReplicateCommandsResponse) String() string

func (*ReplicateCommandsResponse) UnmarshalVT 

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

func (*ReplicateCommandsResponse) UnmarshalVTUnsafe added in v0.4.0 

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

type ReplicateErrResponse 

type ReplicateErrResponse struct {
	Error ReplicateError `protobuf:"varint,1,opt,name=error,proto3,enum=replication.v1.ReplicateError" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicateErrResponse) Descriptor deprecated 

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

Deprecated: Use ReplicateErrResponse.ProtoReflect.Descriptor instead.

func (*ReplicateErrResponse) GetError 

func (x *ReplicateErrResponse) GetError() ReplicateError

func (*ReplicateErrResponse) MarshalToSizedBufferVT 

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

func (*ReplicateErrResponse) MarshalToVT 

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

func (*ReplicateErrResponse) MarshalVT 

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

func (*ReplicateErrResponse) ProtoMessage 

func (*ReplicateErrResponse) ProtoMessage()

func (*ReplicateErrResponse) ProtoReflect 

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

func (*ReplicateErrResponse) Reset 

func (x *ReplicateErrResponse) Reset()

func (*ReplicateErrResponse) SizeVT 

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

func (*ReplicateErrResponse) String 

func (x *ReplicateErrResponse) String() string

func (*ReplicateErrResponse) UnmarshalVT 

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

func (*ReplicateErrResponse) UnmarshalVTUnsafe added in v0.4.0 

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

type ReplicateError 

type ReplicateError int32
const (
	// USE_SNAPSHOT occurs when leader has no longer the specified `leader_index` in the log.
	// Follower must use `GetSnapshot` to catch up.
	ReplicateError_USE_SNAPSHOT ReplicateError = 0
	// LEADER_BEHIND occurs when the index of the leader is smaller than requested `leader_index`.
	// This should never happen. Manual intervention needed.
	ReplicateError_LEADER_BEHIND ReplicateError = 1
)

func (ReplicateError) Descriptor 

func (ReplicateError) Descriptor() protoreflect.EnumDescriptor

func (ReplicateError) Enum 

func (x ReplicateError) Enum() *ReplicateError

func (ReplicateError) EnumDescriptor deprecated 

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

Deprecated: Use ReplicateError.Descriptor instead.

func (ReplicateError) Number 

func (x ReplicateError) Number() protoreflect.EnumNumber

func (ReplicateError) String 

func (x ReplicateError) String() string

func (ReplicateError) Type 

func (ReplicateError) Type() protoreflect.EnumType

type ReplicateRequest 

type ReplicateRequest struct {

	// table is name of the table to replicate
	Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// leader_index is the index in the leader raft log of the last stored item in the follower
	LeaderIndex uint64 `protobuf:"varint,2,opt,name=leader_index,json=leaderIndex,proto3" json:"leader_index,omitempty"`
	// contains filtered or unexported fields
}

ReplicateRequest request of the replication data at given leader_index

func (*ReplicateRequest) Descriptor deprecated 

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

Deprecated: Use ReplicateRequest.ProtoReflect.Descriptor instead.

func (*ReplicateRequest) GetLeaderIndex 

func (x *ReplicateRequest) GetLeaderIndex() uint64

func (*ReplicateRequest) GetTable 

func (x *ReplicateRequest) GetTable() []byte

func (*ReplicateRequest) MarshalToSizedBufferVT 

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

func (*ReplicateRequest) MarshalToVT 

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

func (*ReplicateRequest) MarshalVT 

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

func (*ReplicateRequest) ProtoMessage 

func (*ReplicateRequest) ProtoMessage()

func (*ReplicateRequest) ProtoReflect 

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

func (*ReplicateRequest) Reset 

func (x *ReplicateRequest) Reset()

func (*ReplicateRequest) SizeVT 

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

func (*ReplicateRequest) String 

func (x *ReplicateRequest) String() string

func (*ReplicateRequest) UnmarshalVT 

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

func (*ReplicateRequest) UnmarshalVTUnsafe added in v0.4.0 

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

type ReplicateResponse 

type ReplicateResponse struct {

	// Types that are assignable to Response:
	//
	//	*ReplicateResponse_CommandsResponse
	//	*ReplicateResponse_ErrorResponse
	Response isReplicateResponse_Response `protobuf_oneof:"response"`
	// leader_index is the largest applied leader index at the time of the client RPC.
	LeaderIndex uint64 `protobuf:"varint,8,opt,name=leader_index,json=leaderIndex,proto3" json:"leader_index,omitempty"`
	// contains filtered or unexported fields
}

ReplicateResponse response to the ReplicateRequest

func (*ReplicateResponse) Descriptor deprecated 

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

Deprecated: Use ReplicateResponse.ProtoReflect.Descriptor instead.

func (*ReplicateResponse) GetCommandsResponse 

func (x *ReplicateResponse) GetCommandsResponse() *ReplicateCommandsResponse

func (*ReplicateResponse) GetErrorResponse 

func (x *ReplicateResponse) GetErrorResponse() *ReplicateErrResponse

func (*ReplicateResponse) GetLeaderIndex 

func (x *ReplicateResponse) GetLeaderIndex() uint64

func (*ReplicateResponse) GetResponse 

func (m *ReplicateResponse) GetResponse() isReplicateResponse_Response

func (*ReplicateResponse) MarshalToSizedBufferVT 

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

func (*ReplicateResponse) MarshalToVT 

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

func (*ReplicateResponse) MarshalVT 

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

func (*ReplicateResponse) ProtoMessage 

func (*ReplicateResponse) ProtoMessage()

func (*ReplicateResponse) ProtoReflect 

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

func (*ReplicateResponse) Reset 

func (x *ReplicateResponse) Reset()

func (*ReplicateResponse) SizeVT 

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

func (*ReplicateResponse) String 

func (x *ReplicateResponse) String() string

func (*ReplicateResponse) UnmarshalVT 

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

func (*ReplicateResponse) UnmarshalVTUnsafe added in v0.4.0 

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

type ReplicateResponse_CommandsResponse 

type ReplicateResponse_CommandsResponse struct {
	CommandsResponse *ReplicateCommandsResponse `protobuf:"bytes,1,opt,name=commands_response,json=commandsResponse,proto3,oneof"`
}

func (*ReplicateResponse_CommandsResponse) MarshalToSizedBufferVT 

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

func (*ReplicateResponse_CommandsResponse) MarshalToVT 

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

func (*ReplicateResponse_CommandsResponse) SizeVT 

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

type ReplicateResponse_ErrorResponse 

type ReplicateResponse_ErrorResponse struct {
	ErrorResponse *ReplicateErrResponse `protobuf:"bytes,2,opt,name=error_response,json=errorResponse,proto3,oneof"`
}

func (*ReplicateResponse_ErrorResponse) MarshalToSizedBufferVT 

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

func (*ReplicateResponse_ErrorResponse) MarshalToVT 

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

func (*ReplicateResponse_ErrorResponse) SizeVT 

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

type RequestOp 

type RequestOp struct {

	// request is a union of request types accepted by a transaction.
	//
	// Types that are assignable to Request:
	//
	//	*RequestOp_RequestRange
	//	*RequestOp_RequestPut
	//	*RequestOp_RequestDeleteRange
	Request isRequestOp_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*RequestOp) Descriptor deprecated 

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

Deprecated: Use RequestOp.ProtoReflect.Descriptor instead.

func (*RequestOp) GetRequest 

func (m *RequestOp) GetRequest() isRequestOp_Request

func (*RequestOp) GetRequestDeleteRange 

func (x *RequestOp) GetRequestDeleteRange() *RequestOp_DeleteRange

func (*RequestOp) GetRequestPut 

func (x *RequestOp) GetRequestPut() *RequestOp_Put

func (*RequestOp) GetRequestRange 

func (x *RequestOp) GetRequestRange() *RequestOp_Range

func (*RequestOp) MarshalToSizedBufferVT 

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

func (*RequestOp) MarshalToVT 

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

func (*RequestOp) MarshalVT 

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

func (*RequestOp) ProtoMessage 

func (*RequestOp) ProtoMessage()

func (*RequestOp) ProtoReflect 

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

func (*RequestOp) Reset 

func (x *RequestOp) Reset()

func (*RequestOp) SizeVT 

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

func (*RequestOp) String 

func (x *RequestOp) String() string

func (*RequestOp) UnmarshalVT 

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

func (*RequestOp) UnmarshalVTUnsafe added in v0.4.0 

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

type RequestOp_DeleteRange 

type RequestOp_DeleteRange struct {

	// key is the first key to delete in the range.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// range_end is the key following the last key to delete for the range [key, range_end).
	// If range_end is not given, the range is defined to contain only the key argument.
	// If range_end is one bit larger than the given key, then the range is all the keys
	// with the prefix (the given key).
	// If range_end is '\0', the range is all keys greater than or equal to the key argument.
	RangeEnd []byte `protobuf:"bytes,2,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
	// If prev_kv is set, regatta gets the previous key-value pairs before deleting it.
	// The previous key-value pairs will be returned in the delete response.
	// Beware that getting previous records could have serious performance impact on a delete range spanning a large dataset.
	PrevKv bool `protobuf:"varint,4,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// If count is set, regatta gets the count of previous key-value pairs before deleting it.
	// The deleted field will be set to number of deleted key-value pairs in the response.
	// Beware that counting records could have serious performance impact on a delete range spanning a large dataset.
	Count bool `protobuf:"varint,5,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestOp_DeleteRange) Descriptor deprecated 

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

Deprecated: Use RequestOp_DeleteRange.ProtoReflect.Descriptor instead.

func (*RequestOp_DeleteRange) GetCount 

func (x *RequestOp_DeleteRange) GetCount() bool

func (*RequestOp_DeleteRange) GetKey 

func (x *RequestOp_DeleteRange) GetKey() []byte

func (*RequestOp_DeleteRange) GetPrevKv 

func (x *RequestOp_DeleteRange) GetPrevKv() bool

func (*RequestOp_DeleteRange) GetRangeEnd 

func (x *RequestOp_DeleteRange) GetRangeEnd() []byte

func (*RequestOp_DeleteRange) MarshalToSizedBufferVT 

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

func (*RequestOp_DeleteRange) MarshalToVT 

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

func (*RequestOp_DeleteRange) MarshalVT 

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

func (*RequestOp_DeleteRange) ProtoMessage 

func (*RequestOp_DeleteRange) ProtoMessage()

func (*RequestOp_DeleteRange) ProtoReflect 

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

func (*RequestOp_DeleteRange) Reset 

func (x *RequestOp_DeleteRange) Reset()

func (*RequestOp_DeleteRange) SizeVT 

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

func (*RequestOp_DeleteRange) String 

func (x *RequestOp_DeleteRange) String() string

func (*RequestOp_DeleteRange) UnmarshalVT 

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

func (*RequestOp_DeleteRange) UnmarshalVTUnsafe added in v0.4.0 

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

type RequestOp_Put 

type RequestOp_Put struct {

	// key is the key, in bytes, to put into the key-value store.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// value is the value, in bytes, to associate with the key in the key-value store.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// prev_kv if true the previous key-value pair will be returned in the put response.
	PrevKv bool `protobuf:"varint,3,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestOp_Put) Descriptor deprecated 

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

Deprecated: Use RequestOp_Put.ProtoReflect.Descriptor instead.

func (*RequestOp_Put) GetKey 

func (x *RequestOp_Put) GetKey() []byte

func (*RequestOp_Put) GetPrevKv 

func (x *RequestOp_Put) GetPrevKv() bool

func (*RequestOp_Put) GetValue 

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

func (*RequestOp_Put) MarshalToSizedBufferVT 

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

func (*RequestOp_Put) MarshalToVT 

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

func (*RequestOp_Put) MarshalVT 

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

func (*RequestOp_Put) ProtoMessage 

func (*RequestOp_Put) ProtoMessage()

func (*RequestOp_Put) ProtoReflect 

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

func (*RequestOp_Put) Reset 

func (x *RequestOp_Put) Reset()

func (*RequestOp_Put) SizeVT 

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

func (*RequestOp_Put) String 

func (x *RequestOp_Put) String() string

func (*RequestOp_Put) UnmarshalVT 

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

func (*RequestOp_Put) UnmarshalVTUnsafe added in v0.4.0 

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

type RequestOp_Range 

type RequestOp_Range struct {

	// key is the first key for the range. If range_end is not given, the request only looks up key.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// range_end is the upper bound on the requested range [key, range_end).
	// If range_end is '\0', the range is all keys >= key.
	// If range_end is key plus one (e.g., "aa"+1 == "ab", "a\xff"+1 == "b"),
	// then the range request gets all keys prefixed with key.
	// If both key and range_end are '\0', then the range request returns all keys.
	RangeEnd []byte `protobuf:"bytes,2,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
	// limit is a limit on the number of keys returned for the request. When limit is set to 0,
	// it is treated as no limit.
	Limit int64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// keys_only when set returns only the keys and not the values.
	KeysOnly bool `protobuf:"varint,4,opt,name=keys_only,json=keysOnly,proto3" json:"keys_only,omitempty"`
	// count_only when set returns only the count of the keys in the range.
	CountOnly bool `protobuf:"varint,5,opt,name=count_only,json=countOnly,proto3" json:"count_only,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestOp_Range) Descriptor deprecated 

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

Deprecated: Use RequestOp_Range.ProtoReflect.Descriptor instead.

func (*RequestOp_Range) GetCountOnly 

func (x *RequestOp_Range) GetCountOnly() bool

func (*RequestOp_Range) GetKey 

func (x *RequestOp_Range) GetKey() []byte

func (*RequestOp_Range) GetKeysOnly 

func (x *RequestOp_Range) GetKeysOnly() bool

func (*RequestOp_Range) GetLimit 

func (x *RequestOp_Range) GetLimit() int64

func (*RequestOp_Range) GetRangeEnd 

func (x *RequestOp_Range) GetRangeEnd() []byte

func (*RequestOp_Range) MarshalToSizedBufferVT 

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

func (*RequestOp_Range) MarshalToVT 

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

func (*RequestOp_Range) MarshalVT 

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

func (*RequestOp_Range) ProtoMessage 

func (*RequestOp_Range) ProtoMessage()

func (*RequestOp_Range) ProtoReflect 

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

func (*RequestOp_Range) Reset 

func (x *RequestOp_Range) Reset()

func (*RequestOp_Range) SizeVT 

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

func (*RequestOp_Range) String 

func (x *RequestOp_Range) String() string

func (*RequestOp_Range) UnmarshalVT 

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

func (*RequestOp_Range) UnmarshalVTUnsafe added in v0.4.0 

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

type RequestOp_RequestDeleteRange 

type RequestOp_RequestDeleteRange struct {
	RequestDeleteRange *RequestOp_DeleteRange `protobuf:"bytes,3,opt,name=request_delete_range,json=requestDeleteRange,proto3,oneof"`
}

func (*RequestOp_RequestDeleteRange) MarshalToSizedBufferVT 

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

func (*RequestOp_RequestDeleteRange) MarshalToVT 

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

func (*RequestOp_RequestDeleteRange) SizeVT 

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

type RequestOp_RequestPut 

type RequestOp_RequestPut struct {
	RequestPut *RequestOp_Put `protobuf:"bytes,2,opt,name=request_put,json=requestPut,proto3,oneof"`
}

func (*RequestOp_RequestPut) MarshalToSizedBufferVT 

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

func (*RequestOp_RequestPut) MarshalToVT 

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

func (*RequestOp_RequestPut) SizeVT 

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

type RequestOp_RequestRange 

type RequestOp_RequestRange struct {
	RequestRange *RequestOp_Range `protobuf:"bytes,1,opt,name=request_range,json=requestRange,proto3,oneof"`
}

func (*RequestOp_RequestRange) MarshalToSizedBufferVT 

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

func (*RequestOp_RequestRange) MarshalToVT 

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

func (*RequestOp_RequestRange) SizeVT 

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

type ResetRequest 

type ResetRequest struct {

	// table is a table name to reset.
	Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// reset_all if true all the tables will be reset, use with caution.
	ResetAll bool `protobuf:"varint,2,opt,name=reset_all,json=resetAll,proto3" json:"reset_all,omitempty"`
	// contains filtered or unexported fields
}

ResetRequest resets either a single or multiple tables in the cluster, meaning that their data will be repopulated from the Leader.

func (*ResetRequest) Descriptor deprecated 

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

Deprecated: Use ResetRequest.ProtoReflect.Descriptor instead.

func (*ResetRequest) GetResetAll 

func (x *ResetRequest) GetResetAll() bool

func (*ResetRequest) GetTable 

func (x *ResetRequest) GetTable() []byte

func (*ResetRequest) MarshalToSizedBufferVT 

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

func (*ResetRequest) MarshalToVT 

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

func (*ResetRequest) MarshalVT 

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

func (*ResetRequest) ProtoMessage 

func (*ResetRequest) ProtoMessage()

func (*ResetRequest) ProtoReflect 

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

func (*ResetRequest) Reset 

func (x *ResetRequest) Reset()

func (*ResetRequest) SizeVT 

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

func (*ResetRequest) String 

func (x *ResetRequest) String() string

func (*ResetRequest) UnmarshalVT 

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

func (*ResetRequest) UnmarshalVTUnsafe added in v0.4.0 

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

type ResetResponse 

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

func (*ResetResponse) Descriptor deprecated 

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

Deprecated: Use ResetResponse.ProtoReflect.Descriptor instead.

func (*ResetResponse) MarshalToSizedBufferVT 

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

func (*ResetResponse) MarshalToVT 

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

func (*ResetResponse) MarshalVT 

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

func (*ResetResponse) ProtoMessage 

func (*ResetResponse) ProtoMessage()

func (*ResetResponse) ProtoReflect 

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

func (*ResetResponse) Reset 

func (x *ResetResponse) Reset()

func (*ResetResponse) SizeVT 

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

func (*ResetResponse) String 

func (x *ResetResponse) String() string

func (*ResetResponse) UnmarshalVT 

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

func (*ResetResponse) UnmarshalVTUnsafe added in v0.4.0 

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

type ResponseHeader 

type ResponseHeader struct {

	// shard_id is the ID of the shard which sent the response.
	ShardId uint64 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	// replica_id is the ID of the member which sent the response.
	ReplicaId uint64 `protobuf:"varint,2,opt,name=replica_id,json=replicaId,proto3" json:"replica_id,omitempty"`
	// revision is the key-value store revision when the request was applied.
	Revision uint64 `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"`
	// raft_term is the raft term when the request was applied.
	RaftTerm uint64 `protobuf:"varint,4,opt,name=raft_term,json=raftTerm,proto3" json:"raft_term,omitempty"`
	// raft_leader_id is the ID of the actual raft quorum leader.
	RaftLeaderId uint64 `protobuf:"varint,5,opt,name=raft_leader_id,json=raftLeaderId,proto3" json:"raft_leader_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ResponseHeader) Descriptor deprecated 

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

Deprecated: Use ResponseHeader.ProtoReflect.Descriptor instead.

func (*ResponseHeader) GetRaftLeaderId 

func (x *ResponseHeader) GetRaftLeaderId() uint64

func (*ResponseHeader) GetRaftTerm 

func (x *ResponseHeader) GetRaftTerm() uint64

func (*ResponseHeader) GetReplicaId 

func (x *ResponseHeader) GetReplicaId() uint64

func (*ResponseHeader) GetRevision 

func (x *ResponseHeader) GetRevision() uint64

func (*ResponseHeader) GetShardId 

func (x *ResponseHeader) GetShardId() uint64

func (*ResponseHeader) MarshalToSizedBufferVT 

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

func (*ResponseHeader) MarshalToVT 

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

func (*ResponseHeader) MarshalVT 

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

func (*ResponseHeader) ProtoMessage 

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) ProtoReflect 

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

func (*ResponseHeader) Reset 

func (x *ResponseHeader) Reset()

func (*ResponseHeader) SizeVT 

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

func (*ResponseHeader) String 

func (x *ResponseHeader) String() string

func (*ResponseHeader) UnmarshalVT 

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

func (*ResponseHeader) UnmarshalVTUnsafe added in v0.4.0 

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

type ResponseOp 

type ResponseOp struct {

	// response is a union of response types returned by a transaction.
	//
	// Types that are assignable to Response:
	//
	//	*ResponseOp_ResponseRange
	//	*ResponseOp_ResponsePut
	//	*ResponseOp_ResponseDeleteRange
	Response isResponseOp_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*ResponseOp) Descriptor deprecated 

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

Deprecated: Use ResponseOp.ProtoReflect.Descriptor instead.

func (*ResponseOp) GetResponse 

func (m *ResponseOp) GetResponse() isResponseOp_Response

func (*ResponseOp) GetResponseDeleteRange 

func (x *ResponseOp) GetResponseDeleteRange() *ResponseOp_DeleteRange

func (*ResponseOp) GetResponsePut 

func (x *ResponseOp) GetResponsePut() *ResponseOp_Put

func (*ResponseOp) GetResponseRange 

func (x *ResponseOp) GetResponseRange() *ResponseOp_Range

func (*ResponseOp) MarshalToSizedBufferVT 

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

func (*ResponseOp) MarshalToVT 

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

func (*ResponseOp) MarshalVT 

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

func (*ResponseOp) ProtoMessage 

func (*ResponseOp) ProtoMessage()

func (*ResponseOp) ProtoReflect 

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

func (*ResponseOp) Reset 

func (x *ResponseOp) Reset()

func (*ResponseOp) SizeVT 

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

func (*ResponseOp) String 

func (x *ResponseOp) String() string

func (*ResponseOp) UnmarshalVT 

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

func (*ResponseOp) UnmarshalVTUnsafe added in v0.4.0 

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

type ResponseOp_DeleteRange 

type ResponseOp_DeleteRange struct {

	// deleted is the number of keys deleted by the delete range request.
	Deleted int64 `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// if prev_kv is set in the request, the previous key-value pairs will be returned.
	PrevKvs []*KeyValue `protobuf:"bytes,2,rep,name=prev_kvs,json=prevKvs,proto3" json:"prev_kvs,omitempty"`
	// contains filtered or unexported fields
}

func (*ResponseOp_DeleteRange) Descriptor deprecated 

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

Deprecated: Use ResponseOp_DeleteRange.ProtoReflect.Descriptor instead.

func (*ResponseOp_DeleteRange) GetDeleted 

func (x *ResponseOp_DeleteRange) GetDeleted() int64

func (*ResponseOp_DeleteRange) GetPrevKvs 

func (x *ResponseOp_DeleteRange) GetPrevKvs() []*KeyValue

func (*ResponseOp_DeleteRange) MarshalToSizedBufferVT 

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

func (*ResponseOp_DeleteRange) MarshalToVT 

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

func (*ResponseOp_DeleteRange) MarshalVT 

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

func (*ResponseOp_DeleteRange) ProtoMessage 

func (*ResponseOp_DeleteRange) ProtoMessage()

func (*ResponseOp_DeleteRange) ProtoReflect 

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

func (*ResponseOp_DeleteRange) Reset 

func (x *ResponseOp_DeleteRange) Reset()

func (*ResponseOp_DeleteRange) SizeVT 

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

func (*ResponseOp_DeleteRange) String 

func (x *ResponseOp_DeleteRange) String() string

func (*ResponseOp_DeleteRange) UnmarshalVT 

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

func (*ResponseOp_DeleteRange) UnmarshalVTUnsafe added in v0.4.0 

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

type ResponseOp_Put 

type ResponseOp_Put struct {

	// if prev_kv is set in the request, the previous key-value pair will be returned.
	PrevKv *KeyValue `protobuf:"bytes,1,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// contains filtered or unexported fields
}

func (*ResponseOp_Put) Descriptor deprecated 

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

Deprecated: Use ResponseOp_Put.ProtoReflect.Descriptor instead.

func (*ResponseOp_Put) GetPrevKv 

func (x *ResponseOp_Put) GetPrevKv() *KeyValue

func (*ResponseOp_Put) MarshalToSizedBufferVT 

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

func (*ResponseOp_Put) MarshalToVT 

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

func (*ResponseOp_Put) MarshalVT 

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

func (*ResponseOp_Put) ProtoMessage 

func (*ResponseOp_Put) ProtoMessage()

func (*ResponseOp_Put) ProtoReflect 

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

func (*ResponseOp_Put) Reset 

func (x *ResponseOp_Put) Reset()

func (*ResponseOp_Put) SizeVT 

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

func (*ResponseOp_Put) String 

func (x *ResponseOp_Put) String() string

func (*ResponseOp_Put) UnmarshalVT 

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

func (*ResponseOp_Put) UnmarshalVTUnsafe added in v0.4.0 

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

type ResponseOp_Range 

type ResponseOp_Range struct {

	// kvs is the list of key-value pairs matched by the range request.
	// kvs is empty when count is requested.
	Kvs []*KeyValue `protobuf:"bytes,1,rep,name=kvs,proto3" json:"kvs,omitempty"`
	// more indicates if there are more keys to return in the requested range.
	More bool `protobuf:"varint,2,opt,name=more,proto3" json:"more,omitempty"`
	// count is set to the number of keys within the range when requested.
	Count int64 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ResponseOp_Range) Descriptor deprecated 

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

Deprecated: Use ResponseOp_Range.ProtoReflect.Descriptor instead.

func (*ResponseOp_Range) GetCount 

func (x *ResponseOp_Range) GetCount() int64

func (*ResponseOp_Range) GetKvs 

func (x *ResponseOp_Range) GetKvs() []*KeyValue

func (*ResponseOp_Range) GetMore 

func (x *ResponseOp_Range) GetMore() bool

func (*ResponseOp_Range) MarshalToSizedBufferVT 

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

func (*ResponseOp_Range) MarshalToVT 

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

func (*ResponseOp_Range) MarshalVT 

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

func (*ResponseOp_Range) ProtoMessage 

func (*ResponseOp_Range) ProtoMessage()

func (*ResponseOp_Range) ProtoReflect 

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

func (*ResponseOp_Range) Reset 

func (x *ResponseOp_Range) Reset()

func (*ResponseOp_Range) SizeVT 

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

func (*ResponseOp_Range) String 

func (x *ResponseOp_Range) String() string

func (*ResponseOp_Range) UnmarshalVT 

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

func (*ResponseOp_Range) UnmarshalVTUnsafe added in v0.4.0 

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

type ResponseOp_ResponseDeleteRange 

type ResponseOp_ResponseDeleteRange struct {
	ResponseDeleteRange *ResponseOp_DeleteRange `protobuf:"bytes,3,opt,name=response_delete_range,json=responseDeleteRange,proto3,oneof"`
}

func (*ResponseOp_ResponseDeleteRange) MarshalToSizedBufferVT 

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

func (*ResponseOp_ResponseDeleteRange) MarshalToVT 

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

func (*ResponseOp_ResponseDeleteRange) SizeVT 

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

type ResponseOp_ResponsePut 

type ResponseOp_ResponsePut struct {
	ResponsePut *ResponseOp_Put `protobuf:"bytes,2,opt,name=response_put,json=responsePut,proto3,oneof"`
}

func (*ResponseOp_ResponsePut) MarshalToSizedBufferVT 

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

func (*ResponseOp_ResponsePut) MarshalToVT 

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

func (*ResponseOp_ResponsePut) SizeVT 

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

type ResponseOp_ResponseRange 

type ResponseOp_ResponseRange struct {
	ResponseRange *ResponseOp_Range `protobuf:"bytes,1,opt,name=response_range,json=responseRange,proto3,oneof"`
}

func (*ResponseOp_ResponseRange) MarshalToSizedBufferVT 

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

func (*ResponseOp_ResponseRange) MarshalToVT 

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

func (*ResponseOp_ResponseRange) SizeVT 

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

type RestoreInfo 

type RestoreInfo struct {

	// table is name of the table in the stream.
	Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

RestoreInfo metadata of restore snapshot that is going to be uploaded.

func (*RestoreInfo) Descriptor deprecated 

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

Deprecated: Use RestoreInfo.ProtoReflect.Descriptor instead.

func (*RestoreInfo) GetTable 

func (x *RestoreInfo) GetTable() []byte

func (*RestoreInfo) MarshalToSizedBufferVT 

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

func (*RestoreInfo) MarshalToVT 

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

func (*RestoreInfo) MarshalVT 

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

func (*RestoreInfo) ProtoMessage 

func (*RestoreInfo) ProtoMessage()

func (*RestoreInfo) ProtoReflect 

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

func (*RestoreInfo) Reset 

func (x *RestoreInfo) Reset()

func (*RestoreInfo) SizeVT 

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

func (*RestoreInfo) String 

func (x *RestoreInfo) String() string

func (*RestoreInfo) UnmarshalVT 

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

func (*RestoreInfo) UnmarshalVTUnsafe added in v0.4.0 

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

type RestoreMessage 

type RestoreMessage struct {

	// Types that are assignable to Data:
	//
	//	*RestoreMessage_Info
	//	*RestoreMessage_Chunk
	Data isRestoreMessage_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

RestoreMessage contains either info of the table being restored or chunk of a backup data.

func (*RestoreMessage) Descriptor deprecated 

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

Deprecated: Use RestoreMessage.ProtoReflect.Descriptor instead.

func (*RestoreMessage) GetChunk 

func (x *RestoreMessage) GetChunk() *SnapshotChunk

func (*RestoreMessage) GetData 

func (m *RestoreMessage) GetData() isRestoreMessage_Data

func (*RestoreMessage) GetInfo 

func (x *RestoreMessage) GetInfo() *RestoreInfo

func (*RestoreMessage) MarshalToSizedBufferVT 

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

func (*RestoreMessage) MarshalToVT 

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

func (*RestoreMessage) MarshalVT 

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

func (*RestoreMessage) ProtoMessage 

func (*RestoreMessage) ProtoMessage()

func (*RestoreMessage) ProtoReflect 

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

func (*RestoreMessage) Reset 

func (x *RestoreMessage) Reset()

func (*RestoreMessage) SizeVT 

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

func (*RestoreMessage) String 

func (x *RestoreMessage) String() string

func (*RestoreMessage) UnmarshalVT 

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

func (*RestoreMessage) UnmarshalVTUnsafe added in v0.4.0 

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

type RestoreMessage_Chunk 

type RestoreMessage_Chunk struct {
	Chunk *SnapshotChunk `protobuf:"bytes,2,opt,name=chunk,proto3,oneof"`
}

func (*RestoreMessage_Chunk) MarshalToSizedBufferVT 

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

func (*RestoreMessage_Chunk) MarshalToVT 

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

func (*RestoreMessage_Chunk) SizeVT 

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

type RestoreMessage_Info 

type RestoreMessage_Info struct {
	Info *RestoreInfo `protobuf:"bytes,1,opt,name=info,proto3,oneof"`
}

func (*RestoreMessage_Info) MarshalToSizedBufferVT 

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

func (*RestoreMessage_Info) MarshalToVT 

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

func (*RestoreMessage_Info) SizeVT 

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

type RestoreResponse 

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

func (*RestoreResponse) Descriptor deprecated 

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

Deprecated: Use RestoreResponse.ProtoReflect.Descriptor instead.

func (*RestoreResponse) MarshalToSizedBufferVT 

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

func (*RestoreResponse) MarshalToVT 

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

func (*RestoreResponse) MarshalVT 

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

func (*RestoreResponse) ProtoMessage 

func (*RestoreResponse) ProtoMessage()

func (*RestoreResponse) ProtoReflect 

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

func (*RestoreResponse) Reset 

func (x *RestoreResponse) Reset()

func (*RestoreResponse) SizeVT 

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

func (*RestoreResponse) String 

func (x *RestoreResponse) String() string

func (*RestoreResponse) UnmarshalVT 

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

func (*RestoreResponse) UnmarshalVTUnsafe added in v0.4.0 

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

type SnapshotChunk 

type SnapshotChunk struct {

	// data is chunk of snapshot
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// len is a length of data bytes
	Len uint64 `protobuf:"varint,2,opt,name=len,proto3" json:"len,omitempty"`
	// index the index for which the snapshot was created
	Index uint64 `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

func SnapshotChunkFromVTPool 

func SnapshotChunkFromVTPool() *SnapshotChunk

func (*SnapshotChunk) Descriptor deprecated 

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

Deprecated: Use SnapshotChunk.ProtoReflect.Descriptor instead.

func (*SnapshotChunk) GetData 

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

func (*SnapshotChunk) GetIndex 

func (x *SnapshotChunk) GetIndex() uint64

func (*SnapshotChunk) GetLen 

func (x *SnapshotChunk) GetLen() uint64

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

func (m *SnapshotChunk) ResetVT()

func (*SnapshotChunk) ReturnToVTPool 

func (m *SnapshotChunk) ReturnToVTPool()

func (*SnapshotChunk) SizeVT 

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

func (*SnapshotChunk) String 

func (x *SnapshotChunk) String() string

func (*SnapshotChunk) UnmarshalVT 

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

func (*SnapshotChunk) UnmarshalVTUnsafe added in v0.4.0 

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

type SnapshotClient 

type SnapshotClient interface {
	Stream(ctx context.Context, in *SnapshotRequest, opts ...grpc.CallOption) (Snapshot_StreamClient, error)
}

SnapshotClient is the client API for Snapshot 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 NewSnapshotClient 

func NewSnapshotClient(cc grpc.ClientConnInterface) SnapshotClient

type SnapshotRequest 

type SnapshotRequest struct {

	// table is name of the table to stream
	Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotRequest) Descriptor deprecated 

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

Deprecated: Use SnapshotRequest.ProtoReflect.Descriptor instead.

func (*SnapshotRequest) GetTable 

func (x *SnapshotRequest) GetTable() []byte

func (*SnapshotRequest) MarshalToSizedBufferVT 

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

func (*SnapshotRequest) MarshalToVT 

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

func (*SnapshotRequest) MarshalVT 

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

func (*SnapshotRequest) ProtoMessage 

func (*SnapshotRequest) ProtoMessage()

func (*SnapshotRequest) ProtoReflect 

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

func (*SnapshotRequest) Reset 

func (x *SnapshotRequest) Reset()

func (*SnapshotRequest) SizeVT 

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

func (*SnapshotRequest) String 

func (x *SnapshotRequest) String() string

func (*SnapshotRequest) UnmarshalVT 

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

func (*SnapshotRequest) UnmarshalVTUnsafe added in v0.4.0 

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

type SnapshotServer 

type SnapshotServer interface {
	Stream(*SnapshotRequest, Snapshot_StreamServer) error
	// contains filtered or unexported methods
}

SnapshotServer is the server API for Snapshot service. All implementations must embed UnimplementedSnapshotServer for forward compatibility

type Snapshot_StreamClient 

type Snapshot_StreamClient interface {
	Recv() (*SnapshotChunk, error)
	grpc.ClientStream
}

type Snapshot_StreamServer 

type Snapshot_StreamServer interface {
	Send(*SnapshotChunk) error
	grpc.ServerStream
}

type StatusRequest 

type StatusRequest struct {

	// config controls if the configuration values should be fetched as well.
	Config bool `protobuf:"varint,4,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) GetConfig added in v0.3.0 

func (x *StatusRequest) GetConfig() bool

func (*StatusRequest) MarshalToSizedBufferVT 

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

func (*StatusRequest) MarshalToVT 

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

func (*StatusRequest) MarshalVT 

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

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect 

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

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) SizeVT 

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

func (*StatusRequest) String 

func (x *StatusRequest) String() string

func (*StatusRequest) UnmarshalVT 

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

func (*StatusRequest) UnmarshalVTUnsafe added in v0.4.0 

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

type StatusResponse 

type StatusResponse struct {

	// id is the member ID of this member.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// version is the semver version used by the responding member.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// info is the additional server info.
	Info string `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	// tables is a status of tables of the responding member.
	Tables map[string]*TableStatus `` /* 153-byte string literal not displayed */
	// config the node configuration values.
	Config *structpb.Struct `protobuf:"bytes,5,opt,name=config,proto3" json:"config,omitempty"`
	// errors contains alarm/health information and status.
	Errors []string `protobuf:"bytes,8,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetConfig added in v0.3.0 

func (x *StatusResponse) GetConfig() *structpb.Struct

func (*StatusResponse) GetErrors 

func (x *StatusResponse) GetErrors() []string

func (*StatusResponse) GetId added in v0.2.0 

func (x *StatusResponse) GetId() string

func (*StatusResponse) GetInfo added in v0.2.0 

func (x *StatusResponse) GetInfo() string

func (*StatusResponse) GetTables added in v0.2.0 

func (x *StatusResponse) GetTables() map[string]*TableStatus

func (*StatusResponse) GetVersion 

func (x *StatusResponse) GetVersion() string

func (*StatusResponse) MarshalToSizedBufferVT 

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

func (*StatusResponse) MarshalToVT 

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

func (*StatusResponse) MarshalVT 

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

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) SizeVT 

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

func (*StatusResponse) String 

func (x *StatusResponse) String() string

func (*StatusResponse) UnmarshalVT 

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

func (*StatusResponse) UnmarshalVTUnsafe added in v0.4.0 

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

type Table 

type Table struct {
	Name string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type Table_Type `protobuf:"varint,2,opt,name=type,proto3,enum=replication.v1.Table_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Table) Descriptor deprecated 

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

Deprecated: Use Table.ProtoReflect.Descriptor instead.

func (*Table) GetName 

func (x *Table) GetName() string

func (*Table) GetType 

func (x *Table) GetType() Table_Type

func (*Table) MarshalToSizedBufferVT 

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

func (*Table) MarshalToVT 

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

func (*Table) MarshalVT 

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

func (*Table) ProtoMessage 

func (*Table) ProtoMessage()

func (*Table) ProtoReflect 

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

func (*Table) Reset 

func (x *Table) Reset()

func (*Table) SizeVT 

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

func (*Table) String 

func (x *Table) String() string

func (*Table) UnmarshalVT 

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

func (*Table) UnmarshalVTUnsafe added in v0.4.0 

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

type TableInfo added in v0.4.0 

type TableInfo struct {

	// name of the table.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// id of the table.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// config the table configuration values.
	Config *structpb.Struct `protobuf:"bytes,5,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

TableInfo describes a single table.

func (*TableInfo) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use TableInfo.ProtoReflect.Descriptor instead.

func (*TableInfo) GetConfig added in v0.4.0 

func (x *TableInfo) GetConfig() *structpb.Struct

func (*TableInfo) GetId added in v0.4.0 

func (x *TableInfo) GetId() string

func (*TableInfo) GetName added in v0.4.0 

func (x *TableInfo) GetName() string

func (*TableInfo) MarshalToSizedBufferVT added in v0.4.0 

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

func (*TableInfo) MarshalToVT added in v0.4.0 

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

func (*TableInfo) MarshalVT added in v0.4.0 

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

func (*TableInfo) ProtoMessage added in v0.4.0 

func (*TableInfo) ProtoMessage()

func (*TableInfo) ProtoReflect added in v0.4.0 

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

func (*TableInfo) Reset added in v0.4.0 

func (x *TableInfo) Reset()

func (*TableInfo) SizeVT added in v0.4.0 

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

func (*TableInfo) String added in v0.4.0 

func (x *TableInfo) String() string

func (*TableInfo) UnmarshalVT added in v0.4.0 

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

func (*TableInfo) UnmarshalVTUnsafe added in v0.4.0 

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

type TableStatus added in v0.2.0 

type TableStatus struct {

	// dbSize is the size of the raft log, in bytes, of the responding member.
	LogSize int64 `protobuf:"varint,2,opt,name=logSize,proto3" json:"logSize,omitempty"`
	// dbSize is the size of the backend database physically allocated, in bytes, of the responding member.
	DbSize int64 `protobuf:"varint,3,opt,name=dbSize,proto3" json:"dbSize,omitempty"`
	// leader is the member ID which the responding member believes is the current leader.
	Leader string `protobuf:"bytes,4,opt,name=leader,proto3" json:"leader,omitempty"`
	// raftIndex is the current raft committed index of the responding member.
	RaftIndex uint64 `protobuf:"varint,5,opt,name=raftIndex,proto3" json:"raftIndex,omitempty"`
	// raftTerm is the current raft term of the responding member.
	RaftTerm uint64 `protobuf:"varint,6,opt,name=raftTerm,proto3" json:"raftTerm,omitempty"`
	// raftAppliedIndex is the current raft applied index of the responding member.
	RaftAppliedIndex uint64 `protobuf:"varint,7,opt,name=raftAppliedIndex,proto3" json:"raftAppliedIndex,omitempty"`
	// contains filtered or unexported fields
}

func (*TableStatus) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use TableStatus.ProtoReflect.Descriptor instead.

func (*TableStatus) GetDbSize added in v0.2.0 

func (x *TableStatus) GetDbSize() int64

func (*TableStatus) GetLeader added in v0.2.0 

func (x *TableStatus) GetLeader() string

func (*TableStatus) GetLogSize added in v0.2.0 

func (x *TableStatus) GetLogSize() int64

func (*TableStatus) GetRaftAppliedIndex added in v0.2.0 

func (x *TableStatus) GetRaftAppliedIndex() uint64

func (*TableStatus) GetRaftIndex added in v0.2.0 

func (x *TableStatus) GetRaftIndex() uint64

func (*TableStatus) GetRaftTerm added in v0.2.0 

func (x *TableStatus) GetRaftTerm() uint64

func (*TableStatus) MarshalToSizedBufferVT added in v0.2.0 

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

func (*TableStatus) MarshalToVT added in v0.2.0 

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

func (*TableStatus) MarshalVT added in v0.2.0 

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

func (*TableStatus) ProtoMessage added in v0.2.0 

func (*TableStatus) ProtoMessage()

func (*TableStatus) ProtoReflect added in v0.2.0 

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

func (*TableStatus) Reset added in v0.2.0 

func (x *TableStatus) Reset()

func (*TableStatus) SizeVT added in v0.2.0 

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

func (*TableStatus) String added in v0.2.0 

func (x *TableStatus) String() string

func (*TableStatus) UnmarshalVT added in v0.2.0 

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

func (*TableStatus) UnmarshalVTUnsafe added in v0.4.0 

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

type Table_Type 

type Table_Type int32
const (
	Table_REPLICATED Table_Type = 0
	Table_LOCAL      Table_Type = 1
)

func (Table_Type) Descriptor 

func (Table_Type) Descriptor() protoreflect.EnumDescriptor

func (Table_Type) Enum 

func (x Table_Type) Enum() *Table_Type

func (Table_Type) EnumDescriptor deprecated 

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

Deprecated: Use Table_Type.Descriptor instead.

func (Table_Type) Number 

func (x Table_Type) Number() protoreflect.EnumNumber

func (Table_Type) String 

func (x Table_Type) String() string

func (Table_Type) Type 

func (Table_Type) Type() protoreflect.EnumType

type TablesClient added in v0.4.0 

type TablesClient interface {
	// Create a table. All followers will automatically replicate the table.
	// This procedure is available only in the leader cluster.
	Create(ctx context.Context, in *CreateTableRequest, opts ...grpc.CallOption) (*CreateTableResponse, error)
	// Delete a table. All followers will automatically delete the table.
	// This procedure is available only in the leader cluster.
	Delete(ctx context.Context, in *DeleteTableRequest, opts ...grpc.CallOption) (*DeleteTableResponse, error)
	// Get names of all the tables present in the cluster.
	// This procedure is available in both leader and follower clusters.
	List(ctx context.Context, in *ListTablesRequest, opts ...grpc.CallOption) (*ListTablesResponse, error)
}

TablesClient is the client API for Tables 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 NewTablesClient added in v0.4.0 

func NewTablesClient(cc grpc.ClientConnInterface) TablesClient

type TablesServer added in v0.4.0 

type TablesServer interface {
	// Create a table. All followers will automatically replicate the table.
	// This procedure is available only in the leader cluster.
	Create(context.Context, *CreateTableRequest) (*CreateTableResponse, error)
	// Delete a table. All followers will automatically delete the table.
	// This procedure is available only in the leader cluster.
	Delete(context.Context, *DeleteTableRequest) (*DeleteTableResponse, error)
	// Get names of all the tables present in the cluster.
	// This procedure is available in both leader and follower clusters.
	List(context.Context, *ListTablesRequest) (*ListTablesResponse, error)
	// contains filtered or unexported methods
}

TablesServer is the server API for Tables service. All implementations must embed UnimplementedTablesServer for forward compatibility

type Txn 

type Txn struct {

	// compare is a list of predicates representing a conjunction of terms.
	// If the comparisons succeed, then the success requests will be processed in order,
	// and the response will contain their respective responses in order.
	// If the comparisons fail, then the failure requests will be processed in order,
	// and the response will contain their respective responses in order.
	Compare []*Compare `protobuf:"bytes,1,rep,name=compare,proto3" json:"compare,omitempty"`
	// success is a list of requests which will be applied when compare evaluates to true.
	Success []*RequestOp `protobuf:"bytes,2,rep,name=success,proto3" json:"success,omitempty"`
	// failure is a list of requests which will be applied when compare evaluates to false.
	Failure []*RequestOp `protobuf:"bytes,3,rep,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

func (*Txn) Descriptor deprecated 

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

Deprecated: Use Txn.ProtoReflect.Descriptor instead.

func (*Txn) GetCompare 

func (x *Txn) GetCompare() []*Compare

func (*Txn) GetFailure 

func (x *Txn) GetFailure() []*RequestOp

func (*Txn) GetSuccess 

func (x *Txn) GetSuccess() []*RequestOp

func (*Txn) MarshalToSizedBufferVT 

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

func (*Txn) MarshalToVT 

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

func (*Txn) MarshalVT 

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

func (*Txn) ProtoMessage 

func (*Txn) ProtoMessage()

func (*Txn) ProtoReflect 

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

func (*Txn) Reset 

func (x *Txn) Reset()

func (*Txn) SizeVT 

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

func (*Txn) String 

func (x *Txn) String() string

func (*Txn) UnmarshalVT 

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

func (*Txn) UnmarshalVTUnsafe added in v0.4.0 

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

type TxnRequest 

type TxnRequest struct {

	// table name of the table
	Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// compare is a list of predicates representing a conjunction of terms.
	// If the comparisons succeed, then the success requests will be processed in order,
	// and the response will contain their respective responses in order.
	// If the comparisons fail, then the failure requests will be processed in order,
	// and the response will contain their respective responses in order.
	Compare []*Compare `protobuf:"bytes,2,rep,name=compare,proto3" json:"compare,omitempty"`
	// success is a list of requests which will be applied when compare evaluates to true.
	Success []*RequestOp `protobuf:"bytes,3,rep,name=success,proto3" json:"success,omitempty"`
	// failure is a list of requests which will be applied when compare evaluates to false.
	Failure []*RequestOp `protobuf:"bytes,4,rep,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

From google paxosdb paper: Our implementation hinges around a powerful primitive which we call MultiOp. All other database operations except for iteration are implemented as a single call to MultiOp. A MultiOp is applied atomically and consists of three components: 1. A list of tests called guard. Each test in guard checks a single entry in the database. It may check for the absence or presence of a value, or compare with a given value. Two different tests in the guard may apply to the same or different entries in the database. All tests in the guard are applied and MultiOp returns the results. If all tests are true, MultiOp executes t op (see item 2 below), otherwise it executes f op (see item 3 below). 2. A list of database operations called t op. Each operation in the list is either an insert, delete, or lookup operation, and applies to a database entry(ies). Two different operations in the list may apply to the same or different entries in the database. These operations are executed if guard evaluates to true. 3. A list of database operations called f op. Like t op, but executed if guard evaluates to false.

func (*TxnRequest) Descriptor deprecated 

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

Deprecated: Use TxnRequest.ProtoReflect.Descriptor instead.

func (*TxnRequest) GetCompare 

func (x *TxnRequest) GetCompare() []*Compare

func (*TxnRequest) GetFailure 

func (x *TxnRequest) GetFailure() []*RequestOp

func (*TxnRequest) GetSuccess 

func (x *TxnRequest) GetSuccess() []*RequestOp

func (*TxnRequest) GetTable 

func (x *TxnRequest) GetTable() []byte

func (*TxnRequest) MarshalToSizedBufferVT 

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

func (*TxnRequest) MarshalToVT 

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

func (*TxnRequest) MarshalVT 

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

func (*TxnRequest) ProtoMessage 

func (*TxnRequest) ProtoMessage()

func (*TxnRequest) ProtoReflect 

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

func (*TxnRequest) Reset 

func (x *TxnRequest) Reset()

func (*TxnRequest) SizeVT 

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

func (*TxnRequest) String 

func (x *TxnRequest) String() string

func (*TxnRequest) UnmarshalVT 

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

func (*TxnRequest) UnmarshalVTUnsafe added in v0.4.0 

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

type TxnResponse 

type TxnResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// succeeded is set to true if the compare evaluated to true or false otherwise.
	Succeeded bool `protobuf:"varint,2,opt,name=succeeded,proto3" json:"succeeded,omitempty"`
	// responses is a list of responses corresponding to the results from applying
	// success if succeeded is true or failure if succeeded is false.
	Responses []*ResponseOp `protobuf:"bytes,3,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*TxnResponse) Descriptor deprecated 

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

Deprecated: Use TxnResponse.ProtoReflect.Descriptor instead.

func (*TxnResponse) GetHeader 

func (x *TxnResponse) GetHeader() *ResponseHeader

func (*TxnResponse) GetResponses 

func (x *TxnResponse) GetResponses() []*ResponseOp

func (*TxnResponse) GetSucceeded 

func (x *TxnResponse) GetSucceeded() bool

func (*TxnResponse) MarshalToSizedBufferVT 

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

func (*TxnResponse) MarshalToVT 

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

func (*TxnResponse) MarshalVT 

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

func (*TxnResponse) ProtoMessage 

func (*TxnResponse) ProtoMessage()

func (*TxnResponse) ProtoReflect 

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

func (*TxnResponse) Reset 

func (x *TxnResponse) Reset()

func (*TxnResponse) SizeVT 

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

func (*TxnResponse) String 

func (x *TxnResponse) String() string

func (*TxnResponse) UnmarshalVT 

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

func (*TxnResponse) UnmarshalVTUnsafe added in v0.4.0 

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

type UnimplementedClusterServer 

type UnimplementedClusterServer struct {
}

UnimplementedClusterServer must be embedded to have forward compatible implementations.

func (UnimplementedClusterServer) MemberList 

func (UnimplementedClusterServer) MemberList(context.Context, *MemberListRequest) (*MemberListResponse, error)

func (UnimplementedClusterServer) Status 

func (UnimplementedClusterServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

type UnimplementedKVServer 

type UnimplementedKVServer struct {
}

UnimplementedKVServer must be embedded to have forward compatible implementations.

func (UnimplementedKVServer) DeleteRange 

func (UnimplementedKVServer) DeleteRange(context.Context, *DeleteRangeRequest) (*DeleteRangeResponse, error)

func (UnimplementedKVServer) IterateRange added in v0.3.0 

func (UnimplementedKVServer) IterateRange(*RangeRequest, KV_IterateRangeServer) error

func (UnimplementedKVServer) Put 

func (UnimplementedKVServer) Put(context.Context, *PutRequest) (*PutResponse, error)

func (UnimplementedKVServer) Range 

func (UnimplementedKVServer) Range(context.Context, *RangeRequest) (*RangeResponse, error)

func (UnimplementedKVServer) Txn 

func (UnimplementedKVServer) Txn(context.Context, *TxnRequest) (*TxnResponse, error)

type UnimplementedLogServer 

type UnimplementedLogServer struct {
}

UnimplementedLogServer must be embedded to have forward compatible implementations.

func (UnimplementedLogServer) Replicate 

func (UnimplementedLogServer) Replicate(*ReplicateRequest, Log_ReplicateServer) error

type UnimplementedMaintenanceServer 

type UnimplementedMaintenanceServer struct {
}

UnimplementedMaintenanceServer must be embedded to have forward compatible implementations.

func (UnimplementedMaintenanceServer) Backup 

func (UnimplementedMaintenanceServer) Backup(*BackupRequest, Maintenance_BackupServer) error

func (UnimplementedMaintenanceServer) Reset 

func (UnimplementedMaintenanceServer) Reset(context.Context, *ResetRequest) (*ResetResponse, error)

func (UnimplementedMaintenanceServer) Restore 

func (UnimplementedMaintenanceServer) Restore(Maintenance_RestoreServer) error

type UnimplementedMetadataServer 

type UnimplementedMetadataServer struct {
}

UnimplementedMetadataServer must be embedded to have forward compatible implementations.

func (UnimplementedMetadataServer) Get 

func (UnimplementedMetadataServer) Get(context.Context, *MetadataRequest) (*MetadataResponse, error)

type UnimplementedSnapshotServer 

type UnimplementedSnapshotServer struct {
}

UnimplementedSnapshotServer must be embedded to have forward compatible implementations.

func (UnimplementedSnapshotServer) Stream 

func (UnimplementedSnapshotServer) Stream(*SnapshotRequest, Snapshot_StreamServer) error

type UnimplementedTablesServer added in v0.4.0 

type UnimplementedTablesServer struct {
}

UnimplementedTablesServer must be embedded to have forward compatible implementations.

func (UnimplementedTablesServer) Create added in v0.4.0 

func (UnimplementedTablesServer) Create(context.Context, *CreateTableRequest) (*CreateTableResponse, error)

func (UnimplementedTablesServer) Delete added in v0.4.0 

func (UnimplementedTablesServer) Delete(context.Context, *DeleteTableRequest) (*DeleteTableResponse, error)

func (UnimplementedTablesServer) List added in v0.4.0 

func (UnimplementedTablesServer) List(context.Context, *ListTablesRequest) (*ListTablesResponse, error)

type UnsafeClusterServer 

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

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

type UnsafeKVServer 

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

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

type UnsafeLogServer 

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

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

type UnsafeMaintenanceServer 

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

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

type UnsafeMetadataServer 

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

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

type UnsafeSnapshotServer 

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

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

type UnsafeTablesServer added in v0.4.0 

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

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

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.