v1

package
v2.0.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	ProxyService_SubChannel_FullMethodName = "/coherence.proxy.v1.ProxyService/subChannel"
)

Variables

View Source 
var (
	NamedCacheRequestType_name = map[int32]string{
		0:  "Unknown",
		1:  "EnsureCache",
		2:  "Aggregate",
		3:  "Clear",
		4:  "ContainsEntry",
		5:  "ContainsKey",
		6:  "ContainsValue",
		7:  "Destroy",
		8:  "IsEmpty",
		9:  "IsReady",
		10: "Get",
		11: "GetAll",
		12: "Index",
		13: "Invoke",
		14: "MapListener",
		15: "PageOfEntries",
		16: "PageOfKeys",
		17: "Put",
		18: "PutAll",
		19: "PutIfAbsent",
		20: "QueryEntries",
		21: "QueryKeys",
		22: "QueryValues",
		23: "Remove",
		24: "RemoveMapping",
		25: "Replace",
		26: "ReplaceMapping",
		27: "Size",
		28: "Truncate",
	}
	NamedCacheRequestType_value = map[string]int32{
		"Unknown":        0,
		"EnsureCache":    1,
		"Aggregate":      2,
		"Clear":          3,
		"ContainsEntry":  4,
		"ContainsKey":    5,
		"ContainsValue":  6,
		"Destroy":        7,
		"IsEmpty":        8,
		"IsReady":        9,
		"Get":            10,
		"GetAll":         11,
		"Index":          12,
		"Invoke":         13,
		"MapListener":    14,
		"PageOfEntries":  15,
		"PageOfKeys":     16,
		"Put":            17,
		"PutAll":         18,
		"PutIfAbsent":    19,
		"QueryEntries":   20,
		"QueryKeys":      21,
		"QueryValues":    22,
		"Remove":         23,
		"RemoveMapping":  24,
		"Replace":        25,
		"ReplaceMapping": 26,
		"Size":           27,
		"Truncate":       28,
	}
)

Enum value maps for NamedCacheRequestType.

View Source 
var (
	ResponseType_name = map[int32]string{
		0: "Message",
		1: "MapEvent",
		2: "Destroyed",
		3: "Truncated",
	}
	ResponseType_value = map[string]int32{
		"Message":   0,
		"MapEvent":  1,
		"Destroyed": 2,
		"Truncated": 3,
	}
)

Enum value maps for ResponseType.

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

Enum value maps for MapEventMessage_TransformationState.

View Source 
var (
	NamedQueueRequestType_name = map[int32]string{
		0:  "Unknown",
		1:  "Clear",
		2:  "Destroy",
		3:  "EnsureQueue",
		4:  "IsEmpty",
		5:  "IsReady",
		6:  "OfferTail",
		7:  "OfferHead",
		8:  "PollHead",
		9:  "PeekHead",
		10: "PollTail",
		11: "PeekTail",
		12: "Size",
	}
	NamedQueueRequestType_value = map[string]int32{
		"Unknown":     0,
		"Clear":       1,
		"Destroy":     2,
		"EnsureQueue": 3,
		"IsEmpty":     4,
		"IsReady":     5,
		"OfferTail":   6,
		"OfferHead":   7,
		"PollHead":    8,
		"PeekHead":    9,
		"PollTail":    10,
		"PeekTail":    11,
		"Size":        12,
	}
)

Enum value maps for NamedQueueRequestType.

View Source 
var (
	NamedQueueResponseType_name = map[int32]string{
		0: "Message",
		1: "QueueEvent",
		2: "Destroyed",
		3: "Truncated",
	}
	NamedQueueResponseType_value = map[string]int32{
		"Message":    0,
		"QueueEvent": 1,
		"Destroyed":  2,
		"Truncated":  3,
	}
)

Enum value maps for NamedQueueResponseType.

View Source 
var (
	NamedQueueType_name = map[int32]string{
		0: "Queue",
		1: "Deque",
		3: "PagedQueue",
	}
	NamedQueueType_value = map[string]int32{
		"Queue":      0,
		"Deque":      1,
		"PagedQueue": 3,
	}
)

Enum value maps for NamedQueueType.

View Source 
var File_cache_service_messages_v1_proto protoreflect.FileDescriptor
View Source 
var File_common_messages_v1_proto protoreflect.FileDescriptor
View Source 
var File_proxy_service_messages_v1_proto protoreflect.FileDescriptor
View Source 
var File_proxy_service_v1_proto protoreflect.FileDescriptor
View Source 
var File_queue_service_messages_v1_proto protoreflect.FileDescriptor
View Source 
var ProxyService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "coherence.proxy.v1.ProxyService",
	HandlerType: (*ProxyServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "subChannel",
			Handler:       _ProxyService_SubChannel_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "proxy_service_v1.proto",
}

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

Functions

func RegisterProxyServiceServer 

func RegisterProxyServiceServer(s grpc.ServiceRegistrar, srv ProxyServiceServer)

Types

type BinaryKeyAndValue 

