rpc

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Mar 29, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ReadPreference_name = map[int32]string{
		0: "LEADER",
		1: "LOCAL",
	}
	ReadPreference_value = map[string]int32{
		"LEADER": 0,
		"LOCAL":  1,
	}
)

Enum value maps for ReadPreference.

View Source 
var (
	Error_Code_name = map[int32]string{
		0: "NO_LEADER",
		1: "EMPTY_KEY",
		2: "INVALID_KEY",
		3: "NOT_FOUND",
		4: "INVALID_REQUEST",
		5: "CONFLICT",
		6: "UNAVAILABLE",
	}
	Error_Code_value = map[string]int32{
		"NO_LEADER":       0,
		"EMPTY_KEY":       1,
		"INVALID_KEY":     2,
		"NOT_FOUND":       3,
		"INVALID_REQUEST": 4,
		"CONFLICT":        5,
		"UNAVAILABLE":     6,
	}
)

Enum value maps for Error_Code.

View Source 
var File_internal_rpc_service_proto protoreflect.FileDescriptor
View Source 
var Service_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dbadger.Service",
	HandlerType: (*ServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddPeer",
			Handler:    _Service_AddPeer_Handler,
		},
		{
			MethodName: "RemovePeer",
			Handler:    _Service_RemovePeer_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _Service_Get_Handler,
		},
		{
			MethodName: "GetMany",
			Handler:    _Service_GetMany_Handler,
		},
		{
			MethodName: "GetPrefix",
			Handler:    _Service_GetPrefix_Handler,
		},
		{
			MethodName: "GetRange",
			Handler:    _Service_GetRange_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _Service_Set_Handler,
		},
		{
			MethodName: "SetMany",
			Handler:    _Service_SetMany_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Service_Delete_Handler,
		},
		{
			MethodName: "DeleteMany",
			Handler:    _Service_DeleteMany_Handler,
		},
		{
			MethodName: "DeletePrefix",
			Handler:    _Service_DeletePrefix_Handler,
		},
		{
			MethodName: "DeleteRange",
			Handler:    _Service_DeleteRange_Handler,
		},
		{
			MethodName: "DeleteAll",
			Handler:    _Service_DeleteAll_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/rpc/service.proto",
}

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

Functions

func RegisterServiceServer 

func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer)

Types

type Command 

type Command struct {

	// Types that are assignable to Command:
	//	*Command_AddPeer
	//	*Command_RemovePeer
	//	*Command_Get
	//	*Command_GetMany
	//	*Command_GetPrefix
	//	*Command_GetRange
	//	*Command_Set
	//	*Command_SetMany
	//	*Command_Delete
	//	*Command_DeleteMany
	//	*Command_DeletePrefix
	//	*Command_DeleteRange
	//	*Command_DeleteAll
	Command isCommand_Command `protobuf_oneof:"command"`
	// contains filtered or unexported fields
}

func (*Command) Descriptor deprecated 

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

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetAddPeer 

func (x *Command) GetAddPeer() *CommandAddPeer

func (*Command) GetCommand 

func (m *Command) GetCommand() isCommand_Command

func (*Command) GetDelete 

func (x *Command) GetDelete() *CommandDelete

func (*Command) GetDeleteAll 

func (x *Command) GetDeleteAll() *CommandDeleteAll

func (*Command) GetDeleteMany 

func (x *Command) GetDeleteMany() *CommandDeleteMany

func (*Command) GetDeletePrefix 

func (x *Command) GetDeletePrefix() *CommandDeletePrefix

func (*Command) GetDeleteRange 

func (x *Command) GetDeleteRange() *CommandDeleteRange

func (*Command) GetGet 

func (x *Command) GetGet() *CommandGet

func (*Command) GetGetMany 

func (x *Command) GetGetMany() *CommandGetMany

func (*Command) GetGetPrefix 

func (x *Command) GetGetPrefix() *CommandGetPrefix

func (*Command) GetGetRange 

func (x *Command) GetGetRange() *CommandGetRange

func (*Command) GetRemovePeer 

func (x *Command) GetRemovePeer() *CommandRemovePeer

func (*Command) GetSet 

func (x *Command) GetSet() *CommandSet

func (*Command) GetSetMany 

func (x *Command) GetSetMany() *CommandSetMany

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) ProtoReflect 

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

func (*Command) Reset 

func (x *Command) Reset()

func (*Command) String 

func (x *Command) String() string

type CommandAddPeer 

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

func (*CommandAddPeer) Descriptor deprecated 

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

