distcachev1

package
v2.3.1-rc.1 Latest Latest
Warning

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

 Go to latest Published: May 31, 2023 License: Apache-2.0 Imports: 32 Imported by: 0

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

View Source 
const (
	DistCacheService_GetStats_FullMethodName = "/aperture.distcache.v1.DistCacheService/GetStats"
)

Variables

View Source 
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)

View Source 
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 

func (in *DMap) DeepCopy() *DMap

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 

func (in *DMap) DeepCopyInto(out *DMap)

DeepCopyInto supports using DMap within kubernetes types, where deepcopy-gen is used.

func (*DMap) Descriptor deprecated 

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

Deprecated: Use DMap.ProtoReflect.Descriptor instead.

func (*DMap) GetLength 

func (x *DMap) GetLength() int64

func (*DMap) GetNumTables 

func (x *DMap) GetNumTables() int64

func (*DMap) GetSlabInfo 

func (x *DMap) GetSlabInfo() *SlabInfo

func (*DMap) MarshalJSON 

func (msg *DMap) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*DMap) ProtoMessage 

func (*DMap) ProtoMessage()

func (*DMap) ProtoReflect 

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

func (*DMap) Reset 

func (x *DMap) Reset()

func (*DMap) String 

func (x *DMap) String() string

func (*DMap) UnmarshalJSON 

func (msg *DMap) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*DMap) Validate 

func (m *DMap) Validate() error

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 

func (m *DMap) ValidateAll() error

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 

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 

func (m DMapMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DMapMultiError) Error 

func (m DMapMultiError) Error() string

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

type DMapValidationError 

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 

func (e DMapValidationError) Cause() error

Cause function returns cause value.

func (DMapValidationError) Error 

func (e DMapValidationError) Error() string

Error satisfies the builtin error interface

func (DMapValidationError) ErrorName 

func (e DMapValidationError) ErrorName() string

ErrorName returns error name.

func (DMapValidationError) Field 

func (e DMapValidationError) Field() string

Field function returns field value.

func (DMapValidationError) Key 

func (e DMapValidationError) Key() bool

Key function returns key value.

func (DMapValidationError) Reason 

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 

func (in *DMaps) DeepCopy() *DMaps

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 

func (in *DMaps) DeepCopyInto(out *DMaps)

DeepCopyInto supports using DMaps within kubernetes types, where deepcopy-gen is used.

func (*DMaps) Descriptor deprecated 

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

Deprecated: Use DMaps.ProtoReflect.Descriptor instead.

func (*DMaps) GetDeleteHits 

func (x *DMaps) GetDeleteHits() int64

func (*DMaps) GetDeleteMisses 

func (x *DMaps) GetDeleteMisses() int64

func (*DMaps) GetEntriesTotal 

func (x *DMaps) GetEntriesTotal() int64

func (*DMaps) GetEvictedTotal 

func (x *DMaps) GetEvictedTotal() int64

func (*DMaps) GetGetHits 

func (x *DMaps) GetGetHits() int64

func (*DMaps) GetGetMisses 

func (x *DMaps) GetGetMisses() int64

func (*DMaps) MarshalJSON 

func (msg *DMaps) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*DMaps) ProtoMessage 

func (*DMaps) ProtoMessage()

func (*DMaps) ProtoReflect 

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

func (*DMaps) Reset 

func (x *DMaps) Reset()

func (*DMaps) String 

func (x *DMaps) String() string

func (*DMaps) UnmarshalJSON 

func (msg *DMaps) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*DMaps) Validate 

func (m *DMaps) Validate() error

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 

func (m *DMaps) ValidateAll() error

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 

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 

func (m DMapsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DMapsMultiError) Error 

func (m DMapsMultiError) Error() string

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

type DMapsValidationError 

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 

func (e DMapsValidationError) Cause() error

Cause function returns cause value.

func (DMapsValidationError) Error 

func (e DMapsValidationError) Error() string

Error satisfies the builtin error interface

func (DMapsValidationError) ErrorName 

func (e DMapsValidationError) ErrorName() string

ErrorName returns error name.

func (DMapsValidationError) Field 

func (e DMapsValidationError) Field() string

Field function returns field value.

func (DMapsValidationError) Key 

func (e DMapsValidationError) Key() bool

Key function returns key value.

func (DMapsValidationError) Reason 

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 

func (in *DTopics) DeepCopy() *DTopics

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 

func (in *DTopics) DeepCopyInto(out *DTopics)

DeepCopyInto supports using DTopics within kubernetes types, where deepcopy-gen is used.

func (*DTopics) Descriptor deprecated 

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

Deprecated: Use DTopics.ProtoReflect.Descriptor instead.

func (*DTopics) GetCurrentListeners 

func (x *DTopics) GetCurrentListeners() int64

