cachepb

package
v0.0.35 Latest Latest
Warning

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

 Go to latest Published: Nov 28, 2024 License: Apache-2.0 Imports: 9 Imported by: 7

Documentation

Index

Constants

View Source 
const (
	Cache_List_FullMethodName            = "/cache.proto.Cache/List"
	Cache_Get_FullMethodName             = "/cache.proto.Cache/Get"
	Cache_Create_FullMethodName          = "/cache.proto.Cache/Create"
	Cache_Delete_FullMethodName          = "/cache.proto.Cache/Delete"
	Cache_Exists_FullMethodName          = "/cache.proto.Cache/Exists"
	Cache_CreateCandidate_FullMethodName = "/cache.proto.Cache/CreateCandidate"
	Cache_Clone_FullMethodName           = "/cache.proto.Cache/Clone"
	Cache_Modify_FullMethodName          = "/cache.proto.Cache/Modify"
	Cache_Prune_FullMethodName           = "/cache.proto.Cache/Prune"
	Cache_Read_FullMethodName            = "/cache.proto.Cache/Read"
	Cache_ReadKeys_FullMethodName        = "/cache.proto.Cache/ReadKeys"
	Cache_GetChanges_FullMethodName      = "/cache.proto.Cache/GetChanges"
	Cache_Discard_FullMethodName         = "/cache.proto.Cache/Discard"
	Cache_Commit_FullMethodName          = "/cache.proto.Cache/Commit"
	Cache_Clear_FullMethodName           = "/cache.proto.Cache/Clear"
	Cache_Watch_FullMethodName           = "/cache.proto.Cache/Watch"
)

Variables

View Source 
var (
	Store_name = map[int32]string{
		0: "CONFIG",
		1: "STATE",
		2: "INTENDED",
		3: "INTENTS",
	}
	Store_value = map[string]int32{
		"CONFIG":   0,
		"STATE":    1,
		"INTENDED": 2,
		"INTENTS":  3,
	}
)

Enum value maps for Store.

View Source 
var Cache_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cache.proto.Cache",
	HandlerType: (*CacheServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "List",
			Handler:    _Cache_List_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _Cache_Get_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _Cache_Create_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Cache_Delete_Handler,
		},
		{
			MethodName: "Exists",
			Handler:    _Cache_Exists_Handler,
		},
		{
			MethodName: "CreateCandidate",
			Handler:    _Cache_CreateCandidate_Handler,
		},
		{
			MethodName: "Clone",
			Handler:    _Cache_Clone_Handler,
		},
		{
			MethodName: "Prune",
			Handler:    _Cache_Prune_Handler,
		},
		{
			MethodName: "Discard",
			Handler:    _Cache_Discard_Handler,
		},
		{
			MethodName: "Commit",
			Handler:    _Cache_Commit_Handler,
		},
		{
			MethodName: "Clear",
			Handler:    _Cache_Clear_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Modify",
			Handler:       _Cache_Modify_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "Read",
			Handler:       _Cache_Read_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ReadKeys",
			Handler:       _Cache_ReadKeys_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetChanges",
			Handler:       _Cache_GetChanges_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Watch",
			Handler:       _Cache_Watch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cache.proto",
}

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

View Source 
var File_cache_proto protoreflect.FileDescriptor

Functions

func RegisterCacheServer 

func RegisterCacheServer(s grpc.ServiceRegistrar, srv CacheServer)

Types

type CacheClient 

type CacheClient interface {
	// List cache instances
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	// Get a single cache details
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// Create a new cache instance
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	// Delete a cache instance
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Exists check if a cache instance exists
	Exists(ctx context.Context, in *ExistsRequest, opts ...grpc.CallOption) (*ExistsResponse, error)
	// Create a Candidate
	CreateCandidate(ctx context.Context, in *CreateCandidateRequest, opts ...grpc.CallOption) (*CreateCandidateResponse, error)
	// Clone a cache
	Clone(ctx context.Context, in *CloneRequest, opts ...grpc.CallOption) (*CloneResponse, error)
	// modify a cache instance
	Modify(ctx context.Context, opts ...grpc.CallOption) (Cache_ModifyClient, error)
	// prune deletes
	Prune(ctx context.Context, in *PruneRequest, opts ...grpc.CallOption) (*PruneResponse, error)
	// Read value(s) from a cache instance
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (Cache_ReadClient, error)
	// ReadKeys reads the index of the store and returns the data
	ReadKeys(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (Cache_ReadKeysClient, error)
	// GetChanges made to a candidate
	GetChanges(ctx context.Context, in *GetChangesRequest, opts ...grpc.CallOption) (Cache_GetChangesClient, error)
	// Discard changes made to a candidate
	Discard(ctx context.Context, in *DiscardRequest, opts ...grpc.CallOption) (*DiscardResponse, error)
	// Commit writes a candidate changes into the intended store
	Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error)
	// Clear wipes a cache
	Clear(ctx context.Context, in *ClearRequest, opts ...grpc.CallOption) (*ClearResponse, error)
	// Watch
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Cache_WatchClient, error)
}

CacheClient is the client API for Cache 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 NewCacheClient 

func NewCacheClient(cc grpc.ClientConnInterface) CacheClient

type CacheServer 

