galaxycachepb

package
v1.4.1 Latest Latest
Warning

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

 Go to latest Published: Jan 7, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	GalaxyCache_GetFromPeer_FullMethodName = "/galaxycachepb.GalaxyCache/GetFromPeer"
	GalaxyCache_PeekPeer_FullMethodName    = "/galaxycachepb.GalaxyCache/PeekPeer"
)

Variables

View Source 
var File_galaxycachepb_galaxycache_proto protoreflect.FileDescriptor
View Source 
var GalaxyCache_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "galaxycachepb.GalaxyCache",
	HandlerType: (*GalaxyCacheServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetFromPeer",
			Handler:    _GalaxyCache_GetFromPeer_Handler,
		},
		{
			MethodName: "PeekPeer",
			Handler:    _GalaxyCache_PeekPeer_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "galaxycachepb/galaxycache.proto",
}

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

Functions

func RegisterGalaxyCacheServer 

func RegisterGalaxyCacheServer(s grpc.ServiceRegistrar, srv GalaxyCacheServer)

Types

type GalaxyCacheClient 

type GalaxyCacheClient interface {
	GetFromPeer(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	PeekPeer(ctx context.Context, in *PeekRequest, opts ...grpc.CallOption) (*PeekResponse, error)
}

GalaxyCacheClient is the client API for GalaxyCache 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 NewGalaxyCacheClient 

func NewGalaxyCacheClient(cc grpc.ClientConnInterface) GalaxyCacheClient

type GalaxyCacheServer 

type GalaxyCacheServer interface {
	GetFromPeer(context.Context, *GetRequest) (*GetResponse, error)
	PeekPeer(context.Context, *PeekRequest) (*PeekResponse, error)
	// contains filtered or unexported methods
}

GalaxyCacheServer is the server API for GalaxyCache service. All implementations must embed UnimplementedGalaxyCacheServer for forward compatibility.

type GetRequest 

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

func (*GetRequest) GetGalaxy 

func (x *GetRequest) GetGalaxy() string

func (*GetRequest) GetKey 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect added in v1.0.2 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) SetGalaxy added in v1.3.0 

func (x *GetRequest) SetGalaxy(v string)

func (*GetRequest) SetKey added in v1.3.0 

func (x *GetRequest) SetKey(v []byte)

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetRequest_builder added in v1.3.0 

type GetRequest_builder struct {
	Galaxy string
	Key    []byte
	// contains filtered or unexported fields
}

func (GetRequest_builder) Build added in v1.3.0 

func (b0 GetRequest_builder) Build() *GetRequest

type GetResponse 

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

func (*GetResponse) ClearExpiry added in v1.4.0 

func (x *GetResponse) ClearExpiry()

func (*GetResponse) GetExpiry added in v1.4.0 

func (x *GetResponse) GetExpiry() *timestamppb.Timestamp

func (*GetResponse) GetMinuteQps 

func (x *GetResponse) GetMinuteQps() float64

func (*GetResponse) GetValue 

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

func (*GetResponse) HasExpiry added in v1.4.0 

func (x *GetResponse) HasExpiry() bool

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect added in v1.0.2 

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

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) SetExpiry added in v1.4.0 

func (x *GetResponse) SetExpiry(v *timestamppb.Timestamp)

func (*GetResponse) SetMinuteQps added in v1.3.0 

func (x *GetResponse) SetMinuteQps(v float64)

func (*GetResponse) SetValue added in v1.3.0 

func (x *GetResponse) SetValue(v []byte)

func (*GetResponse) String 

func (x *GetResponse) String() string

type GetResponse_builder added in v1.3.0 

type GetResponse_builder struct {
	Value     []byte
	MinuteQps float64
	Expiry    *timestamppb.Timestamp
	// contains filtered or unexported fields
}

func (GetResponse_builder) Build added in v1.3.0 

func (b0 GetResponse_builder) Build() *GetResponse

type PeekRequest added in v1.3.0 

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

func (*PeekRequest) GetGalaxy added in v1.3.0 

func (x *PeekRequest) GetGalaxy() string

func (*PeekRequest) GetKey added in v1.3.0 

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

func (*PeekRequest) ProtoMessage added in v1.3.0 

func (*PeekRequest) ProtoMessage()

func (*PeekRequest) ProtoReflect added in v1.3.0 

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

func (*PeekRequest) Reset added in v1.3.0 

func (x *PeekRequest) Reset()

func (*PeekRequest) SetGalaxy added in v1.3.0 

func (x *PeekRequest) SetGalaxy(v string)

func (*PeekRequest) SetKey added in v1.3.0 

func (x *PeekRequest) SetKey(v []byte)

func (*PeekRequest) String added in v1.3.0 

func (x *PeekRequest) String() string

type PeekRequest_builder added in v1.3.0 

type PeekRequest_builder struct {
	Galaxy string
	Key    []byte
	// contains filtered or unexported fields
}

func (PeekRequest_builder) Build added in v1.3.0 

func (b0 PeekRequest_builder) Build() *PeekRequest

type PeekResponse added in v1.3.0 

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

func (*PeekResponse) ClearExpiry added in v1.4.0 

func (x *PeekResponse) ClearExpiry()

func (*PeekResponse) GetExpiry added in v1.4.0 

func (x *PeekResponse) GetExpiry() *timestamppb.Timestamp

func (*PeekResponse) GetValue added in v1.3.0 

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

func (*PeekResponse) HasExpiry added in v1.4.0 

func (x *PeekResponse) HasExpiry() bool

func (*PeekResponse) ProtoMessage added in v1.3.0 

func (*PeekResponse) ProtoMessage()

func (*PeekResponse) ProtoReflect added in v1.3.0 

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

func (*PeekResponse) Reset added in v1.3.0 

func (x *PeekResponse) Reset()

func (*PeekResponse) SetExpiry added in v1.4.0 

func (x *PeekResponse) SetExpiry(v *timestamppb.Timestamp)

func (*PeekResponse) SetValue added in v1.3.0 

func (x *PeekResponse) SetValue(v []byte)

func (*PeekResponse) String added in v1.3.0 

func (x *PeekResponse) String() string

type PeekResponse_builder added in v1.3.0 

type PeekResponse_builder struct {
	Value  []byte
	Expiry *timestamppb.Timestamp
	// contains filtered or unexported fields
}

func (PeekResponse_builder) Build added in v1.3.0 

func (b0 PeekResponse_builder) Build() *PeekResponse

type UnimplementedGalaxyCacheServer added in v1.0.2 

type UnimplementedGalaxyCacheServer struct{}

UnimplementedGalaxyCacheServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedGalaxyCacheServer) GetFromPeer added in v1.0.2 

func (UnimplementedGalaxyCacheServer) GetFromPeer(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedGalaxyCacheServer) PeekPeer added in v1.3.0 

func (UnimplementedGalaxyCacheServer) PeekPeer(context.Context, *PeekRequest) (*PeekResponse, error)

type UnsafeGalaxyCacheServer added in v1.0.2 

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

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