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)
	// Conditional (compare-and-swap) operations — issue #254. Each carries a
	// per-key version; a write applies only if the current version matches the
	// caller's expectation. A lost race is reported as success=false with the
	// current version, not a transport error.
	GetObjectWithVersion(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetWithVersionResponse, error)
	PutObjectIfVersion(ctx context.Context, in *PutIfVersionRequest, opts ...grpc.CallOption) (*PutIfVersionResponse, error)
	DeleteIfVersion(ctx context.Context, in *DeleteIfVersionRequest, opts ...grpc.CallOption) (*DeleteIfVersionResponse, error)
	// Streaming variants for values larger than the unary message cap (issue
	// #258). PutStreamIfVersion carries key/ttl/expected_version in the first
	// message and value bytes in the rest (like Put). GetStreamWithVersion sends
	// version+found in the first message and value bytes in the rest (like Get).
	PutStreamIfVersion(ctx context.Context, opts ...grpc.CallOption) (CacheService_PutStreamIfVersionClient, error)
	GetStreamWithVersion(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (CacheService_GetStreamWithVersionClient, 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)
	// Conditional (compare-and-swap) operations — issue #254. Each carries a
	// per-key version; a write applies only if the current version matches the
	// caller's expectation. A lost race is reported as success=false with the
	// current version, not a transport error.
	GetObjectWithVersion(context.Context, *GetRequest) (*GetWithVersionResponse, error)
	PutObjectIfVersion(context.Context, *PutIfVersionRequest) (*PutIfVersionResponse, error)
	DeleteIfVersion(context.Context, *DeleteIfVersionRequest) (*DeleteIfVersionResponse, error)
	// Streaming variants for values larger than the unary message cap (issue
	// #258). PutStreamIfVersion carries key/ttl/expected_version in the first
	// message and value bytes in the rest (like Put). GetStreamWithVersion sends
	// version+found in the first message and value bytes in the rest (like Get).
	PutStreamIfVersion(CacheService_PutStreamIfVersionServer) error
	GetStreamWithVersion(*GetRequest, CacheService_GetStreamWithVersionServer) 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_GetStreamWithVersionClient interface {
	Recv() (*GetWithVersionResponse, error)
	grpc.ClientStream
}

type CacheService_GetStreamWithVersionServer interface {
	Send(*GetWithVersionResponse) 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 CacheService_PutStreamIfVersionClient interface {
	Send(*PutIfVersionRequest) error
	CloseAndRecv() (*PutIfVersionResponse, error)
	grpc.ClientStream
}

type CacheService_PutStreamIfVersionServer interface {
	SendAndClose(*PutIfVersionResponse) error
	Recv() (*PutIfVersionRequest, error)
	grpc.ServerStream
}

type DeleteIfVersionRequest struct {
	Key             string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	ExpectedVersion uint64 `protobuf:"varint,2,opt,name=expected_version,json=expectedVersion,proto3" json:"expected_version,omitempty"`
	// contains filtered or unexported fields
}

type DeleteIfVersionResponse struct {
	Success        bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`                                     // true iff the delete applied (or the key was already absent)
	CurrentVersion uint64 `protobuf:"varint,2,opt,name=current_version,json=currentVersion,proto3" json:"current_version,omitempty"` // the key's current version, set on a mismatch (success=false)
	Error          string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`                                          // nonempty only on a real error
	// contains filtered or unexported fields
}

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 GetWithVersionResponse struct {
	Data    []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Found   bool   `protobuf:"varint,3,opt,name=found,proto3" json:"found,omitempty"`
	// 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 PutIfVersionRequest struct {
	Key             string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	TtlSeconds      int64  `protobuf:"varint,2,opt,name=ttl_seconds,json=ttlSeconds,proto3" json:"ttl_seconds,omitempty"`
	Data            []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	ExpectedVersion uint64 `protobuf:"varint,4,opt,name=expected_version,json=expectedVersion,proto3" json:"expected_version,omitempty"` // a live version, an absent read's token, or 0 = unordered put-if-absent
	// contains filtered or unexported fields
}

type PutIfVersionResponse struct {
	Success        bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`                                     // true iff the CAS applied
	NewVersion     uint64 `protobuf:"varint,2,opt,name=new_version,json=newVersion,proto3" json:"new_version,omitempty"`             // the key's new version, set on success
	CurrentVersion uint64 `protobuf:"varint,3,opt,name=current_version,json=currentVersion,proto3" json:"current_version,omitempty"` // the key's current version, set on a mismatch (success=false)
	Error          string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`                                          // nonempty only on a real error (never for a plain mismatch)
	// 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
}