galaxycachepb

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(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 (x *GetRequest) GetGalaxy() string

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

func (*GetRequest) ProtoMessage()

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

func (x *GetRequest) Reset()

func (x *GetRequest) SetGalaxy(v string)

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

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 (b0 GetRequest_builder) Build() *GetRequest

type GetResponse ¶

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

func (x *GetResponse) ClearExpiry()

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

func (x *GetResponse) GetMinuteQps() float64

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

func (x *GetResponse) HasExpiry() bool

func (*GetResponse) ProtoMessage()

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

func (x *GetResponse) Reset()

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

func (x *GetResponse) SetMinuteQps(v float64)

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

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 (b0 GetResponse_builder) Build() *GetResponse

type PeekRequest ¶ added in v1.3.0

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

func (x *PeekRequest) GetGalaxy() string

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

func (*PeekRequest) ProtoMessage()

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

func (x *PeekRequest) Reset()

func (x *PeekRequest) SetGalaxy(v string)

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

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 (b0 PeekRequest_builder) Build() *PeekRequest

type PeekResponse ¶ added in v1.3.0

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

func (x *PeekResponse) ClearExpiry()

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

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

func (x *PeekResponse) HasExpiry() bool

func (*PeekResponse) ProtoMessage()

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

func (x *PeekResponse) Reset()

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

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

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 (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(context.Context, *GetRequest) (*GetResponse, error)

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.