kv

package
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Jun 23, 2026 License: MIT Imports: 29 Imported by: 0

README

api (cassemdb)

cassemdb component's client SDK.

Documentation

Index

Constants

View Source 
const (
	NEVER_EXPIRED = -2
	EXPIRED       = -1
)

Variables

View Source 
var (
	EntityType_name = map[int32]string{
		0: "UNKNOWN",
		1: "ELT",
		2: "DIR",
	}
	EntityType_value = map[string]int32{
		"UNKNOWN": 0,
		"ELT":     1,
		"DIR":     2,
	}
)

Enum value maps for EntityType.

View Source 
var (
	Change_Op_name = map[int32]string{
		0: "Invalid",
		1: "Set",
		2: "Unset",
	}
	Change_Op_value = map[string]int32{
		"Invalid": 0,
		"Set":     1,
		"Unset":   2,
	}
)

Enum value maps for Change_Op.

View Source 
var (
	LogEntry_Action_name = map[int32]string{
		0: "UNKNOWN",
		1: "Set",
		2: "ChangeSpread",
	}
	LogEntry_Action_value = map[string]int32{
		"UNKNOWN":      0,
		"Set":          1,
		"ChangeSpread": 2,
	}
)

Enum value maps for LogEntry_Action.

View Source 
var File_cassemdb_api_proto protoreflect.FileDescriptor
View Source 
var File_cassemdb_raft_proto protoreflect.FileDescriptor

Functions

func DialWithMode 

func DialWithMode(endpoints []string, mode Mode) (*grpc.ClientConn, error)

DialWithMode support multiple backend server and load balance while request backend servers in round-robin.

target = "cassemdb:///0.0.0.0:2021,1.1.1.1:2021" can only communicate to leader, target = "cassemdb:/all//0.0.0.0:2021,1.1.1.1:2021" can communicate to other nodes, but note that the client can only execute READ operations.

func DialWithModeContext 

func DialWithModeContext(ctx context.Context, endpoints []string, mode Mode) (*grpc.ClientConn, error)

DialWithModeContext lets callers share one context budget across connection establishment and subsequent RPCs, which keeps one-shot workflows from spending extra time outside their configured deadline.

func Marshal 

func Marshal(m proto.Message) ([]byte, error)

func Must 

func Must(d []byte, err error) []byte

func MustUnmarshal 

func MustUnmarshal(data []byte, m proto.Message)

func RegisterClusterServer 

func RegisterClusterServer(s *grpc.Server, srv ClusterServer)

func RegisterKVServer 

func RegisterKVServer(s *grpc.Server, srv KVServer)

func Unmarshal 

func Unmarshal(data []byte, m proto.Message) error

func WithLock 

func WithLock(kv KVClient, lockKey string, ttl int, f func())

Types

type AddNodeRequest 

type AddNodeRequest struct {
	RaftAddr     string `protobuf:"bytes,1,opt,name=raft_addr,json=raftAddr,proto3" json:"raft_addr,omitempty"`
	GrpcEndpoint string `protobuf:"bytes,2,opt,name=grpc_endpoint,json=grpcEndpoint,proto3" json:"grpc_endpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*AddNodeRequest) Descriptor deprecated 

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

Deprecated: Use AddNodeRequest.ProtoReflect.Descriptor instead.

func (*AddNodeRequest) GetGrpcEndpoint 

func (x *AddNodeRequest) GetGrpcEndpoint() string

func (*AddNodeRequest) GetRaftAddr 

func (x *AddNodeRequest) GetRaftAddr() string

func (*AddNodeRequest) ProtoMessage 

func (*AddNodeRequest) ProtoMessage()

func (*AddNodeRequest) ProtoReflect 

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

func (*AddNodeRequest) Reset 

func (x *AddNodeRequest) Reset()

func (*AddNodeRequest) String 

func (x *AddNodeRequest) String() string

func (*AddNodeRequest) Validate 

func (m *AddNodeRequest) Validate() error

Validate checks the field values on AddNodeRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AddNodeRequest) ValidateAll 

func (m *AddNodeRequest) ValidateAll() error

ValidateAll checks the field values on AddNodeRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AddNodeRequestMultiError, or nil if none found.

type AddNodeRequestMultiError 

type AddNodeRequestMultiError []error

AddNodeRequestMultiError is an error wrapping multiple validation errors returned by AddNodeRequest.ValidateAll() if the designated constraints aren't met.

func (AddNodeRequestMultiError) AllErrors 

func (m AddNodeRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AddNodeRequestMultiError) Error 

func (m AddNodeRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AddNodeRequestValidationError 

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

AddNodeRequestValidationError is the validation error returned by AddNodeRequest.Validate if the designated constraints aren't met.

func (AddNodeRequestValidationError) Cause 

func (e AddNodeRequestValidationError) Cause() error

Cause function returns cause value.

func (AddNodeRequestValidationError) Error 

func (e AddNodeRequestValidationError) Error() string

Error satisfies the builtin error interface

func (AddNodeRequestValidationError) ErrorName 

func (e AddNodeRequestValidationError) ErrorName() string

ErrorName returns error name.

func (AddNodeRequestValidationError) Field 

func (e AddNodeRequestValidationError) Field() string

Field function returns field value.

func (AddNodeRequestValidationError) Key 

func (e AddNodeRequestValidationError) Key() bool

Key function returns key value.

func (AddNodeRequestValidationError) Reason 

func (e AddNodeRequestValidationError) Reason() string

Reason function returns reason value.

type AddNodeResponse 

type AddNodeResponse struct {
	NodeId uint64   `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Peers  []string `protobuf:"bytes,2,rep,name=peers,proto3" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

func (*AddNodeResponse) Descriptor deprecated 

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

Deprecated: Use AddNodeResponse.ProtoReflect.Descriptor instead.

func (*AddNodeResponse) GetNodeId 

func (x *AddNodeResponse) GetNodeId() uint64

func (*AddNodeResponse) GetPeers 

func (x *AddNodeResponse) GetPeers() []string

func (*AddNodeResponse) ProtoMessage 

func (*AddNodeResponse) ProtoMessage()

func (*AddNodeResponse) ProtoReflect 

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

func (*AddNodeResponse) Reset 

func (x *AddNodeResponse) Reset()

func (*AddNodeResponse) String 

func (x *AddNodeResponse) String() string

func (*AddNodeResponse) Validate 

func (m *AddNodeResponse) Validate() error

Validate checks the field values on AddNodeResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AddNodeResponse) ValidateAll 

func (m *AddNodeResponse) ValidateAll() error

ValidateAll checks the field values on AddNodeResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AddNodeResponseMultiError, or nil if none found.

type AddNodeResponseMultiError 

type AddNodeResponseMultiError []error

AddNodeResponseMultiError is an error wrapping multiple validation errors returned by AddNodeResponse.ValidateAll() if the designated constraints aren't met.

func (AddNodeResponseMultiError) AllErrors 

func (m AddNodeResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AddNodeResponseMultiError) Error 

func (m AddNodeResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AddNodeResponseValidationError 

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

AddNodeResponseValidationError is the validation error returned by AddNodeResponse.Validate if the designated constraints aren't met.

func (AddNodeResponseValidationError) Cause 

func (e AddNodeResponseValidationError) Cause() error

Cause function returns cause value.

func (AddNodeResponseValidationError) Error 

func (e AddNodeResponseValidationError) Error() string

Error satisfies the builtin error interface

func (AddNodeResponseValidationError) ErrorName 

func (e AddNodeResponseValidationError) ErrorName() string

ErrorName returns error name.

func (AddNodeResponseValidationError) Field 

func (e AddNodeResponseValidationError) Field() string

Field function returns field value.

func (AddNodeResponseValidationError) Key 

func (e AddNodeResponseValidationError) Key() bool

Key function returns key value.

func (AddNodeResponseValidationError) Reason 

func (e AddNodeResponseValidationError) Reason() string

Reason function returns reason value.

type Change 

type Change struct {
	Op      Change_Op `protobuf:"varint,1,opt,name=op,proto3,enum=cassem.db.Change_Op" json:"op,omitempty"`
	Key     string    `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Last    *Entity   `protobuf:"bytes,3,opt,name=last,proto3" json:"last,omitempty"`
	Current *Entity   `protobuf:"bytes,4,opt,name=current,proto3" json:"current,omitempty"`
	// contains filtered or unexported fields
}

func (*Change) Descriptor deprecated 

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

Deprecated: Use Change.ProtoReflect.Descriptor instead.

func (*Change) GetCurrent 

func (x *Change) GetCurrent() *Entity

func (*Change) GetKey 

func (x *Change) GetKey() string

func (*Change) GetLast 

func (x *Change) GetLast() *Entity

func (*Change) GetOp 

func (x *Change) GetOp() Change_Op

func (*Change) ProtoMessage 

func (*Change) ProtoMessage()

func (*Change) ProtoReflect 

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

func (*Change) Reset 

func (x *Change) Reset()

func (*Change) String 

func (x *Change) String() string

func (*Change) Topic 

func (m *Change) Topic() string

func (*Change) Type 

func (*Change) Type() concept.ChangeType

func (*Change) Validate 

func (m *Change) Validate() error

Validate checks the field values on Change with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Change) ValidateAll 

func (m *Change) ValidateAll() error

ValidateAll checks the field values on Change with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ChangeMultiError, or nil if none found.

type ChangeCommand 

