cachepb

package
v0.0.33 Latest Latest
Warning

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

Go to latest
Published: Feb 8, 2024 License: Apache-2.0 Imports: 9 Imported by: 4

Documentation

Index

Constants

This section is empty.

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:    "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)
	// 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
	// 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_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     *any.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() *any.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) Clone

func (UnimplementedCacheServer) Commit

func (UnimplementedCacheServer) Create

func (UnimplementedCacheServer) CreateCandidate

func (UnimplementedCacheServer) Delete

func (UnimplementedCacheServer) Discard

func (UnimplementedCacheServer) Exists

func (UnimplementedCacheServer) Get

func (UnimplementedCacheServer) GetChanges

func (UnimplementedCacheServer) List

func (UnimplementedCacheServer) Modify

func (UnimplementedCacheServer) Prune

func (UnimplementedCacheServer) Read

func (UnimplementedCacheServer) Watch

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 *any.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() *any.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    *any.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() *any.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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL