Documentation ¶
Overview ¶
Package distcachev1 is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Code generated by protoc-gen-deepcopy. DO NOT EDIT.
Index ¶
- Constants
- Variables
- func RegisterDistCacheServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterDistCacheServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DistCacheServiceClient) error
- func RegisterDistCacheServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterDistCacheServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DistCacheServiceServer) error
- func RegisterDistCacheServiceServer(s grpc.ServiceRegistrar, srv DistCacheServiceServer)
- type DMap
- func (in *DMap) DeepCopy() *DMap
- func (in *DMap) DeepCopyInterface() interface{}
- func (in *DMap) DeepCopyInto(out *DMap)
- func (*DMap) Descriptor() ([]byte, []int)deprecated
- func (x *DMap) GetLength() int64
- func (x *DMap) GetNumTables() int64
- func (x *DMap) GetSlabInfo() *SlabInfo
- func (msg *DMap) MarshalJSON() ([]byte, error)
- func (*DMap) ProtoMessage()
- func (x *DMap) ProtoReflect() protoreflect.Message
- func (x *DMap) Reset()
- func (x *DMap) String() string
- func (msg *DMap) UnmarshalJSON(b []byte) error
- func (m *DMap) Validate() error
- func (m *DMap) ValidateAll() error
- type DMapMultiError
- type DMapValidationError
- type DMaps
- func (in *DMaps) DeepCopy() *DMaps
- func (in *DMaps) DeepCopyInterface() interface{}
- func (in *DMaps) DeepCopyInto(out *DMaps)
- func (*DMaps) Descriptor() ([]byte, []int)deprecated
- func (x *DMaps) GetDeleteHits() int64
- func (x *DMaps) GetDeleteMisses() int64
- func (x *DMaps) GetEntriesTotal() int64
- func (x *DMaps) GetEvictedTotal() int64
- func (x *DMaps) GetGetHits() int64
- func (x *DMaps) GetGetMisses() int64
- func (msg *DMaps) MarshalJSON() ([]byte, error)
- func (*DMaps) ProtoMessage()
- func (x *DMaps) ProtoReflect() protoreflect.Message
- func (x *DMaps) Reset()
- func (x *DMaps) String() string
- func (msg *DMaps) UnmarshalJSON(b []byte) error
- func (m *DMaps) Validate() error
- func (m *DMaps) ValidateAll() error
- type DMapsMultiError
- type DMapsValidationError
- type DTopics
- func (in *DTopics) DeepCopy() *DTopics
- func (in *DTopics) DeepCopyInterface() interface{}
- func (in *DTopics) DeepCopyInto(out *DTopics)
- func (*DTopics) Descriptor() ([]byte, []int)deprecated
- func (x *DTopics) GetCurrentListeners() int64
- func (x *DTopics) GetListenersTotal() int64
- func (x *DTopics) GetPublishedTotal() int64
- func (msg *DTopics) MarshalJSON() ([]byte, error)
- func (*DTopics) ProtoMessage()
- func (x *DTopics) ProtoReflect() protoreflect.Message
- func (x *DTopics) Reset()
- func (x *DTopics) String() string
- func (msg *DTopics) UnmarshalJSON(b []byte) error
- func (m *DTopics) Validate() error
- func (m *DTopics) ValidateAll() error
- type DTopicsMultiError
- type DTopicsValidationError
- type DistCacheServiceClient
- type DistCacheServiceServer
- type Member
- func (in *Member) DeepCopy() *Member
- func (in *Member) DeepCopyInterface() interface{}
- func (in *Member) DeepCopyInto(out *Member)
- func (*Member) Descriptor() ([]byte, []int)deprecated
- func (x *Member) GetBirthdate() int64
- func (x *Member) GetId() uint64
- func (x *Member) GetName() string
- func (msg *Member) MarshalJSON() ([]byte, error)
- func (*Member) ProtoMessage()
- func (x *Member) ProtoReflect() protoreflect.Message
- func (x *Member) Reset()
- func (x *Member) String() string
- func (msg *Member) UnmarshalJSON(b []byte) error
- func (m *Member) Validate() error
- func (m *Member) ValidateAll() error
- type MemberMultiError
- type MemberValidationError
- type Network
- func (in *Network) DeepCopy() *Network
- func (in *Network) DeepCopyInterface() interface{}
- func (in *Network) DeepCopyInto(out *Network)
- func (*Network) Descriptor() ([]byte, []int)deprecated
- func (x *Network) GetCommandsTotal() int64
- func (x *Network) GetConnectionsTotal() int64
- func (x *Network) GetCurrentConnections() int64
- func (x *Network) GetReadBytesTotal() int64
- func (x *Network) GetWrittenBytesTotal() int64
- func (msg *Network) MarshalJSON() ([]byte, error)
- func (*Network) ProtoMessage()
- func (x *Network) ProtoReflect() protoreflect.Message
- func (x *Network) Reset()
- func (x *Network) String() string
- func (msg *Network) UnmarshalJSON(b []byte) error
- func (m *Network) Validate() error
- func (m *Network) ValidateAll() error
- type NetworkMultiError
- type NetworkValidationError
- type Partition
- func (in *Partition) DeepCopy() *Partition
- func (in *Partition) DeepCopyInterface() interface{}
- func (in *Partition) DeepCopyInto(out *Partition)
- func (*Partition) Descriptor() ([]byte, []int)deprecated
- func (x *Partition) GetBackups() []*Member
- func (x *Partition) GetDMaps() map[string]*DMap
- func (x *Partition) GetLength() int64
- func (x *Partition) GetPreviousOwners() []*Member
- func (msg *Partition) MarshalJSON() ([]byte, error)
- func (*Partition) ProtoMessage()
- func (x *Partition) ProtoReflect() protoreflect.Message
- func (x *Partition) Reset()
- func (x *Partition) String() string
- func (msg *Partition) UnmarshalJSON(b []byte) error
- func (m *Partition) Validate() error
- func (m *Partition) ValidateAll() error
- type PartitionMultiError
- type PartitionValidationError
- type Runtime
- func (in *Runtime) DeepCopy() *Runtime
- func (in *Runtime) DeepCopyInterface() interface{}
- func (in *Runtime) DeepCopyInto(out *Runtime)
- func (*Runtime) Descriptor() ([]byte, []int)deprecated
- func (x *Runtime) GetGoArch() string
- func (x *Runtime) GetGoOs() string
- func (x *Runtime) GetMemStats() *structpb.Struct
- func (x *Runtime) GetNumCpu() int64
- func (x *Runtime) GetNumGoroutine() int64
- func (x *Runtime) GetVersion() string
- func (msg *Runtime) MarshalJSON() ([]byte, error)
- func (*Runtime) ProtoMessage()
- func (x *Runtime) ProtoReflect() protoreflect.Message
- func (x *Runtime) Reset()
- func (x *Runtime) String() string
- func (msg *Runtime) UnmarshalJSON(b []byte) error
- func (m *Runtime) Validate() error
- func (m *Runtime) ValidateAll() error
- type RuntimeMultiError
- type RuntimeValidationError
- type SlabInfo
- func (in *SlabInfo) DeepCopy() *SlabInfo
- func (in *SlabInfo) DeepCopyInterface() interface{}
- func (in *SlabInfo) DeepCopyInto(out *SlabInfo)
- func (*SlabInfo) Descriptor() ([]byte, []int)deprecated
- func (x *SlabInfo) GetAllocated() int64
- func (x *SlabInfo) GetGarbage() int64
- func (x *SlabInfo) GetInuse() int64
- func (msg *SlabInfo) MarshalJSON() ([]byte, error)
- func (*SlabInfo) ProtoMessage()
- func (x *SlabInfo) ProtoReflect() protoreflect.Message
- func (x *SlabInfo) Reset()
- func (x *SlabInfo) String() string
- func (msg *SlabInfo) UnmarshalJSON(b []byte) error
- func (m *SlabInfo) Validate() error
- func (m *SlabInfo) ValidateAll() error
- type SlabInfoMultiError
- type SlabInfoValidationError
- type Stats
- func (in *Stats) DeepCopy() *Stats
- func (in *Stats) DeepCopyInterface() interface{}
- func (in *Stats) DeepCopyInto(out *Stats)
- func (*Stats) Descriptor() ([]byte, []int)deprecated
- func (x *Stats) GetBackups() map[uint64]*Partition
- func (x *Stats) GetClusterCoordinator() *Member
- func (x *Stats) GetClusterMembers() map[uint64]*Member
- func (x *Stats) GetCmdline() []string
- func (x *Stats) GetDMaps() *DMaps
- func (x *Stats) GetDTopics() *DTopics
- func (x *Stats) GetMember() *Member
- func (x *Stats) GetNetwork() *Network
- func (x *Stats) GetPartitions() map[uint64]*Partition
- func (x *Stats) GetReleaseVersion() string
- func (x *Stats) GetRuntime() *structpb.Struct
- func (x *Stats) GetUptimeSeconds() int64
- func (msg *Stats) MarshalJSON() ([]byte, error)
- func (*Stats) ProtoMessage()
- func (x *Stats) ProtoReflect() protoreflect.Message
- func (x *Stats) Reset()
- func (x *Stats) String() string
- func (msg *Stats) UnmarshalJSON(b []byte) error
- func (m *Stats) Validate() error
- func (m *Stats) ValidateAll() error
- type StatsMultiError
- type StatsValidationError
- type UnimplementedDistCacheServiceServer
- type UnsafeDistCacheServiceServer
Constants ¶
const (
DistCacheService_GetStats_FullMethodName = "/aperture.distcache.v1.DistCacheService/GetStats"
)
Variables ¶
var DistCacheService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "aperture.distcache.v1.DistCacheService", HandlerType: (*DistCacheServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetStats", Handler: _DistCacheService_GetStats_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "aperture/distcache/v1/stats.proto", }
DistCacheService_ServiceDesc is the grpc.ServiceDesc for DistCacheService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_aperture_distcache_v1_stats_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDistCacheServiceHandler ¶
func RegisterDistCacheServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterDistCacheServiceHandler registers the http handlers for service DistCacheService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterDistCacheServiceHandlerClient ¶
func RegisterDistCacheServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DistCacheServiceClient) error
RegisterDistCacheServiceHandlerClient registers the http handlers for service DistCacheService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DistCacheServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DistCacheServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DistCacheServiceClient" to call the correct interceptors.
func RegisterDistCacheServiceHandlerFromEndpoint ¶
func RegisterDistCacheServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterDistCacheServiceHandlerFromEndpoint is same as RegisterDistCacheServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterDistCacheServiceHandlerServer ¶
func RegisterDistCacheServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DistCacheServiceServer) error
RegisterDistCacheServiceHandlerServer registers the http handlers for service DistCacheService to "mux". UnaryRPC :call DistCacheServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterDistCacheServiceHandlerFromEndpoint instead.
func RegisterDistCacheServiceServer ¶
func RegisterDistCacheServiceServer(s grpc.ServiceRegistrar, srv DistCacheServiceServer)
Types ¶
type DMap ¶
type DMap struct { Length int64 `protobuf:"varint,1,opt,name=length,json=Length,proto3" json:"length,omitempty"` SlabInfo *SlabInfo `protobuf:"bytes,2,opt,name=slab_info,json=SlabInfo,proto3" json:"slab_info,omitempty"` NumTables int64 `protobuf:"varint,3,opt,name=num_tables,json=NumTables,proto3" json:"num_tables,omitempty"` // contains filtered or unexported fields }
func (*DMap) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DMap. Required by controller-gen.
func (*DMap) DeepCopyInterface ¶
func (in *DMap) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new DMap. Required by controller-gen.
func (*DMap) DeepCopyInto ¶
DeepCopyInto supports using DMap within kubernetes types, where deepcopy-gen is used.
func (*DMap) Descriptor
deprecated
func (*DMap) GetNumTables ¶
func (*DMap) GetSlabInfo ¶
func (*DMap) MarshalJSON ¶
MarshalJSON implements json.Marshaler
func (*DMap) ProtoMessage ¶
func (*DMap) ProtoMessage()
func (*DMap) ProtoReflect ¶
func (x *DMap) ProtoReflect() protoreflect.Message
func (*DMap) UnmarshalJSON ¶
UnmarshalJSON implements json.Unmarshaler
func (*DMap) Validate ¶ added in v1.2.0
Validate checks the field values on DMap 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 (*DMap) ValidateAll ¶ added in v1.2.0
ValidateAll checks the field values on DMap 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 DMapMultiError, or nil if none found.
type DMapMultiError ¶ added in v1.2.0
type DMapMultiError []error
DMapMultiError is an error wrapping multiple validation errors returned by DMap.ValidateAll() if the designated constraints aren't met.
func (DMapMultiError) AllErrors ¶ added in v1.2.0
func (m DMapMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DMapMultiError) Error ¶ added in v1.2.0
func (m DMapMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DMapValidationError ¶ added in v1.2.0
type DMapValidationError struct {
// contains filtered or unexported fields
}
DMapValidationError is the validation error returned by DMap.Validate if the designated constraints aren't met.
func (DMapValidationError) Cause ¶ added in v1.2.0
func (e DMapValidationError) Cause() error
Cause function returns cause value.
func (DMapValidationError) Error ¶ added in v1.2.0
func (e DMapValidationError) Error() string
Error satisfies the builtin error interface
func (DMapValidationError) ErrorName ¶ added in v1.2.0
func (e DMapValidationError) ErrorName() string
ErrorName returns error name.
func (DMapValidationError) Field ¶ added in v1.2.0
func (e DMapValidationError) Field() string
Field function returns field value.
func (DMapValidationError) Key ¶ added in v1.2.0
func (e DMapValidationError) Key() bool
Key function returns key value.
func (DMapValidationError) Reason ¶ added in v1.2.0
func (e DMapValidationError) Reason() string
Reason function returns reason value.
type DMaps ¶
type DMaps struct { EntriesTotal int64 `protobuf:"varint,1,opt,name=entries_total,json=EntriesTotal,proto3" json:"entries_total,omitempty"` DeleteHits int64 `protobuf:"varint,2,opt,name=delete_hits,json=DeleteHits,proto3" json:"delete_hits,omitempty"` DeleteMisses int64 `protobuf:"varint,3,opt,name=delete_misses,json=DeleteMisses,proto3" json:"delete_misses,omitempty"` GetMisses int64 `protobuf:"varint,4,opt,name=get_misses,json=GetMisses,proto3" json:"get_misses,omitempty"` GetHits int64 `protobuf:"varint,5,opt,name=get_hits,json=GetHits,proto3" json:"get_hits,omitempty"` EvictedTotal int64 `protobuf:"varint,6,opt,name=evicted_total,json=EvictedTotal,proto3" json:"evicted_total,omitempty"` // contains filtered or unexported fields }
func (*DMaps) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DMaps. Required by controller-gen.
func (*DMaps) DeepCopyInterface ¶
func (in *DMaps) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new DMaps. Required by controller-gen.
func (*DMaps) DeepCopyInto ¶
DeepCopyInto supports using DMaps within kubernetes types, where deepcopy-gen is used.
func (*DMaps) Descriptor
deprecated
func (*DMaps) GetDeleteHits ¶
func (*DMaps) GetDeleteMisses ¶
func (*DMaps) GetEntriesTotal ¶
func (*DMaps) GetEvictedTotal ¶
func (*DMaps) GetGetHits ¶
func (*DMaps) GetGetMisses ¶
func (*DMaps) MarshalJSON ¶
MarshalJSON implements json.Marshaler
func (*DMaps) ProtoMessage ¶
func (*DMaps) ProtoMessage()
func (*DMaps) ProtoReflect ¶
func (x *DMaps) ProtoReflect() protoreflect.Message
func (*DMaps) UnmarshalJSON ¶
UnmarshalJSON implements json.Unmarshaler
func (*DMaps) Validate ¶ added in v1.2.0
Validate checks the field values on DMaps 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 (*DMaps) ValidateAll ¶ added in v1.2.0
ValidateAll checks the field values on DMaps 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 DMapsMultiError, or nil if none found.
type DMapsMultiError ¶ added in v1.2.0
type DMapsMultiError []error
DMapsMultiError is an error wrapping multiple validation errors returned by DMaps.ValidateAll() if the designated constraints aren't met.
func (DMapsMultiError) AllErrors ¶ added in v1.2.0
func (m DMapsMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DMapsMultiError) Error ¶ added in v1.2.0
func (m DMapsMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DMapsValidationError ¶ added in v1.2.0
type DMapsValidationError struct {
// contains filtered or unexported fields
}
DMapsValidationError is the validation error returned by DMaps.Validate if the designated constraints aren't met.
func (DMapsValidationError) Cause ¶ added in v1.2.0
func (e DMapsValidationError) Cause() error
Cause function returns cause value.
func (DMapsValidationError) Error ¶ added in v1.2.0
func (e DMapsValidationError) Error() string
Error satisfies the builtin error interface
func (DMapsValidationError) ErrorName ¶ added in v1.2.0
func (e DMapsValidationError) ErrorName() string
ErrorName returns error name.
func (DMapsValidationError) Field ¶ added in v1.2.0
func (e DMapsValidationError) Field() string
Field function returns field value.
func (DMapsValidationError) Key ¶ added in v1.2.0
func (e DMapsValidationError) Key() bool
Key function returns key value.
func (DMapsValidationError) Reason ¶ added in v1.2.0
func (e DMapsValidationError) Reason() string
Reason function returns reason value.
type DTopics ¶
type DTopics struct { PublishedTotal int64 `protobuf:"varint,1,opt,name=published_total,json=PublishedTotal,proto3" json:"published_total,omitempty"` CurrentListeners int64 `protobuf:"varint,2,opt,name=current_listeners,json=CurrentListeners,proto3" json:"current_listeners,omitempty"` ListenersTotal int64 `protobuf:"varint,3,opt,name=listeners_total,json=ListenersTotal,proto3" json:"listeners_total,omitempty"` // contains filtered or unexported fields }
func (*DTopics) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DTopics. Required by controller-gen.
func (*DTopics) DeepCopyInterface ¶
func (in *DTopics) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new DTopics. Required by controller-gen.
func (*DTopics) DeepCopyInto ¶
DeepCopyInto supports using DTopics within kubernetes types, where deepcopy-gen is used.
func (*DTopics) Descriptor
deprecated
func (*DTopics) GetCurrentListeners ¶
func (*DTopics) GetListenersTotal ¶
func (*DTopics) GetPublishedTotal ¶
func (*DTopics) MarshalJSON ¶
MarshalJSON implements json.Marshaler
func (*DTopics) ProtoMessage ¶
func (*DTopics) ProtoMessage()
func (*DTopics) ProtoReflect ¶
func (x *DTopics) ProtoReflect() protoreflect.Message
func (*DTopics) UnmarshalJSON ¶
UnmarshalJSON implements json.Unmarshaler
func (*DTopics) Validate ¶ added in v1.2.0
Validate checks the field values on DTopics 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 (*DTopics) ValidateAll ¶ added in v1.2.0
ValidateAll checks the field values on DTopics 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 DTopicsMultiError, or nil if none found.
type DTopicsMultiError ¶ added in v1.2.0
type DTopicsMultiError []error
DTopicsMultiError is an error wrapping multiple validation errors returned by DTopics.ValidateAll() if the designated constraints aren't met.
func (DTopicsMultiError) AllErrors ¶ added in v1.2.0
func (m DTopicsMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DTopicsMultiError) Error ¶ added in v1.2.0
func (m DTopicsMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DTopicsValidationError ¶ added in v1.2.0
type DTopicsValidationError struct {
// contains filtered or unexported fields
}
DTopicsValidationError is the validation error returned by DTopics.Validate if the designated constraints aren't met.
func (DTopicsValidationError) Cause ¶ added in v1.2.0
func (e DTopicsValidationError) Cause() error
Cause function returns cause value.
func (DTopicsValidationError) Error ¶ added in v1.2.0
func (e DTopicsValidationError) Error() string
Error satisfies the builtin error interface
func (DTopicsValidationError) ErrorName ¶ added in v1.2.0
func (e DTopicsValidationError) ErrorName() string
ErrorName returns error name.
func (DTopicsValidationError) Field ¶ added in v1.2.0
func (e DTopicsValidationError) Field() string
Field function returns field value.
func (DTopicsValidationError) Key ¶ added in v1.2.0
func (e DTopicsValidationError) Key() bool
Key function returns key value.
func (DTopicsValidationError) Reason ¶ added in v1.2.0
func (e DTopicsValidationError) Reason() string
Reason function returns reason value.
type DistCacheServiceClient ¶
type DistCacheServiceClient interface {
GetStats(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Stats, error)
}
DistCacheServiceClient is the client API for DistCacheService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewDistCacheServiceClient ¶
func NewDistCacheServiceClient(cc grpc.ClientConnInterface) DistCacheServiceClient
type DistCacheServiceServer ¶
DistCacheServiceServer is the server API for DistCacheService service. All implementations should embed UnimplementedDistCacheServiceServer for forward compatibility
type Member ¶
type Member struct { Name string `protobuf:"bytes,1,opt,name=name,json=Name,proto3" json:"name,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,json=ID,proto3" json:"id,omitempty"` Birthdate int64 `protobuf:"varint,3,opt,name=birthdate,json=Birthdate,proto3" json:"birthdate,omitempty"` // contains filtered or unexported fields }
func (*Member) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Member. Required by controller-gen.
func (*Member) DeepCopyInterface ¶
func (in *Member) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Member. Required by controller-gen.
func (*Member) DeepCopyInto ¶
DeepCopyInto supports using Member within kubernetes types, where deepcopy-gen is used.
func (*Member) Descriptor
deprecated
func (*Member) GetBirthdate ¶
func (*Member) MarshalJSON ¶
MarshalJSON implements json.Marshaler
func (*Member) ProtoMessage ¶
func (*Member) ProtoMessage()
func (*Member) ProtoReflect ¶
func (x *Member) ProtoReflect() protoreflect.Message
func (*Member) UnmarshalJSON ¶
UnmarshalJSON implements json.Unmarshaler
func (*Member) Validate ¶ added in v1.2.0
Validate checks the field values on Member 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 (*Member) ValidateAll ¶ added in v1.2.0
ValidateAll checks the field values on Member 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 MemberMultiError, or nil if none found.
type MemberMultiError ¶ added in v1.2.0
type MemberMultiError []error
MemberMultiError is an error wrapping multiple validation errors returned by Member.ValidateAll() if the designated constraints aren't met.
func (MemberMultiError) AllErrors ¶ added in v1.2.0
func (m MemberMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (MemberMultiError) Error ¶ added in v1.2.0
func (m MemberMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type MemberValidationError ¶ added in v1.2.0
type MemberValidationError struct {
// contains filtered or unexported fields
}
MemberValidationError is the validation error returned by Member.Validate if the designated constraints aren't met.
func (MemberValidationError) Cause ¶ added in v1.2.0
func (e MemberValidationError) Cause() error
Cause function returns cause value.
func (MemberValidationError) Error ¶ added in v1.2.0
func (e MemberValidationError) Error() string
Error satisfies the builtin error interface
func (MemberValidationError) ErrorName ¶ added in v1.2.0
func (e MemberValidationError) ErrorName() string
ErrorName returns error name.
func (MemberValidationError) Field ¶ added in v1.2.0
func (e MemberValidationError) Field() string
Field function returns field value.
func (MemberValidationError) Key ¶ added in v1.2.0
func (e MemberValidationError) Key() bool
Key function returns key value.
func (MemberValidationError) Reason ¶ added in v1.2.0
func (e MemberValidationError) Reason() string
Reason function returns reason value.
type Network ¶
type Network struct { ConnectionsTotal int64 `protobuf:"varint,1,opt,name=connections_total,json=ConnectionsTotal,proto3" json:"connections_total,omitempty"` CurrentConnections int64 `protobuf:"varint,2,opt,name=current_connections,json=CurrentConnections,proto3" json:"current_connections,omitempty"` WrittenBytesTotal int64 `protobuf:"varint,3,opt,name=written_bytes_total,json=WrittenBytesTotal,proto3" json:"written_bytes_total,omitempty"` ReadBytesTotal int64 `protobuf:"varint,4,opt,name=read_bytes_total,json=ReadBytesTotal,proto3" json:"read_bytes_total,omitempty"` CommandsTotal int64 `protobuf:"varint,5,opt,name=commands_total,json=CommandsTotal,proto3" json:"commands_total,omitempty"` // contains filtered or unexported fields }
func (*Network) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Network. Required by controller-gen.
func (*Network) DeepCopyInterface ¶
func (in *Network) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Network. Required by controller-gen.
func (*Network) DeepCopyInto ¶
DeepCopyInto supports using Network within kubernetes types, where deepcopy-gen is used.
func (*Network) Descriptor
deprecated
func (*Network) GetCommandsTotal ¶
func (*Network) GetConnectionsTotal ¶
func (*Network) GetCurrentConnections ¶
func (*Network) GetReadBytesTotal ¶
func (*Network) GetWrittenBytesTotal ¶
func (*Network) MarshalJSON ¶
MarshalJSON implements json.Marshaler
func (*Network) ProtoMessage ¶
func (*Network) ProtoMessage()
func (*Network) ProtoReflect ¶
func (x *Network) ProtoReflect() protoreflect.Message
func (*Network) UnmarshalJSON ¶
UnmarshalJSON implements json.Unmarshaler
func (*Network) Validate ¶ added in v1.2.0
Validate checks the field values on Network 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 (*Network) ValidateAll ¶ added in v1.2.0
ValidateAll checks the field values on Network 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 NetworkMultiError, or nil if none found.
type NetworkMultiError ¶ added in v1.2.0
type NetworkMultiError []error
NetworkMultiError is an error wrapping multiple validation errors returned by Network.ValidateAll() if the designated constraints aren't met.
func (NetworkMultiError) AllErrors ¶ added in v1.2.0
func (m NetworkMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (NetworkMultiError) Error ¶ added in v1.2.0
func (m NetworkMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type NetworkValidationError ¶ added in v1.2.0
type NetworkValidationError struct {
// contains filtered or unexported fields
}
NetworkValidationError is the validation error returned by Network.Validate if the designated constraints aren't met.
func (NetworkValidationError) Cause ¶ added in v1.2.0
func (e NetworkValidationError) Cause() error
Cause function returns cause value.
func (NetworkValidationError) Error ¶ added in v1.2.0
func (e NetworkValidationError) Error() string
Error satisfies the builtin error interface
func (NetworkValidationError) ErrorName ¶ added in v1.2.0
func (e NetworkValidationError) ErrorName() string
ErrorName returns error name.
func (NetworkValidationError) Field ¶ added in v1.2.0
func (e NetworkValidationError) Field() string
Field function returns field value.
func (NetworkValidationError) Key ¶ added in v1.2.0
func (e NetworkValidationError) Key() bool
Key function returns key value.
func (NetworkValidationError) Reason ¶ added in v1.2.0
func (e NetworkValidationError) Reason() string
Reason function returns reason value.
type Partition ¶
type Partition struct { PreviousOwners []*Member `protobuf:"bytes,1,rep,name=previous_owners,json=PreviousOwners,proto3" json:"previous_owners,omitempty"` Backups []*Member `protobuf:"bytes,2,rep,name=backups,json=Backups,proto3" json:"backups,omitempty"` Length int64 `protobuf:"varint,3,opt,name=length,json=Length,proto3" json:"length,omitempty"` DMaps map[string]*DMap `` /* 164-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Partition) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Partition. Required by controller-gen.
func (*Partition) DeepCopyInterface ¶
func (in *Partition) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Partition. Required by controller-gen.
func (*Partition) DeepCopyInto ¶
DeepCopyInto supports using Partition within kubernetes types, where deepcopy-gen is used.
func (*Partition) Descriptor
deprecated
func (*Partition) GetBackups ¶
func (*Partition) GetPreviousOwners ¶
func (*Partition) MarshalJSON ¶
MarshalJSON implements json.Marshaler
func (*Partition) ProtoMessage ¶
func (*Partition) ProtoMessage()
func (*Partition) ProtoReflect ¶
func (x *Partition) ProtoReflect() protoreflect.Message
func (*Partition) UnmarshalJSON ¶
UnmarshalJSON implements json.Unmarshaler
func (*Partition) Validate ¶ added in v1.2.0
Validate checks the field values on Partition 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 (*Partition) ValidateAll ¶ added in v1.2.0
ValidateAll checks the field values on Partition 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 PartitionMultiError, or nil if none found.
type PartitionMultiError ¶ added in v1.2.0
type PartitionMultiError []error
PartitionMultiError is an error wrapping multiple validation errors returned by Partition.ValidateAll() if the designated constraints aren't met.
func (PartitionMultiError) AllErrors ¶ added in v1.2.0
func (m PartitionMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (PartitionMultiError) Error ¶ added in v1.2.0
func (m PartitionMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type PartitionValidationError ¶ added in v1.2.0
type PartitionValidationError struct {
// contains filtered or unexported fields
}
PartitionValidationError is the validation error returned by Partition.Validate if the designated constraints aren't met.
func (PartitionValidationError) Cause ¶ added in v1.2.0
func (e PartitionValidationError) Cause() error
Cause function returns cause value.
func (PartitionValidationError) Error ¶ added in v1.2.0
func (e PartitionValidationError) Error() string
Error satisfies the builtin error interface
func (PartitionValidationError) ErrorName ¶ added in v1.2.0
func (e PartitionValidationError) ErrorName() string
ErrorName returns error name.
func (PartitionValidationError) Field ¶ added in v1.2.0
func (e PartitionValidationError) Field() string
Field function returns field value.
func (PartitionValidationError) Key ¶ added in v1.2.0
func (e PartitionValidationError) Key() bool
Key function returns key value.
func (PartitionValidationError) Reason ¶ added in v1.2.0
func (e PartitionValidationError) Reason() string
Reason function returns reason value.
type Runtime ¶
type Runtime struct { GoOs string `protobuf:"bytes,1,opt,name=go_os,json=GOOS,proto3" json:"go_os,omitempty"` GoArch string `protobuf:"bytes,2,opt,name=go_arch,json=GOARCH,proto3" json:"go_arch,omitempty"` Version string `protobuf:"bytes,3,opt,name=version,json=Version,proto3" json:"version,omitempty"` NumCpu int64 `protobuf:"varint,4,opt,name=num_cpu,json=NumCPU,proto3" json:"num_cpu,omitempty"` NumGoroutine int64 `protobuf:"varint,5,opt,name=num_goroutine,json=NumGoroutine,proto3" json:"num_goroutine,omitempty"` MemStats *structpb.Struct `protobuf:"bytes,6,opt,name=mem_stats,json=MemStats,proto3" json:"mem_stats,omitempty"` // contains filtered or unexported fields }
func (*Runtime) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Runtime. Required by controller-gen.
func (*Runtime) DeepCopyInterface ¶
func (in *Runtime) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Runtime. Required by controller-gen.
func (*Runtime) DeepCopyInto ¶
DeepCopyInto supports using Runtime within kubernetes types, where deepcopy-gen is used.
func (*Runtime) Descriptor
deprecated
func (*Runtime) GetMemStats ¶
func (*Runtime) GetNumGoroutine ¶
func (*Runtime) GetVersion ¶
func (*Runtime) MarshalJSON ¶
MarshalJSON implements json.Marshaler
func (*Runtime) ProtoMessage ¶
func (*Runtime) ProtoMessage()
func (*Runtime) ProtoReflect ¶
func (x *Runtime) ProtoReflect() protoreflect.Message
func (*Runtime) UnmarshalJSON ¶
UnmarshalJSON implements json.Unmarshaler
func (*Runtime) Validate ¶ added in v1.2.0
Validate checks the field values on Runtime 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 (*Runtime) ValidateAll ¶ added in v1.2.0
ValidateAll checks the field values on Runtime 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 RuntimeMultiError, or nil if none found.
type RuntimeMultiError ¶ added in v1.2.0
type RuntimeMultiError []error
RuntimeMultiError is an error wrapping multiple validation errors returned by Runtime.ValidateAll() if the designated constraints aren't met.
func (RuntimeMultiError) AllErrors ¶ added in v1.2.0
func (m RuntimeMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RuntimeMultiError) Error ¶ added in v1.2.0
func (m RuntimeMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RuntimeValidationError ¶ added in v1.2.0
type RuntimeValidationError struct {
// contains filtered or unexported fields
}
RuntimeValidationError is the validation error returned by Runtime.Validate if the designated constraints aren't met.
func (RuntimeValidationError) Cause ¶ added in v1.2.0
func (e RuntimeValidationError) Cause() error
Cause function returns cause value.
func (RuntimeValidationError) Error ¶ added in v1.2.0
func (e RuntimeValidationError) Error() string
Error satisfies the builtin error interface
func (RuntimeValidationError) ErrorName ¶ added in v1.2.0
func (e RuntimeValidationError) ErrorName() string
ErrorName returns error name.
func (RuntimeValidationError) Field ¶ added in v1.2.0
func (e RuntimeValidationError) Field() string
Field function returns field value.
func (RuntimeValidationError) Key ¶ added in v1.2.0
func (e RuntimeValidationError) Key() bool
Key function returns key value.
func (RuntimeValidationError) Reason ¶ added in v1.2.0
func (e RuntimeValidationError) Reason() string
Reason function returns reason value.
type SlabInfo ¶
type SlabInfo struct { Allocated int64 `protobuf:"varint,1,opt,name=allocated,json=Allocated,proto3" json:"allocated,omitempty"` Inuse int64 `protobuf:"varint,2,opt,name=inuse,json=Inuse,proto3" json:"inuse,omitempty"` Garbage int64 `protobuf:"varint,3,opt,name=garbage,json=Garbage,proto3" json:"garbage,omitempty"` // contains filtered or unexported fields }
func (*SlabInfo) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SlabInfo. Required by controller-gen.
func (*SlabInfo) DeepCopyInterface ¶
func (in *SlabInfo) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new SlabInfo. Required by controller-gen.
func (*SlabInfo) DeepCopyInto ¶
DeepCopyInto supports using SlabInfo within kubernetes types, where deepcopy-gen is used.
func (*SlabInfo) Descriptor
deprecated
func (*SlabInfo) GetAllocated ¶
func (*SlabInfo) GetGarbage ¶
func (*SlabInfo) MarshalJSON ¶
MarshalJSON implements json.Marshaler
func (*SlabInfo) ProtoMessage ¶
func (*SlabInfo) ProtoMessage()
func (*SlabInfo) ProtoReflect ¶
func (x *SlabInfo) ProtoReflect() protoreflect.Message
func (*SlabInfo) UnmarshalJSON ¶
UnmarshalJSON implements json.Unmarshaler
func (*SlabInfo) Validate ¶ added in v1.2.0
Validate checks the field values on SlabInfo 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 (*SlabInfo) ValidateAll ¶ added in v1.2.0
ValidateAll checks the field values on SlabInfo 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 SlabInfoMultiError, or nil if none found.
type SlabInfoMultiError ¶ added in v1.2.0
type SlabInfoMultiError []error
SlabInfoMultiError is an error wrapping multiple validation errors returned by SlabInfo.ValidateAll() if the designated constraints aren't met.
func (SlabInfoMultiError) AllErrors ¶ added in v1.2.0
func (m SlabInfoMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (SlabInfoMultiError) Error ¶ added in v1.2.0
func (m SlabInfoMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type SlabInfoValidationError ¶ added in v1.2.0
type SlabInfoValidationError struct {
// contains filtered or unexported fields
}
SlabInfoValidationError is the validation error returned by SlabInfo.Validate if the designated constraints aren't met.
func (SlabInfoValidationError) Cause ¶ added in v1.2.0
func (e SlabInfoValidationError) Cause() error
Cause function returns cause value.
func (SlabInfoValidationError) Error ¶ added in v1.2.0
func (e SlabInfoValidationError) Error() string
Error satisfies the builtin error interface
func (SlabInfoValidationError) ErrorName ¶ added in v1.2.0
func (e SlabInfoValidationError) ErrorName() string
ErrorName returns error name.
func (SlabInfoValidationError) Field ¶ added in v1.2.0
func (e SlabInfoValidationError) Field() string
Field function returns field value.
func (SlabInfoValidationError) Key ¶ added in v1.2.0
func (e SlabInfoValidationError) Key() bool
Key function returns key value.
func (SlabInfoValidationError) Reason ¶ added in v1.2.0
func (e SlabInfoValidationError) Reason() string
Reason function returns reason value.
type Stats ¶
type Stats struct { Cmdline []string `protobuf:"bytes,1,rep,name=cmdline,json=Cmdline,proto3" json:"cmdline,omitempty"` ReleaseVersion string `protobuf:"bytes,2,opt,name=release_version,json=ReleaseVersion,proto3" json:"release_version,omitempty"` UptimeSeconds int64 `protobuf:"varint,3,opt,name=uptime_seconds,json=UptimeSeconds,proto3" json:"uptime_seconds,omitempty"` Runtime *structpb.Struct `protobuf:"bytes,4,opt,name=runtime,json=Runtime,proto3" json:"runtime,omitempty"` ClusterCoordinator *Member `protobuf:"bytes,5,opt,name=cluster_coordinator,json=ClusterCoordinator,proto3" json:"cluster_coordinator,omitempty"` Member *Member `protobuf:"bytes,6,opt,name=member,json=Member,proto3" json:"member,omitempty"` Partitions map[uint64]*Partition `` /* 178-byte string literal not displayed */ Backups map[uint64]*Partition `` /* 169-byte string literal not displayed */ ClusterMembers map[uint64]*Member `` /* 192-byte string literal not displayed */ Network *Network `protobuf:"bytes,10,opt,name=network,json=Network,proto3" json:"network,omitempty"` DMaps *DMaps `protobuf:"bytes,11,opt,name=d_maps,json=DMaps,proto3" json:"d_maps,omitempty"` DTopics *DTopics `protobuf:"bytes,12,opt,name=d_topics,json=DTopics,proto3" json:"d_topics,omitempty"` // contains filtered or unexported fields }
func (*Stats) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Stats. Required by controller-gen.
func (*Stats) DeepCopyInterface ¶
func (in *Stats) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Stats. Required by controller-gen.
func (*Stats) DeepCopyInto ¶
DeepCopyInto supports using Stats within kubernetes types, where deepcopy-gen is used.
func (*Stats) Descriptor
deprecated
func (*Stats) GetBackups ¶
func (*Stats) GetClusterCoordinator ¶
func (*Stats) GetClusterMembers ¶
func (*Stats) GetCmdline ¶
func (*Stats) GetDTopics ¶
func (*Stats) GetNetwork ¶
func (*Stats) GetPartitions ¶
func (*Stats) GetReleaseVersion ¶
func (*Stats) GetRuntime ¶
func (*Stats) GetUptimeSeconds ¶
func (*Stats) MarshalJSON ¶
MarshalJSON implements json.Marshaler
func (*Stats) ProtoMessage ¶
func (*Stats) ProtoMessage()
func (*Stats) ProtoReflect ¶
func (x *Stats) ProtoReflect() protoreflect.Message
func (*Stats) UnmarshalJSON ¶
UnmarshalJSON implements json.Unmarshaler
func (*Stats) Validate ¶ added in v1.2.0
Validate checks the field values on Stats 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 (*Stats) ValidateAll ¶ added in v1.2.0
ValidateAll checks the field values on Stats 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 StatsMultiError, or nil if none found.
type StatsMultiError ¶ added in v1.2.0
type StatsMultiError []error
StatsMultiError is an error wrapping multiple validation errors returned by Stats.ValidateAll() if the designated constraints aren't met.
func (StatsMultiError) AllErrors ¶ added in v1.2.0
func (m StatsMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StatsMultiError) Error ¶ added in v1.2.0
func (m StatsMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StatsValidationError ¶ added in v1.2.0
type StatsValidationError struct {
// contains filtered or unexported fields
}
StatsValidationError is the validation error returned by Stats.Validate if the designated constraints aren't met.
func (StatsValidationError) Cause ¶ added in v1.2.0
func (e StatsValidationError) Cause() error
Cause function returns cause value.
func (StatsValidationError) Error ¶ added in v1.2.0
func (e StatsValidationError) Error() string
Error satisfies the builtin error interface
func (StatsValidationError) ErrorName ¶ added in v1.2.0
func (e StatsValidationError) ErrorName() string
ErrorName returns error name.
func (StatsValidationError) Field ¶ added in v1.2.0
func (e StatsValidationError) Field() string
Field function returns field value.
func (StatsValidationError) Key ¶ added in v1.2.0
func (e StatsValidationError) Key() bool
Key function returns key value.
func (StatsValidationError) Reason ¶ added in v1.2.0
func (e StatsValidationError) Reason() string
Reason function returns reason value.
type UnimplementedDistCacheServiceServer ¶
type UnimplementedDistCacheServiceServer struct { }
UnimplementedDistCacheServiceServer should be embedded to have forward compatible implementations.
type UnsafeDistCacheServiceServer ¶
type UnsafeDistCacheServiceServer interface {
// contains filtered or unexported methods
}
UnsafeDistCacheServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DistCacheServiceServer will result in compilation errors.