func (*DTopics) GetListenersTotal 

func (x *DTopics) GetListenersTotal() int64

func (*DTopics) GetPublishedTotal 

func (x *DTopics) GetPublishedTotal() int64

func (*DTopics) MarshalJSON 

func (msg *DTopics) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*DTopics) ProtoMessage 

func (*DTopics) ProtoMessage()

func (*DTopics) ProtoReflect 

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

func (*DTopics) Reset 

func (x *DTopics) Reset()

func (*DTopics) String 

func (x *DTopics) String() string

func (*DTopics) UnmarshalJSON 

func (msg *DTopics) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*DTopics) Validate 

func (m *DTopics) Validate() error

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 

func (m *DTopics) ValidateAll() error

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 

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 

func (m DTopicsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DTopicsMultiError) Error 

func (m DTopicsMultiError) Error() string

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

type DTopicsValidationError 

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 

func (e DTopicsValidationError) Cause() error

Cause function returns cause value.

func (DTopicsValidationError) Error 

func (e DTopicsValidationError) Error() string

Error satisfies the builtin error interface

func (DTopicsValidationError) ErrorName 

func (e DTopicsValidationError) ErrorName() string

ErrorName returns error name.

func (DTopicsValidationError) Field 

func (e DTopicsValidationError) Field() string

Field function returns field value.

func (DTopicsValidationError) Key 

func (e DTopicsValidationError) Key() bool

Key function returns key value.

func (DTopicsValidationError) Reason 

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 

type DistCacheServiceServer interface {
	GetStats(context.Context, *emptypb.Empty) (*Stats, error)
}

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 

func (in *Member) DeepCopy() *Member

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 

func (in *Member) DeepCopyInto(out *Member)

DeepCopyInto supports using Member within kubernetes types, where deepcopy-gen is used.

func (*Member) Descriptor deprecated 

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

Deprecated: Use Member.ProtoReflect.Descriptor instead.

func (*Member) GetBirthdate 

func (x *Member) GetBirthdate() int64

func (*Member) GetId 

func (x *Member) GetId() uint64

func (*Member) GetName 

func (x *Member) GetName() string

func (*Member) MarshalJSON 

func (msg *Member) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Member) ProtoMessage 

func (*Member) ProtoMessage()

func (*Member) ProtoReflect 

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

func (*Member) Reset 

func (x *Member) Reset()

func (*Member) String 

func (x *Member) String() string

func (*Member) UnmarshalJSON 

func (msg *Member) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Member) Validate 

func (m *Member) Validate() error

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 

func (m *Member) ValidateAll() error

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 

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 

func (m MemberMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (MemberMultiError) Error 

func (m MemberMultiError) Error() string

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

type MemberValidationError 

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 

func (e MemberValidationError) Cause() error

Cause function returns cause value.

func (MemberValidationError) Error 

func (e MemberValidationError) Error() string

Error satisfies the builtin error interface

func (MemberValidationError) ErrorName 

func (e MemberValidationError) ErrorName() string

ErrorName returns error name.

func (MemberValidationError) Field 

func (e MemberValidationError) Field() string

Field function returns field value.

func (MemberValidationError) Key 

func (e MemberValidationError) Key() bool

Key function returns key value.

func (MemberValidationError) Reason 

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 

func (in *Network) DeepCopy() *Network

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 

func (in *Network) DeepCopyInto(out *Network)

DeepCopyInto supports using Network within kubernetes types, where deepcopy-gen is used.

func (*Network) Descriptor deprecated 

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

Deprecated: Use Network.ProtoReflect.Descriptor instead.

func (*Network) GetCommandsTotal 

func (x *Network) GetCommandsTotal() int64

func (*Network) GetConnectionsTotal 

func (x *Network) GetConnectionsTotal() int64

func (*Network) GetCurrentConnections 

func (x *Network) GetCurrentConnections() int64

func (*Network) GetReadBytesTotal 

func (x *Network) GetReadBytesTotal() int64

func (*Network) GetWrittenBytesTotal 

func (x *Network) GetWrittenBytesTotal() int64

func (*Network) MarshalJSON 

func (msg *Network) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Network) ProtoMessage 

func (*Network) ProtoMessage()

func (*Network) ProtoReflect 

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

func (*Network) Reset 

func (x *Network) Reset()

func (*Network) String 

func (x *Network) String() string

func (*Network) UnmarshalJSON 

func (msg *Network) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Network) Validate 

func (m *Network) Validate() error

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 

func (m *Network) ValidateAll() error

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 

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 

func (m NetworkMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NetworkMultiError) Error 

func (m NetworkMultiError) Error() string

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

type NetworkValidationError 

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 

func (e NetworkValidationError) Cause() error

Cause function returns cause value.

func (NetworkValidationError) Error 

