proto

package
v1.2.2 Latest Latest
Warning

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

 Go to latest Published: May 23, 2024 License: UPL-1.0 Imports: 10 Imported by: 0

Documentation

Overview

Package proto contains automatically generated gRPC code.

Index

Constants

View Source 
const (
	NamedCacheService_AddIndex_FullMethodName         = "/coherence.NamedCacheService/addIndex"
	NamedCacheService_Aggregate_FullMethodName        = "/coherence.NamedCacheService/aggregate"
	NamedCacheService_Clear_FullMethodName            = "/coherence.NamedCacheService/clear"
	NamedCacheService_ContainsEntry_FullMethodName    = "/coherence.NamedCacheService/containsEntry"
	NamedCacheService_ContainsKey_FullMethodName      = "/coherence.NamedCacheService/containsKey"
	NamedCacheService_ContainsValue_FullMethodName    = "/coherence.NamedCacheService/containsValue"
	NamedCacheService_Destroy_FullMethodName          = "/coherence.NamedCacheService/destroy"
	NamedCacheService_EntrySet_FullMethodName         = "/coherence.NamedCacheService/entrySet"
	NamedCacheService_Events_FullMethodName           = "/coherence.NamedCacheService/events"
	NamedCacheService_Get_FullMethodName              = "/coherence.NamedCacheService/get"
	NamedCacheService_GetAll_FullMethodName           = "/coherence.NamedCacheService/getAll"
	NamedCacheService_Invoke_FullMethodName           = "/coherence.NamedCacheService/invoke"
	NamedCacheService_InvokeAll_FullMethodName        = "/coherence.NamedCacheService/invokeAll"
	NamedCacheService_IsEmpty_FullMethodName          = "/coherence.NamedCacheService/isEmpty"
	NamedCacheService_IsReady_FullMethodName          = "/coherence.NamedCacheService/isReady"
	NamedCacheService_KeySet_FullMethodName           = "/coherence.NamedCacheService/keySet"
	NamedCacheService_NextEntrySetPage_FullMethodName = "/coherence.NamedCacheService/nextEntrySetPage"
	NamedCacheService_NextKeySetPage_FullMethodName   = "/coherence.NamedCacheService/nextKeySetPage"
	NamedCacheService_Put_FullMethodName              = "/coherence.NamedCacheService/put"
	NamedCacheService_PutAll_FullMethodName           = "/coherence.NamedCacheService/putAll"
	NamedCacheService_PutIfAbsent_FullMethodName      = "/coherence.NamedCacheService/putIfAbsent"
	NamedCacheService_Remove_FullMethodName           = "/coherence.NamedCacheService/remove"
	NamedCacheService_RemoveIndex_FullMethodName      = "/coherence.NamedCacheService/removeIndex"
	NamedCacheService_RemoveMapping_FullMethodName    = "/coherence.NamedCacheService/removeMapping"
	NamedCacheService_Replace_FullMethodName          = "/coherence.NamedCacheService/replace"
	NamedCacheService_ReplaceMapping_FullMethodName   = "/coherence.NamedCacheService/replaceMapping"
	NamedCacheService_Size_FullMethodName             = "/coherence.NamedCacheService/size"
	NamedCacheService_Truncate_FullMethodName         = "/coherence.NamedCacheService/truncate"
	NamedCacheService_Values_FullMethodName           = "/coherence.NamedCacheService/values"
)

Variables

View Source 
var (
	MapListenerRequest_RequestType_name = map[int32]string{
		0: "INIT",
		1: "KEY",
		2: "FILTER",
	}
	MapListenerRequest_RequestType_value = map[string]int32{
		"INIT":   0,
		"KEY":    1,
		"FILTER": 2,
	}
)

Enum value maps for MapListenerRequest_RequestType.

View Source 
var (
	MapEventResponse_TransformationState_name = map[int32]string{
		0: "NON_TRANSFORMABLE",
		1: "TRANSFORMABLE",
		2: "TRANSFORMED",
	}
	MapEventResponse_TransformationState_value = map[string]int32{
		"NON_TRANSFORMABLE": 0,
		"TRANSFORMABLE":     1,
		"TRANSFORMED":       2,
	}
)

Enum value maps for MapEventResponse_TransformationState.

View Source 
var File_messages_proto protoreflect.FileDescriptor
View Source 
var File_services_proto protoreflect.FileDescriptor
View Source 
var NamedCacheService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "coherence.NamedCacheService",
	HandlerType: (*NamedCacheServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "addIndex",
			Handler:    _NamedCacheService_AddIndex_Handler,
		},
		{
			MethodName: "aggregate",
			Handler:    _NamedCacheService_Aggregate_Handler,
		},
		{
			MethodName: "clear",
			Handler:    _NamedCacheService_Clear_Handler,
		},
		{
			MethodName: "containsEntry",
			Handler:    _NamedCacheService_ContainsEntry_Handler,
		},
		{
			MethodName: "containsKey",
			Handler:    _NamedCacheService_ContainsKey_Handler,
		},
		{
			MethodName: "containsValue",
			Handler:    _NamedCacheService_ContainsValue_Handler,
		},
		{
			MethodName: "destroy",
			Handler:    _NamedCacheService_Destroy_Handler,
		},
		{
			MethodName: "get",
			Handler:    _NamedCacheService_Get_Handler,
		},
		{
			MethodName: "invoke",
			Handler:    _NamedCacheService_Invoke_Handler,
		},
		{
			MethodName: "isEmpty",
			Handler:    _NamedCacheService_IsEmpty_Handler,
		},
		{
			MethodName: "isReady",
			Handler:    _NamedCacheService_IsReady_Handler,
		},
		{
			MethodName: "put",
			Handler:    _NamedCacheService_Put_Handler,
		},
		{
			MethodName: "putAll",
			Handler:    _NamedCacheService_PutAll_Handler,
		},
		{
			MethodName: "putIfAbsent",
			Handler:    _NamedCacheService_PutIfAbsent_Handler,
		},
		{
			MethodName: "remove",
			Handler:    _NamedCacheService_Remove_Handler,
		},
		{
			MethodName: "removeIndex",
			Handler:    _NamedCacheService_RemoveIndex_Handler,
		},
		{
			MethodName: "removeMapping",
			Handler:    _NamedCacheService_RemoveMapping_Handler,
		},
		{
			MethodName: "replace",
			Handler:    _NamedCacheService_Replace_Handler,
		},
		{
			MethodName: "replaceMapping",
			Handler:    _NamedCacheService_ReplaceMapping_Handler,
		},
		{
			MethodName: "size",
			Handler:    _NamedCacheService_Size_Handler,
		},
		{
			MethodName: "truncate",
			Handler:    _NamedCacheService_Truncate_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "entrySet",
			Handler:       _NamedCacheService_EntrySet_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "events",
			Handler:       _NamedCacheService_Events_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "getAll",
			Handler:       _NamedCacheService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "invokeAll",
			Handler:       _NamedCacheService_InvokeAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "keySet",
			Handler:       _NamedCacheService_KeySet_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "nextEntrySetPage",
			Handler:       _NamedCacheService_NextEntrySetPage_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "nextKeySetPage",
			Handler:       _NamedCacheService_NextKeySetPage_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "values",
			Handler:       _NamedCacheService_Values_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "services.proto",
}

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

Functions

func RegisterNamedCacheServiceServer 

func RegisterNamedCacheServiceServer(s grpc.ServiceRegistrar, srv NamedCacheServiceServer)

Types

type AddIndexRequest 

type AddIndexRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The serialized ValueExtractor to use to create the index.
	Extractor []byte `protobuf:"bytes,4,opt,name=extractor,proto3" json:"extractor,omitempty"`
	// A flag indicating whether to sort the index.
	Sorted bool `protobuf:"varint,5,opt,name=sorted,proto3" json:"sorted,omitempty"`
	// The optional comparator to use to sort the index.
	Comparator []byte `protobuf:"bytes,6,opt,name=comparator,proto3" json:"comparator,omitempty"`
	// contains filtered or unexported fields
}

A request to add an index to a cache

func (*AddIndexRequest) Descriptor deprecated 

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

Deprecated: Use AddIndexRequest.ProtoReflect.Descriptor instead.

func (*AddIndexRequest) GetCache 

func (x *AddIndexRequest) GetCache() string

func (*AddIndexRequest) GetComparator 

func (x *AddIndexRequest) GetComparator() []byte

func (*AddIndexRequest) GetExtractor 

func (x *AddIndexRequest) GetExtractor() []byte

func (*AddIndexRequest) GetFormat 

func (x *AddIndexRequest) GetFormat() string

func (*AddIndexRequest) GetScope 

func (x *AddIndexRequest) GetScope() string

func (*AddIndexRequest) GetSorted 

func (x *AddIndexRequest) GetSorted() bool

func (*AddIndexRequest) ProtoMessage 

func (*AddIndexRequest) ProtoMessage()

func (*AddIndexRequest) ProtoReflect 

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

func (*AddIndexRequest) Reset 

func (x *AddIndexRequest) Reset()

func (*AddIndexRequest) String 

func (x *AddIndexRequest) String() string

type AggregateRequest 

type AggregateRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The serialized EntryAggregator to aggregate.
	Aggregator []byte `protobuf:"bytes,4,opt,name=aggregator,proto3" json:"aggregator,omitempty"`
	// The optional set of serialized keys of the entries to aggregate.
	Keys [][]byte `protobuf:"bytes,5,rep,name=keys,proto3" json:"keys,omitempty"`
	// The optional serialized Filter to identify the entries to aggregate.
	Filter []byte `protobuf:"bytes,6,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

A request to aggreagte entries in a cache.

func (*AggregateRequest) Descriptor deprecated 

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

Deprecated: Use AggregateRequest.ProtoReflect.Descriptor instead.

func (*AggregateRequest) GetAggregator 

func (x *AggregateRequest) GetAggregator() []byte

func (*AggregateRequest) GetCache 

func (x *AggregateRequest) GetCache() string

func (*AggregateRequest) GetFilter 

func (x *AggregateRequest) GetFilter() []byte

func (*AggregateRequest) GetFormat 

func (x *AggregateRequest) GetFormat() string

func (*AggregateRequest) GetKeys 

func (x *AggregateRequest) GetKeys() [][]byte

func (*AggregateRequest) GetScope 

func (x *AggregateRequest) GetScope() string

func (*AggregateRequest) ProtoMessage 

func (*AggregateRequest) ProtoMessage()

func (*AggregateRequest) ProtoReflect 

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

func (*AggregateRequest) Reset 

func (x *AggregateRequest) Reset()

func (*AggregateRequest) String 

func (x *AggregateRequest) String() string

type CacheDestroyedResponse 

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

A response to indicate that a cache was destroyed.

func (*CacheDestroyedResponse) Descriptor deprecated 

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

Deprecated: Use CacheDestroyedResponse.ProtoReflect.Descriptor instead.

func (*CacheDestroyedResponse) GetCache 

func (x *CacheDestroyedResponse) GetCache() string

func (*CacheDestroyedResponse) ProtoMessage 

func (*CacheDestroyedResponse) ProtoMessage()

func (*CacheDestroyedResponse) ProtoReflect 

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

func (*CacheDestroyedResponse) Reset 

func (x *CacheDestroyedResponse) Reset()

func (*CacheDestroyedResponse) String 

func (x *CacheDestroyedResponse) String() string

type CacheTruncatedResponse 

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

A response to indicate that a cache was truncated.

func (*CacheTruncatedResponse) Descriptor deprecated 

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

Deprecated: Use CacheTruncatedResponse.ProtoReflect.Descriptor instead.

func (*CacheTruncatedResponse) GetCache 

func (x *CacheTruncatedResponse) GetCache() string

func (*CacheTruncatedResponse) ProtoMessage 

func (*CacheTruncatedResponse) ProtoMessage()

func (*CacheTruncatedResponse) ProtoReflect 

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

func (*CacheTruncatedResponse) Reset 

func (x *CacheTruncatedResponse) Reset()

func (*CacheTruncatedResponse) String 

func (x *CacheTruncatedResponse) String() string

type ClearRequest 

type ClearRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// contains filtered or unexported fields
}

A request to clear all the entries in the cache.

func (*ClearRequest) Descriptor deprecated 

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

Deprecated: Use ClearRequest.ProtoReflect.Descriptor instead.

func (*ClearRequest) GetCache 

func (x *ClearRequest) GetCache() string

func (*ClearRequest) GetScope 

func (x *ClearRequest) GetScope() 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 ContainsEntryRequest 

type ContainsEntryRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The serialization format.
	Key []byte `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// The value of the entry to verify.
	Value []byte `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

A request to determine whether an entry exists in a cache with a specific key and value.

func (*ContainsEntryRequest) Descriptor deprecated 

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

Deprecated: Use ContainsEntryRequest.ProtoReflect.Descriptor instead.

func (*ContainsEntryRequest) GetCache 

func (x *ContainsEntryRequest) GetCache() string

func (*ContainsEntryRequest) GetFormat 

func (x *ContainsEntryRequest) GetFormat() string

func (*ContainsEntryRequest) GetKey 

func (x *ContainsEntryRequest) GetKey() []byte

func (*ContainsEntryRequest) GetScope 

func (x *ContainsEntryRequest) GetScope() string

func (*ContainsEntryRequest) GetValue 

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

func (*ContainsEntryRequest) ProtoMessage 

func (*ContainsEntryRequest) ProtoMessage()

func (*ContainsEntryRequest) ProtoReflect 

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

func (*ContainsEntryRequest) Reset 

func (x *ContainsEntryRequest) Reset()

func (*ContainsEntryRequest) String 

func (x *ContainsEntryRequest) String() string

type ContainsKeyRequest 

type ContainsKeyRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The key of the entry to verify.
	Key []byte `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

A request to determine whether an entry exists in a cache for the specified key.

func (*ContainsKeyRequest) Descriptor deprecated 

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

Deprecated: Use ContainsKeyRequest.ProtoReflect.Descriptor instead.

func (*ContainsKeyRequest) GetCache 

func (x *ContainsKeyRequest) GetCache() string

func (*ContainsKeyRequest) GetFormat 

func (x *ContainsKeyRequest) GetFormat() string

func (*ContainsKeyRequest) GetKey 

func (x *ContainsKeyRequest) GetKey() []byte

func (*ContainsKeyRequest) GetScope 

func (x *ContainsKeyRequest) GetScope() string

func (*ContainsKeyRequest) ProtoMessage 

func (*ContainsKeyRequest) ProtoMessage()

func (*ContainsKeyRequest) ProtoReflect 

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

func (*ContainsKeyRequest) Reset 

func (x *ContainsKeyRequest) Reset()

func (*ContainsKeyRequest) String 

func (x *ContainsKeyRequest) String() string

type ContainsValueRequest 

type ContainsValueRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The value of the entry to verify.
	Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

A request to determine whether an entry exists in a cache with the specified value.

func (*ContainsValueRequest) Descriptor deprecated 

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

Deprecated: Use ContainsValueRequest.ProtoReflect.Descriptor instead.

func (*ContainsValueRequest) GetCache 

func (x *ContainsValueRequest) GetCache() string

func (*ContainsValueRequest) GetFormat 

func (x *ContainsValueRequest) GetFormat() string

func (*ContainsValueRequest) GetScope 

func (x *ContainsValueRequest) GetScope() string

func (*ContainsValueRequest) GetValue 

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

func (*ContainsValueRequest) ProtoMessage 

func (*ContainsValueRequest) ProtoMessage()

func (*ContainsValueRequest) ProtoReflect 

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

func (*ContainsValueRequest) Reset 

func (x *ContainsValueRequest) Reset()

func (*ContainsValueRequest) String 

func (x *ContainsValueRequest) String() string

type DestroyRequest 

type DestroyRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// contains filtered or unexported fields
}

A request to destroy a cache.

func (*DestroyRequest) Descriptor deprecated 

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

Deprecated: Use DestroyRequest.ProtoReflect.Descriptor instead.

func (*DestroyRequest) GetCache 

func (x *DestroyRequest) GetCache() string

func (*DestroyRequest) GetScope 

func (x *DestroyRequest) GetScope() string

func (*DestroyRequest) ProtoMessage 

func (*DestroyRequest) ProtoMessage()

func (*DestroyRequest) ProtoReflect 

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

func (*DestroyRequest) Reset 

func (x *DestroyRequest) Reset()

func (*DestroyRequest) String 

func (x *DestroyRequest) String() string

type Entry 

type Entry struct {

	// The cache entry key.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The value of the entry.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

A key value pair.

func (*Entry) Descriptor deprecated 

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

Deprecated: Use Entry.ProtoReflect.Descriptor instead.

func (*Entry) GetKey 

func (x *Entry) GetKey() []byte

func (*Entry) GetValue 

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

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) ProtoReflect 

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

func (*Entry) Reset 

func (x *Entry) Reset()

func (*Entry) String 

func (x *Entry) String() string

type EntryResult 

type EntryResult struct {

	// The cache entry key.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The cache entry value.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// An opaque cookie to track the requested page.
	Cookie []byte `protobuf:"bytes,3,opt,name=cookie,proto3" json:"cookie,omitempty"`
	// contains filtered or unexported fields
}

A cache entry key/value pair.

func (*EntryResult) Descriptor deprecated 

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

Deprecated: Use EntryResult.ProtoReflect.Descriptor instead.

func (*EntryResult) GetCookie 

func (x *EntryResult) GetCookie() []byte

func (*EntryResult) GetKey 

func (x *EntryResult) GetKey() []byte

func (*EntryResult) GetValue 

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

func (*EntryResult) ProtoMessage 

func (*EntryResult) ProtoMessage()

func (*EntryResult) ProtoReflect 

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

func (*EntryResult) Reset 

func (x *EntryResult) Reset()

func (*EntryResult) String 

func (x *EntryResult) String() string

type EntrySetRequest 

type EntrySetRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The serialized Filter to identify the entries to return.
	Filter []byte `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// The optional comparator to use to sort the returned entries.
	Comparator []byte `protobuf:"bytes,5,opt,name=comparator,proto3" json:"comparator,omitempty"`
	// contains filtered or unexported fields
}

A request to get a set of entries from a cache.

func (*EntrySetRequest) Descriptor deprecated 

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

Deprecated: Use EntrySetRequest.ProtoReflect.Descriptor instead.

func (*EntrySetRequest) GetCache 

func (x *EntrySetRequest) GetCache() string

func (*EntrySetRequest) GetComparator 

func (x *EntrySetRequest) GetComparator() []byte

func (*EntrySetRequest) GetFilter 

func (x *EntrySetRequest) GetFilter() []byte

func (*EntrySetRequest) GetFormat 

func (x *EntrySetRequest) GetFormat() string

func (*EntrySetRequest) GetScope 

func (x *EntrySetRequest) GetScope() string

func (*EntrySetRequest) ProtoMessage 

func (*EntrySetRequest) ProtoMessage()

func (*EntrySetRequest) ProtoReflect 

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

func (*EntrySetRequest) Reset 

func (x *EntrySetRequest) Reset()

func (*EntrySetRequest) String 

func (x *EntrySetRequest) String() string

type GetAllRequest 

type GetAllRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The key of the entry to retrieve.
	Key [][]byte `protobuf:"bytes,4,rep,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

A request to obtain the values that map to the specified keys

func (*GetAllRequest) Descriptor deprecated 

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

Deprecated: Use GetAllRequest.ProtoReflect.Descriptor instead.

func (*GetAllRequest) GetCache 

func (x *GetAllRequest) GetCache() string

func (*GetAllRequest) GetFormat 

func (x *GetAllRequest) GetFormat() string

func (*GetAllRequest) GetKey 

func (x *GetAllRequest) GetKey() [][]byte

func (*GetAllRequest) GetScope 

func (x *GetAllRequest) GetScope() string

func (*GetAllRequest) ProtoMessage 

func (*GetAllRequest) ProtoMessage()

func (*GetAllRequest) ProtoReflect 

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

func (*GetAllRequest) Reset 

func (x *GetAllRequest) Reset()

func (*GetAllRequest) String 

func (x *GetAllRequest) String() string

type GetRequest 

type GetRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The key of the entry to retrieve.
	Key []byte `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

A request to obtain the value to which a cache maps the specified key.

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetCache 

func (x *GetRequest) GetCache() string

func (*GetRequest) GetFormat 

func (x *GetRequest) GetFormat() string

func (*GetRequest) GetKey 

func (x *GetRequest) GetKey() []byte

func (*GetRequest) GetScope 

func (x *GetRequest) GetScope() 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 InvokeAllRequest 

type InvokeAllRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The serialized EntryProcessor to invoke.
	Processor []byte `protobuf:"bytes,4,opt,name=processor,proto3" json:"processor,omitempty"`
	// The optional set of serialized keys of the entries to process.
	Keys [][]byte `protobuf:"bytes,5,rep,name=keys,proto3" json:"keys,omitempty"`
	// The optional serialized Filter to identify the entries to process.
	Filter []byte `protobuf:"bytes,6,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

A request to invoke an entry processor against a number of entries.

func (*InvokeAllRequest) Descriptor deprecated 

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

Deprecated: Use InvokeAllRequest.ProtoReflect.Descriptor instead.

func (*InvokeAllRequest) GetCache 

func (x *InvokeAllRequest) GetCache() string

func (*InvokeAllRequest) GetFilter 

func (x *InvokeAllRequest) GetFilter() []byte

func (*InvokeAllRequest) GetFormat 

func (x *InvokeAllRequest) GetFormat() string

func (*InvokeAllRequest) GetKeys 

func (x *InvokeAllRequest) GetKeys() [][]byte

func (*InvokeAllRequest) GetProcessor 

func (x *InvokeAllRequest) GetProcessor() []byte

func (*InvokeAllRequest) GetScope 

func (x *InvokeAllRequest) GetScope() string

func (*InvokeAllRequest) ProtoMessage 

func (*InvokeAllRequest) ProtoMessage()

func (*InvokeAllRequest) ProtoReflect 

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

func (*InvokeAllRequest) Reset 

func (x *InvokeAllRequest) Reset()

func (*InvokeAllRequest) String 

func (x *InvokeAllRequest) String() string

type InvokeRequest 

type InvokeRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The serialized EntryProcessor to invoke.
	Processor []byte `protobuf:"bytes,4,opt,name=processor,proto3" json:"processor,omitempty"`
	// The serialized key of the entry to process.
	Key []byte `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

A request to invoke an EntryProcessor against a single entry.

func (*InvokeRequest) Descriptor deprecated 

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

Deprecated: Use InvokeRequest.ProtoReflect.Descriptor instead.

func (*InvokeRequest) GetCache 

func (x *InvokeRequest) GetCache() string

func (*InvokeRequest) GetFormat 

func (x *InvokeRequest) GetFormat() string

func (*InvokeRequest) GetKey 

func (x *InvokeRequest) GetKey() []byte

func (*InvokeRequest) GetProcessor 

func (x *InvokeRequest) GetProcessor() []byte

func (*InvokeRequest) GetScope 

func (x *InvokeRequest) GetScope() string

func (*InvokeRequest) ProtoMessage 

func (*InvokeRequest) ProtoMessage()

func (*InvokeRequest) ProtoReflect 

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

func (*InvokeRequest) Reset 

func (x *InvokeRequest) Reset()

func (*InvokeRequest) String 

func (x *InvokeRequest) String() string

type IsEmptyRequest 

type IsEmptyRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// contains filtered or unexported fields
}

A request to determine whether a cache is empty or not.

func (*IsEmptyRequest) Descriptor deprecated 

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

Deprecated: Use IsEmptyRequest.ProtoReflect.Descriptor instead.

func (*IsEmptyRequest) GetCache 

func (x *IsEmptyRequest) GetCache() string

func (*IsEmptyRequest) GetScope 

func (x *IsEmptyRequest) GetScope() string

func (*IsEmptyRequest) ProtoMessage 

func (*IsEmptyRequest) ProtoMessage()

func (*IsEmptyRequest) ProtoReflect 

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

func (*IsEmptyRequest) Reset 

func (x *IsEmptyRequest) Reset()

func (*IsEmptyRequest) String 

func (x *IsEmptyRequest) String() string

type IsReadyRequest added in v1.0.1 

type IsReadyRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// contains filtered or unexported fields
}

A request to check the ready status of a cache. @since 14.1.1.2206.5

func (*IsReadyRequest) Descriptor deprecated added in v1.0.1 

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

Deprecated: Use IsReadyRequest.ProtoReflect.Descriptor instead.

func (*IsReadyRequest) GetCache added in v1.0.1 

func (x *IsReadyRequest) GetCache() string

func (*IsReadyRequest) GetScope added in v1.0.1 

func (x *IsReadyRequest) GetScope() string

func (*IsReadyRequest) ProtoMessage added in v1.0.1 

func (*IsReadyRequest) ProtoMessage()

func (*IsReadyRequest) ProtoReflect added in v1.0.1 

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

func (*IsReadyRequest) Reset added in v1.0.1 

func (x *IsReadyRequest) Reset()

func (*IsReadyRequest) String added in v1.0.1 

func (x *IsReadyRequest) String() string

type KeySetRequest 

type KeySetRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The serialized Filter to identify the keys to return.
	Filter []byte `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

A request to get a set of keys from a cache.

func (*KeySetRequest) Descriptor deprecated 

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

Deprecated: Use KeySetRequest.ProtoReflect.Descriptor instead.

func (*KeySetRequest) GetCache 

func (x *KeySetRequest) GetCache() string

func (*KeySetRequest) GetFilter 

func (x *KeySetRequest) GetFilter() []byte

func (*KeySetRequest) GetFormat 

func (x *KeySetRequest) GetFormat() string

func (*KeySetRequest) GetScope 

func (x *KeySetRequest) GetScope() string

func (*KeySetRequest) ProtoMessage 

func (*KeySetRequest) ProtoMessage()

func (*KeySetRequest) ProtoReflect 

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

func (*KeySetRequest) Reset 

func (x *KeySetRequest) Reset()

func (*KeySetRequest) String 

func (x *KeySetRequest) String() string

type MapEventResponse 

type MapEventResponse struct {

	// The type of the event
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The key of the entry
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// The new value of the entry
	NewValue []byte `protobuf:"bytes,3,opt,name=newValue,proto3" json:"newValue,omitempty"`
	// The old value of the entry
	OldValue []byte `protobuf:"bytes,4,opt,name=oldValue,proto3" json:"oldValue,omitempty"`
	// TransformationState describes how a CacheEvent has been or should be transformed.
	TransformationState MapEventResponse_TransformationState `` /* 144-byte string literal not displayed */
	// The Filter identifiers applicable to the event.
	FilterIds []int64 `protobuf:"varint,6,rep,packed,name=filterIds,proto3" json:"filterIds,omitempty"`
	// A flag indicating whether the event is a synthetic event.
	Synthetic bool `protobuf:"varint,7,opt,name=synthetic,proto3" json:"synthetic,omitempty"`
	// A flag indicating whether the event is a priming event.
	Priming bool `protobuf:"varint,8,opt,name=priming,proto3" json:"priming,omitempty"`
	// contains filtered or unexported fields
}

A response containing a MapEvent for a MapListener

func (*MapEventResponse) Descriptor deprecated 

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

Deprecated: Use MapEventResponse.ProtoReflect.Descriptor instead.

func (*MapEventResponse) GetFilterIds 

func (x *MapEventResponse) GetFilterIds() []int64

func (*MapEventResponse) GetId 

func (x *MapEventResponse) GetId() int32

func (*MapEventResponse) GetKey 

func (x *MapEventResponse) GetKey() []byte

func (*MapEventResponse) GetNewValue 