Deprecated: Use CommandAddPeer.ProtoReflect.Descriptor instead.

func (*CommandAddPeer) GetAddr 

func (x *CommandAddPeer) GetAddr() string

func (*CommandAddPeer) ProtoMessage 

func (*CommandAddPeer) ProtoMessage()

func (*CommandAddPeer) ProtoReflect 

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

func (*CommandAddPeer) Reset 

func (x *CommandAddPeer) Reset()

func (*CommandAddPeer) String 

func (x *CommandAddPeer) String() string

type CommandDelete 

type CommandDelete struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandDelete) Descriptor deprecated 

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

Deprecated: Use CommandDelete.ProtoReflect.Descriptor instead.

func (*CommandDelete) GetKey 

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

func (*CommandDelete) ProtoMessage 

func (*CommandDelete) ProtoMessage()

func (*CommandDelete) ProtoReflect 

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

func (*CommandDelete) Reset 

func (x *CommandDelete) Reset()

func (*CommandDelete) String 

func (x *CommandDelete) String() string

type CommandDeleteAll 

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

func (*CommandDeleteAll) Descriptor deprecated 

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

Deprecated: Use CommandDeleteAll.ProtoReflect.Descriptor instead.

func (*CommandDeleteAll) ProtoMessage 

func (*CommandDeleteAll) ProtoMessage()

func (*CommandDeleteAll) ProtoReflect 

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

func (*CommandDeleteAll) Reset 

func (x *CommandDeleteAll) Reset()

func (*CommandDeleteAll) String 

func (x *CommandDeleteAll) String() string

type CommandDeleteMany 

