proto

package

Go to main page

Versions in this module

v1

v1.2.2

May 23, 2024

v1.2.1

May 16, 2024

v1.2.0

May 2, 2024

v1.1.1

Mar 11, 2024

v1.1.0

Mar 8, 2024

Changes in this version

type PutAllRequest

+ Ttl int64

+ func (x *PutAllRequest) GetTtl() int64

v1.0.3

Oct 27, 2023

v1.0.2

Oct 12, 2023

Changes in this version

+ const NamedCacheService_AddIndex_FullMethodName

+ const NamedCacheService_Aggregate_FullMethodName

+ const NamedCacheService_Clear_FullMethodName

+ const NamedCacheService_ContainsEntry_FullMethodName

+ const NamedCacheService_ContainsKey_FullMethodName

+ const NamedCacheService_ContainsValue_FullMethodName

+ const NamedCacheService_Destroy_FullMethodName

+ const NamedCacheService_EntrySet_FullMethodName

+ const NamedCacheService_Events_FullMethodName

+ const NamedCacheService_GetAll_FullMethodName

+ const NamedCacheService_Get_FullMethodName

+ const NamedCacheService_InvokeAll_FullMethodName

+ const NamedCacheService_Invoke_FullMethodName

+ const NamedCacheService_IsEmpty_FullMethodName

+ const NamedCacheService_IsReady_FullMethodName

+ const NamedCacheService_KeySet_FullMethodName

+ const NamedCacheService_NextEntrySetPage_FullMethodName

+ const NamedCacheService_NextKeySetPage_FullMethodName

+ const NamedCacheService_PutAll_FullMethodName

+ const NamedCacheService_PutIfAbsent_FullMethodName

+ const NamedCacheService_Put_FullMethodName

+ const NamedCacheService_RemoveIndex_FullMethodName

+ const NamedCacheService_RemoveMapping_FullMethodName

+ const NamedCacheService_Remove_FullMethodName

+ const NamedCacheService_ReplaceMapping_FullMethodName

+ const NamedCacheService_Replace_FullMethodName

+ const NamedCacheService_Size_FullMethodName

+ const NamedCacheService_Truncate_FullMethodName

+ const NamedCacheService_Values_FullMethodName

v1.0.1

Aug 21, 2023

Changes in this version

+ type IsReadyRequest struct

+ Cache string

+ Scope string

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

+ func (*IsReadyRequest) ProtoMessage()

+ func (x *IsReadyRequest) GetCache() string

+ func (x *IsReadyRequest) GetScope() string

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

+ func (x *IsReadyRequest) Reset()

+ func (x *IsReadyRequest) String() string

type NamedCacheServiceClient

+ IsReady func(ctx context.Context, in *IsReadyRequest, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)

type NamedCacheServiceServer

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

type UnimplementedNamedCacheServiceServer

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

v1.0.0

Jul 3, 2023

Changes in this version

+ var File_messages_proto protoreflect.FileDescriptor

+ var File_services_proto protoreflect.FileDescriptor

+ var MapEventResponse_TransformationState_name = map[int32]string

+ var MapEventResponse_TransformationState_value = map[string]int32

+ var MapListenerRequest_RequestType_name = map[int32]string

+ var MapListenerRequest_RequestType_value = map[string]int32

+ var NamedCacheService_ServiceDesc = grpc.ServiceDesc

+ func RegisterNamedCacheServiceServer(s grpc.ServiceRegistrar, srv NamedCacheServiceServer)

+ type AddIndexRequest struct

+ Cache string

+ Comparator []byte

+ Extractor []byte

+ Format string

+ Scope string

+ Sorted bool

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

+ func (*AddIndexRequest) ProtoMessage()

+ func (x *AddIndexRequest) GetCache() string

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

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

+ func (x *AddIndexRequest) GetFormat() string

+ func (x *AddIndexRequest) GetScope() string

+ func (x *AddIndexRequest) GetSorted() bool

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

+ func (x *AddIndexRequest) Reset()

+ func (x *AddIndexRequest) String() string