func (x *MapEventResponse) GetNewValue() []byte

func (*MapEventResponse) GetOldValue 

func (x *MapEventResponse) GetOldValue() []byte

func (*MapEventResponse) GetPriming 

func (x *MapEventResponse) GetPriming() bool

func (*MapEventResponse) GetSynthetic 

func (x *MapEventResponse) GetSynthetic() bool

func (*MapEventResponse) GetTransformationState 

func (x *MapEventResponse) GetTransformationState() MapEventResponse_TransformationState

func (*MapEventResponse) ProtoMessage 

func (*MapEventResponse) ProtoMessage()

func (*MapEventResponse) ProtoReflect 

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

func (*MapEventResponse) Reset 

func (x *MapEventResponse) Reset()

func (*MapEventResponse) String 

func (x *MapEventResponse) String() string

type MapEventResponse_TransformationState 

type MapEventResponse_TransformationState int32

An enum of TransformationState values to describes how a CacheEvent has been or should be transformed. 

const (
	// Value used to indicate that an event is non-transformable and should
	// not be passed to any transformer-based listeners.
	MapEventResponse_NON_TRANSFORMABLE MapEventResponse_TransformationState = 0
	// Value used to indicate that an event is transformable and could be
	// passed to transformer-based listeners.
	MapEventResponse_TRANSFORMABLE MapEventResponse_TransformationState = 1
	// Value used to indicate that an event has been transformed, and should
	// only be passed to transformer-based listeners.
	MapEventResponse_TRANSFORMED MapEventResponse_TransformationState = 2
)

func (MapEventResponse_TransformationState) Descriptor 

func (MapEventResponse_TransformationState) Descriptor() protoreflect.EnumDescriptor

func (MapEventResponse_TransformationState) Enum 

func (x MapEventResponse_TransformationState) Enum() *MapEventResponse_TransformationState

func (MapEventResponse_TransformationState) EnumDescriptor deprecated 

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

Deprecated: Use MapEventResponse_TransformationState.Descriptor instead.

func (MapEventResponse_TransformationState) Number 

func (x MapEventResponse_TransformationState) Number() protoreflect.EnumNumber

func (MapEventResponse_TransformationState) String 

func (x MapEventResponse_TransformationState) String() string

func (MapEventResponse_TransformationState) Type 

func (MapEventResponse_TransformationState) Type() protoreflect.EnumType

type MapListenerErrorResponse 