type ChangeCommand struct {
	Change *Change `protobuf:"bytes,1,opt,name=change,proto3" json:"change,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeCommand) Action 

func (*ChangeCommand) Action() LogEntry_Action

func (*ChangeCommand) Descriptor deprecated 

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

Deprecated: Use ChangeCommand.ProtoReflect.Descriptor instead.

func (*ChangeCommand) GetChange 

func (x *ChangeCommand) GetChange() *Change

func (*ChangeCommand) ProtoMessage 

func (*ChangeCommand) ProtoMessage()

func (*ChangeCommand) ProtoReflect 

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

func (*ChangeCommand) Reset 

func (x *ChangeCommand) Reset()

func (*ChangeCommand) String 

func (x *ChangeCommand) String() string

func (*ChangeCommand) Validate 

func (m *ChangeCommand) Validate() error

Validate checks the field values on ChangeCommand with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ChangeCommand) ValidateAll 

func (m *ChangeCommand) ValidateAll() error

ValidateAll checks the field values on ChangeCommand with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ChangeCommandMultiError, or nil if none found.

type ChangeCommandMultiError 

type ChangeCommandMultiError []error

ChangeCommandMultiError is an error wrapping multiple validation errors returned by ChangeCommand.ValidateAll() if the designated constraints aren't met.

func (ChangeCommandMultiError) AllErrors 

func (m ChangeCommandMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ChangeCommandMultiError) Error 

func (m ChangeCommandMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ChangeCommandValidationError 

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

ChangeCommandValidationError is the validation error returned by ChangeCommand.Validate if the designated constraints aren't met.

func (ChangeCommandValidationError) Cause 

func (e ChangeCommandValidationError) Cause() error

Cause function returns cause value.

func (ChangeCommandValidationError) Error 

func (e ChangeCommandValidationError) Error() string

Error satisfies the builtin error interface

func (ChangeCommandValidationError) ErrorName 

func (e ChangeCommandValidationError) ErrorName() string

ErrorName returns error name.

func (ChangeCommandValidationError) Field 

func (e ChangeCommandValidationError) Field() string

Field function returns field value.

func (ChangeCommandValidationError) Key 

func (e ChangeCommandValidationError) Key() bool

Key function returns key value.

func (ChangeCommandValidationError) Reason 

func (e ChangeCommandValidationError) Reason() string

Reason function returns reason value.

type ChangeMultiError 

type ChangeMultiError []error

ChangeMultiError is an error wrapping multiple validation errors returned by Change.ValidateAll() if the designated constraints aren't met.

func (ChangeMultiError) AllErrors 

func (m ChangeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ChangeMultiError) Error 

func (m ChangeMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ChangeValidationError 

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

ChangeValidationError is the validation error returned by Change.Validate if the designated constraints aren't met.

func (ChangeValidationError) Cause 

func (e ChangeValidationError) Cause() error

Cause function returns cause value.

func (ChangeValidationError) Error 

func (e ChangeValidationError) Error() string

Error satisfies the builtin error interface

func (ChangeValidationError) ErrorName 

func (e ChangeValidationError) ErrorName() string

ErrorName returns error name.

func (ChangeValidationError) Field 

func (e ChangeValidationError) Field() string

Field function returns field value.

func (ChangeValidationError) Key 

func (e ChangeValidationError) Key() bool

Key function returns key value.

func (ChangeValidationError) Reason 

func (e ChangeValidationError) Reason() string

Reason function returns reason value.

type Change_Op 

type Change_Op int32
const (
	Change_Invalid Change_Op = 0
	Change_Set     Change_Op = 1
	Change_Unset   Change_Op = 2
)

func (Change_Op) Descriptor 

func (Change_Op) Descriptor() protoreflect.EnumDescriptor

func (Change_Op) Enum 

func (x Change_Op) Enum() *Change_Op

func (Change_Op) EnumDescriptor deprecated 

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

Deprecated: Use Change_Op.Descriptor instead.

func (Change_Op) Number 

func (x Change_Op) Number() protoreflect.EnumNumber

func (Change_Op) String 

func (x Change_Op) String() string

func (Change_Op) Type 

func (Change_Op) Type() protoreflect.EnumType

type ClusterClient 

type ClusterClient interface {
	AddNode(ctx context.Context, in *AddNodeRequest, opts ...grpc.CallOption) (*AddNodeResponse, error)
	RemoveNode(ctx context.Context, in *RemoveNodeRequest, opts ...grpc.CallOption) (*RemoveNodeResponse, error)
	ListMembers(ctx context.Context, in *ListMembersRequest, opts ...grpc.CallOption) (*ListMembersResponse, error)
}

ClusterClient is the client API for Cluster service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClusterClient 

func NewClusterClient(cc grpc.ClientConnInterface) ClusterClient

type ClusterMember 

type ClusterMember struct {
	NodeId       uint64 `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	RaftAddr     string `protobuf:"bytes,2,opt,name=raft_addr,json=raftAddr,proto3" json:"raft_addr,omitempty"`
	GrpcEndpoint string `protobuf:"bytes,3,opt,name=grpc_endpoint,json=grpcEndpoint,proto3" json:"grpc_endpoint,omitempty"`
	Leader       bool   `protobuf:"varint,4,opt,name=leader,proto3" json:"leader,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterMember) Descriptor deprecated 

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

Deprecated: Use ClusterMember.ProtoReflect.Descriptor instead.

func (*ClusterMember) GetGrpcEndpoint 

func (x *ClusterMember) GetGrpcEndpoint() string

func (*ClusterMember) GetLeader 

func (x *ClusterMember) GetLeader() bool

func (*ClusterMember) GetNodeId 

func (x *ClusterMember) GetNodeId() uint64

func (*ClusterMember) GetRaftAddr 

func (x *ClusterMember) GetRaftAddr() string

func (*ClusterMember) ProtoMessage 

func (*ClusterMember) ProtoMessage()

func (*ClusterMember) ProtoReflect 

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

func (*ClusterMember) Reset 

func (x *ClusterMember) Reset()

func (*ClusterMember) String 

func (x *ClusterMember) String() string

func (*ClusterMember) Validate 

func (m *ClusterMember) Validate() error

Validate checks the field values on ClusterMember with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ClusterMember) ValidateAll 

func (m *ClusterMember) ValidateAll() error

ValidateAll checks the field values on ClusterMember with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ClusterMemberMultiError, or nil if none found.

type ClusterMemberMultiError 

type ClusterMemberMultiError []error

ClusterMemberMultiError is an error wrapping multiple validation errors returned by ClusterMember.ValidateAll() if the designated constraints aren't met.

func (ClusterMemberMultiError) AllErrors 

func (m ClusterMemberMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ClusterMemberMultiError) Error 

func (m ClusterMemberMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ClusterMemberValidationError 

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

ClusterMemberValidationError is the validation error returned by ClusterMember.Validate if the designated constraints aren't met.

func (ClusterMemberValidationError) Cause 

func (e ClusterMemberValidationError) Cause() error

Cause function returns cause value.

func (ClusterMemberValidationError) Error 

func (e ClusterMemberValidationError) Error() string

Error satisfies the builtin error interface

func (ClusterMemberValidationError) ErrorName 

func (e ClusterMemberValidationError) ErrorName() string

ErrorName returns error name.

func (ClusterMemberValidationError) Field 

func (e ClusterMemberValidationError) Field() string

Field function returns field value.

func (ClusterMemberValidationError) Key 

func (e ClusterMemberValidationError) Key() bool

Key function returns key value.

func (ClusterMemberValidationError) Reason 

func (e ClusterMemberValidationError) Reason() string

Reason function returns reason value.

type ClusterServer 

type ClusterServer interface {
	AddNode(context.Context, *AddNodeRequest) (*AddNodeResponse, error)
	RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)
	ListMembers(context.Context, *ListMembersRequest) (*ListMembersResponse, error)
}

ClusterServer is the server API for Cluster service.

type CompactElementHistoryReq 

type CompactElementHistoryReq struct {
	ElementKey           string `protobuf:"bytes,1,opt,name=elementKey,proto3" json:"elementKey,omitempty"`
	KeepVersionCount     int32  `protobuf:"varint,2,opt,name=keepVersionCount,proto3" json:"keepVersionCount,omitempty"`
	KeepVersionSeconds   int64  `protobuf:"varint,3,opt,name=keepVersionSeconds,proto3" json:"keepVersionSeconds,omitempty"`
	KeepOperationSeconds int64  `protobuf:"varint,4,opt,name=keepOperationSeconds,proto3" json:"keepOperationSeconds,omitempty"`
	PageSize             int32  `protobuf:"varint,5,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactElementHistoryReq) Descriptor deprecated 

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

Deprecated: Use CompactElementHistoryReq.ProtoReflect.Descriptor instead.

func (*CompactElementHistoryReq) GetElementKey 

func (x *CompactElementHistoryReq) GetElementKey() string

func (*CompactElementHistoryReq) GetKeepOperationSeconds 

func (x *CompactElementHistoryReq) GetKeepOperationSeconds() int64

func (*CompactElementHistoryReq) GetKeepVersionCount 

func (x *CompactElementHistoryReq) GetKeepVersionCount() int32

func (*CompactElementHistoryReq) GetKeepVersionSeconds 

func (x *CompactElementHistoryReq) GetKeepVersionSeconds() int64

func (*CompactElementHistoryReq) GetPageSize 

func (x *CompactElementHistoryReq) GetPageSize() int32

func (*CompactElementHistoryReq) ProtoMessage 

func (*CompactElementHistoryReq) ProtoMessage()

func (*CompactElementHistoryReq) ProtoReflect 

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

func (*CompactElementHistoryReq) Reset 

func (x *CompactElementHistoryReq) Reset()

func (*CompactElementHistoryReq) String 

func (x *CompactElementHistoryReq) String() string

func (*CompactElementHistoryReq) Validate 

func (m *CompactElementHistoryReq) Validate() error

Validate checks the field values on CompactElementHistoryReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CompactElementHistoryReq) ValidateAll 

func (m *CompactElementHistoryReq) ValidateAll() error

ValidateAll checks the field values on CompactElementHistoryReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CompactElementHistoryReqMultiError, or nil if none found.

type CompactElementHistoryReqMultiError 

type CompactElementHistoryReqMultiError []error

CompactElementHistoryReqMultiError is an error wrapping multiple validation errors returned by CompactElementHistoryReq.ValidateAll() if the designated constraints aren't met.

func (CompactElementHistoryReqMultiError) AllErrors 

func (m CompactElementHistoryReqMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CompactElementHistoryReqMultiError) Error 