func (e NetworkValidationError) Error() string

Error satisfies the builtin error interface

func (NetworkValidationError) ErrorName 

func (e NetworkValidationError) ErrorName() string

ErrorName returns error name.

func (NetworkValidationError) Field 

func (e NetworkValidationError) Field() string

Field function returns field value.

func (NetworkValidationError) Key 

func (e NetworkValidationError) Key() bool

Key function returns key value.

func (NetworkValidationError) Reason 

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 

func (in *Partition) DeepCopy() *Partition

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 

func (in *Partition) DeepCopyInto(out *Partition)

DeepCopyInto supports using Partition within kubernetes types, where deepcopy-gen is used.

func (*Partition) Descriptor deprecated 

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

Deprecated: Use Partition.ProtoReflect.Descriptor instead.

func (*Partition) GetBackups 

func (x *Partition) GetBackups() []*Member

func (*Partition) GetDMaps 

func (x *Partition) GetDMaps() map[string]*DMap

func (*Partition) GetLength 

func (x *Partition) GetLength() int64

func (*Partition) GetPreviousOwners 

func (x *Partition) GetPreviousOwners() []*Member

func (*Partition) MarshalJSON 

func (msg *Partition) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Partition) ProtoMessage 

func (*Partition) ProtoMessage()

func (*Partition) ProtoReflect 

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

func (*Partition) Reset 

func (x *Partition) Reset()

func (*Partition) String 

func (x *Partition) String() string

func (*Partition) UnmarshalJSON 

func (msg *Partition) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Partition) Validate 

func (m *Partition) Validate() error

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 

func (m *Partition) ValidateAll() error

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 

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 

func (m PartitionMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PartitionMultiError) Error 

func (m PartitionMultiError) Error() string

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

type PartitionValidationError 

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 

func (e PartitionValidationError) Cause() error

Cause function returns cause value.

func (PartitionValidationError) Error 

func (e PartitionValidationError) Error() string

Error satisfies the builtin error interface

func (PartitionValidationError) ErrorName 

func (e PartitionValidationError) ErrorName() string

ErrorName returns error name.

func (PartitionValidationError) Field 

func (e PartitionValidationError) Field() string

Field function returns field value.

func (PartitionValidationError) Key 

func (e PartitionValidationError) Key() bool

Key function returns key value.

func (PartitionValidationError) Reason 

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 

func (in *Runtime) DeepCopy() *Runtime

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 

func (in *Runtime) DeepCopyInto(out *Runtime)

DeepCopyInto supports using Runtime within kubernetes types, where deepcopy-gen is used.

func (*Runtime) Descriptor deprecated 

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

Deprecated: Use Runtime.ProtoReflect.Descriptor instead.

func (*Runtime) GetGoArch 

func (x *Runtime) GetGoArch() string

func (*Runtime) GetGoOs 

func (x *Runtime) GetGoOs() string

func (*Runtime) GetMemStats 

func (x *Runtime) GetMemStats() *structpb.Struct

func (*Runtime) GetNumCpu 

func (x *Runtime) GetNumCpu() int64

func (*Runtime) GetNumGoroutine 

func (x *Runtime) GetNumGoroutine() int64

func (*Runtime) GetVersion 

func (x *Runtime) GetVersion() string

func (*Runtime) MarshalJSON 

func (msg *Runtime) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Runtime) ProtoMessage 

func (*Runtime) ProtoMessage()

func (*Runtime) ProtoReflect 

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

func (*Runtime) Reset 

func (x *Runtime) Reset()

func (*Runtime) String 

func (x *Runtime) String() string

func (*Runtime) UnmarshalJSON 

func (msg *Runtime) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Runtime) Validate 

func (m *Runtime) Validate() error

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 

func (m *Runtime) ValidateAll() error

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 

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 

func (m RuntimeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RuntimeMultiError) Error 

func (m RuntimeMultiError) Error() string

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

type RuntimeValidationError 

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 

func (e RuntimeValidationError) Cause() error

Cause function returns cause value.

func (RuntimeValidationError) Error 

func (e RuntimeValidationError) Error() string

Error satisfies the builtin error interface

func (RuntimeValidationError) ErrorName 

func (e RuntimeValidationError) ErrorName() string

ErrorName returns error name.

func (RuntimeValidationError) Field 

func (e RuntimeValidationError) Field() string

Field function returns field value.

func (RuntimeValidationError) Key 

func (e RuntimeValidationError) Key() bool

Key function returns key value.

func (RuntimeValidationError) Reason 

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 

func (in *SlabInfo) DeepCopy() *SlabInfo

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 

func (in *SlabInfo) DeepCopyInto(out *SlabInfo)

DeepCopyInto supports using SlabInfo within kubernetes types, where deepcopy-gen is used.

func (*SlabInfo) Descriptor deprecated 

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