type CacheServer interface {
	// List cache instances
	List(context.Context, *ListRequest) (*ListResponse, error)
	// Get a single cache details
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// Create a new cache instance
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	// Delete a cache instance
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// Exists check if a cache instance exists
	Exists(context.Context, *ExistsRequest) (*ExistsResponse, error)
	// Create a Candidate
	CreateCandidate(context.Context, *CreateCandidateRequest) (*CreateCandidateResponse, error)
	// Clone a cache
	Clone(context.Context, *CloneRequest) (*CloneResponse, error)
	// modify a cache instance
	Modify(Cache_ModifyServer) error
	// prune deletes
	Prune(context.Context, *PruneRequest) (*PruneResponse, error)
	// Read value(s) from a cache instance
	Read(*ReadRequest, Cache_ReadServer) error
	// ReadKeys reads the index of the store and returns the data
	ReadKeys(*ReadRequest, Cache_ReadKeysServer) error
	// GetChanges made to a candidate
	GetChanges(*GetChangesRequest, Cache_GetChangesServer) error
	// Discard changes made to a candidate
	Discard(context.Context, *DiscardRequest) (*DiscardResponse, error)
	// Commit writes a candidate changes into the intended store
	Commit(context.Context, *CommitRequest) (*CommitResponse, error)
	// Clear wipes a cache
	Clear(context.Context, *ClearRequest) (*ClearResponse, error)
	// Watch
	Watch(*WatchRequest, Cache_WatchServer) error
	// contains filtered or unexported methods
}

CacheServer is the server API for Cache service. All implementations must embed UnimplementedCacheServer for forward compatibility

type Cache_GetChangesClient 

type Cache_GetChangesClient interface {
	Recv() (*GetChangesResponse, error)
	grpc.ClientStream
}

type Cache_GetChangesServer 

type Cache_GetChangesServer interface {
	Send(*GetChangesResponse) error
	grpc.ServerStream
}

type Cache_ModifyClient 

type Cache_ModifyClient interface {
	Send(*ModifyRequest) error
	CloseAndRecv() (*ModifyResponse, error)
	grpc.ClientStream
}

type Cache_ModifyServer 

type Cache_ModifyServer interface {
	SendAndClose(*ModifyResponse) error
	Recv() (*ModifyRequest, error)
	grpc.ServerStream
}

type Cache_ReadClient 

type Cache_ReadClient interface {
	Recv() (*ReadResponse, error)
	grpc.ClientStream
}

type Cache_ReadKeysClient added in v0.0.34 

type Cache_ReadKeysClient interface {
	Recv() (*ReadResponse, error)
	grpc.ClientStream
}

type Cache_ReadKeysServer added in v0.0.34 

type Cache_ReadKeysServer interface {
	Send(*ReadResponse) error
	grpc.ServerStream
}

type Cache_ReadServer 

type Cache_ReadServer interface {
	Send(*ReadResponse) error
	grpc.ServerStream
}

type Cache_WatchClient 

type Cache_WatchClient interface {
	Recv() (*WatchResponse, error)
	grpc.ClientStream
}

type Cache_WatchServer 

type Cache_WatchServer interface {
	Send(*WatchResponse) error
	grpc.ServerStream
}

type Candidate 

type Candidate struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Owner    string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	Priority int32  `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*Candidate) Descriptor deprecated 

func (*Candidate) Descriptor() ([]byte, []int)

Deprecated: Use Candidate.ProtoReflect.Descriptor instead.

func (*Candidate) GetName 

func (x *Candidate) GetName() string

func (*Candidate) GetOwner 

func (x *Candidate) GetOwner() string

func (*Candidate) GetPriority 

func (x *Candidate) GetPriority() int32

func (*Candidate) ProtoMessage 

func (*Candidate) ProtoMessage()

func (*Candidate) ProtoReflect 

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

func (*Candidate) Reset 

func (x *Candidate) Reset()

func (*Candidate) String 

func (x *Candidate) String() string

type ClearRequest 

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

func (*ClearRequest) Descriptor deprecated 

func (*ClearRequest) Descriptor() ([]byte, []int)

Deprecated: Use ClearRequest.ProtoReflect.Descriptor instead.

func (*ClearRequest) GetName 

func (x *ClearRequest) GetName() string

func (*ClearRequest) ProtoMessage 

func (*ClearRequest) ProtoMessage()

func (*ClearRequest) ProtoReflect 

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

func (*ClearRequest) Reset 

func (x *ClearRequest) Reset()

func (*ClearRequest) String 

func (x *ClearRequest) String() string

type ClearResponse 

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

func (*ClearResponse) Descriptor deprecated 

func (*ClearResponse) Descriptor() ([]byte, []int)

Deprecated: Use ClearResponse.ProtoReflect.Descriptor instead.

func (*ClearResponse) ProtoMessage 

func (*ClearResponse) ProtoMessage()

func (*ClearResponse) ProtoReflect 

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

func (*ClearResponse) Reset 

func (x *ClearResponse) Reset()

func (*ClearResponse) String 

func (x *ClearResponse) String() string

type CloneRequest 

type CloneRequest struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Cname string `protobuf:"bytes,2,opt,name=cname,proto3" json:"cname,omitempty"`
	// contains filtered or unexported fields
}

func (*CloneRequest) Descriptor deprecated 

func (*CloneRequest) Descriptor() ([]byte, []int)

Deprecated: Use CloneRequest.ProtoReflect.Descriptor instead.

func (*CloneRequest) GetCname 

func (x *CloneRequest) GetCname() string

func (*CloneRequest) GetName 

func (x *CloneRequest) GetName() string

func (*CloneRequest) ProtoMessage 

func (*CloneRequest) ProtoMessage()

func (*CloneRequest) ProtoReflect 

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

func (*CloneRequest) Reset 

func (x *CloneRequest) Reset()

func (*CloneRequest) String 

func (x *CloneRequest) String() string

type CloneResponse 

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

func (*CloneResponse) Descriptor deprecated 

func (*CloneResponse) Descriptor() ([]byte, []int)

Deprecated: Use CloneResponse.ProtoReflect.Descriptor instead.

func (*CloneResponse) GetClone 

func (x *CloneResponse) GetClone() string

func (*CloneResponse) ProtoMessage 

func (*CloneResponse) ProtoMessage()

func (*CloneResponse) ProtoReflect 

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

func (*CloneResponse) Reset 

func (x *CloneResponse) Reset()

func (*CloneResponse) String 

func (x *CloneResponse) String() string

type CommitRequest 

type CommitRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Candidate string `protobuf:"bytes,2,opt,name=candidate,proto3" json:"candidate,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitRequest) Descriptor deprecated 