func (m CompactElementHistoryReqMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CompactElementHistoryReqValidationError 

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

CompactElementHistoryReqValidationError is the validation error returned by CompactElementHistoryReq.Validate if the designated constraints aren't met.

func (CompactElementHistoryReqValidationError) Cause 

func (e CompactElementHistoryReqValidationError) Cause() error

Cause function returns cause value.

func (CompactElementHistoryReqValidationError) Error 

func (e CompactElementHistoryReqValidationError) Error() string

Error satisfies the builtin error interface

func (CompactElementHistoryReqValidationError) ErrorName 

func (e CompactElementHistoryReqValidationError) ErrorName() string

ErrorName returns error name.

func (CompactElementHistoryReqValidationError) Field 

func (e CompactElementHistoryReqValidationError) Field() string

Field function returns field value.

func (CompactElementHistoryReqValidationError) Key 

func (e CompactElementHistoryReqValidationError) Key() bool

Key function returns key value.

func (CompactElementHistoryReqValidationError) Reason 

func (e CompactElementHistoryReqValidationError) Reason() string

Reason function returns reason value.

type CompactElementHistoryResp 

type CompactElementHistoryResp struct {
	ScannedVersions   int32    `protobuf:"varint,1,opt,name=scannedVersions,proto3" json:"scannedVersions,omitempty"`
	ScannedOperations int32    `protobuf:"varint,2,opt,name=scannedOperations,proto3" json:"scannedOperations,omitempty"`
	DeletedVersions   int32    `protobuf:"varint,3,opt,name=deletedVersions,proto3" json:"deletedVersions,omitempty"`
	DeletedOperations int32    `protobuf:"varint,4,opt,name=deletedOperations,proto3" json:"deletedOperations,omitempty"`
	FailedKeys        []string `protobuf:"bytes,5,rep,name=failedKeys,proto3" json:"failedKeys,omitempty"`
	Error             string   `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactElementHistoryResp) Descriptor deprecated 

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

Deprecated: Use CompactElementHistoryResp.ProtoReflect.Descriptor instead.

func (*CompactElementHistoryResp) GetDeletedOperations 

func (x *CompactElementHistoryResp) GetDeletedOperations() int32

func (*CompactElementHistoryResp) GetDeletedVersions 

func (x *CompactElementHistoryResp) GetDeletedVersions() int32

func (*CompactElementHistoryResp) GetError 

func (x *CompactElementHistoryResp) GetError() string

func (*CompactElementHistoryResp) GetFailedKeys 

func (x *CompactElementHistoryResp) GetFailedKeys() []string

func (*CompactElementHistoryResp) GetScannedOperations 

func (x *CompactElementHistoryResp) GetScannedOperations() int32

func (*CompactElementHistoryResp) GetScannedVersions 

func (x *CompactElementHistoryResp) GetScannedVersions() int32

func (*CompactElementHistoryResp) ProtoMessage 

func (*CompactElementHistoryResp) ProtoMessage()

func (*CompactElementHistoryResp) ProtoReflect 

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

func (*CompactElementHistoryResp) Reset 

func (x *CompactElementHistoryResp) Reset()

func (*CompactElementHistoryResp) String 

func (x *CompactElementHistoryResp) String() string

func (*CompactElementHistoryResp) Validate 

func (m *CompactElementHistoryResp) Validate() error

Validate checks the field values on CompactElementHistoryResp with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CompactElementHistoryResp) ValidateAll 

func (m *CompactElementHistoryResp) ValidateAll() error

ValidateAll checks the field values on CompactElementHistoryResp with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CompactElementHistoryRespMultiError, or nil if none found.

type CompactElementHistoryRespMultiError 

type CompactElementHistoryRespMultiError []error

CompactElementHistoryRespMultiError is an error wrapping multiple validation errors returned by CompactElementHistoryResp.ValidateAll() if the designated constraints aren't met.

func (CompactElementHistoryRespMultiError) AllErrors 

func (m CompactElementHistoryRespMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CompactElementHistoryRespMultiError) Error 

func (m CompactElementHistoryRespMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CompactElementHistoryRespValidationError 

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

CompactElementHistoryRespValidationError is the validation error returned by CompactElementHistoryResp.Validate if the designated constraints aren't met.

func (CompactElementHistoryRespValidationError) Cause 

func (e CompactElementHistoryRespValidationError) Cause() error

Cause function returns cause value.

func (CompactElementHistoryRespValidationError) Error 

func (e CompactElementHistoryRespValidationError) Error() string

Error satisfies the builtin error interface

func (CompactElementHistoryRespValidationError) ErrorName 

func (e CompactElementHistoryRespValidationError) ErrorName() string

ErrorName returns error name.

func (CompactElementHistoryRespValidationError) Field 

func (e CompactElementHistoryRespValidationError) Field() string

Field function returns field value.

func (CompactElementHistoryRespValidationError) Key 

func (e CompactElementHistoryRespValidationError) Key() bool

Key function returns key value.

func (CompactElementHistoryRespValidationError) Reason 

func (e CompactElementHistoryRespValidationError) Reason() string

Reason function returns reason value.

type Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

func (*Empty) Validate 

func (m *Empty) Validate() error

Validate checks the field values on Empty with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Empty) ValidateAll 

func (m *Empty) ValidateAll() error

ValidateAll checks the field values on Empty with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EmptyMultiError, or nil if none found.

type EmptyMultiError 

type EmptyMultiError []error

EmptyMultiError is an error wrapping multiple validation errors returned by Empty.ValidateAll() if the designated constraints aren't met.

func (EmptyMultiError) AllErrors 

func (m EmptyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EmptyMultiError) Error 

func (m EmptyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type EmptyValidationError 

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

EmptyValidationError is the validation error returned by Empty.Validate if the designated constraints aren't met.

func (EmptyValidationError) Cause 

func (e EmptyValidationError) Cause() error

Cause function returns cause value.

func (EmptyValidationError) Error 

func (e EmptyValidationError) Error() string

Error satisfies the builtin error interface

func (EmptyValidationError) ErrorName 

func (e EmptyValidationError) ErrorName() string

ErrorName returns error name.

func (EmptyValidationError) Field 

func (e EmptyValidationError) Field() string

Field function returns field value.

func (EmptyValidationError) Key 

func (e EmptyValidationError) Key() bool

Key function returns key value.

func (EmptyValidationError) Reason 

func (e EmptyValidationError) Reason() string

Reason function returns reason value.

type Entity 

type Entity struct {
	Fingerprint string     `protobuf:"bytes,1,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	Key         string     `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Val         []byte     `protobuf:"bytes,3,opt,name=val,proto3" json:"val,omitempty"`
	CreatedAt   int64      `protobuf:"varint,4,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	UpdatedAt   int64      `protobuf:"varint,5,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	Ttl         int32      `protobuf:"varint,6,opt,name=ttl,proto3" json:"ttl,omitempty"`
	Typ         EntityType `protobuf:"varint,7,opt,name=typ,proto3,enum=cassem.db.EntityType" json:"typ,omitempty"`
	Size        int32      `protobuf:"varint,8,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func NewEntityWithCreated 

func NewEntityWithCreated(key string, val []byte, ttl int32, created int64) *Entity

func (*Entity) Descriptor deprecated 

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

Deprecated: Use Entity.ProtoReflect.Descriptor instead.

func (*Entity) Expired 

func (m *Entity) Expired() bool

func (*Entity) GetCreatedAt 

func (x *Entity) GetCreatedAt() int64

func (*Entity) GetFingerprint 

func (x *Entity) GetFingerprint() string

func (*Entity) GetKey 

func (x *Entity) GetKey() string

func (*Entity) GetSize 

func (x *Entity) GetSize() int32

func (*Entity) GetTtl 

func (x *Entity) GetTtl() int32

func (*Entity) GetTyp 

func (x *Entity) GetTyp() EntityType

func (*Entity) GetUpdatedAt 

func (x *Entity) GetUpdatedAt() int64

func (*Entity) GetVal 

func (x *Entity) GetVal() []byte

func (*Entity) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) ProtoReflect 

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

func (*Entity) Reset 

func (x *Entity) Reset()

func (*Entity) String 

func (x *Entity) String() string

func (*Entity) Type 

func (m *Entity) Type() EntityType

func (*Entity) Validate 

func (m *Entity) Validate() error

Validate checks the field values on Entity with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Entity) ValidateAll 

func (m *Entity) ValidateAll() error

ValidateAll checks the field values on Entity with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EntityMultiError, or nil if none found.

type EntityMultiError 

type EntityMultiError []error

EntityMultiError is an error wrapping multiple validation errors returned by Entity.ValidateAll() if the designated constraints aren't met.

func (EntityMultiError) AllErrors 

func (m EntityMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EntityMultiError) Error 

func (m EntityMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type EntityType 

type EntityType int32
const (
	EntityType_UNKNOWN EntityType = 0
	EntityType_ELT     EntityType = 1 // element
	EntityType_DIR     EntityType = 2 // directory
)

func (EntityType) Descriptor 

func (EntityType) Descriptor() protoreflect.EnumDescriptor

func (EntityType) Enum 

func (x EntityType) Enum() *EntityType

func (EntityType) EnumDescriptor deprecated 

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

Deprecated: Use EntityType.Descriptor instead.

func (EntityType) Number 

func (x EntityType) Number() protoreflect.EnumNumber

func (EntityType) String 

func (x EntityType) String() string

func (EntityType) Type 

func (EntityType) Type() protoreflect.EnumType

type EntityValidationError 

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

EntityValidationError is the validation error returned by Entity.Validate if the designated constraints aren't met.

func (EntityValidationError) Cause 

func (e EntityValidationError) Cause() error

Cause function returns cause value.

func (EntityValidationError) Error 

func (e EntityValidationError) Error() string

Error satisfies the builtin error interface

func (EntityValidationError) ErrorName 

func (e EntityValidationError) ErrorName() string

ErrorName returns error name.

func (EntityValidationError) Field 

func (e EntityValidationError) Field() string

Field function returns field value.

func (EntityValidationError) Key 

func (e EntityValidationError) Key() bool

Key function returns key value.

func (EntityValidationError) Reason 

func (e EntityValidationError) Reason() string

Reason function returns reason value.

type ExpireReq 

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

func (*ExpireReq) Descriptor deprecated 

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

Deprecated: Use ExpireReq.ProtoReflect.Descriptor instead.

func (*ExpireReq) GetKey 

func (x *ExpireReq) GetKey() string

func (*ExpireReq) ProtoMessage 

func (*ExpireReq) ProtoMessage()

func (*ExpireReq) ProtoReflect 

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

func (*ExpireReq) Reset 

func (x *ExpireReq) Reset()

func (*ExpireReq) String 

func (x *ExpireReq) String() string

func (*ExpireReq) Validate 

func (m *ExpireReq) Validate() error

Validate checks the field values on ExpireReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ExpireReq) ValidateAll 

func (m *ExpireReq) ValidateAll() error

ValidateAll checks the field values on ExpireReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ExpireReqMultiError, or nil if none found.

type ExpireReqMultiError 

type ExpireReqMultiError []error

ExpireReqMultiError is an error wrapping multiple validation errors returned by ExpireReq.ValidateAll() if the designated constraints aren't met.

func (ExpireReqMultiError) AllErrors 

func (m ExpireReqMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExpireReqMultiError) Error 

func (m ExpireReqMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ExpireReqValidationError 

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

ExpireReqValidationError is the validation error returned by ExpireReq.Validate if the designated constraints aren't met.

func (ExpireReqValidationError) Cause 

func (e ExpireReqValidationError) Cause() error

Cause function returns cause value.

func (ExpireReqValidationError) Error 

func (e ExpireReqValidationError) Error() string

Error satisfies the builtin error interface

func (ExpireReqValidationError) ErrorName 

func (e ExpireReqValidationError) ErrorName() string

ErrorName returns error name.

func (ExpireReqValidationError) Field 

func (e ExpireReqValidationError) Field() string

Field function returns field value.

func (ExpireReqValidationError) Key 

func (e ExpireReqValidationError) Key() bool

Key function returns key value.

func (ExpireReqValidationError) Reason 

func (e ExpireReqValidationError) Reason() string

Reason function returns reason value.

type GetKVReq 

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

func (*GetKVReq) Descriptor deprecated 

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

Deprecated: Use GetKVReq.ProtoReflect.Descriptor instead.

func (*GetKVReq) GetKey 

func (x *GetKVReq) GetKey() string

func (*GetKVReq) ProtoMessage 

func (*GetKVReq) ProtoMessage()

func (*GetKVReq) ProtoReflect 

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

func (*GetKVReq) Reset 

func (x *GetKVReq) Reset()

func (*GetKVReq) String 

func (x *GetKVReq) String() string

func (*GetKVReq) Validate 

func (m *GetKVReq) Validate() error

Validate checks the field values on GetKVReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetKVReq) ValidateAll 

func (m *GetKVReq) ValidateAll() error

ValidateAll checks the field values on GetKVReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetKVReqMultiError, or nil if none found.

type GetKVReqMultiError 

type GetKVReqMultiError []error

GetKVReqMultiError is an error wrapping multiple validation errors returned by GetKVReq.ValidateAll() if the designated constraints aren't met.

func (GetKVReqMultiError) AllErrors 

func (m GetKVReqMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetKVReqMultiError) Error 

func (m GetKVReqMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetKVReqValidationError 

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

GetKVReqValidationError is the validation error returned by GetKVReq.Validate if the designated constraints aren't met.

func (GetKVReqValidationError) Cause 

func (e GetKVReqValidationError) Cause() error

Cause function returns cause value.

func (GetKVReqValidationError) Error 

func (e GetKVReqValidationError) Error() string

Error satisfies the builtin error interface

func (GetKVReqValidationError) ErrorName 

func (e GetKVReqValidationError) ErrorName() string

ErrorName returns error name.

func (GetKVReqValidationError) Field 

func (e GetKVReqValidationError) Field() string

Field function returns field value.

func (GetKVReqValidationError) Key 

func (e GetKVReqValidationError) Key() bool

Key function returns key value.

func (GetKVReqValidationError) Reason 

func (e GetKVReqValidationError) Reason() string

Reason function returns reason value.

type GetKVResp 

type GetKVResp struct {
	Entity *Entity `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKVResp) Descriptor deprecated 

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

Deprecated: Use GetKVResp.ProtoReflect.Descriptor instead.

func (*GetKVResp) GetEntity 

func (x *GetKVResp) GetEntity() *Entity

func (*GetKVResp) ProtoMessage 

func (*GetKVResp) ProtoMessage()

func (*GetKVResp) ProtoReflect 

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

func (*GetKVResp) Reset 

func (x *GetKVResp) Reset()

func (*GetKVResp) String 

func (x *GetKVResp) String() string

func (*GetKVResp) Validate 

func (m *GetKVResp) Validate() error

Validate checks the field values on GetKVResp with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetKVResp) ValidateAll 

