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) Enum

func (MapEventResponse_TransformationState) EnumDescriptor deprecated

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

Deprecated: Use MapEventResponse_TransformationState.Descriptor instead.

func (MapEventResponse_TransformationState) Number

func (MapEventResponse_TransformationState) String

func (MapEventResponse_TransformationState) Type

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 (*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) Enum

func (MapListenerRequest_RequestType) EnumDescriptor deprecated

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

Deprecated: Use MapListenerRequest_RequestType.Descriptor instead.

func (MapListenerRequest_RequestType) Number

func (MapListenerRequest_RequestType) String

func (MapListenerRequest_RequestType) Type

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 (*MapListenerResponse) GetEvent

func (x *MapListenerResponse) GetEvent() *MapEventResponse

func (*MapListenerResponse) GetResponseType

func (m *MapListenerResponse) GetResponseType() isMapListenerResponse_ResponseType

func (*MapListenerResponse) GetSubscribed

func (*MapListenerResponse) GetTruncated

func (x *MapListenerResponse) GetTruncated() *CacheTruncatedResponse

func (*MapListenerResponse) GetUnsubscribed

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 (*MapListenerSubscribedResponse) ProtoMessage

func (*MapListenerSubscribedResponse) ProtoMessage()

func (*MapListenerSubscribedResponse) ProtoReflect

func (*MapListenerSubscribedResponse) Reset

func (x *MapListenerSubscribedResponse) Reset()

func (*MapListenerSubscribedResponse) 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 (*MapListenerUnsubscribedResponse) ProtoMessage

func (*MapListenerUnsubscribedResponse) ProtoMessage()

func (*MapListenerUnsubscribedResponse) ProtoReflect

func (*MapListenerUnsubscribedResponse) Reset

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

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) Aggregate

func (UnimplementedNamedCacheServiceServer) Clear

func (UnimplementedNamedCacheServiceServer) ContainsEntry

func (UnimplementedNamedCacheServiceServer) ContainsKey

func (UnimplementedNamedCacheServiceServer) ContainsValue

func (UnimplementedNamedCacheServiceServer) Destroy

func (UnimplementedNamedCacheServiceServer) EntrySet

func (UnimplementedNamedCacheServiceServer) Events

func (UnimplementedNamedCacheServiceServer) Get

func (UnimplementedNamedCacheServiceServer) GetAll

func (UnimplementedNamedCacheServiceServer) Invoke

func (UnimplementedNamedCacheServiceServer) InvokeAll

func (UnimplementedNamedCacheServiceServer) IsEmpty

func (UnimplementedNamedCacheServiceServer) IsReady added in v1.0.1

func (UnimplementedNamedCacheServiceServer) KeySet

func (UnimplementedNamedCacheServiceServer) NextEntrySetPage

func (UnimplementedNamedCacheServiceServer) NextKeySetPage

func (UnimplementedNamedCacheServiceServer) Put

func (UnimplementedNamedCacheServiceServer) PutAll

func (UnimplementedNamedCacheServiceServer) PutIfAbsent

func (UnimplementedNamedCacheServiceServer) Remove

func (UnimplementedNamedCacheServiceServer) RemoveIndex

func (UnimplementedNamedCacheServiceServer) RemoveMapping

func (UnimplementedNamedCacheServiceServer) Replace

func (UnimplementedNamedCacheServiceServer) ReplaceMapping

func (UnimplementedNamedCacheServiceServer) Size

func (UnimplementedNamedCacheServiceServer) Truncate

func (UnimplementedNamedCacheServiceServer) Values

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

Jump to

Keyboard shortcuts

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