distcachev1

package
v0.25.0-rc.2 Latest Latest
Warning

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

 Go to latest Published: Feb 27, 2023 License: Apache-2.0 Imports: 20 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

This section is empty.

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

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

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

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

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

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

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

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

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

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.