type CommandDeleteMany struct {
	Keys [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandDeleteMany) Descriptor deprecated 

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

Deprecated: Use CommandDeleteMany.ProtoReflect.Descriptor instead.

func (*CommandDeleteMany) GetKeys 

func (x *CommandDeleteMany) GetKeys() [][]byte

func (*CommandDeleteMany) ProtoMessage 

func (*CommandDeleteMany) ProtoMessage()

func (*CommandDeleteMany) ProtoReflect 

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

func (*CommandDeleteMany) Reset 

func (x *CommandDeleteMany) Reset()

func (*CommandDeleteMany) String 

func (x *CommandDeleteMany) String() string

type CommandDeletePrefix 

type CommandDeletePrefix struct {
	Prefix []byte `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandDeletePrefix) Descriptor deprecated 

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

Deprecated: Use CommandDeletePrefix.ProtoReflect.Descriptor instead.

func (*CommandDeletePrefix) GetPrefix 

func (x *CommandDeletePrefix) GetPrefix() []byte

func (*CommandDeletePrefix) ProtoMessage 

func (*CommandDeletePrefix) ProtoMessage()

func (*CommandDeletePrefix) ProtoReflect 

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

func (*CommandDeletePrefix) Reset 

func (x *CommandDeletePrefix) Reset()

func (*CommandDeletePrefix) String 

func (x *CommandDeletePrefix) String() string

type CommandDeleteRange 

type CommandDeleteRange struct {
	Min []byte `protobuf:"bytes,1,opt,name=min,proto3" json:"min,omitempty"`
	Max []byte `protobuf:"bytes,2,opt,name=max,proto3" json:"max,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandDeleteRange) Descriptor deprecated 

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

Deprecated: Use CommandDeleteRange.ProtoReflect.Descriptor instead.

func (*CommandDeleteRange) GetMax 

func (x *CommandDeleteRange) GetMax() []byte

func (*CommandDeleteRange) GetMin 

func (x *CommandDeleteRange) GetMin() []byte

func (*CommandDeleteRange) ProtoMessage 

func (*CommandDeleteRange) ProtoMessage()

func (*CommandDeleteRange) ProtoReflect 

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

func (*CommandDeleteRange) Reset 

func (x *CommandDeleteRange) Reset()

func (*CommandDeleteRange) String 

func (x *CommandDeleteRange) String() string

type CommandGet 

type CommandGet struct {
	ReadPreference ReadPreference `protobuf:"varint,1,opt,name=readPreference,proto3,enum=dbadger.ReadPreference" json:"readPreference,omitempty"`
	Key            []byte         `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandGet) Descriptor deprecated 

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

Deprecated: Use CommandGet.ProtoReflect.Descriptor instead.

func (*CommandGet) GetKey 

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

func (*CommandGet) GetReadPreference 

func (x *CommandGet) GetReadPreference() ReadPreference

func (*CommandGet) ProtoMessage 

func (*CommandGet) ProtoMessage()

func (*CommandGet) ProtoReflect 

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

func (*CommandGet) Reset 

func (x *CommandGet) Reset()

func (*CommandGet) String 

func (x *CommandGet) String() string

type CommandGetMany 

type CommandGetMany struct {
	ReadPreference ReadPreference `protobuf:"varint,1,opt,name=readPreference,proto3,enum=dbadger.ReadPreference" json:"readPreference,omitempty"`
	Keys           [][]byte       `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandGetMany) Descriptor deprecated 

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

Deprecated: Use CommandGetMany.ProtoReflect.Descriptor instead.

func (*CommandGetMany) GetKeys 

func (x *CommandGetMany) GetKeys() [][]byte

func (*CommandGetMany) GetReadPreference 

func (x *CommandGetMany) GetReadPreference() ReadPreference

func (*CommandGetMany) ProtoMessage 

func (*CommandGetMany) ProtoMessage()

func (*CommandGetMany) ProtoReflect 

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

func (*CommandGetMany) Reset 

func (x *CommandGetMany) Reset()

func (*CommandGetMany) String 

func (x *CommandGetMany) String() string

type CommandGetPrefix 

type CommandGetPrefix struct {
	ReadPreference ReadPreference `protobuf:"varint,1,opt,name=readPreference,proto3,enum=dbadger.ReadPreference" json:"readPreference,omitempty"`
	Prefix         []byte         `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandGetPrefix) Descriptor deprecated 

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

Deprecated: Use CommandGetPrefix.ProtoReflect.Descriptor instead.

func (*CommandGetPrefix) GetPrefix 

func (x *CommandGetPrefix) GetPrefix() []byte

func (*CommandGetPrefix) GetReadPreference 

func (x *CommandGetPrefix) GetReadPreference() ReadPreference

func (*CommandGetPrefix) ProtoMessage 

func (*CommandGetPrefix) ProtoMessage()

func (*CommandGetPrefix) ProtoReflect 

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

func (*CommandGetPrefix) Reset 

func (x *CommandGetPrefix) Reset()

func (*CommandGetPrefix) String 

func (x *CommandGetPrefix) String() string

type CommandGetRange 

type CommandGetRange struct {
	ReadPreference ReadPreference `protobuf:"varint,1,opt,name=readPreference,proto3,enum=dbadger.ReadPreference" json:"readPreference,omitempty"`
	Min            []byte         `protobuf:"bytes,2,opt,name=min,proto3" json:"min,omitempty"`
	Max            []byte         `protobuf:"bytes,3,opt,name=max,proto3" json:"max,omitempty"`
	Count          uint64         `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandGetRange) Descriptor deprecated 

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

Deprecated: Use CommandGetRange.ProtoReflect.Descriptor instead.

func (*CommandGetRange) GetCount 

func (x *CommandGetRange) GetCount() uint64

func (*CommandGetRange) GetMax 

func (x *CommandGetRange) GetMax() []byte

func (*CommandGetRange) GetMin 

func (x *CommandGetRange) GetMin() []byte

func (*CommandGetRange) GetReadPreference 

func (x *CommandGetRange) GetReadPreference() ReadPreference

func (*CommandGetRange) ProtoMessage 

func (*CommandGetRange) ProtoMessage()

func (*CommandGetRange) ProtoReflect 

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

func (*CommandGetRange) Reset 

func (x *CommandGetRange) Reset()

func (*CommandGetRange) String 

func (x *CommandGetRange) String() string

type CommandRemovePeer 

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

func (*CommandRemovePeer) Descriptor deprecated 

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

Deprecated: Use CommandRemovePeer.ProtoReflect.Descriptor instead.

func (*CommandRemovePeer) GetAddr 

func (x *CommandRemovePeer) GetAddr() string

func (*CommandRemovePeer) ProtoMessage 

func (*CommandRemovePeer) ProtoMessage()

func (*CommandRemovePeer) ProtoReflect 

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

func (*CommandRemovePeer) Reset 

func (x *CommandRemovePeer) Reset()

func (*CommandRemovePeer) String 

func (x *CommandRemovePeer) String() string

type CommandSet 

type CommandSet struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandSet) Descriptor deprecated 

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

Deprecated: Use CommandSet.ProtoReflect.Descriptor instead.

func (*CommandSet) GetKey 

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

func (*CommandSet) GetValue 

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

func (*CommandSet) ProtoMessage 

func (*CommandSet) ProtoMessage()

func (*CommandSet) ProtoReflect 

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

func (*CommandSet) Reset 

func (x *CommandSet) Reset()

func (*CommandSet) String 

func (x *CommandSet) String() string

type CommandSetMany 

type CommandSetMany struct {
	Keys   [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandSetMany) Descriptor deprecated 

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

Deprecated: Use CommandSetMany.ProtoReflect.Descriptor instead.

func (*CommandSetMany) GetKeys 

func (x *CommandSetMany) GetKeys() [][]byte

func (*CommandSetMany) GetValues 

func (x *CommandSetMany) GetValues() [][]byte

func (*CommandSetMany) ProtoMessage 

func (*CommandSetMany) ProtoMessage()

func (*CommandSetMany) ProtoReflect 

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

func (*CommandSetMany) Reset 

func (x *CommandSetMany) Reset()

func (*CommandSetMany) String 

func (x *CommandSetMany) String() string

type Command_AddPeer 

type Command_AddPeer struct {
	AddPeer *CommandAddPeer `protobuf:"bytes,1,opt,name=addPeer,proto3,oneof"`
}

type Command_Delete 

type Command_Delete struct {
	Delete *CommandDelete `protobuf:"bytes,9,opt,name=delete,proto3,oneof"`
}

type Command_DeleteAll 

type Command_DeleteAll struct {
	DeleteAll *CommandDeleteAll `protobuf:"bytes,13,opt,name=deleteAll,proto3,oneof"`
}

type Command_DeleteMany 

type Command_DeleteMany struct {
	DeleteMany *CommandDeleteMany `protobuf:"bytes,10,opt,name=deleteMany,proto3,oneof"`
}

type Command_DeletePrefix 

type Command_DeletePrefix struct {
	DeletePrefix *CommandDeletePrefix `protobuf:"bytes,11,opt,name=deletePrefix,proto3,oneof"`
}

type Command_DeleteRange 

type Command_DeleteRange struct {
	DeleteRange *CommandDeleteRange `protobuf:"bytes,12,opt,name=deleteRange,proto3,oneof"`
}

type Command_Get 

type Command_Get struct {
	Get *CommandGet `protobuf:"bytes,3,opt,name=get,proto3,oneof"`
}

type Command_GetMany 

type Command_GetMany struct {
	GetMany *CommandGetMany `protobuf:"bytes,4,opt,name=getMany,proto3,oneof"`
}

type Command_GetPrefix 

type Command_GetPrefix struct {
	GetPrefix *CommandGetPrefix `protobuf:"bytes,5,opt,name=getPrefix,proto3,oneof"`
}

type Command_GetRange 

type Command_GetRange struct {
	GetRange *CommandGetRange `protobuf:"bytes,6,opt,name=getRange,proto3,oneof"`
}

type Command_RemovePeer 

type Command_RemovePeer struct {
	RemovePeer *CommandRemovePeer `protobuf:"bytes,2,opt,name=removePeer,proto3,oneof"`
}

type Command_Set 

type Command_Set struct {
	Set *CommandSet `protobuf:"bytes,7,opt,name=set,proto3,oneof"`
}

type Command_SetMany 

type Command_SetMany struct {
	SetMany *CommandSetMany `protobuf:"bytes,8,opt,name=setMany,proto3,oneof"`
}

type Error 

type Error struct {
	Code Error_Code `protobuf:"varint,1,opt,name=code,proto3,enum=dbadger.Error_Code" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCode 

func (x *Error) GetCode() Error_Code

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type Error_Code 

type Error_Code int32
const (
	Error_NO_LEADER       Error_Code = 0
	Error_EMPTY_KEY       Error_Code = 1
	Error_INVALID_KEY     Error_Code = 2
	Error_NOT_FOUND       Error_Code = 3
	Error_INVALID_REQUEST Error_Code = 4
	Error_CONFLICT        Error_Code = 5
	Error_UNAVAILABLE     Error_Code = 6
)

func (Error_Code) Descriptor 

func (Error_Code) Descriptor() protoreflect.EnumDescriptor

func (Error_Code) Enum 

func (x Error_Code) Enum() *Error_Code

func (Error_Code) EnumDescriptor deprecated 

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

Deprecated: Use Error_Code.Descriptor instead.

func (Error_Code) Number 

func (x Error_Code) Number() protoreflect.EnumNumber

func (Error_Code) String 

func (x Error_Code) String() string

func (Error_Code) Type 

func (Error_Code) Type() protoreflect.EnumType

type ReadPreference 

type ReadPreference int32
const (
	ReadPreference_LEADER ReadPreference = 0
	ReadPreference_LOCAL  ReadPreference = 1
)

func (ReadPreference) Descriptor 

func (ReadPreference) Descriptor() protoreflect.EnumDescriptor

func (ReadPreference) Enum 

func (x ReadPreference) Enum() *ReadPreference

func (ReadPreference) EnumDescriptor deprecated 

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

Deprecated: Use ReadPreference.Descriptor instead.

func (ReadPreference) Number 

func (x ReadPreference) Number() protoreflect.EnumNumber

func (ReadPreference) String 

func (x ReadPreference) String() string

func (ReadPreference) Type 

func (ReadPreference) Type() protoreflect.EnumType

type Result 

type Result struct {

	// Types that are assignable to Result:
	//	*Result_AddPeer
	//	*Result_RemovePeer
	//	*Result_Get
	//	*Result_GetMany
	//	*Result_GetPrefix
	//	*Result_GetRange
	//	*Result_Set
	//	*Result_SetMany
	//	*Result_Delete
	//	*Result_DeleteMany
	//	*Result_DeletePrefix
	//	*Result_DeleteRange
	//	*Result_DeleteAll
	Result isResult_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*Result) Descriptor deprecated 

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

Deprecated: Use Result.ProtoReflect.Descriptor instead.

func (*Result) GetAddPeer 

func (x *Result) GetAddPeer() *ResultAddPeer

func (*Result) GetDelete 

func (x *Result) GetDelete() *ResultDelete

func (*Result) GetDeleteAll 

func (x *Result) GetDeleteAll() *ResultDeleteAll

func (*Result) GetDeleteMany 

func (x *Result) GetDeleteMany() *ResultDeleteMany

func (*Result) GetDeletePrefix 

func (x *Result) GetDeletePrefix() *ResultDeletePrefix

func (*Result) GetDeleteRange 

func (x *Result) GetDeleteRange() *ResultDeleteRange

func (*Result) GetGet 

func (x *Result) GetGet() *ResultGet

func (*Result) GetGetMany 

func (x *Result) GetGetMany() *ResultGetMany

func (*Result) GetGetPrefix 

func (x *Result) GetGetPrefix() *ResultGetPrefix

func (*Result) GetGetRange 

func (x *Result) GetGetRange() *ResultGetRange

func (*Result) GetRemovePeer 

func (x *Result) GetRemovePeer() *ResultRemovePeer

func (*Result) GetResult 

func (m *Result) GetResult() isResult_Result

func (*Result) GetSet 

func (x *Result) GetSet() *ResultSet

func (*Result) GetSetMany 

func (x *Result) GetSetMany() *ResultSetMany

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) ProtoReflect 

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

func (*Result) Reset 

func (x *Result) Reset()

func (*Result) String 

func (x *Result) String() string

type ResultAddPeer 

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

func (*ResultAddPeer) Descriptor deprecated 

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

Deprecated: Use ResultAddPeer.ProtoReflect.Descriptor instead.

func (*ResultAddPeer) ProtoMessage 

func (*ResultAddPeer) ProtoMessage()

func (*ResultAddPeer) ProtoReflect 

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

func (*ResultAddPeer) Reset 

func (x *ResultAddPeer) Reset()

func (*ResultAddPeer) String 

func (x *ResultAddPeer) String() string

type ResultDelete 

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

func (*ResultDelete) Descriptor deprecated 

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

Deprecated: Use ResultDelete.ProtoReflect.Descriptor instead.

func (*ResultDelete) ProtoMessage 

func (*ResultDelete) ProtoMessage()

func (*ResultDelete) ProtoReflect 

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

func (*ResultDelete) Reset 

func (x *ResultDelete) Reset()

func (*ResultDelete) String 

func (x *ResultDelete) String() string

type ResultDeleteAll 

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

func (*ResultDeleteAll) Descriptor deprecated 

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

Deprecated: Use ResultDeleteAll.ProtoReflect.Descriptor instead.

func (*ResultDeleteAll) ProtoMessage 

func (*ResultDeleteAll) ProtoMessage()

func (*ResultDeleteAll) ProtoReflect 

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

func (*ResultDeleteAll) Reset 

func (x *ResultDeleteAll) Reset()

func (*ResultDeleteAll) String 

func (x *ResultDeleteAll) String() string

type ResultDeleteMany 

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

func (*ResultDeleteMany) Descriptor deprecated 

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

Deprecated: Use ResultDeleteMany.ProtoReflect.Descriptor instead.

func (*ResultDeleteMany) ProtoMessage 

func (*ResultDeleteMany) ProtoMessage()

func (*ResultDeleteMany) ProtoReflect 

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

func (*ResultDeleteMany) Reset 

func (x *ResultDeleteMany) Reset()

func (*ResultDeleteMany) String 

func (x *ResultDeleteMany) String() string

type ResultDeletePrefix 

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

func (*ResultDeletePrefix) Descriptor deprecated 

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

Deprecated: Use ResultDeletePrefix.ProtoReflect.Descriptor instead.

func (*ResultDeletePrefix) ProtoMessage 

func (*ResultDeletePrefix) ProtoMessage()

func (*ResultDeletePrefix) ProtoReflect 

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

func (*ResultDeletePrefix) Reset 

func (x *ResultDeletePrefix) Reset()

func (*ResultDeletePrefix) String 

func (x *ResultDeletePrefix) String() string

type ResultDeleteRange 

type ResultDeleteRange struct {
	Keys [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultDeleteRange) Descriptor deprecated 

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

Deprecated: Use ResultDeleteRange.ProtoReflect.Descriptor instead.

func (*ResultDeleteRange) GetKeys 

func (x *ResultDeleteRange) GetKeys() [][]byte

func (*ResultDeleteRange) ProtoMessage 

func (*ResultDeleteRange) ProtoMessage()

func (*ResultDeleteRange) ProtoReflect 

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

func (*ResultDeleteRange) Reset 

func (x *ResultDeleteRange) Reset()

func (*ResultDeleteRange) String 

func (x *ResultDeleteRange) String() string

type ResultGet 

type ResultGet struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultGet) Descriptor deprecated 

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

Deprecated: Use ResultGet.ProtoReflect.Descriptor instead.

func (*ResultGet) GetValue 

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

func (*ResultGet) ProtoMessage 

func (*ResultGet) ProtoMessage()

func (*ResultGet) ProtoReflect 

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

func (*ResultGet) Reset 

func (x *ResultGet) Reset()

func (*ResultGet) String 

func (x *ResultGet) String() string

type ResultGetMany 

type ResultGetMany struct {
	Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultGetMany) Descriptor deprecated 

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

Deprecated: Use ResultGetMany.ProtoReflect.Descriptor instead.

func (*ResultGetMany) GetValues 

func (x *ResultGetMany) GetValues() [][]byte

func (*ResultGetMany) ProtoMessage 

func (*ResultGetMany) ProtoMessage()

func (*ResultGetMany) ProtoReflect 

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

func (*ResultGetMany) Reset 

func (x *ResultGetMany) Reset()

func (*ResultGetMany) String 

func (x *ResultGetMany) String() string

type ResultGetPrefix 

type ResultGetPrefix struct {
	Keys   [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultGetPrefix) Descriptor deprecated 

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

Deprecated: Use ResultGetPrefix.ProtoReflect.Descriptor instead.

func (*ResultGetPrefix) GetKeys 

func (x *ResultGetPrefix) GetKeys() [][]byte

func (*ResultGetPrefix) GetValues 

func (x *ResultGetPrefix) GetValues() [][]byte

func (*ResultGetPrefix) ProtoMessage 

func (*ResultGetPrefix) ProtoMessage()

func (*ResultGetPrefix) ProtoReflect 

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

func (*ResultGetPrefix) Reset 

func (x *ResultGetPrefix) Reset()

func (*ResultGetPrefix) String 

func (x *ResultGetPrefix) String() string

type ResultGetRange 

type ResultGetRange struct {
	Keys   [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultGetRange) Descriptor deprecated 

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

Deprecated: Use ResultGetRange.ProtoReflect.Descriptor instead.

func (*ResultGetRange) GetKeys 

func (x *ResultGetRange) GetKeys() [][]byte

func (*ResultGetRange) GetValues 

func (x *ResultGetRange) GetValues() [][]byte

func (*ResultGetRange) ProtoMessage 

func (*ResultGetRange) ProtoMessage()

func (*ResultGetRange) ProtoReflect 

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

func (*ResultGetRange) Reset 

func (x *ResultGetRange) Reset()

func (*ResultGetRange) String 

func (x *ResultGetRange) String() string

type ResultRemovePeer 

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

func (*ResultRemovePeer) Descriptor deprecated 

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

Deprecated: Use ResultRemovePeer.ProtoReflect.Descriptor instead.

func (*ResultRemovePeer) ProtoMessage 

func (*ResultRemovePeer) ProtoMessage()

func (*ResultRemovePeer) ProtoReflect 

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

func (*ResultRemovePeer) Reset 

func (x *ResultRemovePeer) Reset()

func (*ResultRemovePeer) String 

func (x *ResultRemovePeer) String() string

type ResultSet 

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

func (*ResultSet) Descriptor deprecated 

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

Deprecated: Use ResultSet.ProtoReflect.Descriptor instead.

func (*ResultSet) ProtoMessage 

func (*ResultSet) ProtoMessage()

func (*ResultSet) ProtoReflect 

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

func (*ResultSet) Reset 

func (x *ResultSet) Reset()

func (*ResultSet) String 

func (x *ResultSet) String() string

type ResultSetMany 

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

func (*ResultSetMany) Descriptor deprecated 

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

Deprecated: Use ResultSetMany.ProtoReflect.Descriptor instead.

func (*ResultSetMany) ProtoMessage 

func (*ResultSetMany) ProtoMessage()

func (*ResultSetMany) ProtoReflect 

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

func (*ResultSetMany) Reset 

func (x *ResultSetMany) Reset()

func (*ResultSetMany) String 

func (x *ResultSetMany) String() string

type Result_AddPeer 

type Result_AddPeer struct {
	AddPeer *ResultAddPeer `protobuf:"bytes,1,opt,name=addPeer,proto3,oneof"`
}

type Result_Delete 

type Result_Delete struct {
	Delete *ResultDelete `protobuf:"bytes,9,opt,name=delete,proto3,oneof"`
}

type Result_DeleteAll 

type Result_DeleteAll struct {
	DeleteAll *ResultDeleteAll `protobuf:"bytes,13,opt,name=deleteAll,proto3,oneof"`
}

type Result_DeleteMany 

type Result_DeleteMany struct {
	DeleteMany *ResultDeleteMany `protobuf:"bytes,10,opt,name=deleteMany,proto3,oneof"`
}

type Result_DeletePrefix 

type Result_DeletePrefix struct {
	DeletePrefix *ResultDeletePrefix `protobuf:"bytes,11,opt,name=deletePrefix,proto3,oneof"`
}

type Result_DeleteRange 

type Result_DeleteRange struct {
	DeleteRange *ResultDeleteRange `protobuf:"bytes,12,opt,name=deleteRange,proto3,oneof"`
}

type Result_Get 

type Result_Get struct {
	Get *ResultGet `protobuf:"bytes,3,opt,name=get,proto3,oneof"`
}

type Result_GetMany 

type Result_GetMany struct {
	GetMany *ResultGetMany `protobuf:"bytes,4,opt,name=getMany,proto3,oneof"`
}

type Result_GetPrefix 

type Result_GetPrefix struct {
	GetPrefix *ResultGetPrefix `protobuf:"bytes,5,opt,name=getPrefix,proto3,oneof"`
}

type Result_GetRange 

type Result_GetRange struct {
	GetRange *ResultGetRange `protobuf:"bytes,6,opt,name=getRange,proto3,oneof"`
}

type Result_RemovePeer 

type Result_RemovePeer struct {
	RemovePeer *ResultRemovePeer `protobuf:"bytes,2,opt,name=removePeer,proto3,oneof"`
}

type Result_Set 

type Result_Set struct {
	Set *ResultSet `protobuf:"bytes,7,opt,name=set,proto3,oneof"`
}

type Result_SetMany 

type Result_SetMany struct {
	SetMany *ResultSetMany `protobuf:"bytes,8,opt,name=setMany,proto3,oneof"`
}

type ServiceClient 

type ServiceClient interface {
	AddPeer(ctx context.Context, in *CommandAddPeer, opts ...grpc.CallOption) (*ResultAddPeer, error)
	RemovePeer(ctx context.Context, in *CommandRemovePeer, opts ...grpc.CallOption) (*ResultRemovePeer, error)
	Get(ctx context.Context, in *CommandGet, opts ...grpc.CallOption) (*ResultGet, error)
	GetMany(ctx context.Context, in *CommandGetMany, opts ...grpc.CallOption) (*ResultGetMany, error)
	GetPrefix(ctx context.Context, in *CommandGetPrefix, opts ...grpc.CallOption) (*ResultGetPrefix, error)
	GetRange(ctx context.Context, in *CommandGetRange, opts ...grpc.CallOption) (*ResultGetRange, error)
	Set(ctx context.Context, in *CommandSet, opts ...grpc.CallOption) (*ResultSet, error)
	SetMany(ctx context.Context, in *CommandSetMany, opts ...grpc.CallOption) (*ResultSetMany, error)
	Delete(ctx context.Context, in *CommandDelete, opts ...grpc.CallOption) (*ResultDelete, error)
	DeleteMany(ctx context.Context, in *CommandDeleteMany, opts ...grpc.CallOption) (*ResultDeleteMany, error)
	DeletePrefix(ctx context.Context, in *CommandDeletePrefix, opts ...grpc.CallOption) (*ResultDeletePrefix, error)
	DeleteRange(ctx context.Context, in *CommandDeleteRange, opts ...grpc.CallOption) (*ResultDeleteRange, error)
	DeleteAll(ctx context.Context, in *CommandDeleteAll, opts ...grpc.CallOption) (*ResultDeleteAll, error)
}

ServiceClient is the client API for Service 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 NewServiceClient 

func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient

type ServiceServer 

type ServiceServer interface {
	AddPeer(context.Context, *CommandAddPeer) (*ResultAddPeer, error)
	RemovePeer(context.Context, *CommandRemovePeer) (*ResultRemovePeer, error)
	Get(context.Context, *CommandGet) (*ResultGet, error)
	GetMany(context.Context, *CommandGetMany) (*ResultGetMany, error)
	GetPrefix(context.Context, *CommandGetPrefix) (*ResultGetPrefix, error)
	GetRange(context.Context, *CommandGetRange) (*ResultGetRange, error)
	Set(context.Context, *CommandSet) (*ResultSet, error)
	SetMany(context.Context, *CommandSetMany) (*ResultSetMany, error)
	Delete(context.Context, *CommandDelete) (*ResultDelete, error)
	DeleteMany(context.Context, *CommandDeleteMany) (*ResultDeleteMany, error)
	DeletePrefix(context.Context, *CommandDeletePrefix) (*ResultDeletePrefix, error)
	DeleteRange(context.Context, *CommandDeleteRange) (*ResultDeleteRange, error)
	DeleteAll(context.Context, *CommandDeleteAll) (*ResultDeleteAll, error)
	// contains filtered or unexported methods
}

ServiceServer is the server API for Service service. All implementations must embed UnimplementedServiceServer for forward compatibility

type UnimplementedServiceServer 

type UnimplementedServiceServer struct {
}

UnimplementedServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedServiceServer) AddPeer 

func (UnimplementedServiceServer) AddPeer(context.Context, *CommandAddPeer) (*ResultAddPeer, error)

func (UnimplementedServiceServer) Delete 

func (UnimplementedServiceServer) Delete(context.Context, *CommandDelete) (*ResultDelete, error)

func (UnimplementedServiceServer) DeleteAll 

func (UnimplementedServiceServer) DeleteAll(context.Context, *CommandDeleteAll) (*ResultDeleteAll, error)

func (UnimplementedServiceServer) DeleteMany 

func (UnimplementedServiceServer) DeleteMany(context.Context, *CommandDeleteMany) (*ResultDeleteMany, error)

func (UnimplementedServiceServer) DeletePrefix 

func (UnimplementedServiceServer) DeletePrefix(context.Context, *CommandDeletePrefix) (*ResultDeletePrefix, error)

func (UnimplementedServiceServer) DeleteRange 

func (UnimplementedServiceServer) DeleteRange(context.Context, *CommandDeleteRange) (*ResultDeleteRange, error)

func (UnimplementedServiceServer) Get 

func (UnimplementedServiceServer) Get(context.Context, *CommandGet) (*ResultGet, error)

func (UnimplementedServiceServer) GetMany 

func (UnimplementedServiceServer) GetMany(context.Context, *CommandGetMany) (*ResultGetMany, error)

func (UnimplementedServiceServer) GetPrefix 

func (UnimplementedServiceServer) GetPrefix(context.Context, *CommandGetPrefix) (*ResultGetPrefix, error)

func (UnimplementedServiceServer) GetRange 

func (UnimplementedServiceServer) GetRange(context.Context, *CommandGetRange) (*ResultGetRange, error)

func (UnimplementedServiceServer) RemovePeer 

func (UnimplementedServiceServer) RemovePeer(context.Context, *CommandRemovePeer) (*ResultRemovePeer, error)

func (UnimplementedServiceServer) Set 

func (UnimplementedServiceServer) Set(context.Context, *CommandSet) (*ResultSet, error)

func (UnimplementedServiceServer) SetMany 

func (UnimplementedServiceServer) SetMany(context.Context, *CommandSetMany) (*ResultSetMany, error)

type UnsafeServiceServer 

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

UnsafeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServiceServer 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.