+ type AggregateRequest struct

+ Aggregator []byte

+ Cache string

+ Filter []byte

+ Format string

+ Keys [][]byte

+ Scope string

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

+ func (*AggregateRequest) ProtoMessage()

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

+ func (x *AggregateRequest) GetCache() string

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

+ func (x *AggregateRequest) GetFormat() string

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

+ func (x *AggregateRequest) GetScope() string

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

+ func (x *AggregateRequest) Reset()

+ func (x *AggregateRequest) String() string

+ type CacheDestroyedResponse struct

+ Cache string

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

+ func (*CacheDestroyedResponse) ProtoMessage()

+ func (x *CacheDestroyedResponse) GetCache() string

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

+ func (x *CacheDestroyedResponse) Reset()

+ func (x *CacheDestroyedResponse) String() string

+ type CacheTruncatedResponse struct

+ Cache string

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

+ func (*CacheTruncatedResponse) ProtoMessage()

+ func (x *CacheTruncatedResponse) GetCache() string

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

+ func (x *CacheTruncatedResponse) Reset()

+ func (x *CacheTruncatedResponse) String() string

+ type ClearRequest struct

+ Cache string

+ Scope string

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

+ func (*ClearRequest) ProtoMessage()

+ func (x *ClearRequest) GetCache() string

+ func (x *ClearRequest) GetScope() string

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

+ func (x *ClearRequest) Reset()

+ func (x *ClearRequest) String() string

+ type ContainsEntryRequest struct

+ Cache string

+ Format string

+ Key []byte

+ Scope string

+ Value []byte

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

+ func (*ContainsEntryRequest) ProtoMessage()

+ func (x *ContainsEntryRequest) GetCache() string

+ func (x *ContainsEntryRequest) GetFormat() string

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

+ func (x *ContainsEntryRequest) GetScope() string

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

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

+ func (x *ContainsEntryRequest) Reset()

+ func (x *ContainsEntryRequest) String() string

+ type ContainsKeyRequest struct

+ Cache string

+ Format string

+ Key []byte

+ Scope string

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

+ func (*ContainsKeyRequest) ProtoMessage()

+ func (x *ContainsKeyRequest) GetCache() string

+ func (x *ContainsKeyRequest) GetFormat() string

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

+ func (x *ContainsKeyRequest) GetScope() string

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

+ func (x *ContainsKeyRequest) Reset()

+ func (x *ContainsKeyRequest) String() string

+ type ContainsValueRequest struct

+ Cache string

+ Format string

+ Scope string

+ Value []byte

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

+ func (*ContainsValueRequest) ProtoMessage()

+ func (x *ContainsValueRequest) GetCache() string

+ func (x *ContainsValueRequest) GetFormat() string

+ func (x *ContainsValueRequest) GetScope() string

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

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

+ func (x *ContainsValueRequest) Reset()

+ func (x *ContainsValueRequest) String() string

+ type DestroyRequest struct

+ Cache string

+ Scope string

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

+ func (*DestroyRequest) ProtoMessage()

+ func (x *DestroyRequest) GetCache() string

+ func (x *DestroyRequest) GetScope() string

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

+ func (x *DestroyRequest) Reset()

+ func (x *DestroyRequest) String() string

+ type Entry struct

+ Key []byte

+ Value []byte

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

+ func (*Entry) ProtoMessage()

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

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

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

+ func (x *Entry) Reset()

+ func (x *Entry) String() string

+ type EntryResult struct

+ Cookie []byte

+ Key []byte

+ Value []byte

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

+ func (*EntryResult) ProtoMessage()

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

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

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

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

+ func (x *EntryResult) Reset()

+ func (x *EntryResult) String() string

+ type EntrySetRequest struct

+ Cache string

+ Comparator []byte

+ Filter []byte

+ Format string

+ Scope string

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

+ func (*EntrySetRequest) ProtoMessage()

+ func (x *EntrySetRequest) GetCache() string

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

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

+ func (x *EntrySetRequest) GetFormat() string

+ func (x *EntrySetRequest) GetScope() string

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