func (*CommitRequest) Descriptor() ([]byte, []int)

Deprecated: Use CommitRequest.ProtoReflect.Descriptor instead.

func (*CommitRequest) GetCandidate 

func (x *CommitRequest) GetCandidate() string

func (*CommitRequest) GetName 

func (x *CommitRequest) GetName() string

func (*CommitRequest) ProtoMessage 

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) ProtoReflect 

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

func (*CommitRequest) Reset 

func (x *CommitRequest) Reset()

func (*CommitRequest) String 

func (x *CommitRequest) String() string

type CommitResponse 

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

func (*CommitResponse) Descriptor deprecated 

func (*CommitResponse) Descriptor() ([]byte, []int)

Deprecated: Use CommitResponse.ProtoReflect.Descriptor instead.

func (*CommitResponse) ProtoMessage 

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) ProtoReflect 

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

func (*CommitResponse) Reset 

func (x *CommitResponse) Reset()

func (*CommitResponse) String 

func (x *CommitResponse) String() string

type CreateCandidateRequest 

type CreateCandidateRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Candidate string `protobuf:"bytes,2,opt,name=candidate,proto3" json:"candidate,omitempty"`
	Owner     string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	Priority  int32  `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateCandidateRequest) Descriptor deprecated 

func (*CreateCandidateRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateCandidateRequest.ProtoReflect.Descriptor instead.

func (*CreateCandidateRequest) GetCandidate 

func (x *CreateCandidateRequest) GetCandidate() string

func (*CreateCandidateRequest) GetName 

func (x *CreateCandidateRequest) GetName() string

func (*CreateCandidateRequest) GetOwner 

func (x *CreateCandidateRequest) GetOwner() string

func (*CreateCandidateRequest) GetPriority 

func (x *CreateCandidateRequest) GetPriority() int32

func (*CreateCandidateRequest) ProtoMessage 

func (*CreateCandidateRequest) ProtoMessage()

func (*CreateCandidateRequest) ProtoReflect 

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

func (*CreateCandidateRequest) Reset 

func (x *CreateCandidateRequest) Reset()

func (*CreateCandidateRequest) String 

func (x *CreateCandidateRequest) String() string

type CreateCandidateResponse 

type CreateCandidateResponse struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Candidate string `protobuf:"bytes,2,opt,name=candidate,proto3" json:"candidate,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateCandidateResponse) Descriptor deprecated 