type MapListenerErrorResponse struct {
	Uid     string   `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Message string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Code    int32    `protobuf:"varint,3,opt,name=code,proto3" json:"code,omitempty"`
	Stack   []string `protobuf:"bytes,4,rep,name=stack,proto3" json:"stack,omitempty"`
	// contains filtered or unexported fields
}

A response to indicate that an error occurred processing a MapListener request.

func (*MapListenerErrorResponse) Descriptor deprecated 

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

Deprecated: Use MapListenerErrorResponse.ProtoReflect.Descriptor instead.

func (*MapListenerErrorResponse) GetCode 

func (x *MapListenerErrorResponse) GetCode() int32

func (*MapListenerErrorResponse) GetMessage 

func (x *MapListenerErrorResponse) GetMessage() string

func (*MapListenerErrorResponse) GetStack 

func (x *MapListenerErrorResponse) GetStack() []string

func (*MapListenerErrorResponse) GetUid 

func (x *MapListenerErrorResponse) GetUid() string

func (*MapListenerErrorResponse) ProtoMessage 

func (*MapListenerErrorResponse) ProtoMessage()

func (*MapListenerErrorResponse) ProtoReflect 

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

func (*MapListenerErrorResponse) Reset 

func (x *MapListenerErrorResponse) Reset()

func (*MapListenerErrorResponse) String 

func (x *MapListenerErrorResponse) String() string

type MapListenerRequest 

type MapListenerRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// A unique identifier for the request so that the client
	// can match a request to a response
	Uid string `protobuf:"bytes,4,opt,name=uid,proto3" json:"uid,omitempty"`
	// The type of the request.
	Type MapListenerRequest_RequestType `protobuf:"varint,5,opt,name=type,proto3,enum=coherence.MapListenerRequest_RequestType" json:"type,omitempty"`
	// The serialized Filter to identify the entries to subscribe to.
	Filter []byte `protobuf:"bytes,6,opt,name=filter,proto3" json:"filter,omitempty"`
	// The serialized key to identify the entry to subscribe to.
	Key []byte `protobuf:"bytes,7,opt,name=key,proto3" json:"key,omitempty"`
	// A flag set to true to indicate that the MapEvent objects do
	// not have to include the OldValue and NewValue property values
	// in order to allow optimizations
	Lite bool `protobuf:"varint,8,opt,name=lite,proto3" json:"lite,omitempty"`
	// A flag indicating whether to subscribe to (true) or unsubscribe from (false) events.
	Subscribe bool `protobuf:"varint,9,opt,name=subscribe,proto3" json:"subscribe,omitempty"`
	// A flag set to true to indicate that the listener is a priming listener.
	Priming bool `protobuf:"varint,10,opt,name=priming,proto3" json:"priming,omitempty"`
	// An optional serialized MapTrigger.
	Trigger []byte `protobuf:"bytes,11,opt,name=trigger,proto3" json:"trigger,omitempty"`
	// A unique filter identifier.
	FilterId int64 `protobuf:"varint,12,opt,name=filterId,proto3" json:"filterId,omitempty"`
	// contains filtered or unexported fields
}

A message to subscribe to or unsubscribe from MapEvents for a cache.

func (*MapListenerRequest) Descriptor deprecated 

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

Deprecated: Use MapListenerRequest.ProtoReflect.Descriptor instead.

func (*MapListenerRequest) GetCache 

func (x *MapListenerRequest) GetCache() string

func (*MapListenerRequest) GetFilter 

func (x *MapListenerRequest) GetFilter() []byte

func (*MapListenerRequest) GetFilterId 

func (x *MapListenerRequest) GetFilterId() int64

func (*MapListenerRequest) GetFormat 

func (x *MapListenerRequest) GetFormat() string

func (*MapListenerRequest) GetKey 

func (x *MapListenerRequest) GetKey() []byte

func (*MapListenerRequest) GetLite 

func (x *MapListenerRequest) GetLite() bool

func (*MapListenerRequest) GetPriming 

func (x *MapListenerRequest) GetPriming() bool

func (*MapListenerRequest) GetScope 

func (x *MapListenerRequest) GetScope() string

func (*MapListenerRequest) GetSubscribe 

func (x *MapListenerRequest) GetSubscribe() bool

func (*MapListenerRequest) GetTrigger 

func (x *MapListenerRequest) GetTrigger() []byte

func (*MapListenerRequest) GetType 

func (x *MapListenerRequest) GetType() MapListenerRequest_RequestType

func (*MapListenerRequest) GetUid 

func (x *MapListenerRequest) GetUid() string

func (*MapListenerRequest) ProtoMessage 

func (*MapListenerRequest) ProtoMessage()

func (*MapListenerRequest) ProtoReflect 

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

func (*MapListenerRequest) Reset 

func (x *MapListenerRequest) Reset()

func (*MapListenerRequest) String 

func (x *MapListenerRequest) String() string

type MapListenerRequest_RequestType 

type MapListenerRequest_RequestType int32

An enum representing the request type 

const (
	// The request to initialise the channel.
	MapListenerRequest_INIT MapListenerRequest_RequestType = 0
	// The request is for a key listener.
	MapListenerRequest_KEY MapListenerRequest_RequestType = 1
	// The request is for a Filter listener.
	MapListenerRequest_FILTER MapListenerRequest_RequestType = 2
)

func (MapListenerRequest_RequestType) Descriptor 

func (MapListenerRequest_RequestType) Descriptor() protoreflect.EnumDescriptor

func (MapListenerRequest_RequestType) Enum 

func (x MapListenerRequest_RequestType) Enum() *MapListenerRequest_RequestType

func (MapListenerRequest_RequestType) EnumDescriptor deprecated 

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

Deprecated: Use MapListenerRequest_RequestType.Descriptor instead.

func (MapListenerRequest_RequestType) Number 

func (x MapListenerRequest_RequestType) Number() protoreflect.EnumNumber

func (MapListenerRequest_RequestType) String 

func (x MapListenerRequest_RequestType) String() string

func (MapListenerRequest_RequestType) Type 

func (MapListenerRequest_RequestType) Type() protoreflect.EnumType

type MapListenerResponse 

type MapListenerResponse struct {

	// A response can be one of either a subscribed response or an event response.
	//
	// Types that are assignable to ResponseType:
	//
	//	*MapListenerResponse_Subscribed
	//	*MapListenerResponse_Unsubscribed
	//	*MapListenerResponse_Event
	//	*MapListenerResponse_Error
	//	*MapListenerResponse_Destroyed
	//	*MapListenerResponse_Truncated
	ResponseType isMapListenerResponse_ResponseType `protobuf_oneof:"response_type"`
	// contains filtered or unexported fields
}

A response to indicate that a MapListener was subscribed to a cache.

func (*MapListenerResponse) Descriptor deprecated 

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

Deprecated: Use MapListenerResponse.ProtoReflect.Descriptor instead.

func (*MapListenerResponse) GetDestroyed 

func (x *MapListenerResponse) GetDestroyed() *CacheDestroyedResponse

func (*MapListenerResponse) GetError 

func (x *MapListenerResponse) GetError() *MapListenerErrorResponse

func (*MapListenerResponse) GetEvent 

func (x *MapListenerResponse) GetEvent() *MapEventResponse

func (*MapListenerResponse) GetResponseType 

func (m *MapListenerResponse) GetResponseType() isMapListenerResponse_ResponseType

func (*MapListenerResponse) GetSubscribed 

func (x *MapListenerResponse) GetSubscribed() *MapListenerSubscribedResponse

func (*MapListenerResponse) GetTruncated 

func (x *MapListenerResponse) GetTruncated() *CacheTruncatedResponse

func (*MapListenerResponse) GetUnsubscribed 

func (x *MapListenerResponse) GetUnsubscribed() *MapListenerUnsubscribedResponse

func (*MapListenerResponse) ProtoMessage 

func (*MapListenerResponse) ProtoMessage()

func (*MapListenerResponse) ProtoReflect 

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

func (*MapListenerResponse) Reset 

func (x *MapListenerResponse) Reset()

func (*MapListenerResponse) String 

func (x *MapListenerResponse) String() string

type MapListenerResponse_Destroyed 

type MapListenerResponse_Destroyed struct {
	Destroyed *CacheDestroyedResponse `protobuf:"bytes,5,opt,name=destroyed,proto3,oneof"`
}

type MapListenerResponse_Error 

type MapListenerResponse_Error struct {
	Error *MapListenerErrorResponse `protobuf:"bytes,4,opt,name=error,proto3,oneof"`
}

type MapListenerResponse_Event 

type MapListenerResponse_Event struct {
	Event *MapEventResponse `protobuf:"bytes,3,opt,name=event,proto3,oneof"`
}

type MapListenerResponse_Subscribed 

type MapListenerResponse_Subscribed struct {
	Subscribed *MapListenerSubscribedResponse `protobuf:"bytes,1,opt,name=subscribed,proto3,oneof"`
}

type MapListenerResponse_Truncated 

type MapListenerResponse_Truncated struct {
	Truncated *CacheTruncatedResponse `protobuf:"bytes,6,opt,name=truncated,proto3,oneof"`
}

type MapListenerResponse_Unsubscribed 

type MapListenerResponse_Unsubscribed struct {
	Unsubscribed *MapListenerUnsubscribedResponse `protobuf:"bytes,2,opt,name=unsubscribed,proto3,oneof"`
}

type MapListenerSubscribedResponse 

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

A response to indicate that a MapListener was subscribed to a cache.

func (*MapListenerSubscribedResponse) Descriptor deprecated 

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

Deprecated: Use MapListenerSubscribedResponse.ProtoReflect.Descriptor instead.

func (*MapListenerSubscribedResponse) GetUid 

func (x *MapListenerSubscribedResponse) GetUid() string

func (*MapListenerSubscribedResponse) ProtoMessage 

func (*MapListenerSubscribedResponse) ProtoMessage()

func (*MapListenerSubscribedResponse) ProtoReflect 

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

func (*MapListenerSubscribedResponse) Reset 

func (x *MapListenerSubscribedResponse) Reset()

func (*MapListenerSubscribedResponse) String 

func (x *MapListenerSubscribedResponse) String() string

type MapListenerUnsubscribedResponse 

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

A response to indicate that a MapListener was unsubscribed from a cache.

func (*MapListenerUnsubscribedResponse) Descriptor deprecated 

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

Deprecated: Use MapListenerUnsubscribedResponse.ProtoReflect.Descriptor instead.

func (*MapListenerUnsubscribedResponse) GetUid 

func (x *MapListenerUnsubscribedResponse) GetUid() string

func (*MapListenerUnsubscribedResponse) ProtoMessage 

func (*MapListenerUnsubscribedResponse) ProtoMessage()

func (*MapListenerUnsubscribedResponse) ProtoReflect 

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

func (*MapListenerUnsubscribedResponse) Reset 

func (x *MapListenerUnsubscribedResponse) Reset()

func (*MapListenerUnsubscribedResponse) String 

func (x *MapListenerUnsubscribedResponse) String() string

type NamedCacheServiceClient 

type NamedCacheServiceClient interface {
	// Add an index to a cache.
	AddIndex(ctx context.Context, in *AddIndexRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Obtain the results of running an entry aggregator against the cache.
	// The aggregator may run against entries specified by key or entries
	// matching a given filter.
	Aggregate(ctx context.Context, in *AggregateRequest, opts ...grpc.CallOption) (*wrapperspb.BytesValue, error)
	// Clear a cache.
	Clear(ctx context.Context, in *ClearRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Check if this map contains a mapping for the specified key to the specified value.
	ContainsEntry(ctx context.Context, in *ContainsEntryRequest, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)
	// Check if this map contains a mapping for the specified key.
	ContainsKey(ctx context.Context, in *ContainsKeyRequest, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)
	// Check if this map contains a mapping for the specified value.
	ContainsValue(ctx context.Context, in *ContainsValueRequest, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)
	// Destroy a cache.
	Destroy(ctx context.Context, in *DestroyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Obtain all of the entries in the cache where the cache entries
	// match a given filter.
	EntrySet(ctx context.Context, in *EntrySetRequest, opts ...grpc.CallOption) (NamedCacheService_EntrySetClient, error)
	// Sets up a bidirectional channel for cache events.
	Events(ctx context.Context, opts ...grpc.CallOption) (NamedCacheService_EventsClient, error)
	// Get a value for a given key from a cache.
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*OptionalValue, error)
	// Get all of the values from a cache for a given collection of keys.
	GetAll(ctx context.Context, in *GetAllRequest, opts ...grpc.CallOption) (NamedCacheService_GetAllClient, error)
	// Invoke an entry processor against an entry in a cache.
	Invoke(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (*wrapperspb.BytesValue, error)
	// Invoke an entry processor against a number of entries in a cache.
	InvokeAll(ctx context.Context, in *InvokeAllRequest, opts ...grpc.CallOption) (NamedCacheService_InvokeAllClient, error)
	// Determine whether a cache is empty.
	IsEmpty(ctx context.Context, in *IsEmptyRequest, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)
	// Determine whether a cache is empty.
	IsReady(ctx context.Context, in *IsReadyRequest, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)
	// Obtain all of the keys in the cache where the cache entries
	// match a given filter.
	KeySet(ctx context.Context, in *KeySetRequest, opts ...grpc.CallOption) (NamedCacheService_KeySetClient, error)
	// Get the next page of a paged entry set request.
	NextEntrySetPage(ctx context.Context, in *PageRequest, opts ...grpc.CallOption) (NamedCacheService_NextEntrySetPageClient, error)
	// Get the next page of a paged key set request.
	NextKeySetPage(ctx context.Context, in *PageRequest, opts ...grpc.CallOption) (NamedCacheService_NextKeySetPageClient, error)
	// Associate the specified value with the specified key in this cache.
	// If the cache previously contained a mapping for the key, the old value
	// is replaced by the specified value.
	// An optional expiry (TTL) value may be set for the entry to expire the
	// entry from the cache after that time.
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*wrapperspb.BytesValue, error)
	// Copies all of the mappings from the request into the cache.
	PutAll(ctx context.Context, in *PutAllRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// If the specified key is not already associated with a value (or is mapped
	// to null associate it with the given value and returns null, else return
	// the current value.
	PutIfAbsent(ctx context.Context, in *PutIfAbsentRequest, opts ...grpc.CallOption) (*wrapperspb.BytesValue, error)
	// Remove the mapping that is associated with the specified key.
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*wrapperspb.BytesValue, error)
	// Remove an index from the cache.
	RemoveIndex(ctx context.Context, in *RemoveIndexRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Remove the mapping that is associated with the specified key only
	// if the mapping exists in the cache.
	RemoveMapping(ctx context.Context, in *RemoveMappingRequest, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)
	// Replace the entry for the specified key only if it is currently
	// mapped to some value.
	Replace(ctx context.Context, in *ReplaceRequest, opts ...grpc.CallOption) (*wrapperspb.BytesValue, error)
	// Replace the mapping for the specified key only if currently mapped
	// to the specified value.
	ReplaceMapping(ctx context.Context, in *ReplaceMappingRequest, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)
	// Determine the number of entries in a cache.
	Size(ctx context.Context, in *SizeRequest, opts ...grpc.CallOption) (*wrapperspb.Int32Value, error)
	// Truncate a cache. This is the same as clearing a cache but no
	// cache entry events will be generated.
	Truncate(ctx context.Context, in *TruncateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Obtain all of the values in the cache where the cache entries
	// match a given filter.
	Values(ctx context.Context, in *ValuesRequest, opts ...grpc.CallOption) (NamedCacheService_ValuesClient, error)
}

NamedCacheServiceClient is the client API for NamedCacheService 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 NewNamedCacheServiceClient 

func NewNamedCacheServiceClient(cc grpc.ClientConnInterface) NamedCacheServiceClient

type NamedCacheServiceServer 

type NamedCacheServiceServer interface {
	// Add an index to a cache.
	AddIndex(context.Context, *AddIndexRequest) (*emptypb.Empty, error)
	// Obtain the results of running an entry aggregator against the cache.
	// The aggregator may run against entries specified by key or entries
	// matching a given filter.
	Aggregate(context.Context, *AggregateRequest) (*wrapperspb.BytesValue, error)
	// Clear a cache.
	Clear(context.Context, *ClearRequest) (*emptypb.Empty, error)
	// Check if this map contains a mapping for the specified key to the specified value.
	ContainsEntry(context.Context, *ContainsEntryRequest) (*wrapperspb.BoolValue, error)
	// Check if this map contains a mapping for the specified key.
	ContainsKey(context.Context, *ContainsKeyRequest) (*wrapperspb.BoolValue, error)
	// Check if this map contains a mapping for the specified value.
	ContainsValue(context.Context, *ContainsValueRequest) (*wrapperspb.BoolValue, error)
	// Destroy a cache.
	Destroy(context.Context, *DestroyRequest) (*emptypb.Empty, error)
	// Obtain all of the entries in the cache where the cache entries
	// match a given filter.
	EntrySet(*EntrySetRequest, NamedCacheService_EntrySetServer) error
	// Sets up a bidirectional channel for cache events.
	Events(NamedCacheService_EventsServer) error
	// Get a value for a given key from a cache.
	Get(context.Context, *GetRequest) (*OptionalValue, error)
	// Get all of the values from a cache for a given collection of keys.
	GetAll(*GetAllRequest, NamedCacheService_GetAllServer) error
	// Invoke an entry processor against an entry in a cache.
	Invoke(context.Context, *InvokeRequest) (*wrapperspb.BytesValue, error)
	// Invoke an entry processor against a number of entries in a cache.
	InvokeAll(*InvokeAllRequest, NamedCacheService_InvokeAllServer) error
	// Determine whether a cache is empty.
	IsEmpty(context.Context, *IsEmptyRequest) (*wrapperspb.BoolValue, error)
	// Determine whether a cache is empty.
	IsReady(context.Context, *IsReadyRequest) (*wrapperspb.BoolValue, error)
	// Obtain all of the keys in the cache where the cache entries
	// match a given filter.
	KeySet(*KeySetRequest, NamedCacheService_KeySetServer) error
	// Get the next page of a paged entry set request.
	NextEntrySetPage(*PageRequest, NamedCacheService_NextEntrySetPageServer) error
	// Get the next page of a paged key set request.
	NextKeySetPage(*PageRequest, NamedCacheService_NextKeySetPageServer) error
	// Associate the specified value with the specified key in this cache.
	// If the cache previously contained a mapping for the key, the old value
	// is replaced by the specified value.
	// An optional expiry (TTL) value may be set for the entry to expire the
	// entry from the cache after that time.
	Put(context.Context, *PutRequest) (*wrapperspb.BytesValue, error)
	// Copies all of the mappings from the request into the cache.
	PutAll(context.Context, *PutAllRequest) (*emptypb.Empty, error)
	// If the specified key is not already associated with a value (or is mapped
	// to null associate it with the given value and returns null, else return
	// the current value.
	PutIfAbsent(context.Context, *PutIfAbsentRequest) (*wrapperspb.BytesValue, error)
	// Remove the mapping that is associated with the specified key.
	Remove(context.Context, *RemoveRequest) (*wrapperspb.BytesValue, error)
	// Remove an index from the cache.
	RemoveIndex(context.Context, *RemoveIndexRequest) (*emptypb.Empty, error)
	// Remove the mapping that is associated with the specified key only
	// if the mapping exists in the cache.
	RemoveMapping(context.Context, *RemoveMappingRequest) (*wrapperspb.BoolValue, error)
	// Replace the entry for the specified key only if it is currently
	// mapped to some value.
	Replace(context.Context, *ReplaceRequest) (*wrapperspb.BytesValue, error)
	// Replace the mapping for the specified key only if currently mapped
	// to the specified value.
	ReplaceMapping(context.Context, *ReplaceMappingRequest) (*wrapperspb.BoolValue, error)
	// Determine the number of entries in a cache.
	Size(context.Context, *SizeRequest) (*wrapperspb.Int32Value, error)
	// Truncate a cache. This is the same as clearing a cache but no
	// cache entry events will be generated.
	Truncate(context.Context, *TruncateRequest) (*emptypb.Empty, error)
	// Obtain all of the values in the cache where the cache entries
	// match a given filter.
	Values(*ValuesRequest, NamedCacheService_ValuesServer) error
	// contains filtered or unexported methods
}

NamedCacheServiceServer is the server API for NamedCacheService service. All implementations must embed UnimplementedNamedCacheServiceServer for forward compatibility

type NamedCacheService_EntrySetClient 

type NamedCacheService_EntrySetClient interface {
	Recv() (*Entry, error)
	grpc.ClientStream
}

type NamedCacheService_EntrySetServer 

type NamedCacheService_EntrySetServer interface {
	Send(*Entry) error
	grpc.ServerStream
}

type NamedCacheService_EventsClient 

type NamedCacheService_EventsClient interface {
	Send(*MapListenerRequest) error
	Recv() (*MapListenerResponse, error)
	grpc.ClientStream
}

type NamedCacheService_EventsServer 

type NamedCacheService_EventsServer interface {
	Send(*MapListenerResponse) error
	Recv() (*MapListenerRequest, error)
	grpc.ServerStream
}

type NamedCacheService_GetAllClient 

type NamedCacheService_GetAllClient interface {
	Recv() (*Entry, error)
	grpc.ClientStream
}

type NamedCacheService_GetAllServer 

type NamedCacheService_GetAllServer interface {
	Send(*Entry) error
	grpc.ServerStream
}

type NamedCacheService_InvokeAllClient 

type NamedCacheService_InvokeAllClient interface {
	Recv() (*Entry, error)
	grpc.ClientStream
}

type NamedCacheService_InvokeAllServer 

type NamedCacheService_InvokeAllServer interface {
	Send(*Entry) error
	grpc.ServerStream
}

type NamedCacheService_KeySetClient 

type NamedCacheService_KeySetClient interface {
	Recv() (*wrapperspb.BytesValue, error)
	grpc.ClientStream
}

type NamedCacheService_KeySetServer 

type NamedCacheService_KeySetServer interface {
	Send(*wrapperspb.BytesValue) error
	grpc.ServerStream
}

type NamedCacheService_NextEntrySetPageClient 

type NamedCacheService_NextEntrySetPageClient interface {
	Recv() (*EntryResult, error)
	grpc.ClientStream
}

type NamedCacheService_NextEntrySetPageServer 

type NamedCacheService_NextEntrySetPageServer interface {
	Send(*EntryResult) error
	grpc.ServerStream
}

type NamedCacheService_NextKeySetPageClient 

type NamedCacheService_NextKeySetPageClient interface {
	Recv() (*wrapperspb.BytesValue, error)
	grpc.ClientStream
}

type NamedCacheService_NextKeySetPageServer 

type NamedCacheService_NextKeySetPageServer interface {
	Send(*wrapperspb.BytesValue) error
	grpc.ServerStream
}

type NamedCacheService_ValuesClient 

type NamedCacheService_ValuesClient interface {
	Recv() (*wrapperspb.BytesValue, error)
	grpc.ClientStream
}

type NamedCacheService_ValuesServer 

type NamedCacheService_ValuesServer interface {
	Send(*wrapperspb.BytesValue) error
	grpc.ServerStream
}

type OptionalValue 

type OptionalValue struct {

	// A flag indicating whether the value is present.
	Present bool `protobuf:"varint,1,opt,name=present,proto3" json:"present,omitempty"`
	// The serialized value.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

An optional value.

func (*OptionalValue) Descriptor deprecated 

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

Deprecated: Use OptionalValue.ProtoReflect.Descriptor instead.

func (*OptionalValue) GetPresent 

func (x *OptionalValue) GetPresent() bool

func (*OptionalValue) GetValue 

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

func (*OptionalValue) ProtoMessage 

func (*OptionalValue) ProtoMessage()

func (*OptionalValue) ProtoReflect 

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

func (*OptionalValue) Reset 

func (x *OptionalValue) Reset()

func (*OptionalValue) String 

func (x *OptionalValue) String() string

type PageRequest 

type PageRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// An opaque cookie to track the requested page.
	Cookie []byte `protobuf:"bytes,4,opt,name=cookie,proto3" json:"cookie,omitempty"`
	// contains filtered or unexported fields
}

A request for a page of data from a cache. This request is used for implementing methods such as NamedCache.keySet(), NamedCache.entrySet() and NamedCache.values() where it would be impractical to return the whole data set in one response.

func (*PageRequest) Descriptor deprecated 

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

Deprecated: Use PageRequest.ProtoReflect.Descriptor instead.

func (*PageRequest) GetCache 

func (x *PageRequest) GetCache() string

func (*PageRequest) GetCookie 

func (x *PageRequest) GetCookie() []byte

func (*PageRequest) GetFormat 

func (x *PageRequest) GetFormat() string

func (*PageRequest) GetScope 

func (x *PageRequest) GetScope() string

func (*PageRequest) ProtoMessage 

func (*PageRequest) ProtoMessage()

func (*PageRequest) ProtoReflect 

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

func (*PageRequest) Reset 

func (x *PageRequest) Reset()

func (*PageRequest) String 

func (x *PageRequest) String() string

type PutAllRequest 

type PutAllRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The cache entries to put.
	Entry []*Entry `protobuf:"bytes,4,rep,name=entry,proto3" json:"entry,omitempty"`
	// The time to live in millis.
	Ttl int64 `protobuf:"varint,6,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

A request to associate the specified value with the specified key in a cache.

func (*PutAllRequest) Descriptor deprecated 

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

Deprecated: Use PutAllRequest.ProtoReflect.Descriptor instead.

func (*PutAllRequest) GetCache 

func (x *PutAllRequest) GetCache() string

func (*PutAllRequest) GetEntry 

func (x *PutAllRequest) GetEntry() []*Entry

func (*PutAllRequest) GetFormat 

func (x *PutAllRequest) GetFormat() string

func (*PutAllRequest) GetScope 

func (x *PutAllRequest) GetScope() string

func (*PutAllRequest) GetTtl added in v1.1.0 

func (x *PutAllRequest) GetTtl() int64

func (*PutAllRequest) ProtoMessage 

func (*PutAllRequest) ProtoMessage()

func (*PutAllRequest) ProtoReflect 

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

func (*PutAllRequest) Reset 

func (x *PutAllRequest) Reset()

func (*PutAllRequest) String 

func (x *PutAllRequest) String() string

type PutIfAbsentRequest 

type PutIfAbsentRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The cache entry key.
	Key []byte `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// The value to be put.
	Value []byte `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	// The time to live in millis.
	Ttl int64 `protobuf:"varint,6,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

A request to associate the specified value with the specified key in a cache only if the specified key is not associated with any value (including null).

func (*PutIfAbsentRequest) Descriptor deprecated 

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

Deprecated: Use PutIfAbsentRequest.ProtoReflect.Descriptor instead.

func (*PutIfAbsentRequest) GetCache 

func (x *PutIfAbsentRequest) GetCache() string

func (*PutIfAbsentRequest) GetFormat 

func (x *PutIfAbsentRequest) GetFormat() string

func (*PutIfAbsentRequest) GetKey 

func (x *PutIfAbsentRequest) GetKey() []byte

func (*PutIfAbsentRequest) GetScope 

func (x *PutIfAbsentRequest) GetScope() string

func (*PutIfAbsentRequest) GetTtl 

func (x *PutIfAbsentRequest) GetTtl() int64

func (*PutIfAbsentRequest) GetValue 

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

func (*PutIfAbsentRequest) ProtoMessage 

func (*PutIfAbsentRequest) ProtoMessage()

func (*PutIfAbsentRequest) ProtoReflect 

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

func (*PutIfAbsentRequest) Reset 

func (x *PutIfAbsentRequest) Reset()

func (*PutIfAbsentRequest) String 

func (x *PutIfAbsentRequest) String() string

type PutRequest 

type PutRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The cache entry key.
	Key []byte `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// The value of the entry.
	Value []byte `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	// The time to live in millis.
	Ttl int64 `protobuf:"varint,6,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

A request to associate the specified value with the specified key in a cache.

func (*PutRequest) Descriptor deprecated 

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetCache 

func (x *PutRequest) GetCache() string

func (*PutRequest) GetFormat 

func (x *PutRequest) GetFormat() string

func (*PutRequest) GetKey 

func (x *PutRequest) GetKey() []byte

func (*PutRequest) GetScope 

func (x *PutRequest) GetScope() string

func (*PutRequest) GetTtl 

func (x *PutRequest) GetTtl() int64

func (*PutRequest) GetValue 

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

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect 

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

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) String 