+ func (x *EntrySetRequest) Reset()

+ func (x *EntrySetRequest) String() string

+ type GetAllRequest struct

+ Cache string

+ Format string

+ Key [][]byte

+ Scope string

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

+ func (*GetAllRequest) ProtoMessage()

+ func (x *GetAllRequest) GetCache() string

+ func (x *GetAllRequest) GetFormat() string

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

+ func (x *GetAllRequest) GetScope() string

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

+ func (x *GetAllRequest) Reset()

+ func (x *GetAllRequest) String() string

+ type GetRequest struct

+ Cache string

+ Format string

+ Key []byte

+ Scope string

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

+ func (*GetRequest) ProtoMessage()

+ func (x *GetRequest) GetCache() string

+ func (x *GetRequest) GetFormat() string

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

+ func (x *GetRequest) GetScope() string

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

+ func (x *GetRequest) Reset()

+ func (x *GetRequest) String() string

+ type InvokeAllRequest struct

+ Cache string

+ Filter []byte

+ Format string

+ Keys [][]byte

+ Processor []byte

+ Scope string

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

+ func (*InvokeAllRequest) ProtoMessage()

+ func (x *InvokeAllRequest) GetCache() string

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

+ func (x *InvokeAllRequest) GetFormat() string

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

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

+ func (x *InvokeAllRequest) GetScope() string

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

+ func (x *InvokeAllRequest) Reset()

+ func (x *InvokeAllRequest) String() string

+ type InvokeRequest struct

+ Cache string

+ Format string

+ Key []byte

+ Processor []byte

+ Scope string

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

+ func (*InvokeRequest) ProtoMessage()

+ func (x *InvokeRequest) GetCache() string

+ func (x *InvokeRequest) GetFormat() string

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

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

+ func (x *InvokeRequest) GetScope() string

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

+ func (x *InvokeRequest) Reset()

+ func (x *InvokeRequest) String() string

+ type IsEmptyRequest struct

+ Cache string

+ Scope string

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

+ func (*IsEmptyRequest) ProtoMessage()

+ func (x *IsEmptyRequest) GetCache() string

+ func (x *IsEmptyRequest) GetScope() string

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

+ func (x *IsEmptyRequest) Reset()

+ func (x *IsEmptyRequest) String() string

+ type KeySetRequest struct

+ Cache string

+ Filter []byte

+ Format string

+ Scope string

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

+ func (*KeySetRequest) ProtoMessage()

+ func (x *KeySetRequest) GetCache() string

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

+ func (x *KeySetRequest) GetFormat() string

+ func (x *KeySetRequest) GetScope() string

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

+ func (x *KeySetRequest) Reset()

+ func (x *KeySetRequest) String() string

+ type MapEventResponse struct

+ FilterIds []int64

+ Id int32

+ Key []byte

+ NewValue []byte

+ OldValue []byte

+ Priming bool

+ Synthetic bool

+ TransformationState MapEventResponse_TransformationState

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

+ func (*MapEventResponse) ProtoMessage()

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

+ func (x *MapEventResponse) GetId() int32

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

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

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

+ func (x *MapEventResponse) GetPriming() bool

+ func (x *MapEventResponse) GetSynthetic() bool

+ func (x *MapEventResponse) GetTransformationState() MapEventResponse_TransformationState

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

+ func (x *MapEventResponse) Reset()

+ func (x *MapEventResponse) String() string

+ type MapEventResponse_TransformationState int32

+ const MapEventResponse_NON_TRANSFORMABLE

+ const MapEventResponse_TRANSFORMABLE

+ const MapEventResponse_TRANSFORMED

+ func (MapEventResponse_TransformationState) Descriptor() protoreflect.EnumDescriptor

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

+ func (MapEventResponse_TransformationState) Type() protoreflect.EnumType

+ func (x MapEventResponse_TransformationState) Enum() *MapEventResponse_TransformationState

+ func (x MapEventResponse_TransformationState) Number() protoreflect.EnumNumber

+ func (x MapEventResponse_TransformationState) String() string