func (m *GetKVResp) ValidateAll() error

ValidateAll checks the field values on GetKVResp with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetKVRespMultiError, or nil if none found.

type GetKVRespMultiError 

type GetKVRespMultiError []error

GetKVRespMultiError is an error wrapping multiple validation errors returned by GetKVResp.ValidateAll() if the designated constraints aren't met.

func (GetKVRespMultiError) AllErrors 

func (m GetKVRespMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetKVRespMultiError) Error 

func (m GetKVRespMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetKVRespValidationError 

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

GetKVRespValidationError is the validation error returned by GetKVResp.Validate if the designated constraints aren't met.

func (GetKVRespValidationError) Cause 

func (e GetKVRespValidationError) Cause() error

Cause function returns cause value.

func (GetKVRespValidationError) Error 

func (e GetKVRespValidationError) Error() string

Error satisfies the builtin error interface

func (GetKVRespValidationError) ErrorName 

func (e GetKVRespValidationError) ErrorName() string

ErrorName returns error name.

func (GetKVRespValidationError) Field 

func (e GetKVRespValidationError) Field() string

Field function returns field value.

func (GetKVRespValidationError) Key 

func (e GetKVRespValidationError) Key() bool

Key function returns key value.

func (GetKVRespValidationError) Reason 

func (e GetKVRespValidationError) Reason() string

Reason function returns reason value.

type GetKVsReq 

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

func (*GetKVsReq) Descriptor deprecated 

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

Deprecated: Use GetKVsReq.ProtoReflect.Descriptor instead.

func (*GetKVsReq) GetKeys 

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

func (*GetKVsReq) ProtoMessage 

func (*GetKVsReq) ProtoMessage()

func (*GetKVsReq) ProtoReflect 

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

func (*GetKVsReq) Reset 

func (x *GetKVsReq) Reset()

func (*GetKVsReq) String 

func (x *GetKVsReq) String() string

func (*GetKVsReq) Validate 

func (m *GetKVsReq) Validate() error

Validate checks the field values on GetKVsReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetKVsReq) ValidateAll 

func (m *GetKVsReq) ValidateAll() error

ValidateAll checks the field values on GetKVsReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetKVsReqMultiError, or nil if none found.

type GetKVsReqMultiError 

type GetKVsReqMultiError []error

GetKVsReqMultiError is an error wrapping multiple validation errors returned by GetKVsReq.ValidateAll() if the designated constraints aren't met.

func (GetKVsReqMultiError) AllErrors 

func (m GetKVsReqMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetKVsReqMultiError) Error 

func (m GetKVsReqMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetKVsReqValidationError 

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

GetKVsReqValidationError is the validation error returned by GetKVsReq.Validate if the designated constraints aren't met.

func (GetKVsReqValidationError) Cause 

func (e GetKVsReqValidationError) Cause() error

Cause function returns cause value.

func (GetKVsReqValidationError) Error 

func (e GetKVsReqValidationError) Error() string

Error satisfies the builtin error interface

func (GetKVsReqValidationError) ErrorName 

func (e GetKVsReqValidationError) ErrorName() string

ErrorName returns error name.

func (GetKVsReqValidationError) Field 

func (e GetKVsReqValidationError) Field() string

Field function returns field value.

func (GetKVsReqValidationError) Key 

func (e GetKVsReqValidationError) Key() bool

Key function returns key value.

func (GetKVsReqValidationError) Reason 

func (e GetKVsReqValidationError) Reason() string

Reason function returns reason value.

type GetKVsResp 

type GetKVsResp struct {
	Entities []*Entity   `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	Errors   []*KeyError `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKVsResp) Descriptor deprecated 

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

Deprecated: Use GetKVsResp.ProtoReflect.Descriptor instead.

func (*GetKVsResp) GetEntities 

func (x *GetKVsResp) GetEntities() []*Entity

func (*GetKVsResp) GetErrors 

func (x *GetKVsResp) GetErrors() []*KeyError

func (*GetKVsResp) ProtoMessage 

func (*GetKVsResp) ProtoMessage()

func (*GetKVsResp) ProtoReflect 

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

func (*GetKVsResp) Reset 

func (x *GetKVsResp) Reset()

func (*GetKVsResp) String 

func (x *GetKVsResp) String() string

func (*GetKVsResp) Validate 

func (m *GetKVsResp) Validate() error

Validate checks the field values on GetKVsResp with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetKVsResp) ValidateAll 

func (m *GetKVsResp) ValidateAll() error

ValidateAll checks the field values on GetKVsResp with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetKVsRespMultiError, or nil if none found.

type GetKVsRespMultiError 

type GetKVsRespMultiError []error

GetKVsRespMultiError is an error wrapping multiple validation errors returned by GetKVsResp.ValidateAll() if the designated constraints aren't met.

func (GetKVsRespMultiError) AllErrors 

func (m GetKVsRespMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetKVsRespMultiError) Error 

