proto

type CacheServiceClient interface {
	Put(ctx context.Context, opts ...grpc.CallOption) (CacheService_PutClient, error)
	PutObject(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (CacheService_GetClient, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	// ListLocal is an internal RPC for cluster mode: queries local node only
	// Returns sorted, paginated keys from this node's storage
	ListLocal(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	ListWithValues(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListWithValuesResponse, error)
	// ListLocalWithValues is an internal RPC for cluster mode: queries local node only
	// Returns sorted, paginated key-value pairs from this node's storage
	ListLocalWithValues(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListWithValuesResponse, error)
	GetTopology(ctx context.Context, in *GetTopologyRequest, opts ...grpc.CallOption) (*GetTopologyResponse, error)
}

type CacheServiceServer interface {
	Put(CacheService_PutServer) error
	PutObject(context.Context, *PutRequest) (*PutResponse, error)
	Get(*GetRequest, CacheService_GetServer) error
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	List(context.Context, *ListRequest) (*ListResponse, error)
	// ListLocal is an internal RPC for cluster mode: queries local node only
	// Returns sorted, paginated keys from this node's storage
	ListLocal(context.Context, *ListRequest) (*ListResponse, error)
	ListWithValues(context.Context, *ListRequest) (*ListWithValuesResponse, error)
	// ListLocalWithValues is an internal RPC for cluster mode: queries local node only
	// Returns sorted, paginated key-value pairs from this node's storage
	ListLocalWithValues(context.Context, *ListRequest) (*ListWithValuesResponse, error)
	GetTopology(context.Context, *GetTopologyRequest) (*GetTopologyResponse, error)
	// contains filtered or unexported methods
}

type CacheService_GetClient interface {
	Recv() (*GetResponse, error)
	grpc.ClientStream
}

type CacheService_GetServer interface {
	Send(*GetResponse) error
	grpc.ServerStream
}

type CacheService_PutClient interface {
	Send(*PutRequest) error
	CloseAndRecv() (*PutResponse, error)
	grpc.ClientStream
}

type CacheService_PutServer interface {
	SendAndClose(*PutResponse) error
	Recv() (*PutRequest, error)
	grpc.ServerStream
}

type DeleteRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type DeleteResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type GetRequest struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Start int64  `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"` // inclusive byte offset in the object (0-based)
	End   int64  `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"`     // inclusive byte offset (if 0 or omitted, read to EOF)
	// contains filtered or unexported fields
}

type GetResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

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

type GetTopologyResponse struct {
	Topology *proto.ClusterTopology `protobuf:"bytes,1,opt,name=topology,proto3" json:"topology,omitempty"` // Reuse ClusterTopology from cluster.proto
	Error    string                 `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`       // non-empty if error occurred (e.g., cluster mode not enabled)
	// contains filtered or unexported fields
}

type KeyValue struct {
	Key          string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value        []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	ValueLength  int64  `protobuf:"varint,3,opt,name=value_length,json=valueLength,proto3" json:"value_length,omitempty"`    // Size of the value in bytes (set even when value is omitted)
	ValueOmitted bool   `protobuf:"varint,4,opt,name=value_omitted,json=valueOmitted,proto3" json:"value_omitted,omitempty"` // True if the value was omitted because it exceeds the List value-size cap
	// contains filtered or unexported fields
}

type ListRequest struct {
	Prefix            string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`                                                // Optional prefix to filter keys
	StartKey          string `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`                            // Start listing after this key (exclusive), for pagination
	Limit             int32  `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`                                                 // Maximum number of keys to return (default 1000, max 1000)
	ContinuationToken string `protobuf:"bytes,4,opt,name=continuation_token,json=continuationToken,proto3" json:"continuation_token,omitempty"` // Opaque token for resuming pagination
	// contains filtered or unexported fields
}

type ListResponse struct {
	Keys              []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	ContinuationToken string   `protobuf:"bytes,2,opt,name=continuation_token,json=continuationToken,proto3" json:"continuation_token,omitempty"` // Token to resume listing from where this response ended
	HasMore           bool     `protobuf:"varint,3,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`                              // True if more keys are available beyond this page
	// contains filtered or unexported fields
}

type ListWithValuesResponse struct {
	Entries           []*KeyValue `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	ContinuationToken string      `protobuf:"bytes,2,opt,name=continuation_token,json=continuationToken,proto3" json:"continuation_token,omitempty"` // Token to resume listing from where this response ended
	HasMore           bool        `protobuf:"varint,3,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`                              // True if more entries are available beyond this page
	// contains filtered or unexported fields
}

type PutRequest struct {
	Key        string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`                                  // the cache key; only required in the first message
	TtlSeconds int64  `protobuf:"varint,2,opt,name=ttl_seconds,json=ttlSeconds,proto3" json:"ttl_seconds,omitempty"` // optional TTL; only used in the first message
	Data       []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`                                // raw chunk of the object
	// contains filtered or unexported fields
}

type PutResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // nonempty if something went wrong
	// contains filtered or unexported fields
}

type UnimplementedCacheServiceServer struct {
}

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