+ type MapListenerErrorResponse struct

+ Code int32

+ Message string

+ Stack []string

+ Uid string

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

+ func (*MapListenerErrorResponse) ProtoMessage()

+ func (x *MapListenerErrorResponse) GetCode() int32

+ func (x *MapListenerErrorResponse) GetMessage() string

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

+ func (x *MapListenerErrorResponse) GetUid() string

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

+ func (x *MapListenerErrorResponse) Reset()

+ func (x *MapListenerErrorResponse) String() string

+ type MapListenerRequest struct

+ Cache string

+ Filter []byte

+ FilterId int64

+ Format string

+ Key []byte

+ Lite bool

+ Priming bool

+ Scope string

+ Subscribe bool

+ Trigger []byte

+ Type MapListenerRequest_RequestType

+ Uid string

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

+ func (*MapListenerRequest) ProtoMessage()

+ func (x *MapListenerRequest) GetCache() string

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

+ func (x *MapListenerRequest) GetFilterId() int64

+ func (x *MapListenerRequest) GetFormat() string

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

+ func (x *MapListenerRequest) GetLite() bool

+ func (x *MapListenerRequest) GetPriming() bool

+ func (x *MapListenerRequest) GetScope() string

+ func (x *MapListenerRequest) GetSubscribe() bool

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

+ func (x *MapListenerRequest) GetType() MapListenerRequest_RequestType

+ func (x *MapListenerRequest) GetUid() string

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

+ func (x *MapListenerRequest) Reset()

+ func (x *MapListenerRequest) String() string

+ type MapListenerRequest_RequestType int32

+ const MapListenerRequest_FILTER

+ const MapListenerRequest_INIT

+ const MapListenerRequest_KEY

+ func (MapListenerRequest_RequestType) Descriptor() protoreflect.EnumDescriptor

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

+ func (MapListenerRequest_RequestType) Type() protoreflect.EnumType

+ func (x MapListenerRequest_RequestType) Enum() *MapListenerRequest_RequestType

+ func (x MapListenerRequest_RequestType) Number() protoreflect.EnumNumber

+ func (x MapListenerRequest_RequestType) String() string

+ type MapListenerResponse struct

+ ResponseType isMapListenerResponse_ResponseType

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

+ func (*MapListenerResponse) ProtoMessage()

+ func (m *MapListenerResponse) GetResponseType() isMapListenerResponse_ResponseType

+ func (x *MapListenerResponse) GetDestroyed() *CacheDestroyedResponse

+ func (x *MapListenerResponse) GetError() *MapListenerErrorResponse

+ func (x *MapListenerResponse) GetEvent() *MapEventResponse

+ func (x *MapListenerResponse) GetSubscribed() *MapListenerSubscribedResponse

+ func (x *MapListenerResponse) GetTruncated() *CacheTruncatedResponse

+ func (x *MapListenerResponse) GetUnsubscribed() *MapListenerUnsubscribedResponse

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

+ func (x *MapListenerResponse) Reset()

+ func (x *MapListenerResponse) String() string

+ type MapListenerResponse_Destroyed struct

+ Destroyed *CacheDestroyedResponse

+ type MapListenerResponse_Error struct

+ Error *MapListenerErrorResponse

+ type MapListenerResponse_Event struct

+ Event *MapEventResponse

+ type MapListenerResponse_Subscribed struct

+ Subscribed *MapListenerSubscribedResponse

+ type MapListenerResponse_Truncated struct

+ Truncated *CacheTruncatedResponse

+ type MapListenerResponse_Unsubscribed struct

+ Unsubscribed *MapListenerUnsubscribedResponse

+ type MapListenerSubscribedResponse struct

+ Uid string

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

+ func (*MapListenerSubscribedResponse) ProtoMessage()

+ func (x *MapListenerSubscribedResponse) GetUid() string

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

+ func (x *MapListenerSubscribedResponse) Reset()

+ func (x *MapListenerSubscribedResponse) String() string

+ type MapListenerUnsubscribedResponse struct

+ Uid string

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