func (m GetKVsRespMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetKVsRespValidationError 

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

GetKVsRespValidationError is the validation error returned by GetKVsResp.Validate if the designated constraints aren't met.

func (GetKVsRespValidationError) Cause 

func (e GetKVsRespValidationError) Cause() error

Cause function returns cause value.

func (GetKVsRespValidationError) Error 

func (e GetKVsRespValidationError) Error() string

Error satisfies the builtin error interface

func (GetKVsRespValidationError) ErrorName 

func (e GetKVsRespValidationError) ErrorName() string

ErrorName returns error name.

func (GetKVsRespValidationError) Field 

func (e GetKVsRespValidationError) Field() string

Field function returns field value.

func (GetKVsRespValidationError) Key 

func (e GetKVsRespValidationError) Key() bool

Key function returns key value.

func (GetKVsRespValidationError) Reason 

func (e GetKVsRespValidationError) Reason() string

Reason function returns reason value.

type KVClient 

type KVClient interface {
	GetKV(ctx context.Context, in *GetKVReq, opts ...grpc.CallOption) (*GetKVResp, error)
	GetKVs(ctx context.Context, in *GetKVsReq, opts ...grpc.CallOption) (*GetKVsResp, error)
	SetKV(ctx context.Context, in *SetKVReq, opts ...grpc.CallOption) (*Empty, error)
	UnsetKV(ctx context.Context, in *UnsetKVReq, opts ...grpc.CallOption) (*Empty, error)
	// Watch will rev a stream response in client.
	Watch(ctx context.Context, in *WatchReq, opts ...grpc.CallOption) (KV_WatchClient, error)
	TTL(ctx context.Context, in *TtlReq, opts ...grpc.CallOption) (*TtlResp, error)
	Expire(ctx context.Context, in *ExpireReq, opts ...grpc.CallOption) (*Empty, error)
	Range(ctx context.Context, in *RangeReq, opts ...grpc.CallOption) (*RangeResp, error)
	CompactElementHistory(ctx context.Context, in *CompactElementHistoryReq, opts ...grpc.CallOption) (*CompactElementHistoryResp, error)
}

KVClient is the client API for KV service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewKVClient 

func NewKVClient(cc grpc.ClientConnInterface) KVClient

type KVServer 

type KVServer interface {
	GetKV(context.Context, *GetKVReq) (*GetKVResp, error)
	GetKVs(context.Context, *GetKVsReq) (*GetKVsResp, error)
	SetKV(context.Context, *SetKVReq) (*Empty, error)
	UnsetKV(context.Context, *UnsetKVReq) (*Empty, error)
	// Watch will rev a stream response in client.
	Watch(*WatchReq, KV_WatchServer) error
	TTL(context.Context, *TtlReq) (*TtlResp, error)
	Expire(context.Context, *ExpireReq) (*Empty, error)
	Range(context.Context, *RangeReq) (*RangeResp, error)
	CompactElementHistory(context.Context, *CompactElementHistoryReq) (*CompactElementHistoryResp, error)
}

KVServer is the server API for KV service.

type KV_WatchClient 

type KV_WatchClient interface {
	Recv() (*Change, error)
	grpc.ClientStream
}

type KV_WatchServer 

type KV_WatchServer interface {
	Send(*Change) error
	grpc.ServerStream
}

type KeyError 

type KeyError struct {
	Key     string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Code    string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyError) Descriptor deprecated 

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

Deprecated: Use KeyError.ProtoReflect.Descriptor instead.

func (*KeyError) GetCode 

func (x *KeyError) GetCode() string

func (*KeyError) GetKey 

func (x *KeyError) GetKey() string

func (*KeyError) GetMessage 

func (x *KeyError) GetMessage() string

func (*KeyError) ProtoMessage 

func (*KeyError) ProtoMessage()

func (*KeyError) ProtoReflect 

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

func (*KeyError) Reset 

func (x *KeyError) Reset()

func (*KeyError) String 

func (x *KeyError) String() string

func (*KeyError) Validate 

func (m *KeyError) Validate() error

Validate checks the field values on KeyError with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*KeyError) ValidateAll 

func (m *KeyError) ValidateAll() error

ValidateAll checks the field values on KeyError with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in KeyErrorMultiError, or nil if none found.

type KeyErrorMultiError 

type KeyErrorMultiError []error

KeyErrorMultiError is an error wrapping multiple validation errors returned by KeyError.ValidateAll() if the designated constraints aren't met.

func (KeyErrorMultiError) AllErrors 

