Versions in this module Expand all Collapse all v0 v0.6.3 Sep 26, 2022 v0.6.2 Aug 5, 2022 v0.6.1 Mar 23, 2022 v0.6.0 Mar 21, 2022 v0.5.3 Feb 26, 2022 v0.5.2 Feb 22, 2022 v0.5.1 Feb 19, 2022 Changes in this version + var File_gsharedmemoryproto_sharedmemory_proto protoreflect.FileDescriptor + var SharedMemory_ServiceDesc = grpc.ServiceDesc + func RegisterSharedMemoryServer(s grpc.ServiceRegistrar, srv SharedMemoryServer) + type ApplyRequest struct + Batches []*Batch + Continues bool + Id int64 + Requests []*AtomicRequest + func (*ApplyRequest) Descriptor() ([]byte, []int) + func (*ApplyRequest) ProtoMessage() + func (x *ApplyRequest) GetBatches() []*Batch + func (x *ApplyRequest) GetContinues() bool + func (x *ApplyRequest) GetId() int64 + func (x *ApplyRequest) GetRequests() []*AtomicRequest + func (x *ApplyRequest) ProtoReflect() protoreflect.Message + func (x *ApplyRequest) Reset() + func (x *ApplyRequest) String() string + type ApplyResponse struct + func (*ApplyResponse) Descriptor() ([]byte, []int) + func (*ApplyResponse) ProtoMessage() + func (x *ApplyResponse) ProtoReflect() protoreflect.Message + func (x *ApplyResponse) Reset() + func (x *ApplyResponse) String() string + type AtomicRequest struct + PeerChainId []byte + PutRequests []*Element + RemoveRequests [][]byte + func (*AtomicRequest) Descriptor() ([]byte, []int) + func (*AtomicRequest) ProtoMessage() + func (x *AtomicRequest) GetPeerChainId() []byte + func (x *AtomicRequest) GetPutRequests() []*Element + func (x *AtomicRequest) GetRemoveRequests() [][]byte + func (x *AtomicRequest) ProtoReflect() protoreflect.Message + func (x *AtomicRequest) Reset() + func (x *AtomicRequest) String() string + type Batch struct + Deletes []*BatchDelete + Id int64 + Puts []*BatchPut + func (*Batch) Descriptor() ([]byte, []int) + func (*Batch) ProtoMessage() + func (x *Batch) GetDeletes() []*BatchDelete + func (x *Batch) GetId() int64 + func (x *Batch) GetPuts() []*BatchPut + func (x *Batch) ProtoReflect() protoreflect.Message + func (x *Batch) Reset() + func (x *Batch) String() string + type BatchDelete struct + Key []byte + func (*BatchDelete) Descriptor() ([]byte, []int) + func (*BatchDelete) ProtoMessage() + func (x *BatchDelete) GetKey() []byte + func (x *BatchDelete) ProtoReflect() protoreflect.Message + func (x *BatchDelete) Reset() + func (x *BatchDelete) String() string + type BatchPut struct + Key []byte + Value []byte + func (*BatchPut) Descriptor() ([]byte, []int) + func (*BatchPut) ProtoMessage() + func (x *BatchPut) GetKey() []byte + func (x *BatchPut) GetValue() []byte + func (x *BatchPut) ProtoReflect() protoreflect.Message + func (x *BatchPut) Reset() + func (x *BatchPut) String() string + type Element struct + Key []byte + Traits [][]byte + Value []byte + func (*Element) Descriptor() ([]byte, []int) + func (*Element) ProtoMessage() + func (x *Element) GetKey() []byte + func (x *Element) GetTraits() [][]byte + func (x *Element) GetValue() []byte + func (x *Element) ProtoReflect() protoreflect.Message + func (x *Element) Reset() + func (x *Element) String() string + type GetRequest struct + Continues bool + Id int64 + Keys [][]byte + PeerChainId []byte + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (x *GetRequest) GetContinues() bool + func (x *GetRequest) GetId() int64 + func (x *GetRequest) GetKeys() [][]byte + func (x *GetRequest) GetPeerChainId() []byte + func (x *GetRequest) ProtoReflect() protoreflect.Message + func (x *GetRequest) Reset() + func (x *GetRequest) String() string + type GetResponse struct + Continues bool + Values [][]byte + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (x *GetResponse) GetContinues() bool + func (x *GetResponse) GetValues() [][]byte + func (x *GetResponse) ProtoReflect() protoreflect.Message + func (x *GetResponse) Reset() + func (x *GetResponse) String() string + type IndexedRequest struct + Continues bool + Id int64 + Limit int32 + PeerChainId []byte + StartKey []byte + StartTrait []byte + Traits [][]byte + func (*IndexedRequest) Descriptor() ([]byte, []int) + func (*IndexedRequest) ProtoMessage() + func (x *IndexedRequest) GetContinues() bool + func (x *IndexedRequest) GetId() int64 + func (x *IndexedRequest) GetLimit() int32 + func (x *IndexedRequest) GetPeerChainId() []byte + func (x *IndexedRequest) GetStartKey() []byte + func (x *IndexedRequest) GetStartTrait() []byte + func (x *IndexedRequest) GetTraits() [][]byte + func (x *IndexedRequest) ProtoReflect() protoreflect.Message + func (x *IndexedRequest) Reset() + func (x *IndexedRequest) String() string + type IndexedResponse struct + Continues bool + LastKey []byte + LastTrait []byte + Values [][]byte + func (*IndexedResponse) Descriptor() ([]byte, []int) + func (*IndexedResponse) ProtoMessage() + func (x *IndexedResponse) GetContinues() bool + func (x *IndexedResponse) GetLastKey() []byte + func (x *IndexedResponse) GetLastTrait() []byte + func (x *IndexedResponse) GetValues() [][]byte + func (x *IndexedResponse) ProtoReflect() protoreflect.Message + func (x *IndexedResponse) Reset() + func (x *IndexedResponse) String() string + type SharedMemoryClient interface + Apply func(ctx context.Context, in *ApplyRequest, opts ...grpc.CallOption) (*ApplyResponse, error) + Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) + Indexed func(ctx context.Context, in *IndexedRequest, opts ...grpc.CallOption) (*IndexedResponse, error) + func NewSharedMemoryClient(cc grpc.ClientConnInterface) SharedMemoryClient + type SharedMemoryServer interface + Apply func(context.Context, *ApplyRequest) (*ApplyResponse, error) + Get func(context.Context, *GetRequest) (*GetResponse, error) + Indexed func(context.Context, *IndexedRequest) (*IndexedResponse, error) + type UnimplementedSharedMemoryServer struct + func (UnimplementedSharedMemoryServer) Apply(context.Context, *ApplyRequest) (*ApplyResponse, error) + func (UnimplementedSharedMemoryServer) Get(context.Context, *GetRequest) (*GetResponse, error) + func (UnimplementedSharedMemoryServer) Indexed(context.Context, *IndexedRequest) (*IndexedResponse, error) + type UnsafeSharedMemoryServer interface
Go to main page