func (x *PutRequest) String() string

type RemoveIndexRequest 

type RemoveIndexRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The serialized ValueExtractor to use to create the index.
	Extractor []byte `protobuf:"bytes,4,opt,name=extractor,proto3" json:"extractor,omitempty"`
	// contains filtered or unexported fields
}

A request to remove an index from a cache

func (*RemoveIndexRequest) Descriptor deprecated 

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

Deprecated: Use RemoveIndexRequest.ProtoReflect.Descriptor instead.

func (*RemoveIndexRequest) GetCache 

func (x *RemoveIndexRequest) GetCache() string

func (*RemoveIndexRequest) GetExtractor 

func (x *RemoveIndexRequest) GetExtractor() []byte

func (*RemoveIndexRequest) GetFormat 

func (x *RemoveIndexRequest) GetFormat() string

func (*RemoveIndexRequest) GetScope 

func (x *RemoveIndexRequest) GetScope() string

func (*RemoveIndexRequest) ProtoMessage 

func (*RemoveIndexRequest) ProtoMessage()

func (*RemoveIndexRequest) ProtoReflect 

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

func (*RemoveIndexRequest) Reset 

func (x *RemoveIndexRequest) Reset()

func (*RemoveIndexRequest) String 

func (x *RemoveIndexRequest) String() string

