Versions in this module Expand all Collapse all v0 v0.0.13 Sep 23, 2022 v0.0.12 Sep 23, 2022 v0.0.11 Sep 23, 2022 v0.0.10 Sep 23, 2022 v0.0.9 Sep 23, 2022 v0.0.8 Sep 23, 2022 v0.0.6 Sep 23, 2022 Changes in this version + var File_sharedmemory_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