+ func (*MapListenerUnsubscribedResponse) ProtoMessage()

+ func (x *MapListenerUnsubscribedResponse) GetUid() string

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

+ func (x *MapListenerUnsubscribedResponse) Reset()

+ func (x *MapListenerUnsubscribedResponse) String() string

+ type NamedCacheServiceClient interface

+ AddIndex func(ctx context.Context, in *AddIndexRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Aggregate func(ctx context.Context, in *AggregateRequest, opts ...grpc.CallOption) (*wrapperspb.BytesValue, error)

+ Clear func(ctx context.Context, in *ClearRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ ContainsEntry func(ctx context.Context, in *ContainsEntryRequest, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)

+ ContainsKey func(ctx context.Context, in *ContainsKeyRequest, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)

+ ContainsValue func(ctx context.Context, in *ContainsValueRequest, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)

+ Destroy func(ctx context.Context, in *DestroyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ EntrySet func(ctx context.Context, in *EntrySetRequest, opts ...grpc.CallOption) (NamedCacheService_EntrySetClient, error)

+ Events func(ctx context.Context, opts ...grpc.CallOption) (NamedCacheService_EventsClient, error)

+ Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*OptionalValue, error)

+ GetAll func(ctx context.Context, in *GetAllRequest, opts ...grpc.CallOption) (NamedCacheService_GetAllClient, error)

+ Invoke func(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (*wrapperspb.BytesValue, error)

+ InvokeAll func(ctx context.Context, in *InvokeAllRequest, opts ...grpc.CallOption) (NamedCacheService_InvokeAllClient, error)

+ IsEmpty func(ctx context.Context, in *IsEmptyRequest, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)

+ KeySet func(ctx context.Context, in *KeySetRequest, opts ...grpc.CallOption) (NamedCacheService_KeySetClient, error)

+ NextEntrySetPage func(ctx context.Context, in *PageRequest, opts ...grpc.CallOption) (NamedCacheService_NextEntrySetPageClient, error)

+ NextKeySetPage func(ctx context.Context, in *PageRequest, opts ...grpc.CallOption) (NamedCacheService_NextKeySetPageClient, error)

+ Put func(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*wrapperspb.BytesValue, error)

+ PutAll func(ctx context.Context, in *PutAllRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ PutIfAbsent func(ctx context.Context, in *PutIfAbsentRequest, opts ...grpc.CallOption) (*wrapperspb.BytesValue, error)

+ Remove func(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*wrapperspb.BytesValue, error)

+ RemoveIndex func(ctx context.Context, in *RemoveIndexRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ RemoveMapping func(ctx context.Context, in *RemoveMappingRequest, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)

+ Replace func(ctx context.Context, in *ReplaceRequest, opts ...grpc.CallOption) (*wrapperspb.BytesValue, error)

+ ReplaceMapping func(ctx context.Context, in *ReplaceMappingRequest, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)

+ Size func(ctx context.Context, in *SizeRequest, opts ...grpc.CallOption) (*wrapperspb.Int32Value, error)

+ Truncate func(ctx context.Context, in *TruncateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Values func(ctx context.Context, in *ValuesRequest, opts ...grpc.CallOption) (NamedCacheService_ValuesClient, error)

+ func NewNamedCacheServiceClient(cc grpc.ClientConnInterface) NamedCacheServiceClient

+ type NamedCacheServiceServer interface

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

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

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

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

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

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

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

+ EntrySet func(*EntrySetRequest, NamedCacheService_EntrySetServer) error

+ Events func(NamedCacheService_EventsServer) error

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

+ GetAll func(*GetAllRequest, NamedCacheService_GetAllServer) error

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

+ InvokeAll func(*InvokeAllRequest, NamedCacheService_InvokeAllServer) error

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

+ KeySet func(*KeySetRequest, NamedCacheService_KeySetServer) error

+ NextEntrySetPage func(*PageRequest, NamedCacheService_NextEntrySetPageServer) error

+ NextKeySetPage func(*PageRequest, NamedCacheService_NextKeySetPageServer) error

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

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

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

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

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

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

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

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

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

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

+ Values func(*ValuesRequest, NamedCacheService_ValuesServer) error

+ type NamedCacheService_EntrySetClient interface

+ Recv func() (*Entry, error)

+ type NamedCacheService_EntrySetServer interface

+ Send func(*Entry) error

+ type NamedCacheService_EventsClient interface

+ Recv func() (*MapListenerResponse, error)

+ Send func(*MapListenerRequest) error

+ type NamedCacheService_EventsServer interface

+ Recv func() (*MapListenerRequest, error)

+ Send func(*MapListenerResponse) error

+ type NamedCacheService_GetAllClient interface

+ Recv func() (*Entry, error)

+ type NamedCacheService_GetAllServer interface

+ Send func(*Entry) error

+ type NamedCacheService_InvokeAllClient interface

+ Recv func() (*Entry, error)

+ type NamedCacheService_InvokeAllServer interface

+ Send func(*Entry) error

+ type NamedCacheService_KeySetClient interface

+ Recv func() (*wrapperspb.BytesValue, error)

+ type NamedCacheService_KeySetServer interface

+ Send func(*wrapperspb.BytesValue) error

+ type NamedCacheService_NextEntrySetPageClient interface

+ Recv func() (*EntryResult, error)

+ type NamedCacheService_NextEntrySetPageServer interface

+ Send func(*EntryResult) error

+ type NamedCacheService_NextKeySetPageClient interface

+ Recv func() (*wrapperspb.BytesValue, error)

+ type NamedCacheService_NextKeySetPageServer interface

+ Send func(*wrapperspb.BytesValue) error

+ type NamedCacheService_ValuesClient interface

+ Recv func() (*wrapperspb.BytesValue, error)

+ type NamedCacheService_ValuesServer interface

+ Send func(*wrapperspb.BytesValue) error

+ type OptionalValue struct

+ Present bool

+ Value []byte

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

+ func (*OptionalValue) ProtoMessage()

+ func (x *OptionalValue) GetPresent() bool

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

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

+ func (x *OptionalValue) Reset()

+ func (x *OptionalValue) String() string

+ type PageRequest struct

+ Cache string

+ Cookie []byte

+ Format string

+ Scope string

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

+ func (*PageRequest) ProtoMessage()

+ func (x *PageRequest) GetCache() string

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

+ func (x *PageRequest) GetFormat() string

+ func (x *PageRequest) GetScope() string

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

+ func (x *PageRequest) Reset()

+ func (x *PageRequest) String() string

+ type PutAllRequest struct

+ Cache string

+ Entry []*Entry

+ Format string

+ Scope string

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

+ func (*PutAllRequest) ProtoMessage()

+ func (x *PutAllRequest) GetCache() string

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

+ func (x *PutAllRequest) GetFormat() string

+ func (x *PutAllRequest) GetScope() string

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

+ func (x *PutAllRequest) Reset()

+ func (x *PutAllRequest) String() string

+ type PutIfAbsentRequest struct

+ Cache string

+ Format string

+ Key []byte

+ Scope string

+ Ttl int64

+ Value []byte

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

+ func (*PutIfAbsentRequest) ProtoMessage()

+ func (x *PutIfAbsentRequest) GetCache() string

+ func (x *PutIfAbsentRequest) GetFormat() string

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

+ func (x *PutIfAbsentRequest) GetScope() string

+ func (x *PutIfAbsentRequest) GetTtl() int64

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

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

+ func (x *PutIfAbsentRequest) Reset()

+ func (x *PutIfAbsentRequest) String() string

+ type PutRequest struct

+ Cache string

+ Format string

+ Key []byte

+ Scope string

+ Ttl int64

+ Value []byte

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

+ func (*PutRequest) ProtoMessage()

+ func (x *PutRequest) GetCache() string

+ func (x *PutRequest) GetFormat() string

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

+ func (x *PutRequest) GetScope() string

+ func (x *PutRequest) GetTtl() int64

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

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

+ func (x *PutRequest) Reset()

+ func (x *PutRequest) String() string

+ type RemoveIndexRequest struct

+ Cache string

+ Extractor []byte

+ Format string

+ Scope string

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

+ func (*RemoveIndexRequest) ProtoMessage()

+ func (x *RemoveIndexRequest) GetCache() string

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

+ func (x *RemoveIndexRequest) GetFormat() string

+ func (x *RemoveIndexRequest) GetScope() string

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

+ func (x *RemoveIndexRequest) Reset()

+ func (x *RemoveIndexRequest) String() string

+ type RemoveMappingRequest struct

+ Cache string

+ Format string

+ Key []byte

+ Scope string

+ Value []byte

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

+ func (*RemoveMappingRequest) ProtoMessage()

+ func (x *RemoveMappingRequest) GetCache() string

+ func (x *RemoveMappingRequest) GetFormat() string

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

+ func (x *RemoveMappingRequest) GetScope() string

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

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

+ func (x *RemoveMappingRequest) Reset()

+ func (x *RemoveMappingRequest) String() string

+ type RemoveRequest struct

+ Cache string

+ Format string

+ Key []byte

+ Scope string

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

+ func (*RemoveRequest) ProtoMessage()

+ func (x *RemoveRequest) GetCache() string

+ func (x *RemoveRequest) GetFormat() string

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

+ func (x *RemoveRequest) GetScope() string

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

+ func (x *RemoveRequest) Reset()

+ func (x *RemoveRequest) String() string

+ type ReplaceMappingRequest struct

+ Cache string

+ Format string

+ Key []byte

+ NewValue []byte

+ PreviousValue []byte

+ Scope string

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

+ func (*ReplaceMappingRequest) ProtoMessage()

+ func (x *ReplaceMappingRequest) GetCache() string

+ func (x *ReplaceMappingRequest) GetFormat() string

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

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

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

+ func (x *ReplaceMappingRequest) GetScope() string

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

+ func (x *ReplaceMappingRequest) Reset()

+ func (x *ReplaceMappingRequest) String() string

+ type ReplaceRequest struct

+ Cache string

+ Format string

+ Key []byte

+ Scope string

+ Value []byte

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

+ func (*ReplaceRequest) ProtoMessage()

+ func (x *ReplaceRequest) GetCache() string

+ func (x *ReplaceRequest) GetFormat() string

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

+ func (x *ReplaceRequest) GetScope() string

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

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

+ func (x *ReplaceRequest) Reset()

+ func (x *ReplaceRequest) String() string

+ type SizeRequest struct

+ Cache string

+ Scope string

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

+ func (*SizeRequest) ProtoMessage()

+ func (x *SizeRequest) GetCache() string

+ func (x *SizeRequest) GetScope() string

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

+ func (x *SizeRequest) Reset()

+ func (x *SizeRequest) String() string

+ type TruncateRequest struct

+ Cache string

+ Scope string

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

+ func (*TruncateRequest) ProtoMessage()

+ func (x *TruncateRequest) GetCache() string

+ func (x *TruncateRequest) GetScope() string

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

+ func (x *TruncateRequest) Reset()

+ func (x *TruncateRequest) String() string

+ type UnimplementedNamedCacheServiceServer struct

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

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

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

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

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

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

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

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

+ func (UnimplementedNamedCacheServiceServer) Events(NamedCacheService_EventsServer) error

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type UnsafeNamedCacheServiceServer interface

+ type ValuesRequest struct

+ Cache string

+ Comparator []byte

+ Filter []byte

+ Format string

+ Scope string

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

+ func (*ValuesRequest) ProtoMessage()

+ func (x *ValuesRequest) GetCache() string

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

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

+ func (x *ValuesRequest) GetFormat() string

+ func (x *ValuesRequest) GetScope() string

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

+ func (x *ValuesRequest) Reset()

+ func (x *ValuesRequest) String() string

v1.0.0-rc3

Jun 20, 2023

v1.0.0-rc2

May 3, 2023

v1.0.0-rc1

Apr 28, 2023

Other modules containing this package

github.com/oracle/coherence-go-client/v2

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