type RemoveMappingRequest 

type RemoveMappingRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The key of the entry to be removed.
	Key []byte `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// The value of the entry to verify.
	Value []byte `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

A request to remove the mapping for a key from a cache only if the specified key is associated with the specified value in that cache.

func (*RemoveMappingRequest) Descriptor deprecated 

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

Deprecated: Use RemoveMappingRequest.ProtoReflect.Descriptor instead.

func (*RemoveMappingRequest) GetCache 

func (x *RemoveMappingRequest) GetCache() string

func (*RemoveMappingRequest) GetFormat 

func (x *RemoveMappingRequest) GetFormat() string

func (*RemoveMappingRequest) GetKey 

func (x *RemoveMappingRequest) GetKey() []byte

func (*RemoveMappingRequest) GetScope 

func (x *RemoveMappingRequest) GetScope() string

func (*RemoveMappingRequest) GetValue 

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

func (*RemoveMappingRequest) ProtoMessage 

func (*RemoveMappingRequest) ProtoMessage()

func (*RemoveMappingRequest) ProtoReflect 

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

func (*RemoveMappingRequest) Reset 

func (x *RemoveMappingRequest) Reset()

func (*RemoveMappingRequest) String 

func (x *RemoveMappingRequest) String() string

type RemoveRequest 

type RemoveRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The key of the entry to be removed.
	Key []byte `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

A request to remove the mapping for a key from a cache if it is present.

func (*RemoveRequest) Descriptor deprecated 

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

Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.

func (*RemoveRequest) GetCache 

func (x *RemoveRequest) GetCache() string

func (*RemoveRequest) GetFormat 

func (x *RemoveRequest) GetFormat() string

func (*RemoveRequest) GetKey 

func (x *RemoveRequest) GetKey() []byte

func (*RemoveRequest) GetScope 

func (x *RemoveRequest) GetScope() string

func (*RemoveRequest) ProtoMessage 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) ProtoReflect 

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

func (*RemoveRequest) Reset 

func (x *RemoveRequest) Reset()

func (*RemoveRequest) String 

func (x *RemoveRequest) String() string

type ReplaceMappingRequest 

type ReplaceMappingRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The key of the entry to be replaced.
	Key []byte `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// The previous value that should exist in the cache.
	PreviousValue []byte `protobuf:"bytes,5,opt,name=previousValue,proto3" json:"previousValue,omitempty"`
	// The new value to put.
	NewValue []byte `protobuf:"bytes,6,opt,name=newValue,proto3" json:"newValue,omitempty"`
	// contains filtered or unexported fields
}

A request to replace the mapping for the specified key with the specified newValue in a cache only if the specified key is associated with the specified previousValue in that cache.

func (*ReplaceMappingRequest) Descriptor deprecated 

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

Deprecated: Use ReplaceMappingRequest.ProtoReflect.Descriptor instead.

func (*ReplaceMappingRequest) GetCache 

func (x *ReplaceMappingRequest) GetCache() string

func (*ReplaceMappingRequest) GetFormat 

func (x *ReplaceMappingRequest) GetFormat() string

func (*ReplaceMappingRequest) GetKey 

func (x *ReplaceMappingRequest) GetKey() []byte

func (*ReplaceMappingRequest) GetNewValue 

func (x *ReplaceMappingRequest) GetNewValue() []byte

func (*ReplaceMappingRequest) GetPreviousValue 

func (x *ReplaceMappingRequest) GetPreviousValue() []byte

func (*ReplaceMappingRequest) GetScope 

func (x *ReplaceMappingRequest) GetScope() string

func (*ReplaceMappingRequest) ProtoMessage 

func (*ReplaceMappingRequest) ProtoMessage()

func (*ReplaceMappingRequest) ProtoReflect 

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

func (*ReplaceMappingRequest) Reset 

func (x *ReplaceMappingRequest) Reset()

func (*ReplaceMappingRequest) String 

func (x *ReplaceMappingRequest) String() string

type ReplaceRequest 

type ReplaceRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The key of the entry to be replaced.
	Key []byte `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// The value of the entry to be replaced.
	Value []byte `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

A request to replace the mapping for the specified key with the specified value in a cache only if the specified key is associated with some value in that cache.

func (*ReplaceRequest) Descriptor deprecated 

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

Deprecated: Use ReplaceRequest.ProtoReflect.Descriptor instead.

func (*ReplaceRequest) GetCache 

func (x *ReplaceRequest) GetCache() string

func (*ReplaceRequest) GetFormat 

func (x *ReplaceRequest) GetFormat() string

func (*ReplaceRequest) GetKey 

func (x *ReplaceRequest) GetKey() []byte

func (*ReplaceRequest) GetScope 

func (x *ReplaceRequest) GetScope() string

func (*ReplaceRequest) GetValue 

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

func (*ReplaceRequest) ProtoMessage 