func (m KeyErrorMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (KeyErrorMultiError) Error 

func (m KeyErrorMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type KeyErrorValidationError 

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

KeyErrorValidationError is the validation error returned by KeyError.Validate if the designated constraints aren't met.

func (KeyErrorValidationError) Cause 

func (e KeyErrorValidationError) Cause() error

Cause function returns cause value.

func (KeyErrorValidationError) Error 

func (e KeyErrorValidationError) Error() string

Error satisfies the builtin error interface

func (KeyErrorValidationError) ErrorName 

func (e KeyErrorValidationError) ErrorName() string

ErrorName returns error name.

func (KeyErrorValidationError) Field 

func (e KeyErrorValidationError) Field() string

Field function returns field value.

func (KeyErrorValidationError) Key 

func (e KeyErrorValidationError) Key() bool

Key function returns key value.

func (KeyErrorValidationError) Reason 

func (e KeyErrorValidationError) Reason() string

Reason function returns reason value.

type ListMembersRequest 

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

func (*ListMembersRequest) Descriptor deprecated 

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

Deprecated: Use ListMembersRequest.ProtoReflect.Descriptor instead.

func (*ListMembersRequest) ProtoMessage 

func (*ListMembersRequest) ProtoMessage()

func (*ListMembersRequest) ProtoReflect 

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

func (*ListMembersRequest) Reset 

func (x *ListMembersRequest) Reset()

func (*ListMembersRequest) String 

func (x *ListMembersRequest) String() string

func (*ListMembersRequest) Validate 

func (m *ListMembersRequest) Validate() error

Validate checks the field values on ListMembersRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListMembersRequest) ValidateAll 

func (m *ListMembersRequest) ValidateAll() error

ValidateAll checks the field values on ListMembersRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListMembersRequestMultiError, or nil if none found.

type ListMembersRequestMultiError 

type ListMembersRequestMultiError []error

ListMembersRequestMultiError is an error wrapping multiple validation errors returned by ListMembersRequest.ValidateAll() if the designated constraints aren't met.

func (ListMembersRequestMultiError) AllErrors 

func (m ListMembersRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListMembersRequestMultiError) Error 

func (m ListMembersRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ListMembersRequestValidationError 

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

ListMembersRequestValidationError is the validation error returned by ListMembersRequest.Validate if the designated constraints aren't met.

func (ListMembersRequestValidationError) Cause 

func (e ListMembersRequestValidationError) Cause() error

Cause function returns cause value.

func (ListMembersRequestValidationError) Error 

func (e ListMembersRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ListMembersRequestValidationError) ErrorName 

func (e ListMembersRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ListMembersRequestValidationError) Field 

func (e ListMembersRequestValidationError) Field() string

Field function returns field value.

func (ListMembersRequestValidationError) Key 

func (e ListMembersRequestValidationError) Key() bool

Key function returns key value.

func (ListMembersRequestValidationError) Reason 

func (e ListMembersRequestValidationError) Reason() string

Reason function returns reason value.

type ListMembersResponse 

type ListMembersResponse struct {
	Members []*ClusterMember `protobuf:"bytes,1,rep,name=members,proto3" json:"members,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMembersResponse) Descriptor deprecated 

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

Deprecated: Use ListMembersResponse.ProtoReflect.Descriptor instead.

func (*ListMembersResponse) GetMembers 

func (x *ListMembersResponse) GetMembers() []*ClusterMember

func (*ListMembersResponse) ProtoMessage 

func (*ListMembersResponse) ProtoMessage()

func (*ListMembersResponse) ProtoReflect 

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

func (*ListMembersResponse) Reset 

func (x *ListMembersResponse) Reset()

func (*ListMembersResponse) String 

func (x *ListMembersResponse) String() string

func (*ListMembersResponse) Validate 

func (m *ListMembersResponse) Validate() error

Validate checks the field values on ListMembersResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListMembersResponse) ValidateAll 

func (m *ListMembersResponse) ValidateAll() error

ValidateAll checks the field values on ListMembersResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListMembersResponseMultiError, or nil if none found.

type ListMembersResponseMultiError 

type ListMembersResponseMultiError []error

ListMembersResponseMultiError is an error wrapping multiple validation errors returned by ListMembersResponse.ValidateAll() if the designated constraints aren't met.

func (ListMembersResponseMultiError) AllErrors 

func (m ListMembersResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListMembersResponseMultiError) Error 

func (m ListMembersResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ListMembersResponseValidationError 

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

ListMembersResponseValidationError is the validation error returned by ListMembersResponse.Validate if the designated constraints aren't met.

func (ListMembersResponseValidationError) Cause 

func (e ListMembersResponseValidationError) Cause() error

Cause function returns cause value.

func (ListMembersResponseValidationError) Error 

func (e ListMembersResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ListMembersResponseValidationError) ErrorName 

func (e ListMembersResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ListMembersResponseValidationError) Field 

func (e ListMembersResponseValidationError) Field() string

Field function returns field value.

func (ListMembersResponseValidationError) Key 

func (e ListMembersResponseValidationError) Key() bool

Key function returns key value.

func (ListMembersResponseValidationError) Reason 

func (e ListMembersResponseValidationError) Reason() string

Reason function returns reason value.

type LogEntry 

type LogEntry struct {

	// action indicates what's the format of data dose the log entry contains.
	Action    LogEntry_Action `protobuf:"varint,1,opt,name=action,proto3,enum=cassem.db.LogEntry_Action" json:"action,omitempty"`
	Command   []byte          `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	CreatedAt int64           `protobuf:"varint,3,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEntry) Descriptor deprecated 

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

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) Expired 

func (m *LogEntry) Expired() bool

Expired represents the LogEntry has expired, could not be applied by raft node. this method should only be used in some case which cares about duplicate log entries applied.

func (*LogEntry) GetAction 

func (x *LogEntry) GetAction() LogEntry_Action

func (*LogEntry) GetCommand 

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

func (*LogEntry) GetCreatedAt 

func (x *LogEntry) GetCreatedAt() int64

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect 

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

func (*LogEntry) Reset 

func (x *LogEntry) Reset()

func (*LogEntry) String 

func (x *LogEntry) String() string

func (*LogEntry) Validate 

func (m *LogEntry) Validate() error

Validate checks the field values on LogEntry with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LogEntry) ValidateAll 

func (m *LogEntry) ValidateAll() error

ValidateAll checks the field values on LogEntry with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LogEntryMultiError, or nil if none found.

type LogEntryMultiError 

type LogEntryMultiError []error

LogEntryMultiError is an error wrapping multiple validation errors returned by LogEntry.ValidateAll() if the designated constraints aren't met.

func (LogEntryMultiError) AllErrors 

func (m LogEntryMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogEntryMultiError) Error 

func (m LogEntryMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type LogEntryValidationError 

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

LogEntryValidationError is the validation error returned by LogEntry.Validate if the designated constraints aren't met.

func (LogEntryValidationError) Cause 

func (e LogEntryValidationError) Cause() error

Cause function returns cause value.

func (LogEntryValidationError) Error 

func (e LogEntryValidationError) Error() string

Error satisfies the builtin error interface

func (LogEntryValidationError) ErrorName 

func (e LogEntryValidationError) ErrorName() string

ErrorName returns error name.

func (LogEntryValidationError) Field 

func (e LogEntryValidationError) Field() string

Field function returns field value.

func (LogEntryValidationError) Key 

func (e LogEntryValidationError) Key() bool

Key function returns key value.

func (LogEntryValidationError) Reason 

func (e LogEntryValidationError) Reason() string

Reason function returns reason value.

type LogEntry_Action 

type LogEntry_Action int32
const (
	LogEntry_UNKNOWN      LogEntry_Action = 0
	LogEntry_Set          LogEntry_Action = 1
	LogEntry_ChangeSpread LogEntry_Action = 2
)

func (LogEntry_Action) Descriptor 

func (LogEntry_Action) Descriptor() protoreflect.EnumDescriptor

func (LogEntry_Action) Enum 

func (x LogEntry_Action) Enum() *LogEntry_Action

func (LogEntry_Action) EnumDescriptor deprecated 

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

Deprecated: Use LogEntry_Action.Descriptor instead.

func (LogEntry_Action) Number 

func (x LogEntry_Action) Number() protoreflect.EnumNumber

func (LogEntry_Action) String 

func (x LogEntry_Action) String() string

func (LogEntry_Action) Type 

func (LogEntry_Action) Type() protoreflect.EnumType

type Mode 

type Mode uint8

Mode indicates the way that gRPC client communicate with cassemdb cluster. 

const (
	// Mode_R means read only
	Mode_R Mode = iota + 1
	// Mode_X means read / write, but only communicate with leader node.
	Mode_X
)

type ParentDirectoryChange 

type ParentDirectoryChange struct {
	Change        *Change `protobuf:"bytes,1,opt,name=change,proto3" json:"change,omitempty"`
	SpecificTopic string  `protobuf:"bytes,2,opt,name=specificTopic,proto3" json:"specificTopic,omitempty"`
	// contains filtered or unexported fields
}

func (*ParentDirectoryChange) Descriptor deprecated 

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

Deprecated: Use ParentDirectoryChange.ProtoReflect.Descriptor instead.

func (*ParentDirectoryChange) GetChange 

func (x *ParentDirectoryChange) GetChange() *Change

func (*ParentDirectoryChange) GetSpecificTopic 

func (x *ParentDirectoryChange) GetSpecificTopic() string

func (*ParentDirectoryChange) ProtoMessage 

func (*ParentDirectoryChange) ProtoMessage()

func (*ParentDirectoryChange) ProtoReflect 

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

func (*ParentDirectoryChange) Reset 

func (x *ParentDirectoryChange) Reset()

func (*ParentDirectoryChange) String 

func (x *ParentDirectoryChange) String() string

func (*ParentDirectoryChange) Topic 

func (m *ParentDirectoryChange) Topic() string

func (*ParentDirectoryChange) Type 

func (*ParentDirectoryChange) Type() concept.ChangeType

func (*ParentDirectoryChange) Validate 

func (m *ParentDirectoryChange) Validate() error

Validate checks the field values on ParentDirectoryChange with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ParentDirectoryChange) ValidateAll 

func (m *ParentDirectoryChange) ValidateAll() error

ValidateAll checks the field values on ParentDirectoryChange with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ParentDirectoryChangeMultiError, or nil if none found.

type ParentDirectoryChangeMultiError 

type ParentDirectoryChangeMultiError []error

ParentDirectoryChangeMultiError is an error wrapping multiple validation errors returned by ParentDirectoryChange.ValidateAll() if the designated constraints aren't met.

func (ParentDirectoryChangeMultiError) AllErrors 

func (m ParentDirectoryChangeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ParentDirectoryChangeMultiError) Error 

func (m ParentDirectoryChangeMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ParentDirectoryChangeValidationError 

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

ParentDirectoryChangeValidationError is the validation error returned by ParentDirectoryChange.Validate if the designated constraints aren't met.

func (ParentDirectoryChangeValidationError) Cause 

func (e ParentDirectoryChangeValidationError) Cause() error

Cause function returns cause value.

func (ParentDirectoryChangeValidationError) Error 

func (e ParentDirectoryChangeValidationError) Error() string

Error satisfies the builtin error interface

func (ParentDirectoryChangeValidationError) ErrorName 

func (e ParentDirectoryChangeValidationError) ErrorName() string

ErrorName returns error name.

func (ParentDirectoryChangeValidationError) Field 

func (e ParentDirectoryChangeValidationError) Field() string

Field function returns field value.

func (ParentDirectoryChangeValidationError) Key 

func (e ParentDirectoryChangeValidationError) Key() bool

Key function returns key value.

func (ParentDirectoryChangeValidationError) Reason 

func (e ParentDirectoryChangeValidationError) Reason() string

Reason function returns reason value.

type Propose 

type Propose struct {
	Ctx   context.Context
	Entry *LogEntry
	ErrC  chan<- error
}

Propose is wrapper of log entry, and only used by node internal.

func NewPropose 

func NewPropose(entry *LogEntry, errC chan<- error) *Propose

func NewProposeWithContext 

func NewProposeWithContext(ctx context.Context, entry *LogEntry, errC chan<- error) *Propose

type RangeReq 

type RangeReq struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Seek  string `protobuf:"bytes,2,opt,name=seek,proto3" json:"seek,omitempty"`
	Limit int32  `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*RangeReq) Descriptor deprecated 

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

Deprecated: Use RangeReq.ProtoReflect.Descriptor instead.

func (*RangeReq) GetKey 

func (x *RangeReq) GetKey() string

func (*RangeReq) GetLimit 

func (x *RangeReq) GetLimit() int32

func (*RangeReq) GetSeek 

func (x *RangeReq) GetSeek() string

func (*RangeReq) ProtoMessage 

func (*RangeReq) ProtoMessage()

func (*RangeReq) ProtoReflect 

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

func (*RangeReq) Reset 

func (x *RangeReq) Reset()

func (*RangeReq) String 

func (x *RangeReq) String() string

func (*RangeReq) Validate 

func (m *RangeReq) Validate() error

Validate checks the field values on RangeReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*RangeReq) ValidateAll 

func (m *RangeReq) ValidateAll() error

ValidateAll checks the field values on RangeReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RangeReqMultiError, or nil if none found.

type RangeReqMultiError 

type RangeReqMultiError []error

RangeReqMultiError is an error wrapping multiple validation errors returned by RangeReq.ValidateAll() if the designated constraints aren't met.

func (RangeReqMultiError) AllErrors 

func (m RangeReqMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RangeReqMultiError) Error 

func (m RangeReqMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type RangeReqValidationError 

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

RangeReqValidationError is the validation error returned by RangeReq.Validate if the designated constraints aren't met.

func (RangeReqValidationError) Cause 

func (e RangeReqValidationError) Cause() error

Cause function returns cause value.

func (RangeReqValidationError) Error 

func (e RangeReqValidationError) Error() string

Error satisfies the builtin error interface

func (RangeReqValidationError) ErrorName 

func (e RangeReqValidationError) ErrorName() string

ErrorName returns error name.

func (RangeReqValidationError) Field 

func (e RangeReqValidationError) Field() string

Field function returns field value.

func (RangeReqValidationError) Key 

func (e RangeReqValidationError) Key() bool

Key function returns key value.

func (RangeReqValidationError) Reason 

func (e RangeReqValidationError) Reason() string

Reason function returns reason value.

type RangeResp 

type RangeResp struct {
	Entities    []*Entity `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	HasMore     bool      `protobuf:"varint,2,opt,name=hasMore,proto3" json:"hasMore,omitempty"`
	NextSeekKey string    `protobuf:"bytes,3,opt,name=nextSeekKey,proto3" json:"nextSeekKey,omitempty"`
	// contains filtered or unexported fields
}

func (*RangeResp) Descriptor deprecated 

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

Deprecated: Use RangeResp.ProtoReflect.Descriptor instead.

func (*RangeResp) GetEntities 

func (x *RangeResp) GetEntities() []*Entity

func (*RangeResp) GetHasMore 

func (x *RangeResp) GetHasMore() bool

func (*RangeResp) GetNextSeekKey 

func (x *RangeResp) GetNextSeekKey() string

func (*RangeResp) ProtoMessage 

func (*RangeResp) ProtoMessage()

func (*RangeResp) ProtoReflect 

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

func (*RangeResp) Reset 

func (x *RangeResp) Reset()

func (*RangeResp) String 

func (x *RangeResp) String() string

func (*RangeResp) Validate 

func (m *RangeResp) Validate() error

Validate checks the field values on RangeResp with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*RangeResp) ValidateAll 

func (m *RangeResp) ValidateAll() error

ValidateAll checks the field values on RangeResp with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RangeRespMultiError, or nil if none found.

type RangeRespMultiError 

type RangeRespMultiError []error

RangeRespMultiError is an error wrapping multiple validation errors returned by RangeResp.ValidateAll() if the designated constraints aren't met.

func (RangeRespMultiError) AllErrors 

func (m RangeRespMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RangeRespMultiError) Error 

func (m RangeRespMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type RangeRespValidationError 

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

RangeRespValidationError is the validation error returned by RangeResp.Validate if the designated constraints aren't met.

func (RangeRespValidationError) Cause 

func (e RangeRespValidationError) Cause() error

Cause function returns cause value.

func (RangeRespValidationError) Error 

func (e RangeRespValidationError) Error() string

Error satisfies the builtin error interface

func (RangeRespValidationError) ErrorName 

func (e RangeRespValidationError) ErrorName() string

ErrorName returns error name.

func (RangeRespValidationError) Field 

func (e RangeRespValidationError) Field() string

Field function returns field value.

func (RangeRespValidationError) Key 

func (e RangeRespValidationError) Key() bool

Key function returns key value.

func (RangeRespValidationError) Reason 

func (e RangeRespValidationError) Reason() string

Reason function returns reason value.

type RemoveNodeRequest 

type RemoveNodeRequest struct {
	NodeId uint64 `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveNodeRequest) Descriptor deprecated 

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

Deprecated: Use RemoveNodeRequest.ProtoReflect.Descriptor instead.

func (*RemoveNodeRequest) GetNodeId 

func (x *RemoveNodeRequest) GetNodeId() uint64

func (*RemoveNodeRequest) ProtoMessage 

func (*RemoveNodeRequest) ProtoMessage()

func (*RemoveNodeRequest) ProtoReflect 

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

func (*RemoveNodeRequest) Reset 

func (x *RemoveNodeRequest) Reset()

func (*RemoveNodeRequest) String 

func (x *RemoveNodeRequest) String() string

func (*RemoveNodeRequest) Validate 

func (m *RemoveNodeRequest) Validate() error

Validate checks the field values on RemoveNodeRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*RemoveNodeRequest) ValidateAll 

func (m *RemoveNodeRequest) ValidateAll() error

ValidateAll checks the field values on RemoveNodeRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RemoveNodeRequestMultiError, or nil if none found.

type RemoveNodeRequestMultiError 

type RemoveNodeRequestMultiError []error

RemoveNodeRequestMultiError is an error wrapping multiple validation errors returned by RemoveNodeRequest.ValidateAll() if the designated constraints aren't met.

func (RemoveNodeRequestMultiError) AllErrors 

func (m RemoveNodeRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RemoveNodeRequestMultiError) Error 

func (m RemoveNodeRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type RemoveNodeRequestValidationError 

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

RemoveNodeRequestValidationError is the validation error returned by RemoveNodeRequest.Validate if the designated constraints aren't met.

func (RemoveNodeRequestValidationError) Cause 

func (e RemoveNodeRequestValidationError) Cause() error

Cause function returns cause value.

func (RemoveNodeRequestValidationError) Error 

func (e RemoveNodeRequestValidationError) Error() string

Error satisfies the builtin error interface

func (RemoveNodeRequestValidationError) ErrorName 

func (e RemoveNodeRequestValidationError) ErrorName() string

ErrorName returns error name.

func (RemoveNodeRequestValidationError) Field 

func (e RemoveNodeRequestValidationError) Field() string

Field function returns field value.

func (RemoveNodeRequestValidationError) Key 

func (e RemoveNodeRequestValidationError) Key() bool

Key function returns key value.

func (RemoveNodeRequestValidationError) Reason 

func (e RemoveNodeRequestValidationError) Reason() string

Reason function returns reason value.

type RemoveNodeResponse 

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

func (*RemoveNodeResponse) Descriptor deprecated 

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

Deprecated: Use RemoveNodeResponse.ProtoReflect.Descriptor instead.

func (*RemoveNodeResponse) ProtoMessage 

func (*RemoveNodeResponse) ProtoMessage()

func (*RemoveNodeResponse) ProtoReflect 

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

func (*RemoveNodeResponse) Reset 

func (x *RemoveNodeResponse) Reset()

func (*RemoveNodeResponse) String 

func (x *RemoveNodeResponse) String() string

func (*RemoveNodeResponse) Validate 

func (m *RemoveNodeResponse) Validate() error

Validate checks the field values on RemoveNodeResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*RemoveNodeResponse) ValidateAll 

func (m *RemoveNodeResponse) ValidateAll() error

ValidateAll checks the field values on RemoveNodeResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RemoveNodeResponseMultiError, or nil if none found.

type RemoveNodeResponseMultiError 

type RemoveNodeResponseMultiError []error

RemoveNodeResponseMultiError is an error wrapping multiple validation errors returned by RemoveNodeResponse.ValidateAll() if the designated constraints aren't met.

func (RemoveNodeResponseMultiError) AllErrors 

func (m RemoveNodeResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RemoveNodeResponseMultiError) Error 

func (m RemoveNodeResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type RemoveNodeResponseValidationError 

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

RemoveNodeResponseValidationError is the validation error returned by RemoveNodeResponse.Validate if the designated constraints aren't met.

func (RemoveNodeResponseValidationError) Cause 

func (e RemoveNodeResponseValidationError) Cause() error

Cause function returns cause value.

func (RemoveNodeResponseValidationError) Error 

func (e RemoveNodeResponseValidationError) Error() string

Error satisfies the builtin error interface

func (RemoveNodeResponseValidationError) ErrorName 

func (e RemoveNodeResponseValidationError) ErrorName() string

ErrorName returns error name.

func (RemoveNodeResponseValidationError) Field 

func (e RemoveNodeResponseValidationError) Field() string

Field function returns field value.

func (RemoveNodeResponseValidationError) Key 

func (e RemoveNodeResponseValidationError) Key() bool

Key function returns key value.

func (RemoveNodeResponseValidationError) Reason 

func (e RemoveNodeResponseValidationError) Reason() string

Reason function returns reason value.

type SetCommand 

type SetCommand struct {
	DeleteKey string  `protobuf:"bytes,1,opt,name=deleteKey,proto3" json:"deleteKey,omitempty"`
	IsDir     bool    `protobuf:"varint,2,opt,name=isDir,proto3" json:"isDir,omitempty"`
	SetKey    string  `protobuf:"bytes,3,opt,name=setKey,proto3" json:"setKey,omitempty"`
	Value     *Entity `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SetCommand) Action 

func (*SetCommand) Action() LogEntry_Action

func (*SetCommand) Descriptor deprecated 

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

Deprecated: Use SetCommand.ProtoReflect.Descriptor instead.

func (*SetCommand) GetDeleteKey 

func (x *SetCommand) GetDeleteKey() string

func (*SetCommand) GetIsDir 

func (x *SetCommand) GetIsDir() bool

func (*SetCommand) GetSetKey 

func (x *SetCommand) GetSetKey() string

func (*SetCommand) GetValue 

func (x *SetCommand) GetValue() *Entity

func (*SetCommand) ProtoMessage 

func (*SetCommand) ProtoMessage()

func (*SetCommand) ProtoReflect 

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

func (*SetCommand) Reset 

func (x *SetCommand) Reset()

func (*SetCommand) String 

func (x *SetCommand) String() string

func (*SetCommand) Validate 

func (m *SetCommand) Validate() error

Validate checks the field values on SetCommand with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*SetCommand) ValidateAll 

func (m *SetCommand) ValidateAll() error

ValidateAll checks the field values on SetCommand with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SetCommandMultiError, or nil if none found.

type SetCommandMultiError 

type SetCommandMultiError []error

SetCommandMultiError is an error wrapping multiple validation errors returned by SetCommand.ValidateAll() if the designated constraints aren't met.

func (SetCommandMultiError) AllErrors 

func (m SetCommandMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SetCommandMultiError) Error 

func (m SetCommandMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type SetCommandValidationError 

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

SetCommandValidationError is the validation error returned by SetCommand.Validate if the designated constraints aren't met.

func (SetCommandValidationError) Cause 

func (e SetCommandValidationError) Cause() error

Cause function returns cause value.

func (SetCommandValidationError) Error 

func (e SetCommandValidationError) Error() string

Error satisfies the builtin error interface

func (SetCommandValidationError) ErrorName 

func (e SetCommandValidationError) ErrorName() string

ErrorName returns error name.

func (SetCommandValidationError) Field 

func (e SetCommandValidationError) Field() string

Field function returns field value.

func (SetCommandValidationError) Key 

func (e SetCommandValidationError) Key() bool

Key function returns key value.

func (SetCommandValidationError) Reason 

func (e SetCommandValidationError) Reason() string

Reason function returns reason value.

type SetKVReq 

type SetKVReq struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	IsDir bool   `protobuf:"varint,2,opt,name=isDir,proto3" json:"isDir,omitempty"`
	Ttl   int32  `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"` // ttl is Time to Live (n seconds)
	// val's size in [1, 256K] Byte
	Val       []byte `protobuf:"bytes,4,opt,name=val,proto3" json:"val,omitempty"`
	Overwrite bool   `protobuf:"varint,5,opt,name=overwrite,proto3" json:"overwrite,omitempty"`
	// contains filtered or unexported fields
}

func (*SetKVReq) Descriptor deprecated 

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

Deprecated: Use SetKVReq.ProtoReflect.Descriptor instead.

func (*SetKVReq) GetIsDir 

func (x *SetKVReq) GetIsDir() bool

func (*SetKVReq) GetKey 

func (x *SetKVReq) GetKey() string

func (*SetKVReq) GetOverwrite 

func (x *SetKVReq) GetOverwrite() bool

func (*SetKVReq) GetTtl 

func (x *SetKVReq) GetTtl() int32

func (*SetKVReq) GetVal 

func (x *SetKVReq) GetVal() []byte

func (*SetKVReq) ProtoMessage 

func (*SetKVReq) ProtoMessage()

func (*SetKVReq) ProtoReflect 

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

func (*SetKVReq) Reset 

func (x *SetKVReq) Reset()

func (*SetKVReq) String 

func (x *SetKVReq) String() string

func (*SetKVReq) Validate 

func (m *SetKVReq) Validate() error

Validate checks the field values on SetKVReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*SetKVReq) ValidateAll 

func (m *SetKVReq) ValidateAll() error

ValidateAll checks the field values on SetKVReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SetKVReqMultiError, or nil if none found.

type SetKVReqMultiError 

type SetKVReqMultiError []error

SetKVReqMultiError is an error wrapping multiple validation errors returned by SetKVReq.ValidateAll() if the designated constraints aren't met.

func (SetKVReqMultiError) AllErrors 

func (m SetKVReqMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SetKVReqMultiError) Error 

func (m SetKVReqMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type SetKVReqValidationError 

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

SetKVReqValidationError is the validation error returned by SetKVReq.Validate if the designated constraints aren't met.

func (SetKVReqValidationError) Cause 

func (e SetKVReqValidationError) Cause() error

Cause function returns cause value.

func (SetKVReqValidationError) Error 

func (e SetKVReqValidationError) Error() string

Error satisfies the builtin error interface

func (SetKVReqValidationError) ErrorName 

func (e SetKVReqValidationError) ErrorName() string

ErrorName returns error name.

func (SetKVReqValidationError) Field 

func (e SetKVReqValidationError) Field() string

Field function returns field value.

func (SetKVReqValidationError) Key 

func (e SetKVReqValidationError) Key() bool

Key function returns key value.

func (SetKVReqValidationError) Reason 

func (e SetKVReqValidationError) Reason() string

Reason function returns reason value.

type TtlReq 

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

func (*TtlReq) Descriptor deprecated 

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

Deprecated: Use TtlReq.ProtoReflect.Descriptor instead.

func (*TtlReq) GetKey 

func (x *TtlReq) GetKey() string

func (*TtlReq) ProtoMessage 

func (*TtlReq) ProtoMessage()

func (*TtlReq) ProtoReflect 

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

func (*TtlReq) Reset 

func (x *TtlReq) Reset()

func (*TtlReq) String 

func (x *TtlReq) String() string

func (*TtlReq) Validate 

func (m *TtlReq) Validate() error

Validate checks the field values on TtlReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TtlReq) ValidateAll 

func (m *TtlReq) ValidateAll() error

ValidateAll checks the field values on TtlReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TtlReqMultiError, or nil if none found.

type TtlReqMultiError 

type TtlReqMultiError []error

TtlReqMultiError is an error wrapping multiple validation errors returned by TtlReq.ValidateAll() if the designated constraints aren't met.

func (TtlReqMultiError) AllErrors 

func (m TtlReqMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TtlReqMultiError) Error 

func (m TtlReqMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TtlReqValidationError 

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

TtlReqValidationError is the validation error returned by TtlReq.Validate if the designated constraints aren't met.

func (TtlReqValidationError) Cause 

func (e TtlReqValidationError) Cause() error

Cause function returns cause value.

func (TtlReqValidationError) Error 

func (e TtlReqValidationError) Error() string

Error satisfies the builtin error interface

func (TtlReqValidationError) ErrorName 

func (e TtlReqValidationError) ErrorName() string

ErrorName returns error name.

func (TtlReqValidationError) Field 

func (e TtlReqValidationError) Field() string

Field function returns field value.

func (TtlReqValidationError) Key 

func (e TtlReqValidationError) Key() bool

Key function returns key value.

func (TtlReqValidationError) Reason 

func (e TtlReqValidationError) Reason() string

Reason function returns reason value.

type TtlResp 

type TtlResp struct {
	Ttl int32 `protobuf:"varint,1,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*TtlResp) Descriptor deprecated 

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

Deprecated: Use TtlResp.ProtoReflect.Descriptor instead.

func (*TtlResp) GetTtl 

func (x *TtlResp) GetTtl() int32

func (*TtlResp) ProtoMessage 

func (*TtlResp) ProtoMessage()

func (*TtlResp) ProtoReflect 

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

func (*TtlResp) Reset 

func (x *TtlResp) Reset()

func (*TtlResp) String 

func (x *TtlResp) String() string

func (*TtlResp) Validate 

func (m *TtlResp) Validate() error

Validate checks the field values on TtlResp with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TtlResp) ValidateAll 

func (m *TtlResp) ValidateAll() error

ValidateAll checks the field values on TtlResp with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TtlRespMultiError, or nil if none found.

type TtlRespMultiError 

type TtlRespMultiError []error

TtlRespMultiError is an error wrapping multiple validation errors returned by TtlResp.ValidateAll() if the designated constraints aren't met.

func (TtlRespMultiError) AllErrors 

func (m TtlRespMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TtlRespMultiError) Error 

func (m TtlRespMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TtlRespValidationError 

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

TtlRespValidationError is the validation error returned by TtlResp.Validate if the designated constraints aren't met.

func (TtlRespValidationError) Cause 

func (e TtlRespValidationError) Cause() error

Cause function returns cause value.

func (TtlRespValidationError) Error 

func (e TtlRespValidationError) Error() string

Error satisfies the builtin error interface

func (TtlRespValidationError) ErrorName 

func (e TtlRespValidationError) ErrorName() string

ErrorName returns error name.

func (TtlRespValidationError) Field 

func (e TtlRespValidationError) Field() string

Field function returns field value.

func (TtlRespValidationError) Key 

func (e TtlRespValidationError) Key() bool

Key function returns key value.

func (TtlRespValidationError) Reason 

func (e TtlRespValidationError) Reason() string

Reason function returns reason value.

type UnimplementedClusterServer 

type UnimplementedClusterServer struct {
}

UnimplementedClusterServer can be embedded to have forward compatible implementations.

func (*UnimplementedClusterServer) AddNode 

func (*UnimplementedClusterServer) AddNode(context.Context, *AddNodeRequest) (*AddNodeResponse, error)

func (*UnimplementedClusterServer) ListMembers 

func (*UnimplementedClusterServer) ListMembers(context.Context, *ListMembersRequest) (*ListMembersResponse, error)

func (*UnimplementedClusterServer) RemoveNode 

func (*UnimplementedClusterServer) RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)

type UnimplementedKVServer 

type UnimplementedKVServer struct {
}

UnimplementedKVServer can be embedded to have forward compatible implementations.

func (*UnimplementedKVServer) CompactElementHistory 

func (*UnimplementedKVServer) CompactElementHistory(context.Context, *CompactElementHistoryReq) (*CompactElementHistoryResp, error)

func (*UnimplementedKVServer) Expire 

func (*UnimplementedKVServer) Expire(context.Context, *ExpireReq) (*Empty, error)

func (*UnimplementedKVServer) GetKV 

func (*UnimplementedKVServer) GetKV(context.Context, *GetKVReq) (*GetKVResp, error)

func (*UnimplementedKVServer) GetKVs 

func (*UnimplementedKVServer) GetKVs(context.Context, *GetKVsReq) (*GetKVsResp, error)

func (*UnimplementedKVServer) Range 

func (*UnimplementedKVServer) Range(context.Context, *RangeReq) (*RangeResp, error)

func (*UnimplementedKVServer) SetKV 

func (*UnimplementedKVServer) SetKV(context.Context, *SetKVReq) (*Empty, error)

func (*UnimplementedKVServer) TTL 

func (*UnimplementedKVServer) TTL(context.Context, *TtlReq) (*TtlResp, error)

func (*UnimplementedKVServer) UnsetKV 

func (*UnimplementedKVServer) UnsetKV(context.Context, *UnsetKVReq) (*Empty, error)

func (*UnimplementedKVServer) Watch 

func (*UnimplementedKVServer) Watch(*WatchReq, KV_WatchServer) error

type UnsetKVReq 

type UnsetKVReq struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	IsDir bool   `protobuf:"varint,2,opt,name=isDir,proto3" json:"isDir,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsetKVReq) Descriptor deprecated 

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

Deprecated: Use UnsetKVReq.ProtoReflect.Descriptor instead.

func (*UnsetKVReq) GetIsDir 

func (x *UnsetKVReq) GetIsDir() bool

func (*UnsetKVReq) GetKey 

func (x *UnsetKVReq) GetKey() string

func (*UnsetKVReq) ProtoMessage 

func (*UnsetKVReq) ProtoMessage()

func (*UnsetKVReq) ProtoReflect 

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

func (*UnsetKVReq) Reset 

func (x *UnsetKVReq) Reset()

func (*UnsetKVReq) String 

func (x *UnsetKVReq) String() string

func (*UnsetKVReq) Validate 

func (m *UnsetKVReq) Validate() error

Validate checks the field values on UnsetKVReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*UnsetKVReq) ValidateAll 

func (m *UnsetKVReq) ValidateAll() error

ValidateAll checks the field values on UnsetKVReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in UnsetKVReqMultiError, or nil if none found.

type UnsetKVReqMultiError 

type UnsetKVReqMultiError []error

UnsetKVReqMultiError is an error wrapping multiple validation errors returned by UnsetKVReq.ValidateAll() if the designated constraints aren't met.

func (UnsetKVReqMultiError) AllErrors 

func (m UnsetKVReqMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UnsetKVReqMultiError) Error 

func (m UnsetKVReqMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type UnsetKVReqValidationError 

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

UnsetKVReqValidationError is the validation error returned by UnsetKVReq.Validate if the designated constraints aren't met.

func (UnsetKVReqValidationError) Cause 

func (e UnsetKVReqValidationError) Cause() error

Cause function returns cause value.

func (UnsetKVReqValidationError) Error 

func (e UnsetKVReqValidationError) Error() string

Error satisfies the builtin error interface

func (UnsetKVReqValidationError) ErrorName 

func (e UnsetKVReqValidationError) ErrorName() string

ErrorName returns error name.

func (UnsetKVReqValidationError) Field 

func (e UnsetKVReqValidationError) Field() string

Field function returns field value.

func (UnsetKVReqValidationError) Key 

func (e UnsetKVReqValidationError) Key() bool

Key function returns key value.

func (UnsetKVReqValidationError) Reason 

func (e UnsetKVReqValidationError) Reason() string

Reason function returns reason value.

type WatchReq 

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

func (*WatchReq) Descriptor deprecated 

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

Deprecated: Use WatchReq.ProtoReflect.Descriptor instead.

func (*WatchReq) GetKeys 

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

func (*WatchReq) ProtoMessage 

func (*WatchReq) ProtoMessage()

func (*WatchReq) ProtoReflect 

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

func (*WatchReq) Reset 

func (x *WatchReq) Reset()

func (*WatchReq) String 

func (x *WatchReq) String() string

func (*WatchReq) Validate 

func (m *WatchReq) Validate() error

Validate checks the field values on WatchReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*WatchReq) ValidateAll 

func (m *WatchReq) ValidateAll() error

ValidateAll checks the field values on WatchReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in WatchReqMultiError, or nil if none found.

type WatchReqMultiError 

type WatchReqMultiError []error

WatchReqMultiError is an error wrapping multiple validation errors returned by WatchReq.ValidateAll() if the designated constraints aren't met.

func (WatchReqMultiError) AllErrors 

func (m WatchReqMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (WatchReqMultiError) Error 

func (m WatchReqMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type WatchReqValidationError 

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

WatchReqValidationError is the validation error returned by WatchReq.Validate if the designated constraints aren't met.

func (WatchReqValidationError) Cause 

func (e WatchReqValidationError) Cause() error

Cause function returns cause value.

func (WatchReqValidationError) Error 

func (e WatchReqValidationError) Error() string

Error satisfies the builtin error interface

func (WatchReqValidationError) ErrorName 

func (e WatchReqValidationError) ErrorName() string

ErrorName returns error name.

func (WatchReqValidationError) Field 

func (e WatchReqValidationError) Field() string

Field function returns field value.

func (WatchReqValidationError) Key 

func (e WatchReqValidationError) Key() bool

Key function returns key value.

func (WatchReqValidationError) Reason 

func (e WatchReqValidationError) Reason() string

Reason function returns reason value.

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.