Versions in this module Expand all Collapse all v0 v0.1.3 Jun 25, 2022 v0.1.0 Jun 25, 2022 Changes in this version + var File_gsharedmemory_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