Deprecated: Use SlabInfo.ProtoReflect.Descriptor instead.

func (*SlabInfo) GetAllocated 

func (x *SlabInfo) GetAllocated() int64

func (*SlabInfo) GetGarbage 

func (x *SlabInfo) GetGarbage() int64

func (*SlabInfo) GetInuse 

func (x *SlabInfo) GetInuse() int64

func (*SlabInfo) MarshalJSON 

func (msg *SlabInfo) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*SlabInfo) ProtoMessage 

func (*SlabInfo) ProtoMessage()

func (*SlabInfo) ProtoReflect 

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

func (*SlabInfo) Reset 

func (x *SlabInfo) Reset()

func (*SlabInfo) String 

func (x *SlabInfo) String() string

func (*SlabInfo) UnmarshalJSON 

func (msg *SlabInfo) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*SlabInfo) Validate 

func (m *SlabInfo) Validate() error

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 

func (m *SlabInfo) ValidateAll() error

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 

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 

func (m SlabInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SlabInfoMultiError) Error 

func (m SlabInfoMultiError) Error() string

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

type SlabInfoValidationError 

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 

func (e SlabInfoValidationError) Cause() error

Cause function returns cause value.

func (SlabInfoValidationError) Error 

func (e SlabInfoValidationError) Error() string

Error satisfies the builtin error interface

func (SlabInfoValidationError) ErrorName 

func (e SlabInfoValidationError) ErrorName() string

ErrorName returns error name.

func (SlabInfoValidationError) Field 

func (e SlabInfoValidationError) Field() string

Field function returns field value.

func (SlabInfoValidationError) Key 

func (e SlabInfoValidationError) Key() bool

Key function returns key value.

func (SlabInfoValidationError) Reason 

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 

func (in *Stats) DeepCopy() *Stats

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 

func (in *Stats) DeepCopyInto(out *Stats)

DeepCopyInto supports using Stats within kubernetes types, where deepcopy-gen is used.

func (*Stats) Descriptor deprecated 

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

Deprecated: Use Stats.ProtoReflect.Descriptor instead.

func (*Stats) GetBackups 

func (x *Stats) GetBackups() map[uint64]*Partition

func (*Stats) GetClusterCoordinator 

func (x *Stats) GetClusterCoordinator() *Member

func (*Stats) GetClusterMembers 

func (x *Stats) GetClusterMembers() map[uint64]*Member

func (*Stats) GetCmdline 

func (x *Stats) GetCmdline() []string

func (*Stats) GetDMaps 

func (x *Stats) GetDMaps() *DMaps

func (*Stats) GetDTopics 

func (x *Stats) GetDTopics() *DTopics

func (*Stats) GetMember 

func (x *Stats) GetMember() *Member

func (*Stats) GetNetwork 

func (x *Stats) GetNetwork() *Network

func (*Stats) GetPartitions 

func (x *Stats) GetPartitions() map[uint64]*Partition

func (*Stats) GetReleaseVersion 

func (x *Stats) GetReleaseVersion() string

func (*Stats) GetRuntime 

func (x *Stats) GetRuntime() *structpb.Struct

func (*Stats) GetUptimeSeconds 

func (x *Stats) GetUptimeSeconds() int64

func (*Stats) MarshalJSON 

func (msg *Stats) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Stats) ProtoMessage 

func (*Stats) ProtoMessage()

func (*Stats) ProtoReflect 

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

func (*Stats) Reset 

func (x *Stats) Reset()

func (*Stats) String 

func (x *Stats) String() string

func (*Stats) UnmarshalJSON 

func (msg *Stats) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Stats) Validate 

func (m *Stats) Validate() error

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 

func (m *Stats) ValidateAll() error

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 

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 

func (m StatsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatsMultiError) Error 

func (m StatsMultiError) Error() string

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

type StatsValidationError 

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 

func (e StatsValidationError) Cause() error

Cause function returns cause value.

func (StatsValidationError) Error 

func (e StatsValidationError) Error() string

Error satisfies the builtin error interface

func (StatsValidationError) ErrorName 

func (e StatsValidationError) ErrorName() string

ErrorName returns error name.

func (StatsValidationError) Field 

func (e StatsValidationError) Field() string

Field function returns field value.

func (StatsValidationError) Key 

func (e StatsValidationError) Key() bool

Key function returns key value.

func (StatsValidationError) Reason 

func (e StatsValidationError) Reason() string

Reason function returns reason value.

type UnimplementedDistCacheServiceServer 

type UnimplementedDistCacheServiceServer struct {
}

UnimplementedDistCacheServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedDistCacheServiceServer) GetStats 

func (UnimplementedDistCacheServiceServer) GetStats(context.Context, *emptypb.Empty) (*Stats, error)

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.

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.