Documentation
¶
Index ¶
- func StartGRPCGatewayServer(coord *coordinator.Coordinator, grpcAddr string, listenHTTP string)
- func StartGRPCServer(coord *coordinator.Coordinator, storage *stor.Storage, listenAddr string, ...)
- type CacheService
- func (s *CacheService) Delete(ctx context.Context, req *pb.DeleteRequest) (*pb.DeleteResponse, error)
- func (s *CacheService) Get(req *pb.GetRequest, stream pb.CacheService_GetServer) error
- func (s *CacheService) GetTopology(ctx context.Context, req *pb.GetTopologyRequest) (*pb.GetTopologyResponse, error)
- func (s *CacheService) List(ctx context.Context, req *pb.ListRequest) (*pb.ListResponse, error)
- func (s *CacheService) ListLocal(ctx context.Context, req *pb.ListRequest) (*pb.ListResponse, error)
- func (s *CacheService) ListLocalWithValues(ctx context.Context, req *pb.ListRequest) (*pb.ListWithValuesResponse, error)
- func (s *CacheService) ListWithValues(ctx context.Context, req *pb.ListRequest) (*pb.ListWithValuesResponse, error)
- func (s *CacheService) Operations() *operations.Operations
- func (s *CacheService) Put(stream pb.CacheService_PutServer) error
- func (s *CacheService) PutObject(ctx context.Context, req *pb.PutRequest) (*pb.PutResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func StartGRPCGatewayServer ¶
func StartGRPCGatewayServer(coord *coordinator.Coordinator, grpcAddr string, listenHTTP string)
func StartGRPCServer ¶
func StartGRPCServer(coord *coordinator.Coordinator, storage *stor.Storage, listenAddr string, requestLogging bool)
Types ¶
type CacheService ¶
type CacheService struct {
pb.UnimplementedCacheServiceServer
// contains filtered or unexported fields
}
CacheService implements pb.CacheServiceServer
func NewCacheService ¶
func NewCacheService(coord *coordinator.Coordinator, storage *stor.Storage) *CacheService
NewCacheService creates a new cache service, optionally with clustering support
func (*CacheService) Delete ¶
func (s *CacheService) Delete(ctx context.Context, req *pb.DeleteRequest) (*pb.DeleteResponse, error)
Delete implementation
func (*CacheService) Get ¶
func (s *CacheService) Get(req *pb.GetRequest, stream pb.CacheService_GetServer) error
Streaming Get for large values with byte-range support
func (*CacheService) GetTopology ¶
func (s *CacheService) GetTopology(ctx context.Context, req *pb.GetTopologyRequest) (*pb.GetTopologyResponse, error)
GetTopology returns the current cluster topology (for cluster-aware clients)
func (*CacheService) List ¶
func (s *CacheService) List(ctx context.Context, req *pb.ListRequest) (*pb.ListResponse, error)
List implements the public List RPC In cluster mode, coordinates K-way merge across all nodes via operations layer Returns a single response with sorted, paginated keys and continuation token
func (*CacheService) ListLocal ¶
func (s *CacheService) ListLocal(ctx context.Context, req *pb.ListRequest) (*pb.ListResponse, error)
ListLocal implements the internal node-local List RPC This is used by the coordinator to query individual nodes in cluster mode Returns sorted, paginated keys from this node's local storage
func (*CacheService) ListLocalWithValues ¶
func (s *CacheService) ListLocalWithValues(ctx context.Context, req *pb.ListRequest) (*pb.ListWithValuesResponse, error)
ListLocalWithValues implements the internal node-local ListWithValues RPC. Returns sorted, paginated key-value pairs from this node's local storage.
func (*CacheService) ListWithValues ¶
func (s *CacheService) ListWithValues(ctx context.Context, req *pb.ListRequest) (*pb.ListWithValuesResponse, error)
ListWithValues implements the public ListWithValues RPC. Returns sorted, paginated key-value pairs with continuation token.
func (*CacheService) Operations ¶
func (s *CacheService) Operations() *operations.Operations
Operations returns the underlying operations layer for embedded use. This allows embedded clients to access the routing logic directly.
func (*CacheService) Put ¶
func (s *CacheService) Put(stream pb.CacheService_PutServer) error
Streaming Put for large values
func (*CacheService) PutObject ¶
func (s *CacheService) PutObject(ctx context.Context, req *pb.PutRequest) (*pb.PutResponse, error)
PutObject implements the unary REST/HTTP endpoint for cache put
Source Files