func (*ReplaceRequest) ProtoMessage()

func (*ReplaceRequest) ProtoReflect 

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

func (*ReplaceRequest) Reset 

func (x *ReplaceRequest) Reset()

func (*ReplaceRequest) String 

func (x *ReplaceRequest) String() string

type SizeRequest 

type SizeRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// contains filtered or unexported fields
}

A request to determine the number of entries in a cache.

func (*SizeRequest) Descriptor deprecated 

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

Deprecated: Use SizeRequest.ProtoReflect.Descriptor instead.

func (*SizeRequest) GetCache 

func (x *SizeRequest) GetCache() string

func (*SizeRequest) GetScope 

func (x *SizeRequest) GetScope() string

func (*SizeRequest) ProtoMessage 

func (*SizeRequest) ProtoMessage()

func (*SizeRequest) ProtoReflect 

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

func (*SizeRequest) Reset 

func (x *SizeRequest) Reset()

func (*SizeRequest) String 

func (x *SizeRequest) String() string

type TruncateRequest 

type TruncateRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// contains filtered or unexported fields
}

A request to truncate a cache.

func (*TruncateRequest) Descriptor deprecated 

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

Deprecated: Use TruncateRequest.ProtoReflect.Descriptor instead.

func (*TruncateRequest) GetCache 

func (x *TruncateRequest) GetCache() string

func (*TruncateRequest) GetScope 

func (x *TruncateRequest) GetScope() string

func (*TruncateRequest) ProtoMessage 

func (*TruncateRequest) ProtoMessage()

func (*TruncateRequest) ProtoReflect 

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

func (*TruncateRequest) Reset 

func (x *TruncateRequest) Reset()

func (*TruncateRequest) String 

func (x *TruncateRequest) String() string

type UnimplementedNamedCacheServiceServer 

type UnimplementedNamedCacheServiceServer struct {
}

UnimplementedNamedCacheServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedNamedCacheServiceServer) AddIndex 

func (UnimplementedNamedCacheServiceServer) AddIndex(context.Context, *AddIndexRequest) (*emptypb.Empty, error)

func (UnimplementedNamedCacheServiceServer) Aggregate 

func (UnimplementedNamedCacheServiceServer) Aggregate(context.Context, *AggregateRequest) (*wrapperspb.BytesValue, error)

func (UnimplementedNamedCacheServiceServer) Clear 

func (UnimplementedNamedCacheServiceServer) Clear(context.Context, *ClearRequest) (*emptypb.Empty, error)

func (UnimplementedNamedCacheServiceServer) ContainsEntry 

func (UnimplementedNamedCacheServiceServer) ContainsEntry(context.Context, *ContainsEntryRequest) (*wrapperspb.BoolValue, error)

func (UnimplementedNamedCacheServiceServer) ContainsKey 

func (UnimplementedNamedCacheServiceServer) ContainsKey(context.Context, *ContainsKeyRequest) (*wrapperspb.BoolValue, error)

func (UnimplementedNamedCacheServiceServer) ContainsValue 

func (UnimplementedNamedCacheServiceServer) ContainsValue(context.Context, *ContainsValueRequest) (*wrapperspb.BoolValue, error)

func (UnimplementedNamedCacheServiceServer) Destroy 

func (UnimplementedNamedCacheServiceServer) Destroy(context.Context, *DestroyRequest) (*emptypb.Empty, error)

func (UnimplementedNamedCacheServiceServer) EntrySet 

func (UnimplementedNamedCacheServiceServer) EntrySet(*EntrySetRequest, NamedCacheService_EntrySetServer) error

func (UnimplementedNamedCacheServiceServer) Events 

func (UnimplementedNamedCacheServiceServer) Events(NamedCacheService_EventsServer) error

func (UnimplementedNamedCacheServiceServer) Get 

func (UnimplementedNamedCacheServiceServer) Get(context.Context, *GetRequest) (*OptionalValue, error)

func (UnimplementedNamedCacheServiceServer) GetAll 

func (UnimplementedNamedCacheServiceServer) GetAll(*GetAllRequest, NamedCacheService_GetAllServer) error

func (UnimplementedNamedCacheServiceServer) Invoke 

func (UnimplementedNamedCacheServiceServer) Invoke(context.Context, *InvokeRequest) (*wrapperspb.BytesValue, error)

func (UnimplementedNamedCacheServiceServer) InvokeAll 

func (UnimplementedNamedCacheServiceServer) InvokeAll(*InvokeAllRequest, NamedCacheService_InvokeAllServer) error

func (UnimplementedNamedCacheServiceServer) IsEmpty 

func (UnimplementedNamedCacheServiceServer) IsEmpty(context.Context, *IsEmptyRequest) (*wrapperspb.BoolValue, error)

func (UnimplementedNamedCacheServiceServer) IsReady added in v1.0.1 

func (UnimplementedNamedCacheServiceServer) IsReady(context.Context, *IsReadyRequest) (*wrapperspb.BoolValue, error)

func (UnimplementedNamedCacheServiceServer) KeySet 

func (UnimplementedNamedCacheServiceServer) KeySet(*KeySetRequest, NamedCacheService_KeySetServer) error

func (UnimplementedNamedCacheServiceServer) NextEntrySetPage 

func (UnimplementedNamedCacheServiceServer) NextEntrySetPage(*PageRequest, NamedCacheService_NextEntrySetPageServer) error

func (UnimplementedNamedCacheServiceServer) NextKeySetPage 

func (UnimplementedNamedCacheServiceServer) NextKeySetPage(*PageRequest, NamedCacheService_NextKeySetPageServer) error

func (UnimplementedNamedCacheServiceServer) Put 

func (UnimplementedNamedCacheServiceServer) Put(context.Context, *PutRequest) (*wrapperspb.BytesValue, error)

func (UnimplementedNamedCacheServiceServer) PutAll 

func (UnimplementedNamedCacheServiceServer) PutAll(context.Context, *PutAllRequest) (*emptypb.Empty, error)

func (UnimplementedNamedCacheServiceServer) PutIfAbsent 

func (UnimplementedNamedCacheServiceServer) PutIfAbsent(context.Context, *PutIfAbsentRequest) (*wrapperspb.BytesValue, error)

func (UnimplementedNamedCacheServiceServer) Remove 

func (UnimplementedNamedCacheServiceServer) Remove(context.Context, *RemoveRequest) (*wrapperspb.BytesValue, error)

func (UnimplementedNamedCacheServiceServer) RemoveIndex 

func (UnimplementedNamedCacheServiceServer) RemoveIndex(context.Context, *RemoveIndexRequest) (*emptypb.Empty, error)

func (UnimplementedNamedCacheServiceServer) RemoveMapping 

func (UnimplementedNamedCacheServiceServer) RemoveMapping(context.Context, *RemoveMappingRequest) (*wrapperspb.BoolValue, error)

func (UnimplementedNamedCacheServiceServer) Replace 

func (UnimplementedNamedCacheServiceServer) Replace(context.Context, *ReplaceRequest) (*wrapperspb.BytesValue, error)

func (UnimplementedNamedCacheServiceServer) ReplaceMapping 

func (UnimplementedNamedCacheServiceServer) ReplaceMapping(context.Context, *ReplaceMappingRequest) (*wrapperspb.BoolValue, error)

func (UnimplementedNamedCacheServiceServer) Size 

func (UnimplementedNamedCacheServiceServer) Size(context.Context, *SizeRequest) (*wrapperspb.Int32Value, error)

func (UnimplementedNamedCacheServiceServer) Truncate 

func (UnimplementedNamedCacheServiceServer) Truncate(context.Context, *TruncateRequest) (*emptypb.Empty, error)

func (UnimplementedNamedCacheServiceServer) Values 

func (UnimplementedNamedCacheServiceServer) Values(*ValuesRequest, NamedCacheService_ValuesServer) error

type UnsafeNamedCacheServiceServer 

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

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

type ValuesRequest 

type ValuesRequest struct {

	// The scope name to use to obtain the cache.
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// The name of the cache.
	Cache string `protobuf:"bytes,2,opt,name=cache,proto3" json:"cache,omitempty"`
	// The serialization format.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The serialized Filter to identify the values to return.
	Filter []byte `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// The optional comparator to use to sort the returned values.
	Comparator []byte `protobuf:"bytes,5,opt,name=comparator,proto3" json:"comparator,omitempty"`
	// contains filtered or unexported fields
}

A request to get a collection of values from a cache.

func (*ValuesRequest) Descriptor deprecated 

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

Deprecated: Use ValuesRequest.ProtoReflect.Descriptor instead.

func (*ValuesRequest) GetCache 

func (x *ValuesRequest) GetCache() string

func (*ValuesRequest) GetComparator 

func (x *ValuesRequest) GetComparator() []byte

func (*ValuesRequest) GetFilter 

func (x *ValuesRequest) GetFilter() []byte

func (*ValuesRequest) GetFormat 

func (x *ValuesRequest) GetFormat() string

func (*ValuesRequest) GetScope 

func (x *ValuesRequest) GetScope() string

func (*ValuesRequest) ProtoMessage 

func (*ValuesRequest) ProtoMessage()

func (*ValuesRequest) ProtoReflect 

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

func (*ValuesRequest) Reset 

func (x *ValuesRequest) Reset()

func (*ValuesRequest) String 

func (x *ValuesRequest) 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.