func (*CreateCandidateResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateCandidateResponse.ProtoReflect.Descriptor instead.

func (*CreateCandidateResponse) GetCandidate 

func (x *CreateCandidateResponse) GetCandidate() string

func (*CreateCandidateResponse) GetName 

func (x *CreateCandidateResponse) GetName() string

func (*CreateCandidateResponse) ProtoMessage 

func (*CreateCandidateResponse) ProtoMessage()

func (*CreateCandidateResponse) ProtoReflect 

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

func (*CreateCandidateResponse) Reset 

func (x *CreateCandidateResponse) Reset()

func (*CreateCandidateResponse) String 

func (x *CreateCandidateResponse) String() string

type CreateRequest 

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

func (*CreateRequest) Descriptor deprecated 

func (*CreateRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) GetName 

func (x *CreateRequest) GetName() string

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect 

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

func (*CreateRequest) Reset 

func (x *CreateRequest) Reset()

func (*CreateRequest) String 

func (x *CreateRequest) String() string

type CreateResponse 

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

func (*CreateResponse) Descriptor deprecated 

func (*CreateResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect 

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

func (*CreateResponse) Reset 

func (x *CreateResponse) Reset()

func (*CreateResponse) String 

func (x *CreateResponse) String() string

type DeleteRequest 

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

func (*DeleteRequest) Descriptor deprecated 

func (*DeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetName 

func (x *DeleteRequest) GetName() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

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

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DeleteResponse 

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

func (*DeleteResponse) Descriptor deprecated 

func (*DeleteResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

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

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

type DeleteValueRequest 

type DeleteValueRequest struct {
	Name     string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Path     []string `protobuf:"bytes,2,rep,name=path,proto3" json:"path,omitempty"`
	Store    Store    `protobuf:"varint,3,opt,name=store,proto3,enum=cache.proto.Store" json:"store,omitempty"`
	Owner    string   `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"`
	Priority int32    `protobuf:"varint,5,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteValueRequest) Descriptor deprecated 

func (*DeleteValueRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteValueRequest.ProtoReflect.Descriptor instead.

func (*DeleteValueRequest) GetName 

func (x *DeleteValueRequest) GetName() string

func (*DeleteValueRequest) GetOwner 

func (x *DeleteValueRequest) GetOwner() string

func (*DeleteValueRequest) GetPath 

func (x *DeleteValueRequest) GetPath() []string

func (*DeleteValueRequest) GetPriority 

func (x *DeleteValueRequest) GetPriority() int32

func (*DeleteValueRequest) GetStore 

func (x *DeleteValueRequest) GetStore() Store

func (*DeleteValueRequest) ProtoMessage 

func (*DeleteValueRequest) ProtoMessage()

func (*DeleteValueRequest) ProtoReflect 

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

func (*DeleteValueRequest) Reset 

func (x *DeleteValueRequest) Reset()

func (*DeleteValueRequest) String 

func (x *DeleteValueRequest) String() string

type DeleteValueResponse 

type DeleteValueResponse struct {
	Name  string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Path  []string `protobuf:"bytes,2,rep,name=path,proto3" json:"path,omitempty"`
	Error string   `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteValueResponse) Descriptor deprecated 

func (*DeleteValueResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteValueResponse.ProtoReflect.Descriptor instead.

func (*DeleteValueResponse) GetError 

func (x *DeleteValueResponse) GetError() string

func (*DeleteValueResponse) GetName 

func (x *DeleteValueResponse) GetName() string

func (*DeleteValueResponse) GetPath 

func (x *DeleteValueResponse) GetPath() []string

func (*DeleteValueResponse) ProtoMessage 

func (*DeleteValueResponse) ProtoMessage()

func (*DeleteValueResponse) ProtoReflect 

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

func (*DeleteValueResponse) Reset 

func (x *DeleteValueResponse) Reset()

func (*DeleteValueResponse) String 

func (x *DeleteValueResponse) String() string

type DiscardRequest 

type DiscardRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Candidate string `protobuf:"bytes,2,opt,name=candidate,proto3" json:"candidate,omitempty"`
	// contains filtered or unexported fields
}

func (*DiscardRequest) Descriptor deprecated 

func (*DiscardRequest) Descriptor() ([]byte, []int)

Deprecated: Use DiscardRequest.ProtoReflect.Descriptor instead.

func (*DiscardRequest) GetCandidate 

func (x *DiscardRequest) GetCandidate() string

func (*DiscardRequest) GetName 

func (x *DiscardRequest) GetName() string

func (*DiscardRequest) ProtoMessage 

func (*DiscardRequest) ProtoMessage()

func (*DiscardRequest) ProtoReflect 

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

func (*DiscardRequest) Reset 

func (x *DiscardRequest) Reset()

func (*DiscardRequest) String 

func (x *DiscardRequest) String() string

type DiscardResponse 

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

func (*DiscardResponse) Descriptor deprecated 

func (*DiscardResponse) Descriptor() ([]byte, []int)

Deprecated: Use DiscardResponse.ProtoReflect.Descriptor instead.

func (*DiscardResponse) ProtoMessage 

func (*DiscardResponse) ProtoMessage()

func (*DiscardResponse) ProtoReflect 

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

func (*DiscardResponse) Reset 

func (x *DiscardResponse) Reset()

func (*DiscardResponse) String 

func (x *DiscardResponse) String() string

type ExistsRequest 

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

func (*ExistsRequest) Descriptor deprecated 

func (*ExistsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExistsRequest.ProtoReflect.Descriptor instead.

func (*ExistsRequest) GetName 

func (x *ExistsRequest) GetName() string

func (*ExistsRequest) ProtoMessage 

func (*ExistsRequest) ProtoMessage()

func (*ExistsRequest) ProtoReflect 

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

func (*ExistsRequest) Reset 

func (x *ExistsRequest) Reset()

func (*ExistsRequest) String 

func (x *ExistsRequest) String() string

type ExistsResponse 

type ExistsResponse struct {
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

func (*ExistsResponse) Descriptor deprecated 

func (*ExistsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExistsResponse.ProtoReflect.Descriptor instead.

func (*ExistsResponse) GetExists 

func (x *ExistsResponse) GetExists() bool

func (*ExistsResponse) ProtoMessage 

func (*ExistsResponse) ProtoMessage()

func (*ExistsResponse) ProtoReflect 

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

func (*ExistsResponse) Reset 

func (x *ExistsResponse) Reset()

func (*ExistsResponse) String 

func (x *ExistsResponse) String() string

type GetChangesRequest 

type GetChangesRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Candidate string `protobuf:"bytes,2,opt,name=candidate,proto3" json:"candidate,omitempty"`
	// contains filtered or unexported fields
}

func (*GetChangesRequest) Descriptor deprecated 

func (*GetChangesRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetChangesRequest.ProtoReflect.Descriptor instead.

func (*GetChangesRequest) GetCandidate 

func (x *GetChangesRequest) GetCandidate() string

func (*GetChangesRequest) GetName 

func (x *GetChangesRequest) GetName() string

func (*GetChangesRequest) ProtoMessage 

func (*GetChangesRequest) ProtoMessage()

func (*GetChangesRequest) ProtoReflect 

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

func (*GetChangesRequest) Reset 

func (x *GetChangesRequest) Reset()

func (*GetChangesRequest) String 

func (x *GetChangesRequest) String() string

type GetChangesResponse 

type GetChangesResponse struct {
	Name      string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Candidate string   `protobuf:"bytes,2,opt,name=candidate,proto3" json:"candidate,omitempty"`
	Update    *Update  `protobuf:"bytes,3,opt,name=update,proto3" json:"update,omitempty"`
	Delete    []string `protobuf:"bytes,4,rep,name=delete,proto3" json:"delete,omitempty"`
	// contains filtered or unexported fields
}

func (*GetChangesResponse) Descriptor deprecated 

func (*GetChangesResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetChangesResponse.ProtoReflect.Descriptor instead.

func (*GetChangesResponse) GetCandidate 

func (x *GetChangesResponse) GetCandidate() string

func (*GetChangesResponse) GetDelete 

func (x *GetChangesResponse) GetDelete() []string

func (*GetChangesResponse) GetName 

func (x *GetChangesResponse) GetName() string

func (*GetChangesResponse) GetUpdate 

func (x *GetChangesResponse) GetUpdate() *Update

func (*GetChangesResponse) ProtoMessage 

func (*GetChangesResponse) ProtoMessage()

func (*GetChangesResponse) ProtoReflect 

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

func (*GetChangesResponse) Reset 

func (x *GetChangesResponse) Reset()

func (*GetChangesResponse) String 

func (x *GetChangesResponse) String() string

type GetRequest 

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

func (*GetRequest) Descriptor deprecated 

func (*GetRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetName 

func (x *GetRequest) GetName() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// bool                ephemeral = 2;
	// bool                cached    = 3;
	Candidate []*Candidate `protobuf:"bytes,4,rep,name=candidate,proto3" json:"candidate,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

func (*GetResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetCandidate 

func (x *GetResponse) GetCandidate() []*Candidate

func (*GetResponse) GetName 

func (x *GetResponse) GetName() string

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

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

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type InstanceStats 

type InstanceStats struct {
	Name              string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	KeyCountPerBucket map[string]int64 `` /* 205-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*InstanceStats) Descriptor deprecated 

func (*InstanceStats) Descriptor() ([]byte, []int)

Deprecated: Use InstanceStats.ProtoReflect.Descriptor instead.

func (*InstanceStats) GetKeyCountPerBucket 

func (x *InstanceStats) GetKeyCountPerBucket() map[string]int64

func (*InstanceStats) GetName 

func (x *InstanceStats) GetName() string

func (*InstanceStats) ProtoMessage 

func (*InstanceStats) ProtoMessage()

func (*InstanceStats) ProtoReflect 

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

func (*InstanceStats) Reset 

func (x *InstanceStats) Reset()

func (*InstanceStats) String 

func (x *InstanceStats) String() string

type ListRequest 

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

func (*ListRequest) Descriptor deprecated 

func (*ListRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListResponse 

type ListResponse struct {
	Cache []string `protobuf:"bytes,1,rep,name=cache,proto3" json:"cache,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated 

func (*ListResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetCache 

func (x *ListResponse) GetCache() []string

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

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

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) String 

func (x *ListResponse) String() string

type ModifyRequest 

type ModifyRequest struct {

	// Types that are assignable to Request:
	//
	//	*ModifyRequest_Write
	//	*ModifyRequest_Delete
	Request isModifyRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*ModifyRequest) Descriptor deprecated 

func (*ModifyRequest) Descriptor() ([]byte, []int)

Deprecated: Use ModifyRequest.ProtoReflect.Descriptor instead.

func (*ModifyRequest) GetDelete 

func (x *ModifyRequest) GetDelete() *DeleteValueRequest

func (*ModifyRequest) GetRequest 

func (m *ModifyRequest) GetRequest() isModifyRequest_Request

func (*ModifyRequest) GetWrite 

func (x *ModifyRequest) GetWrite() *WriteValueRequest

func (*ModifyRequest) ProtoMessage 

func (*ModifyRequest) ProtoMessage()

func (*ModifyRequest) ProtoReflect 

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

func (*ModifyRequest) Reset 

func (x *ModifyRequest) Reset()

func (*ModifyRequest) String 

func (x *ModifyRequest) String() string

type ModifyRequest_Delete 

type ModifyRequest_Delete struct {
	Delete *DeleteValueRequest `protobuf:"bytes,2,opt,name=delete,proto3,oneof"`
}

type ModifyRequest_Write 

type ModifyRequest_Write struct {
	Write *WriteValueRequest `protobuf:"bytes,1,opt,name=write,proto3,oneof"`
}

type ModifyResponse 

type ModifyResponse struct {

	// Types that are assignable to Response:
	//
	//	*ModifyResponse_Write
	//	*ModifyResponse_Delete
	Response isModifyResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*ModifyResponse) Descriptor deprecated 

func (*ModifyResponse) Descriptor() ([]byte, []int)

Deprecated: Use ModifyResponse.ProtoReflect.Descriptor instead.

func (*ModifyResponse) GetDelete 

func (x *ModifyResponse) GetDelete() *DeleteValueResponse

func (*ModifyResponse) GetResponse 

func (m *ModifyResponse) GetResponse() isModifyResponse_Response

func (*ModifyResponse) GetWrite 

func (x *ModifyResponse) GetWrite() *WriteValueResponse

func (*ModifyResponse) ProtoMessage 

func (*ModifyResponse) ProtoMessage()

func (*ModifyResponse) ProtoReflect 

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

func (*ModifyResponse) Reset 

func (x *ModifyResponse) Reset()

func (*ModifyResponse) String 

func (x *ModifyResponse) String() string

type ModifyResponse_Delete 

type ModifyResponse_Delete struct {
	Delete *DeleteValueResponse `protobuf:"bytes,2,opt,name=delete,proto3,oneof"`
}

type ModifyResponse_Write 

type ModifyResponse_Write struct {
	Write *WriteValueResponse `protobuf:"bytes,1,opt,name=write,proto3,oneof"`
}

type Path 

type Path struct {
	Elem []string `protobuf:"bytes,1,rep,name=elem,proto3" json:"elem,omitempty"`
	// contains filtered or unexported fields
}

func (*Path) Descriptor deprecated 

func (*Path) Descriptor() ([]byte, []int)

Deprecated: Use Path.ProtoReflect.Descriptor instead.

func (*Path) GetElem 

func (x *Path) GetElem() []string

func (*Path) ProtoMessage 

func (*Path) ProtoMessage()

func (*Path) ProtoReflect 

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

func (*Path) Reset 

func (x *Path) Reset()

func (*Path) String 

func (x *Path) String() string

type PruneRequest 

type PruneRequest struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id    string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Force bool   `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*PruneRequest) Descriptor deprecated 

func (*PruneRequest) Descriptor() ([]byte, []int)

Deprecated: Use PruneRequest.ProtoReflect.Descriptor instead.

func (*PruneRequest) GetForce 

func (x *PruneRequest) GetForce() bool

func (*PruneRequest) GetId 

func (x *PruneRequest) GetId() string

func (*PruneRequest) GetName 

func (x *PruneRequest) GetName() string

func (*PruneRequest) ProtoMessage 

func (*PruneRequest) ProtoMessage()

func (*PruneRequest) ProtoReflect 

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

func (*PruneRequest) Reset 

func (x *PruneRequest) Reset()

func (*PruneRequest) String 

func (x *PruneRequest) String() string

type PruneResponse 

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

func (*PruneResponse) Descriptor deprecated 

func (*PruneResponse) Descriptor() ([]byte, []int)

Deprecated: Use PruneResponse.ProtoReflect.Descriptor instead.

func (*PruneResponse) GetId 

func (x *PruneResponse) GetId() string

func (*PruneResponse) ProtoMessage 

func (*PruneResponse) ProtoMessage()

func (*PruneResponse) ProtoReflect 

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

func (*PruneResponse) Reset 

func (x *PruneResponse) Reset()

func (*PruneResponse) String 

func (x *PruneResponse) String() string

type ReadRequest 

type ReadRequest struct {

	// cache instance name
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// paths
	Path []*Path `protobuf:"bytes,3,rep,name=path,proto3" json:"path,omitempty"`
	// store type: config, state, intended, intents
	Store Store `protobuf:"varint,4,opt,name=store,proto3,enum=cache.proto.Store" json:"store,omitempty"`
	// read period in nano seconds, if > 0
	// this read becomes a sample subscription
	Period uint64 `protobuf:"varint,5,opt,name=period,proto3" json:"period,omitempty"`
	// read a specific owner
	Owner string `protobuf:"bytes,6,opt,name=owner,proto3" json:"owner,omitempty"`
	// read a specific priority.
	// if 0: read the highest.
	// if < 0: read all priorities.
	Priority int32 `protobuf:"varint,7,opt,name=priority,proto3" json:"priority,omitempty"`
	// in case priority == 0; this specifies how
	// many "highest" priorities we want to read.
	PriorityCount uint64 `protobuf:"varint,8,opt,name=priority_count,json=priorityCount,proto3" json:"priority_count,omitempty"`
	// return keys only, used for reading raw intents
	// from the intents store
	KeysOnly bool `protobuf:"varint,9,opt,name=keys_only,json=keysOnly,proto3" json:"keys_only,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadRequest) Descriptor deprecated 

func (*ReadRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.

func (*ReadRequest) GetKeysOnly 

func (x *ReadRequest) GetKeysOnly() bool

func (*ReadRequest) GetName 

func (x *ReadRequest) GetName() string

func (*ReadRequest) GetOwner 

func (x *ReadRequest) GetOwner() string

func (*ReadRequest) GetPath 

func (x *ReadRequest) GetPath() []*Path

func (*ReadRequest) GetPeriod 

func (x *ReadRequest) GetPeriod() uint64

func (*ReadRequest) GetPriority 

func (x *ReadRequest) GetPriority() int32

func (*ReadRequest) GetPriorityCount 

func (x *ReadRequest) GetPriorityCount() uint64

func (*ReadRequest) GetStore 

func (x *ReadRequest) GetStore() Store

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) ProtoReflect 

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

func (*ReadRequest) Reset 

func (x *ReadRequest) Reset()

func (*ReadRequest) String 

func (x *ReadRequest) String() string

type ReadResponse 

type ReadResponse struct {
	Name      string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Path      []string  `protobuf:"bytes,3,rep,name=path,proto3" json:"path,omitempty"`
	Value     *any1.Any `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Store     Store     `protobuf:"varint,5,opt,name=store,proto3,enum=cache.proto.Store" json:"store,omitempty"`
	Owner     string    `protobuf:"bytes,6,opt,name=owner,proto3" json:"owner,omitempty"`
	Priority  int32     `protobuf:"varint,7,opt,name=priority,proto3" json:"priority,omitempty"`
	Timestamp int64     `protobuf:"varint,8,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse) Descriptor deprecated 

func (*ReadResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.

func (*ReadResponse) GetName 

func (x *ReadResponse) GetName() string

func (*ReadResponse) GetOwner 

func (x *ReadResponse) GetOwner() string

func (*ReadResponse) GetPath 

func (x *ReadResponse) GetPath() []string

func (*ReadResponse) GetPriority 

func (x *ReadResponse) GetPriority() int32

func (*ReadResponse) GetStore 

func (x *ReadResponse) GetStore() Store

func (*ReadResponse) GetTimestamp 

func (x *ReadResponse) GetTimestamp() int64

func (*ReadResponse) GetValue 

func (x *ReadResponse) GetValue() *any1.Any

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) ProtoReflect 

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

func (*ReadResponse) Reset 

func (x *ReadResponse) Reset()

func (*ReadResponse) String 

func (x *ReadResponse) String() string

type StatsRequest 

type StatsRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	KeysCount bool   `protobuf:"varint,2,opt,name=keys_count,json=keysCount,proto3" json:"keys_count,omitempty"`
	// contains filtered or unexported fields
}

func (*StatsRequest) Descriptor deprecated 

func (*StatsRequest) Descriptor() ([]byte, []int)

Deprecated: Use StatsRequest.ProtoReflect.Descriptor instead.

func (*StatsRequest) GetKeysCount 

func (x *StatsRequest) GetKeysCount() bool

func (*StatsRequest) GetName 

func (x *StatsRequest) GetName() string

func (*StatsRequest) ProtoMessage 

func (*StatsRequest) ProtoMessage()

func (*StatsRequest) ProtoReflect 

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

func (*StatsRequest) Reset 

func (x *StatsRequest) Reset()

func (*StatsRequest) String 

func (x *StatsRequest) String() string

type StatsResponse 

type StatsResponse struct {
	NumCache int64                     `protobuf:"varint,1,opt,name=num_cache,json=numCache,proto3" json:"num_cache,omitempty"`
	KeyCount map[string]*InstanceStats `` /* 173-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StatsResponse) Descriptor deprecated 

func (*StatsResponse) Descriptor() ([]byte, []int)

Deprecated: Use StatsResponse.ProtoReflect.Descriptor instead.

func (*StatsResponse) GetKeyCount 

func (x *StatsResponse) GetKeyCount() map[string]*InstanceStats

func (*StatsResponse) GetNumCache 

func (x *StatsResponse) GetNumCache() int64

func (*StatsResponse) ProtoMessage 

func (*StatsResponse) ProtoMessage()

func (*StatsResponse) ProtoReflect 

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

func (*StatsResponse) Reset 

func (x *StatsResponse) Reset()

func (*StatsResponse) String 

func (x *StatsResponse) String() string

type Store 

type Store int32
const (
	Store_CONFIG   Store = 0
	Store_STATE    Store = 1
	Store_INTENDED Store = 2
	Store_INTENTS  Store = 3
)

func (Store) Descriptor 

func (Store) Descriptor() protoreflect.EnumDescriptor

func (Store) Enum 

func (x Store) Enum() *Store

func (Store) EnumDescriptor deprecated 

func (Store) EnumDescriptor() ([]byte, []int)

Deprecated: Use Store.Descriptor instead.

func (Store) Number 

func (x Store) Number() protoreflect.EnumNumber

func (Store) String 

func (x Store) String() string

func (Store) Type 

func (Store) Type() protoreflect.EnumType

type UnimplementedCacheServer 

type UnimplementedCacheServer struct {
}

UnimplementedCacheServer must be embedded to have forward compatible implementations.

func (UnimplementedCacheServer) Clear 

func (UnimplementedCacheServer) Clear(context.Context, *ClearRequest) (*ClearResponse, error)

func (UnimplementedCacheServer) Clone 

func (UnimplementedCacheServer) Clone(context.Context, *CloneRequest) (*CloneResponse, error)

func (UnimplementedCacheServer) Commit 

func (UnimplementedCacheServer) Commit(context.Context, *CommitRequest) (*CommitResponse, error)

func (UnimplementedCacheServer) Create 

func (UnimplementedCacheServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)

func (UnimplementedCacheServer) CreateCandidate 

func (UnimplementedCacheServer) CreateCandidate(context.Context, *CreateCandidateRequest) (*CreateCandidateResponse, error)

func (UnimplementedCacheServer) Delete 

func (UnimplementedCacheServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedCacheServer) Discard 

func (UnimplementedCacheServer) Discard(context.Context, *DiscardRequest) (*DiscardResponse, error)

func (UnimplementedCacheServer) Exists 

func (UnimplementedCacheServer) Exists(context.Context, *ExistsRequest) (*ExistsResponse, error)

func (UnimplementedCacheServer) Get 

func (UnimplementedCacheServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedCacheServer) GetChanges 

func (UnimplementedCacheServer) GetChanges(*GetChangesRequest, Cache_GetChangesServer) error

func (UnimplementedCacheServer) List 

func (UnimplementedCacheServer) List(context.Context, *ListRequest) (*ListResponse, error)

func (UnimplementedCacheServer) Modify 

func (UnimplementedCacheServer) Modify(Cache_ModifyServer) error

func (UnimplementedCacheServer) Prune 

func (UnimplementedCacheServer) Prune(context.Context, *PruneRequest) (*PruneResponse, error)

func (UnimplementedCacheServer) Read 

func (UnimplementedCacheServer) Read(*ReadRequest, Cache_ReadServer) error

func (UnimplementedCacheServer) ReadKeys added in v0.0.34 

func (UnimplementedCacheServer) ReadKeys(*ReadRequest, Cache_ReadKeysServer) error

func (UnimplementedCacheServer) Watch 

func (UnimplementedCacheServer) Watch(*WatchRequest, Cache_WatchServer) error

type UnsafeCacheServer 

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

UnsafeCacheServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CacheServer will result in compilation errors.

type Update 

type Update struct {
	Path  []string  `protobuf:"bytes,2,rep,name=path,proto3" json:"path,omitempty"`
	Value *any1.Any `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

sub messages

func (*Update) Descriptor deprecated 

func (*Update) Descriptor() ([]byte, []int)

Deprecated: Use Update.ProtoReflect.Descriptor instead.

func (*Update) GetPath 

func (x *Update) GetPath() []string

func (*Update) GetValue 

func (x *Update) GetValue() *any1.Any

func (*Update) ProtoMessage 

func (*Update) ProtoMessage()

func (*Update) ProtoReflect 

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

func (*Update) Reset 

func (x *Update) Reset()

func (*Update) String 

func (x *Update) String() string

type WatchRequest 

type WatchRequest struct {
	Name  string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Store Store   `protobuf:"varint,2,opt,name=store,proto3,enum=cache.proto.Store" json:"store,omitempty"`
	Path  []*Path `protobuf:"bytes,3,rep,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchRequest) Descriptor deprecated 

func (*WatchRequest) Descriptor() ([]byte, []int)

Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.

func (*WatchRequest) GetName 

func (x *WatchRequest) GetName() string

func (*WatchRequest) GetPath 

func (x *WatchRequest) GetPath() []*Path

func (*WatchRequest) GetStore 

func (x *WatchRequest) GetStore() Store

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) ProtoReflect 

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

func (*WatchRequest) Reset 

func (x *WatchRequest) Reset()

func (*WatchRequest) String 

func (x *WatchRequest) String() string

type WatchResponse 

type WatchResponse struct {
	Path  []string `protobuf:"bytes,1,rep,name=path,proto3" json:"path,omitempty"`
	Value []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchResponse) Descriptor deprecated 

func (*WatchResponse) Descriptor() ([]byte, []int)

Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.

func (*WatchResponse) GetPath 

func (x *WatchResponse) GetPath() []string

func (*WatchResponse) GetValue 

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

func (*WatchResponse) ProtoMessage 

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) ProtoReflect 

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

func (*WatchResponse) Reset 

func (x *WatchResponse) Reset()

func (*WatchResponse) String 

func (x *WatchResponse) String() string

type WriteValueRequest 

type WriteValueRequest struct {
	Name     string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Path     []string  `protobuf:"bytes,2,rep,name=path,proto3" json:"path,omitempty"`
	Value    *any1.Any `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Store    Store     `protobuf:"varint,4,opt,name=store,proto3,enum=cache.proto.Store" json:"store,omitempty"`
	Owner    string    `protobuf:"bytes,5,opt,name=owner,proto3" json:"owner,omitempty"`
	Priority int32     `protobuf:"varint,6,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteValueRequest) Descriptor deprecated 

func (*WriteValueRequest) Descriptor() ([]byte, []int)

Deprecated: Use WriteValueRequest.ProtoReflect.Descriptor instead.

func (*WriteValueRequest) GetName 

func (x *WriteValueRequest) GetName() string

func (*WriteValueRequest) GetOwner 

func (x *WriteValueRequest) GetOwner() string

func (*WriteValueRequest) GetPath 

func (x *WriteValueRequest) GetPath() []string

func (*WriteValueRequest) GetPriority 

func (x *WriteValueRequest) GetPriority() int32

func (*WriteValueRequest) GetStore 

func (x *WriteValueRequest) GetStore() Store

func (*WriteValueRequest) GetValue 

func (x *WriteValueRequest) GetValue() *any1.Any

func (*WriteValueRequest) ProtoMessage 

func (*WriteValueRequest) ProtoMessage()

func (*WriteValueRequest) ProtoReflect 

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

func (*WriteValueRequest) Reset 

func (x *WriteValueRequest) Reset()

func (*WriteValueRequest) String 

func (x *WriteValueRequest) String() string

type WriteValueResponse 

type WriteValueResponse struct {
	Name  string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Path  []string `protobuf:"bytes,2,rep,name=path,proto3" json:"path,omitempty"`
	Error string   `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	Store Store    `protobuf:"varint,4,opt,name=store,proto3,enum=cache.proto.Store" json:"store,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteValueResponse) Descriptor deprecated 

func (*WriteValueResponse) Descriptor() ([]byte, []int)

Deprecated: Use WriteValueResponse.ProtoReflect.Descriptor instead.

func (*WriteValueResponse) GetError 

func (x *WriteValueResponse) GetError() string

func (*WriteValueResponse) GetName 

func (x *WriteValueResponse) GetName() string

func (*WriteValueResponse) GetPath 

func (x *WriteValueResponse) GetPath() []string

func (*WriteValueResponse) GetStore 

func (x *WriteValueResponse) GetStore() Store

func (*WriteValueResponse) ProtoMessage 

func (*WriteValueResponse) ProtoMessage()

func (*WriteValueResponse) ProtoReflect 

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

func (*WriteValueResponse) Reset 

func (x *WriteValueResponse) Reset()

func (*WriteValueResponse) String 

func (x *WriteValueResponse) String() string

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.