type BinaryKeyAndValue struct {

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

A message containing a serialized key and value.

func (*BinaryKeyAndValue) Descriptor deprecated 

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

Deprecated: Use BinaryKeyAndValue.ProtoReflect.Descriptor instead.

func (*BinaryKeyAndValue) GetKey 

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

func (*BinaryKeyAndValue) GetValue 

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

func (*BinaryKeyAndValue) ProtoMessage 

func (*BinaryKeyAndValue) ProtoMessage()

func (*BinaryKeyAndValue) ProtoReflect 

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

func (*BinaryKeyAndValue) Reset 

func (x *BinaryKeyAndValue) Reset()

func (*BinaryKeyAndValue) String 

func (x *BinaryKeyAndValue) String() string

type CollectionOfBytesValues 

type CollectionOfBytesValues struct {

	// The serialized values
	Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

A message that contains a collection of serialized binary values.

func (*CollectionOfBytesValues) Descriptor deprecated 

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

Deprecated: Use CollectionOfBytesValues.ProtoReflect.Descriptor instead.

func (*CollectionOfBytesValues) GetValues 

func (x *CollectionOfBytesValues) GetValues() [][]byte

func (*CollectionOfBytesValues) ProtoMessage 

func (*CollectionOfBytesValues) ProtoMessage()

func (*CollectionOfBytesValues) ProtoReflect 

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

func (*CollectionOfBytesValues) Reset 

func (x *CollectionOfBytesValues) Reset()

func (*CollectionOfBytesValues) String 

func (x *CollectionOfBytesValues) String() string

type Complete 

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

A message to indicate completion of a request response.

func (*Complete) Descriptor deprecated 

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

Deprecated: Use Complete.ProtoReflect.Descriptor instead.

func (*Complete) ProtoMessage 

func (*Complete) ProtoMessage()

func (*Complete) ProtoReflect 

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

func (*Complete) Reset 

func (x *Complete) Reset()

func (*Complete) String 

func (x *Complete) String() string

type EnsureCacheRequest 

type EnsureCacheRequest struct {

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

A request to ensure a specific cache.

func (*EnsureCacheRequest) Descriptor deprecated 

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

Deprecated: Use EnsureCacheRequest.ProtoReflect.Descriptor instead.

func (*EnsureCacheRequest) GetCache 

func (x *EnsureCacheRequest) GetCache() string

func (*EnsureCacheRequest) ProtoMessage 

func (*EnsureCacheRequest) ProtoMessage()

func (*EnsureCacheRequest) ProtoReflect 

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

func (*EnsureCacheRequest) Reset 

func (x *EnsureCacheRequest) Reset()

func (*EnsureCacheRequest) String 

func (x *EnsureCacheRequest) String() string

type EnsureQueueRequest 

type EnsureQueueRequest struct {

	// The name of the queue.
	Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// The type of queue
	Type NamedQueueType `protobuf:"varint,2,opt,name=type,proto3,enum=coherence.concurrent.queue.v1.NamedQueueType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

A request to ensure a specific queue.

func (*EnsureQueueRequest) Descriptor deprecated 

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

Deprecated: Use EnsureQueueRequest.ProtoReflect.Descriptor instead.

func (*EnsureQueueRequest) GetQueue 

func (x *EnsureQueueRequest) GetQueue() string

func (*EnsureQueueRequest) GetType 

func (x *EnsureQueueRequest) GetType() NamedQueueType

func (*EnsureQueueRequest) ProtoMessage 

func (*EnsureQueueRequest) ProtoMessage()

func (*EnsureQueueRequest) ProtoReflect 

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

func (*EnsureQueueRequest) Reset 

func (x *EnsureQueueRequest) Reset()

func (*EnsureQueueRequest) String 

func (x *EnsureQueueRequest) String() string

type ErrorMessage 

type ErrorMessage struct {

	// The text of the error message
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// An optional Exception serialized using the client's serializer
	Error []byte `protobuf:"bytes,2,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

An error message

func (*ErrorMessage) Descriptor deprecated 

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

Deprecated: Use ErrorMessage.ProtoReflect.Descriptor instead.

func (*ErrorMessage) GetError 

func (x *ErrorMessage) GetError() []byte

func (*ErrorMessage) GetMessage 

func (x *ErrorMessage) GetMessage() string

func (*ErrorMessage) ProtoMessage 

func (*ErrorMessage) ProtoMessage()

func (*ErrorMessage) ProtoReflect 

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

func (*ErrorMessage) Reset 

func (x *ErrorMessage) Reset()

func (*ErrorMessage) String 

func (x *ErrorMessage) String() string

type ExecuteRequest 

type ExecuteRequest struct {

	// The serialized executable agent (for example an entry processor or aggregator).
	Agent []byte `protobuf:"bytes,1,opt,name=agent,proto3" json:"agent,omitempty"`
	// The optional collection of keys or filter to use to execute the agent.
	Keys *KeysOrFilter `protobuf:"bytes,3,opt,name=keys,proto3,oneof" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

A request to aggregate entries in a cache.

func (*ExecuteRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetAgent 

func (x *ExecuteRequest) GetAgent() []byte

func (*ExecuteRequest) GetKeys 

func (x *ExecuteRequest) GetKeys() *KeysOrFilter

func (*ExecuteRequest) ProtoMessage 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) ProtoReflect 

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

func (*ExecuteRequest) Reset 

func (x *ExecuteRequest) Reset()

func (*ExecuteRequest) String 

func (x *ExecuteRequest) String() string

type HeartbeatMessage 

type HeartbeatMessage struct {

	// The UUID of the client
	Uuid []byte `protobuf:"bytes,1,opt,name=uuid,proto3,oneof" json:"uuid,omitempty"`
	// True to send a heartbeat response
	Ack bool `protobuf:"varint,2,opt,name=ack,proto3" json:"ack,omitempty"`
	// contains filtered or unexported fields
}

A heart beat message.

func (*HeartbeatMessage) Descriptor deprecated 

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

Deprecated: Use HeartbeatMessage.ProtoReflect.Descriptor instead.

func (*HeartbeatMessage) GetAck 

func (x *HeartbeatMessage) GetAck() bool

func (*HeartbeatMessage) GetUuid 

func (x *HeartbeatMessage) GetUuid() []byte

func (*HeartbeatMessage) ProtoMessage 

func (*HeartbeatMessage) ProtoMessage()

func (*HeartbeatMessage) ProtoReflect 

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

func (*HeartbeatMessage) Reset 

func (x *HeartbeatMessage) Reset()

func (*HeartbeatMessage) String 

func (x *HeartbeatMessage) String() string

type IndexRequest 

type IndexRequest struct {

	// True to add an index, false to remove an index
	Add bool `protobuf:"varint,1,opt,name=add,proto3" json:"add,omitempty"`
	// The serialized ValueExtractor to use to create or remove the index.
	Extractor []byte `protobuf:"bytes,2,opt,name=extractor,proto3" json:"extractor,omitempty"`
	// A flag indicating whether to sort the index.
	// This is not required for index removal.
	Sorted *bool `protobuf:"varint,3,opt,name=sorted,proto3,oneof" json:"sorted,omitempty"`
	// The optional comparator to use to sort the index.
	// This is not required for index removal.
	Comparator []byte `protobuf:"bytes,4,opt,name=comparator,proto3,oneof" json:"comparator,omitempty"`
	// contains filtered or unexported fields
}

A request to add or remove an index to a cache

func (*IndexRequest) Descriptor deprecated 

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

Deprecated: Use IndexRequest.ProtoReflect.Descriptor instead.

func (*IndexRequest) GetAdd 

func (x *IndexRequest) GetAdd() bool

func (*IndexRequest) GetComparator 

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

func (*IndexRequest) GetExtractor 

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

func (*IndexRequest) GetSorted 

func (x *IndexRequest) GetSorted() bool

func (*IndexRequest) ProtoMessage 

func (*IndexRequest) ProtoMessage()

func (*IndexRequest) ProtoReflect 

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

func (*IndexRequest) Reset 

func (x *IndexRequest) Reset()

func (*IndexRequest) String 

func (x *IndexRequest) String() string

type InitRequest 

type InitRequest struct {

	// The scope name to use to obtain the server resources.
	Scope string `protobuf:"bytes,2,opt,name=scope,proto3" json:"scope,omitempty"`
	// The serialization format to use.
	Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"`
	// The protocol to use for the channel
	Protocol string `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// The protocol version requested by the client
	ProtocolVersion int32 `protobuf:"varint,5,opt,name=protocolVersion,proto3" json:"protocolVersion,omitempty"`
	// The minimum protocol version supported by the client
	SupportedProtocolVersion int32 `protobuf:"varint,6,opt,name=supportedProtocolVersion,proto3" json:"supportedProtocolVersion,omitempty"`
	// The requested frequency that heartbeat messages should be sent by the server (in millis)
	Heartbeat *int64 `protobuf:"varint,7,opt,name=heartbeat,proto3,oneof" json:"heartbeat,omitempty"`
	// The optional client UUID (usually from Coherence clients that have a local Member UUID).
	ClientUuid []byte `protobuf:"bytes,8,opt,name=clientUuid,proto3,oneof" json:"clientUuid,omitempty"`
	// contains filtered or unexported fields
}

Initialize a connection.

func (*InitRequest) Descriptor deprecated 

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

Deprecated: Use InitRequest.ProtoReflect.Descriptor instead.

func (*InitRequest) GetClientUuid 

func (x *InitRequest) GetClientUuid() []byte

func (*InitRequest) GetFormat 

func (x *InitRequest) GetFormat() string

func (*InitRequest) GetHeartbeat 

func (x *InitRequest) GetHeartbeat() int64

func (*InitRequest) GetProtocol 

func (x *InitRequest) GetProtocol() string

func (*InitRequest) GetProtocolVersion 

func (x *InitRequest) GetProtocolVersion() int32

func (*InitRequest) GetScope 

func (x *InitRequest) GetScope() string

func (*InitRequest) GetSupportedProtocolVersion 

func (x *InitRequest) GetSupportedProtocolVersion() int32

func (*InitRequest) ProtoMessage 

func (*InitRequest) ProtoMessage()

func (*InitRequest) ProtoReflect 

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

func (*InitRequest) Reset 

func (x *InitRequest) Reset()

func (*InitRequest) String 

func (x *InitRequest) String() string

type InitResponse 

type InitResponse struct {

	// This client connection's UUID.
	Uuid []byte `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// The Coherence version of the proxy
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// The encoded version of the proxy
	EncodedVersion int32 `protobuf:"varint,3,opt,name=encodedVersion,proto3" json:"encodedVersion,omitempty"`
	// The protocol version the client should use
	ProtocolVersion int32 `protobuf:"varint,4,opt,name=protocolVersion,proto3" json:"protocolVersion,omitempty"`
	// The proxy member Id
	ProxyMemberId int32 `protobuf:"varint,5,opt,name=proxyMemberId,proto3" json:"proxyMemberId,omitempty"`
	// The proxy member UUID
	ProxyMemberUuid []byte `protobuf:"bytes,6,opt,name=proxyMemberUuid,proto3" json:"proxyMemberUuid,omitempty"`
	// contains filtered or unexported fields
}

The response to an InitRequest

func (*InitResponse) Descriptor deprecated 

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

Deprecated: Use InitResponse.ProtoReflect.Descriptor instead.

func (*InitResponse) GetEncodedVersion 

func (x *InitResponse) GetEncodedVersion() int32

func (*InitResponse) GetProtocolVersion 

func (x *InitResponse) GetProtocolVersion() int32

func (*InitResponse) GetProxyMemberId 

func (x *InitResponse) GetProxyMemberId() int32

func (*InitResponse) GetProxyMemberUuid 

func (x *InitResponse) GetProxyMemberUuid() []byte

func (*InitResponse) GetUuid 

func (x *InitResponse) GetUuid() []byte

func (*InitResponse) GetVersion 

func (x *InitResponse) GetVersion() string

func (*InitResponse) ProtoMessage 

func (*InitResponse) ProtoMessage()

func (*InitResponse) ProtoReflect 

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

func (*InitResponse) Reset 

func (x *InitResponse) Reset()

func (*InitResponse) String 

func (x *InitResponse) String() string

type KeyOrFilter 

type KeyOrFilter struct {

	// Types that are assignable to KeyOrFilter:
	//
	//	*KeyOrFilter_Key
	//	*KeyOrFilter_Filter
	KeyOrFilter isKeyOrFilter_KeyOrFilter `protobuf_oneof:"keyOrFilter"`
	// contains filtered or unexported fields
}

A message containing either a single serialized key, or a serialized Filter.

func (*KeyOrFilter) Descriptor deprecated 

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

Deprecated: Use KeyOrFilter.ProtoReflect.Descriptor instead.

func (*KeyOrFilter) GetFilter 

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

func (*KeyOrFilter) GetKey 

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

func (*KeyOrFilter) GetKeyOrFilter 

func (m *KeyOrFilter) GetKeyOrFilter() isKeyOrFilter_KeyOrFilter

func (*KeyOrFilter) ProtoMessage 

func (*KeyOrFilter) ProtoMessage()

func (*KeyOrFilter) ProtoReflect 

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

func (*KeyOrFilter) Reset 

func (x *KeyOrFilter) Reset()

func (*KeyOrFilter) String 

func (x *KeyOrFilter) String() string

type KeyOrFilter_Filter 

type KeyOrFilter_Filter struct {
	// The serialized filter
	Filter []byte `protobuf:"bytes,2,opt,name=filter,proto3,oneof"`
}

type KeyOrFilter_Key 

type KeyOrFilter_Key struct {
	// A single serialized key
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3,oneof"`
}

type KeysOrFilter 

type KeysOrFilter struct {

	// Types that are assignable to KeyOrFilter:
	//
	//	*KeysOrFilter_Key
	//	*KeysOrFilter_Keys
	//	*KeysOrFilter_Filter
	KeyOrFilter isKeysOrFilter_KeyOrFilter `protobuf_oneof:"keyOrFilter"`
	// contains filtered or unexported fields
}

A message containing either a single serialized key, or a collection of serialized keys, or a serialized Filter.

func (*KeysOrFilter) Descriptor deprecated 

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

Deprecated: Use KeysOrFilter.ProtoReflect.Descriptor instead.

func (*KeysOrFilter) GetFilter 

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

func (*KeysOrFilter) GetKey 

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

func (*KeysOrFilter) GetKeyOrFilter 

func (m *KeysOrFilter) GetKeyOrFilter() isKeysOrFilter_KeyOrFilter

func (*KeysOrFilter) GetKeys 

func (x *KeysOrFilter) GetKeys() *CollectionOfBytesValues

func (*KeysOrFilter) ProtoMessage 

func (*KeysOrFilter) ProtoMessage()

func (*KeysOrFilter) ProtoReflect 

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

func (*KeysOrFilter) Reset 

func (x *KeysOrFilter) Reset()

func (*KeysOrFilter) String 

func (x *KeysOrFilter) String() string

type KeysOrFilter_Filter 

type KeysOrFilter_Filter struct {
	// The serialized filter
	Filter []byte `protobuf:"bytes,3,opt,name=filter,proto3,oneof"`
}

type KeysOrFilter_Key 

type KeysOrFilter_Key struct {
	// A single serialized key
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3,oneof"`
}

type KeysOrFilter_Keys 

type KeysOrFilter_Keys struct {
	// The collection of serialized keys
	Keys *CollectionOfBytesValues `protobuf:"bytes,2,opt,name=keys,proto3,oneof"`
}

type MapEventMessage 

type MapEventMessage 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 MapEventMessage_TransformationState `` /* 152-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"`
	// A flag indicating whether this is an expiry event.
	Expired bool `protobuf:"varint,9,opt,name=expired,proto3" json:"expired,omitempty"`
	// true iff this event is caused by a synthetic version update sent
	// by the server to notify clients of the current version.
	VersionUpdate bool `protobuf:"varint,10,opt,name=versionUpdate,proto3" json:"versionUpdate,omitempty"`
	// contains filtered or unexported fields
}

A response containing a MapEvent for a MapListener

func (*MapEventMessage) Descriptor deprecated 

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

Deprecated: Use MapEventMessage.ProtoReflect.Descriptor instead.

func (*MapEventMessage) GetExpired 

func (x *MapEventMessage) GetExpired() bool

func (*MapEventMessage) GetFilterIds 

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

func (*MapEventMessage) GetId 

func (x *MapEventMessage) GetId() int32

func (*MapEventMessage) GetKey 

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

func (*MapEventMessage) GetNewValue 

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

func (*MapEventMessage) GetOldValue 

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

func (*MapEventMessage) GetPriming 

func (x *MapEventMessage) GetPriming() bool

func (*MapEventMessage) GetSynthetic 

func (x *MapEventMessage) GetSynthetic() bool

func (*MapEventMessage) GetTransformationState 

func (x *MapEventMessage) GetTransformationState() MapEventMessage_TransformationState

func (*MapEventMessage) GetVersionUpdate 

func (x *MapEventMessage) GetVersionUpdate() bool

func (*MapEventMessage) ProtoMessage 

func (*MapEventMessage) ProtoMessage()

func (*MapEventMessage) ProtoReflect 

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

func (*MapEventMessage) Reset 

func (x *MapEventMessage) Reset()

func (*MapEventMessage) String 

func (x *MapEventMessage) String() string

type MapEventMessage_TransformationState 

type MapEventMessage_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.
	MapEventMessage_NON_TRANSFORMABLE MapEventMessage_TransformationState = 0
	// Value used to indicate that an event is transformable and could be
	// passed to transformer-based listeners.
	MapEventMessage_TRANSFORMABLE MapEventMessage_TransformationState = 1
	// Value used to indicate that an event has been transformed, and should
	// only be passed to transformer-based listeners.
	MapEventMessage_TRANSFORMED MapEventMessage_TransformationState = 2
)

func (MapEventMessage_TransformationState) Descriptor 

func (MapEventMessage_TransformationState) Descriptor() protoreflect.EnumDescriptor

func (MapEventMessage_TransformationState) Enum 

func (x MapEventMessage_TransformationState) Enum() *MapEventMessage_TransformationState

func (MapEventMessage_TransformationState) EnumDescriptor deprecated 

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

Deprecated: Use MapEventMessage_TransformationState.Descriptor instead.

func (MapEventMessage_TransformationState) Number 

func (x MapEventMessage_TransformationState) Number() protoreflect.EnumNumber

func (MapEventMessage_TransformationState) String 

func (x MapEventMessage_TransformationState) String() string

func (MapEventMessage_TransformationState) Type 

func (MapEventMessage_TransformationState) Type() protoreflect.EnumType

type MapListenerRequest 

type MapListenerRequest struct {

	// A flag indicating whether to subscribe to (true) or unsubscribe from (false) events.
	Subscribe bool `protobuf:"varint,1,opt,name=subscribe,proto3" json:"subscribe,omitempty"`
	// The optional serialized key, or serialized Filter, to identify the entry
	// (or entries) to subscribe to.
	// If neither key nor filter are set then an Always filter will be used.
	KeyOrFilter *KeyOrFilter `protobuf:"bytes,2,opt,name=keyOrFilter,proto3,oneof" json:"keyOrFilter,omitempty"`
	// A unique filter identifier used if the keyOrFilter contains a Filter.
	FilterId int64 `protobuf:"varint,3,opt,name=filterId,proto3" json:"filterId,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,4,opt,name=lite,proto3" json:"lite,omitempty"`
	// Whether the listener is synchronous
	Synchronous bool `protobuf:"varint,5,opt,name=synchronous,proto3" json:"synchronous,omitempty"`
	// A flag set to true to indicate that the listener is a priming listener.
	// A priming listener can only be used when the keyOrFilter field contains
	// a single key, or an InKeySetFilter.
	Priming bool `protobuf:"varint,6,opt,name=priming,proto3" json:"priming,omitempty"`
	// An optional serialized MapTrigger.
	Trigger []byte `protobuf:"bytes,7,opt,name=trigger,proto3" json:"trigger,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) GetFilterId 

func (x *MapListenerRequest) GetFilterId() int64

func (*MapListenerRequest) GetKeyOrFilter 

func (x *MapListenerRequest) GetKeyOrFilter() *KeyOrFilter

func (*MapListenerRequest) GetLite 

func (x *MapListenerRequest) GetLite() bool

func (*MapListenerRequest) GetPriming 

func (x *MapListenerRequest) GetPriming() bool

func (*MapListenerRequest) GetSubscribe 

func (x *MapListenerRequest) GetSubscribe() bool

func (*MapListenerRequest) GetSynchronous 

func (x *MapListenerRequest) GetSynchronous() bool

func (*MapListenerRequest) GetTrigger 

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

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 NamedCacheRequest 

type NamedCacheRequest struct {

	// The type of the request
	Type NamedCacheRequestType `protobuf:"varint,1,opt,name=type,proto3,enum=coherence.cache.v1.NamedCacheRequestType" json:"type,omitempty"`
	// The cache identifier for the request.
	// The identifier must be the same value returned by the initial ensure cache request.
	// This is optional only for EnsureCache as this cannot have a cache identifier
	CacheId *int32 `protobuf:"varint,2,opt,name=cacheId,proto3,oneof" json:"cacheId,omitempty"`
	// The actual request message, this is optional because some messages do not require
	// a message body, for example cache.size()
	// The actual request message should be packed inside an Any message and set in this field.
	// The proxy will know which message type to expect here based on the "type" field's value.
	Message *anypb.Any `protobuf:"bytes,3,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// contains filtered or unexported fields
}

A request to perform an operation on a remote NamedCache.

func (*NamedCacheRequest) Descriptor deprecated 

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

Deprecated: Use NamedCacheRequest.ProtoReflect.Descriptor instead.

func (*NamedCacheRequest) GetCacheId 

func (x *NamedCacheRequest) GetCacheId() int32

func (*NamedCacheRequest) GetMessage 

func (x *NamedCacheRequest) GetMessage() *anypb.Any

func (*NamedCacheRequest) GetType 

func (x *NamedCacheRequest) GetType() NamedCacheRequestType

func (*NamedCacheRequest) ProtoMessage 

func (*NamedCacheRequest) ProtoMessage()

func (*NamedCacheRequest) ProtoReflect 

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

func (*NamedCacheRequest) Reset 

func (x *NamedCacheRequest) Reset()

func (*NamedCacheRequest) String 

func (x *NamedCacheRequest) String() string

type NamedCacheRequestType 

type NamedCacheRequestType int32

An enum representing the types of request for a Named Cache Service proxy

NOTE: The index numbers for the enum elements MUST NOT BE CHANGED as that would break backwards compatibility. Only new index numbers can be added. 

const (
	// An unknown message.
	// This request type is not used, it is here as enums must have a zero value,
	// but we need to know the difference between a zero value and the field being
	// incorrectly set.
	NamedCacheRequestType_Unknown NamedCacheRequestType = 0
	// Called to ensure a cache.
	// Must be the first message called prior to any other cache requests.
	// The message field must be an EnsureCacheRequest.
	// The response will contain the Cache Id and an empty response field.
	NamedCacheRequestType_EnsureCache NamedCacheRequestType = 1
	// Execute an aggregator on the cache and return the result.
	// The message field must contain an ExecuteRequest where the agent field
	// is the serialized aggregator.
	// The response will be a BytesValue containing the aggregator result.
	NamedCacheRequestType_Aggregate NamedCacheRequestType = 2
	// Clear the specified cache.
	// The message field should not be set.
	// The response will just be a Complete message corresponding to the request id.
	NamedCacheRequestType_Clear NamedCacheRequestType = 3
	// Determine whether the specified cache is contains a specified key mapped
	// to a specified value.
	// The message field must contain a BinaryKeyAndValue that contains the
	// serialized key and value.
	// The response will contain the Cache Id and a BoolValue in the response field.
	NamedCacheRequestType_ContainsEntry NamedCacheRequestType = 4
	// Determine whether the specified cache is contains a specified key.
	// The message field must contain a BytesValue that contains the
	// serialized key.
	// The response will contain the Cache Id and a BoolValue in the response field.
	NamedCacheRequestType_ContainsKey NamedCacheRequestType = 5
	// Determine whether the specified cache is contains a specified value.
	// The message field must contain a BytesValue that contains the
	// serialized value.
	// The response will contain the Cache Id and a BoolValue in the response field.
	NamedCacheRequestType_ContainsValue NamedCacheRequestType = 6
	// Destroy the specified cache.
	// The message field should not be set.
	// The response will just be a Complete message corresponding to the request id.
	NamedCacheRequestType_Destroy NamedCacheRequestType = 7
	// Determine whether the specified cache is empty.
	// The message field should not be set.
	// The response will contain the Cache Id and a BoolValue in the response field.
	NamedCacheRequestType_IsEmpty NamedCacheRequestType = 8
	// Determine whether the specified cache is ready.
	// The message field should not be set.
	// The response will contain the Cache Id and a BoolValue in the response field.
	NamedCacheRequestType_IsReady NamedCacheRequestType = 9
	// Determine whether the specified cache is contains a specified key.
	// The message field must contain a BytesValue that contains the
	// serialized key of the entry to get.
	// The response will contain the Cache Id and an OptionalValue that will be empty
	// if the cache did not contain an entry for the key or will contain the value from
	// the cache.
	NamedCacheRequestType_Get NamedCacheRequestType = 10
	// Return the values from the specified cache that are mapped to a collection of keys.
	// The message field must contain a CollectionOfBytesValues that contains the
	// serialized keys of the entries to get.
	// There will be multiple responses containing the Cache Id and an BinaryKeyAndValue for
	// each requested key.
	NamedCacheRequestType_GetAll NamedCacheRequestType = 11
	// Add or remove an index.
	// The message field must contain an IndexRequest.
	// The response will just be a Complete message corresponding to the request id.
	NamedCacheRequestType_Index NamedCacheRequestType = 12
	// Execute an entry processor against a single entry in the cache and return the result.
	// The message field must contain a ExecuteRequest where the agent field
	// is the serialized entry processor.
	// The response will be a stream of BinaryKeyAndValue values followed by a Complete
	// message to signal the end of the response stream.
	NamedCacheRequestType_Invoke NamedCacheRequestType = 13
	// Add or remove a MapListener.
	// The message field must contain a MapListenerRequest.
	// The response will just be a Complete message corresponding to the request id.
	NamedCacheRequestType_MapListener NamedCacheRequestType = 14
	// Retrieve a page of entries from the cache
	// The message field must contain a BytesValue that is the opaque cookie returned
	// by a previous page request, or an empty (or not set) BytesValue to retrieve the
	// first page.
	// The response will be a stream of results. The first response will be a BytesValue
	// which is the new cookie, followed by a stream of BinaryKeyAndValue messages for
	// each cache entry in the page, finally followed by a Complete message to signal
	// the end of the response stream.
	NamedCacheRequestType_PageOfEntries NamedCacheRequestType = 15
	// Retrieve a page of keys from the cache
	// The message field must contain a BytesValue that is the opaque cookie returned
	// by a previous page request, or an empty (or not set) BytesValue to retrieve the
	// first page.
	// The response will be a stream of results. The first response will be a BytesValue
	// which is the new cookie, followed by a stream of BytesValue messages for
	// each cache key in the page, finally followed by a Complete message to signal
	// the end of the response stream.
	NamedCacheRequestType_PageOfKeys NamedCacheRequestType = 16
	// Add a key and value to the cache, with an optional TTL.
	// The message field must contain a PutRequest that contains the
	// serialized key, serialized value and optional TTL.
	// The response will contain the Cache Id and an BytesValue that will be empty
	// if the cache did not contain an entry for the key or will contain the previous
	// value from the cache that was mapped to the key.
	NamedCacheRequestType_Put NamedCacheRequestType = 17
	// Add a set of keys and values to the cache, with an optional TTL.
	// The message field must contain a PutAllRequest that contains the
	// serialized keys and values and optional TTL.
	// The response will just be a Complete message corresponding to the request id.
	NamedCacheRequestType_PutAll NamedCacheRequestType = 18
	// Add a key and value to the cache if a value is not already mapped to the key.
	// The message field should contain a PutRequest that contains the
	// serialized key, serialized value.
	// The response will contain the Cache Id and an BytesValue that will contain the
	// serialized previous value mapped to the key.
	NamedCacheRequestType_PutIfAbsent NamedCacheRequestType = 19
	// Execute a query for cache entries
	// The message field must contain a QueryRequest
	// The response will be a stream of BinaryKeyAndValue representing each cache entry
	// in the results of the query, finally followed by a Complete message to signal
	// the end of the response stream.
	NamedCacheRequestType_QueryEntries NamedCacheRequestType = 20
	// Execute a query for cache keys
	// The message field must contain a QueryRequest
	// The response will be a stream of BytesValue representing each cache key in
	// the results of the query, finally followed by a Complete message to signal
	// the end of the response stream.
	NamedCacheRequestType_QueryKeys NamedCacheRequestType = 21
	// Execute a query for cache values
	// The message field must contain a QueryRequest
	// The response will be a stream of BytesValue representing each cache value in
	// the results of the query, finally followed by a Complete message to signal
	// the end of the response stream.
	NamedCacheRequestType_QueryValues NamedCacheRequestType = 22
	// Remove an entry from the cache.
	// The message field must contain a BytesValue that contains the
	// serialized key of the entry to remove.
	// The response will contain the Cache Id and an BytesValue that will be empty
	// if the cache did not contain an entry for the key or will contain the value from
	// the cache.
	NamedCacheRequestType_Remove NamedCacheRequestType = 23
	// Remove an entry from the cache if the specified key maps to the specified value.
	// The message field must contain a BinaryKeyAndValue that contains the
	// serialized key and expected value of the entry to remove.
	// The response will contain the Cache Id and an BoolValue that will true if the
	// entry was removed.
	NamedCacheRequestType_RemoveMapping NamedCacheRequestType = 24
	// Replace an entry in the cache only if the key is currently mapped to a value.
	// The message field must contain a BinaryKeyAndValue that contains the
	// serialized key of the entry to replace and the serialized value to map to the
	// key.
	// The response will contain the Cache Id and an BytesValue that will contain the
	// serialized previous value mapped to the key.
	NamedCacheRequestType_Replace NamedCacheRequestType = 25
	// Replace an entry in the cache only if the key is currently mapped to a
	// specified value.
	// The message field must contain a ReplaceMappingRequest that contains the
	// serialized key of the entry to replace, the serialized expected value and the
	// serialized new value to map to the key.
	// The response will contain the Cache Id and an BoolValue that will be true if
	// the cache mapping was updated.
	NamedCacheRequestType_ReplaceMapping NamedCacheRequestType = 26
	// Obtain the size of the specified cache.
	// The message field should not be set.
	// The response will contain the Cache Id and an Int32Value in the response field.
	NamedCacheRequestType_Size NamedCacheRequestType = 27
	// Truncate the specified cache.
	// The message field should not be set.
	// The response will just be a Complete message corresponding to the request id.
	NamedCacheRequestType_Truncate NamedCacheRequestType = 28
)

func (NamedCacheRequestType) Descriptor 

func (NamedCacheRequestType) Descriptor() protoreflect.EnumDescriptor

func (NamedCacheRequestType) Enum 

func (x NamedCacheRequestType) Enum() *NamedCacheRequestType

func (NamedCacheRequestType) EnumDescriptor deprecated 

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

Deprecated: Use NamedCacheRequestType.Descriptor instead.

func (NamedCacheRequestType) Number 

func (x NamedCacheRequestType) Number() protoreflect.EnumNumber

func (NamedCacheRequestType) String 

func (x NamedCacheRequestType) String() string

func (NamedCacheRequestType) Type 

func (NamedCacheRequestType) Type() protoreflect.EnumType

type NamedCacheResponse 

type NamedCacheResponse struct {

	// The cache identifier for the request
	CacheId int32 `protobuf:"varint,1,opt,name=cacheId,proto3" json:"cacheId,omitempty"`
	// An enum representing different response types.
	// The type of the request.
	Type ResponseType `protobuf:"varint,2,opt,name=type,proto3,enum=coherence.cache.v1.ResponseType" json:"type,omitempty"`
	// The response can contain one of a number of response types
	// The sender of the corresponding request should know which
	// response type it expects
	Message *anypb.Any `protobuf:"bytes,3,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// contains filtered or unexported fields
}

A response message from a Named Cache Service proxy.

NOTE: If you add a new request message to this message the protocol version in com.oracle.coherence.grpc.NamedCacheProtocol must be increased. This only needs to be done once for any given Coherence release.

func (*NamedCacheResponse) Descriptor deprecated 

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

Deprecated: Use NamedCacheResponse.ProtoReflect.Descriptor instead.

func (*NamedCacheResponse) GetCacheId 

func (x *NamedCacheResponse) GetCacheId() int32

func (*NamedCacheResponse) GetMessage 

func (x *NamedCacheResponse) GetMessage() *anypb.Any

func (*NamedCacheResponse) GetType 

func (x *NamedCacheResponse) GetType() ResponseType

func (*NamedCacheResponse) ProtoMessage 

func (*NamedCacheResponse) ProtoMessage()

func (*NamedCacheResponse) ProtoReflect 

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

func (*NamedCacheResponse) Reset 

func (x *NamedCacheResponse) Reset()

func (*NamedCacheResponse) String 

func (x *NamedCacheResponse) String() string

type NamedQueueRequest 

type NamedQueueRequest struct {

	// The type of the request
	Type NamedQueueRequestType `protobuf:"varint,1,opt,name=type,proto3,enum=coherence.concurrent.queue.v1.NamedQueueRequestType" json:"type,omitempty"`
	// The queue identifier for the request.
	// The identifier must be the same value returned by the initial ensure queue request.
	// This is optional only for EnsureQueue as this cannot have a queue identifier
	QueueId *int32 `protobuf:"varint,2,opt,name=queueId,proto3,oneof" json:"queueId,omitempty"`
	// The actual request message, this is optional because some messages do not require
	// a message body, for example queue.size()
	// The actual request message should be packed inside an Any message and set in this field.
	// The proxy will know which message type to expect here based on the "type" field's value.
	Message *anypb.Any `protobuf:"bytes,3,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// contains filtered or unexported fields
}

A request to perform an operation on a remote NamedQueue.

func (*NamedQueueRequest) Descriptor deprecated 

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

Deprecated: Use NamedQueueRequest.ProtoReflect.Descriptor instead.

func (*NamedQueueRequest) GetMessage 

func (x *NamedQueueRequest) GetMessage() *anypb.Any

func (*NamedQueueRequest) GetQueueId 

func (x *NamedQueueRequest) GetQueueId() int32

func (*NamedQueueRequest) GetType 

func (x *NamedQueueRequest) GetType() NamedQueueRequestType

func (*NamedQueueRequest) ProtoMessage 

func (*NamedQueueRequest) ProtoMessage()

func (*NamedQueueRequest) ProtoReflect 

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

func (*NamedQueueRequest) Reset 

func (x *NamedQueueRequest) Reset()

func (*NamedQueueRequest) String 

func (x *NamedQueueRequest) String() string

type NamedQueueRequestType 

type NamedQueueRequestType int32

An enum representing the types of request for a Named Queue Service proxy

NOTE: The index numbers for the enum elements MUST NOT BE CHANGED as that would break backwards compatibility. Only new index numbers can be added. 

const (
	// An unknown message.
	// This request type is not used, it is here as enums must have a zero value,
	// but we need to know the difference between a zero value and the field being
	// incorrectly set.
	NamedQueueRequestType_Unknown NamedQueueRequestType = 0
	// Clear the specified queue.
	// The message field should not be set.
	// The response will just be a Complete message corresponding to the request id.
	NamedQueueRequestType_Clear NamedQueueRequestType = 1
	// Destroy the specified queue.
	// The message field should not be set.
	// The response will just be a Complete message corresponding to the request id.
	NamedQueueRequestType_Destroy NamedQueueRequestType = 2
	// Called to ensure a queue.
	// Must be the first message called prior to any other queue requests.
	// The message field must be an EnsureQueueRequest.
	// The response will contain the Queue Id and an empty response field.
	NamedQueueRequestType_EnsureQueue NamedQueueRequestType = 3
	// Determine whether the specified queue is empty.
	// The message field should not be set.
	// The response will contain the Queue Id and a BoolValue in the response field.
	NamedQueueRequestType_IsEmpty NamedQueueRequestType = 4
	// Determine whether the specified queue is ready.
	// The message field should not be set.
	// The response will contain the Queue Id and a BoolValue in the response field.
	NamedQueueRequestType_IsReady NamedQueueRequestType = 5
	// Add a value to the tail of a Queue.
	// The message field must contain a BytesValue that contains the
	// serialized value.
	// The response will contain the Queue Id and a QueueOfferResult containing the
	// result of the offer operation.
	NamedQueueRequestType_OfferTail NamedQueueRequestType = 6
	// Add a value to the head of a Deque.
	// This method is only supported for a double ended Deque.
	// The queue type used to ensure the queue must have been a Deque
	// The message field must contain a BytesValue that contains the
	// serialized value.
	// The response will contain the Queue Id and a QueueOfferResult containing the
	// result of the offer operation.
	NamedQueueRequestType_OfferHead NamedQueueRequestType = 7
	// Retrieves and removes the head of this queue.
	// The response will contain the Queue Id and an OptionalValue that will be empty
	// if the queue was empty.
	NamedQueueRequestType_PollHead NamedQueueRequestType = 8
	// Retrieves, but does not remove, the head of this queue.
	// The response will contain the Queue Id and an OptionalValue that will be empty
	// if the queue was empty.
	NamedQueueRequestType_PeekHead NamedQueueRequestType = 9
	// Retrieves and removes the head of this queue.
	// This method is only supported for a double ended Deque.
	// The queue type used to ensure the queue must have been a Deque
	// The response will contain the Queue Id and an OptionalValue that will be empty
	// if the deque was empty.
	NamedQueueRequestType_PollTail NamedQueueRequestType = 10
	// Retrieves, but does not remove, the head of a Deque.
	// This method is only supported for a double ended Deque.
	// The queue type used to ensure the queue must have been a Deque
	// The response will contain the Queue Id and an OptionalValue that will be empty
	// if the queue was empty.
	NamedQueueRequestType_PeekTail NamedQueueRequestType = 11
	// Obtain the size of the specified queue.
	// The message field should not be set.
	// The response will contain the Queue Id and an Int32Value in the response field.
	NamedQueueRequestType_Size NamedQueueRequestType = 12
)

func (NamedQueueRequestType) Descriptor 

func (NamedQueueRequestType) Descriptor() protoreflect.EnumDescriptor

func (NamedQueueRequestType) Enum 

func (x NamedQueueRequestType) Enum() *NamedQueueRequestType

func (NamedQueueRequestType) EnumDescriptor deprecated 

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

Deprecated: Use NamedQueueRequestType.Descriptor instead.

func (NamedQueueRequestType) Number 

func (x NamedQueueRequestType) Number() protoreflect.EnumNumber

func (NamedQueueRequestType) String 

func (x NamedQueueRequestType) String() string

func (NamedQueueRequestType) Type 

func (NamedQueueRequestType) Type() protoreflect.EnumType

type NamedQueueResponse 

type NamedQueueResponse struct {

	// The queue identifier for the request
	QueueId int32 `protobuf:"varint,1,opt,name=queueId,proto3" json:"queueId,omitempty"`
	// An enum representing different response types.
	Type NamedQueueResponseType `protobuf:"varint,2,opt,name=type,proto3,enum=coherence.concurrent.queue.v1.NamedQueueResponseType" json:"type,omitempty"`
	// The response can contain one of a number of response types
	// The sender of the corresponding request should know which
	// response type it expects
	Message *anypb.Any `protobuf:"bytes,3,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// contains filtered or unexported fields
}

A response message from a Named Queue Service proxy.

NOTE: If you add a new request message to this message the protocol version in com.oracle.coherence.grpc.NamedQueueProtocol must be increased. This only needs to be done once for any given Coherence release.

func (*NamedQueueResponse) Descriptor deprecated 

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

Deprecated: Use NamedQueueResponse.ProtoReflect.Descriptor instead.

func (*NamedQueueResponse) GetMessage 

func (x *NamedQueueResponse) GetMessage() *anypb.Any

func (*NamedQueueResponse) GetQueueId 

func (x *NamedQueueResponse) GetQueueId() int32

func (*NamedQueueResponse) GetType 

func (x *NamedQueueResponse) GetType() NamedQueueResponseType

func (*NamedQueueResponse) ProtoMessage 

func (*NamedQueueResponse) ProtoMessage()

func (*NamedQueueResponse) ProtoReflect 

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

func (*NamedQueueResponse) Reset 

func (x *NamedQueueResponse) Reset()

func (*NamedQueueResponse) String 

func (x *NamedQueueResponse) String() string

type NamedQueueResponseType 

type NamedQueueResponseType int32

An enum representing different types of response.

NOTE: The index numbers for the enum elements MUST NOT BE CHANGED as that would break backwards compatibility. Only new index numbers can be added. 

const (
	// The response is a message.
	NamedQueueResponseType_Message NamedQueueResponseType = 0
	// The response is a queue event.
	NamedQueueResponseType_QueueEvent NamedQueueResponseType = 1
	// The response is destroy event
	NamedQueueResponseType_Destroyed NamedQueueResponseType = 2
	// The response is truncated event
	NamedQueueResponseType_Truncated NamedQueueResponseType = 3
)

func (NamedQueueResponseType) Descriptor 

func (NamedQueueResponseType) Descriptor() protoreflect.EnumDescriptor

func (NamedQueueResponseType) Enum 

func (x NamedQueueResponseType) Enum() *NamedQueueResponseType

func (NamedQueueResponseType) EnumDescriptor deprecated 

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

Deprecated: Use NamedQueueResponseType.Descriptor instead.

func (NamedQueueResponseType) Number 

func (x NamedQueueResponseType) Number() protoreflect.EnumNumber

func (NamedQueueResponseType) String 

func (x NamedQueueResponseType) String() string

func (NamedQueueResponseType) Type 

func (NamedQueueResponseType) Type() protoreflect.EnumType

type NamedQueueType 

type NamedQueueType int32

An enum representing the type of a queue. 

const (
	// A plain Queue
	NamedQueueType_Queue NamedQueueType = 0
	// A double ended Deque
	NamedQueueType_Deque NamedQueueType = 1
	// A distributed paged
	NamedQueueType_PagedQueue NamedQueueType = 3
)

func (NamedQueueType) Descriptor 

func (NamedQueueType) Descriptor() protoreflect.EnumDescriptor

func (NamedQueueType) Enum 

func (x NamedQueueType) Enum() *NamedQueueType

func (NamedQueueType) EnumDescriptor deprecated 

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

Deprecated: Use NamedQueueType.Descriptor instead.

func (NamedQueueType) Number 

func (x NamedQueueType) Number() protoreflect.EnumNumber

func (NamedQueueType) String 

func (x NamedQueueType) String() string

func (NamedQueueType) Type 

func (NamedQueueType) Type() protoreflect.EnumType

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 ProxyRequest 

type ProxyRequest struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Request:
	//
	//	*ProxyRequest_Init
	//	*ProxyRequest_Message
	//	*ProxyRequest_Heartbeat
	Request isProxyRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

A request to the Coherence gRPC proxy. Except for a Heartbeat, every request must have a unique id field.

func (*ProxyRequest) Descriptor deprecated 

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

Deprecated: Use ProxyRequest.ProtoReflect.Descriptor instead.

func (*ProxyRequest) GetHeartbeat 

func (x *ProxyRequest) GetHeartbeat() *HeartbeatMessage

func (*ProxyRequest) GetId 

func (x *ProxyRequest) GetId() int64

func (*ProxyRequest) GetInit 

func (x *ProxyRequest) GetInit() *InitRequest

func (*ProxyRequest) GetMessage 

func (x *ProxyRequest) GetMessage() *anypb.Any

func (*ProxyRequest) GetRequest 

func (m *ProxyRequest) GetRequest() isProxyRequest_Request

func (*ProxyRequest) ProtoMessage 

func (*ProxyRequest) ProtoMessage()

func (*ProxyRequest) ProtoReflect 

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

func (*ProxyRequest) Reset 

func (x *ProxyRequest) Reset()

func (*ProxyRequest) String 

func (x *ProxyRequest) String() string

type ProxyRequest_Heartbeat 

type ProxyRequest_Heartbeat struct {
	// A periodic heartbeat message sent by the client
	Heartbeat *HeartbeatMessage `protobuf:"bytes,5,opt,name=heartbeat,proto3,oneof"`
}

type ProxyRequest_Init 

type ProxyRequest_Init struct {
	// The initialization request, which must be the first request sent.
	Init *InitRequest `protobuf:"bytes,3,opt,name=init,proto3,oneof"`
}

type ProxyRequest_Message 

type ProxyRequest_Message struct {
	// A message that is specific to a Coherence gRPC service.
	// Each service on the proxy will know what type to expect here.
	Message *anypb.Any `protobuf:"bytes,4,opt,name=message,proto3,oneof"`
}

type ProxyResponse 

type ProxyResponse struct {

	// The identifier of the request messages this response is for, or zero if
	// this message is non-request related, for example it is an event.
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The actual response message.
	//
	// Types that are assignable to Response:
	//
	//	*ProxyResponse_Init
	//	*ProxyResponse_Message
	//	*ProxyResponse_Error
	//	*ProxyResponse_Complete
	//	*ProxyResponse_Heartbeat
	Response isProxyResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

A response from a Coherence gRPC proxy. Except for a Heartbeat, every response will contain an id field that corresponds to the id of the request that the response if for.

func (*ProxyResponse) Descriptor deprecated 

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

Deprecated: Use ProxyResponse.ProtoReflect.Descriptor instead.

func (*ProxyResponse) GetComplete 

func (x *ProxyResponse) GetComplete() *Complete

func (*ProxyResponse) GetError 

func (x *ProxyResponse) GetError() *ErrorMessage

func (*ProxyResponse) GetHeartbeat 

func (x *ProxyResponse) GetHeartbeat() *HeartbeatMessage

func (*ProxyResponse) GetId 

func (x *ProxyResponse) GetId() int64

func (*ProxyResponse) GetInit 

func (x *ProxyResponse) GetInit() *InitResponse

func (*ProxyResponse) GetMessage 

func (x *ProxyResponse) GetMessage() *anypb.Any

func (*ProxyResponse) GetResponse 

func (m *ProxyResponse) GetResponse() isProxyResponse_Response

func (*ProxyResponse) ProtoMessage 

func (*ProxyResponse) ProtoMessage()

func (*ProxyResponse) ProtoReflect 

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

func (*ProxyResponse) Reset 

func (x *ProxyResponse) Reset()

func (*ProxyResponse) String 

func (x *ProxyResponse) String() string

type ProxyResponse_Complete 

type ProxyResponse_Complete struct {
	// A complete message is sent to indicate that a stream of messages for
	// the same request id have been completed.
	Complete *Complete `protobuf:"bytes,7,opt,name=complete,proto3,oneof"`
}

type ProxyResponse_Error 

type ProxyResponse_Error struct {
	// An error response to a specific request id
	Error *ErrorMessage `protobuf:"bytes,6,opt,name=error,proto3,oneof"`
}

type ProxyResponse_Heartbeat 

type ProxyResponse_Heartbeat struct {
	// A periodic heart beat sent by the server
	Heartbeat *HeartbeatMessage `protobuf:"bytes,8,opt,name=heartbeat,proto3,oneof"`
}

type ProxyResponse_Init 

type ProxyResponse_Init struct {
	// The response to the initial InitRequest.
	Init *InitResponse `protobuf:"bytes,4,opt,name=init,proto3,oneof"`
}

type ProxyResponse_Message 

type ProxyResponse_Message struct {
	// A response of a type specific to a Coherence gRPC service.
	// The client that sent the corresponding request will know what
	// type of message it expects in this field.
	Message *anypb.Any `protobuf:"bytes,5,opt,name=message,proto3,oneof"`
}

type ProxyServiceClient 

type ProxyServiceClient interface {
	// Sets up a bidirectional channel for cache requests and responses.
	SubChannel(ctx context.Context, opts ...grpc.CallOption) (ProxyService_SubChannelClient, error)
}

ProxyServiceClient is the client API for ProxyService 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 NewProxyServiceClient 

func NewProxyServiceClient(cc grpc.ClientConnInterface) ProxyServiceClient

type ProxyServiceServer 

type ProxyServiceServer interface {
	// Sets up a bidirectional channel for cache requests and responses.
	SubChannel(ProxyService_SubChannelServer) error
	// contains filtered or unexported methods
}

ProxyServiceServer is the server API for ProxyService service. All implementations must embed UnimplementedProxyServiceServer for forward compatibility

type ProxyService_SubChannelClient 

type ProxyService_SubChannelClient interface {
	Send(*ProxyRequest) error
	Recv() (*ProxyResponse, error)
	grpc.ClientStream
}

type ProxyService_SubChannelServer 

type ProxyService_SubChannelServer interface {
	Send(*ProxyResponse) error
	Recv() (*ProxyRequest, error)
	grpc.ServerStream
}

type PutAllRequest 

type PutAllRequest struct {

	// The cache entries to put.
	Entries []*BinaryKeyAndValue `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// The time to live in millis.
	Ttl *int64 `protobuf:"varint,2,opt,name=ttl,proto3,oneof" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

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

func (*PutAllRequest) Descriptor deprecated 

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

Deprecated: Use PutAllRequest.ProtoReflect.Descriptor instead.

func (*PutAllRequest) GetEntries 

func (x *PutAllRequest) GetEntries() []*BinaryKeyAndValue

func (*PutAllRequest) GetTtl 

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 PutRequest 

type PutRequest 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"`
	// The time to live in millis.
	Ttl *int64 `protobuf:"varint,3,opt,name=ttl,proto3,oneof" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

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

func (*PutRequest) Descriptor deprecated 

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetKey 

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

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 QueryRequest 

type QueryRequest struct {

	// The serialized Filter to identify the data to return.
	Filter []byte `protobuf:"bytes,1,opt,name=filter,proto3,oneof" json:"filter,omitempty"`
	// The optional comparator to use to sort the returned data.
	Comparator []byte `protobuf:"bytes,2,opt,name=comparator,proto3,oneof" json:"comparator,omitempty"`
	// contains filtered or unexported fields
}

A request cache query request.

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetComparator 

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

func (*QueryRequest) GetFilter 

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

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

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

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type QueueOfferResult 

type QueueOfferResult struct {

	// A flag indicating whether the offer was successful
	Succeeded bool `protobuf:"varint,1,opt,name=succeeded,proto3" json:"succeeded,omitempty"`
	// An int64 value representing an index into the queue
	// where the element was added.
	Index int64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

The result of offering an element to a queue.

func (*QueueOfferResult) Descriptor deprecated 

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

Deprecated: Use QueueOfferResult.ProtoReflect.Descriptor instead.

func (*QueueOfferResult) GetIndex 

func (x *QueueOfferResult) GetIndex() int64

func (*QueueOfferResult) GetSucceeded 

func (x *QueueOfferResult) GetSucceeded() bool

func (*QueueOfferResult) ProtoMessage 

func (*QueueOfferResult) ProtoMessage()

func (*QueueOfferResult) ProtoReflect 

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

func (*QueueOfferResult) Reset 

func (x *QueueOfferResult) Reset()

func (*QueueOfferResult) String 

func (x *QueueOfferResult) String() string

type ReplaceMappingRequest 

type ReplaceMappingRequest struct {

	// The key of the entry to be replaced.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The previous value that should exist in the cache.
	PreviousValue []byte `protobuf:"bytes,2,opt,name=previousValue,proto3" json:"previousValue,omitempty"`
	// The new value to put.
	NewValue []byte `protobuf:"bytes,3,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) GetKey 

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

func (*ReplaceMappingRequest) GetNewValue 

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

func (*ReplaceMappingRequest) GetPreviousValue 

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

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 ResponseType 

type ResponseType int32

An enum representing different types of response.

NOTE: The index numbers for the enum elements MUST NOT BE CHANGED as that would break backwards compatibility. Only new index numbers can be added. 

const (
	// The response is a message.
	ResponseType_Message ResponseType = 0
	// The response is a map event.
	ResponseType_MapEvent ResponseType = 1
	// The response is destroy event
	ResponseType_Destroyed ResponseType = 2
	// The response is truncated event
	ResponseType_Truncated ResponseType = 3
)

func (ResponseType) Descriptor 

func (ResponseType) Descriptor() protoreflect.EnumDescriptor

func (ResponseType) Enum 

func (x ResponseType) Enum() *ResponseType

func (ResponseType) EnumDescriptor deprecated 

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

Deprecated: Use ResponseType.Descriptor instead.

func (ResponseType) Number 

func (x ResponseType) Number() protoreflect.EnumNumber

func (ResponseType) String 

func (x ResponseType) String() string

func (ResponseType) Type 

func (ResponseType) Type() protoreflect.EnumType

type UnimplementedProxyServiceServer 

type UnimplementedProxyServiceServer struct {
}

UnimplementedProxyServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProxyServiceServer) SubChannel 

func (UnimplementedProxyServiceServer) SubChannel(ProxyService_SubChannelServer) error

type UnsafeProxyServiceServer 

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

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

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.