gsharedmemoryproto

Sep 11, 2020

Changes in this version

+ func RegisterSharedMemoryServer(s *grpc.Server, srv SharedMemoryServer)

+ type Batch struct

+ Deletes []*BatchDelete

+ Puts []*BatchPut

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Batch) ProtoMessage()

+ func (m *Batch) GetDeletes() []*BatchDelete

+ func (m *Batch) GetPuts() []*BatchPut

+ func (m *Batch) Reset()

+ func (m *Batch) String() string

+ func (m *Batch) XXX_DiscardUnknown()

+ func (m *Batch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Batch) XXX_Merge(src proto.Message)

+ func (m *Batch) XXX_Size() int

+ func (m *Batch) XXX_Unmarshal(b []byte) error

+ type BatchDelete struct

+ Key []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BatchDelete) ProtoMessage()

+ func (m *BatchDelete) GetKey() []byte

+ func (m *BatchDelete) Reset()

+ func (m *BatchDelete) String() string

+ func (m *BatchDelete) XXX_DiscardUnknown()

+ func (m *BatchDelete) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BatchDelete) XXX_Merge(src proto.Message)

+ func (m *BatchDelete) XXX_Size() int

+ func (m *BatchDelete) XXX_Unmarshal(b []byte) error

+ type BatchPut struct

+ Key []byte

+ Value []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BatchPut) ProtoMessage()

+ func (m *BatchPut) GetKey() []byte

+ func (m *BatchPut) GetValue() []byte

+ func (m *BatchPut) Reset()

+ func (m *BatchPut) String() string

+ func (m *BatchPut) XXX_DiscardUnknown()

+ func (m *BatchPut) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BatchPut) XXX_Merge(src proto.Message)

+ func (m *BatchPut) XXX_Size() int

+ func (m *BatchPut) XXX_Unmarshal(b []byte) error

+ type Element struct

+ Key []byte

+ Traits [][]byte

+ Value []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Element) ProtoMessage()

+ func (m *Element) GetKey() []byte

+ func (m *Element) GetTraits() [][]byte

+ func (m *Element) GetValue() []byte

+ func (m *Element) Reset()

+ func (m *Element) String() string

+ func (m *Element) XXX_DiscardUnknown()

+ func (m *Element) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Element) XXX_Merge(src proto.Message)

+ func (m *Element) XXX_Size() int

+ func (m *Element) XXX_Unmarshal(b []byte) error

+ type GetRequest struct

+ Keys [][]byte

+ PeerChainID []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetRequest) ProtoMessage()

+ func (m *GetRequest) GetKeys() [][]byte

+ func (m *GetRequest) GetPeerChainID() []byte

+ func (m *GetRequest) Reset()

+ func (m *GetRequest) String() string

+ func (m *GetRequest) XXX_DiscardUnknown()

+ func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetRequest) XXX_Merge(src proto.Message)

+ func (m *GetRequest) XXX_Size() int

+ func (m *GetRequest) XXX_Unmarshal(b []byte) error

+ type GetResponse struct

+ Values [][]byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetResponse) ProtoMessage()

+ func (m *GetResponse) GetValues() [][]byte

+ func (m *GetResponse) Reset()

+ func (m *GetResponse) String() string

+ func (m *GetResponse) XXX_DiscardUnknown()

+ func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetResponse) XXX_Merge(src proto.Message)

+ func (m *GetResponse) XXX_Size() int

+ func (m *GetResponse) XXX_Unmarshal(b []byte) error

+ type IndexedRequest struct

+ Limit int32

+ PeerChainID []byte

+ StartKey []byte

+ StartTrait []byte

+ Traits [][]byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*IndexedRequest) ProtoMessage()

+ func (m *IndexedRequest) GetLimit() int32

+ func (m *IndexedRequest) GetPeerChainID() []byte

+ func (m *IndexedRequest) GetStartKey() []byte

+ func (m *IndexedRequest) GetStartTrait() []byte

+ func (m *IndexedRequest) GetTraits() [][]byte

+ func (m *IndexedRequest) Reset()

+ func (m *IndexedRequest) String() string

+ func (m *IndexedRequest) XXX_DiscardUnknown()

+ func (m *IndexedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IndexedRequest) XXX_Merge(src proto.Message)

+ func (m *IndexedRequest) XXX_Size() int

+ func (m *IndexedRequest) XXX_Unmarshal(b []byte) error

+ type IndexedResponse struct

+ LastKey []byte

+ LastTrait []byte

+ Values [][]byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*IndexedResponse) ProtoMessage()

+ func (m *IndexedResponse) GetLastKey() []byte

+ func (m *IndexedResponse) GetLastTrait() []byte

+ func (m *IndexedResponse) GetValues() [][]byte

+ func (m *IndexedResponse) Reset()

+ func (m *IndexedResponse) String() string

+ func (m *IndexedResponse) XXX_DiscardUnknown()

+ func (m *IndexedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IndexedResponse) XXX_Merge(src proto.Message)

+ func (m *IndexedResponse) XXX_Size() int

+ func (m *IndexedResponse) XXX_Unmarshal(b []byte) error

+ type PutRequest struct

+ Batches []*Batch

+ Elems []*Element

+ PeerChainID []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PutRequest) ProtoMessage()

+ func (m *PutRequest) GetBatches() []*Batch

+ func (m *PutRequest) GetElems() []*Element

+ func (m *PutRequest) GetPeerChainID() []byte

+ func (m *PutRequest) Reset()

+ func (m *PutRequest) String() string

+ func (m *PutRequest) XXX_DiscardUnknown()

+ func (m *PutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PutRequest) XXX_Merge(src proto.Message)

+ func (m *PutRequest) XXX_Size() int

+ func (m *PutRequest) XXX_Unmarshal(b []byte) error

+ type PutResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PutResponse) ProtoMessage()

+ func (m *PutResponse) Reset()

+ func (m *PutResponse) String() string

+ func (m *PutResponse) XXX_DiscardUnknown()

+ func (m *PutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PutResponse) XXX_Merge(src proto.Message)

+ func (m *PutResponse) XXX_Size() int

+ func (m *PutResponse) XXX_Unmarshal(b []byte) error

+ type RemoveRequest struct

+ Batches []*Batch

+ Keys [][]byte

+ PeerChainID []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RemoveRequest) ProtoMessage()

+ func (m *RemoveRequest) GetBatches() []*Batch

+ func (m *RemoveRequest) GetKeys() [][]byte

+ func (m *RemoveRequest) GetPeerChainID() []byte

+ func (m *RemoveRequest) Reset()

+ func (m *RemoveRequest) String() string

+ func (m *RemoveRequest) XXX_DiscardUnknown()

+ func (m *RemoveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RemoveRequest) XXX_Merge(src proto.Message)

+ func (m *RemoveRequest) XXX_Size() int

+ func (m *RemoveRequest) XXX_Unmarshal(b []byte) error

+ type RemoveResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RemoveResponse) ProtoMessage()

+ func (m *RemoveResponse) Reset()

+ func (m *RemoveResponse) String() string

+ func (m *RemoveResponse) XXX_DiscardUnknown()

+ func (m *RemoveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RemoveResponse) XXX_Merge(src proto.Message)

+ func (m *RemoveResponse) XXX_Size() int

+ func (m *RemoveResponse) XXX_Unmarshal(b []byte) error

+ type SharedMemoryClient interface

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

+ Indexed func(ctx context.Context, in *IndexedRequest, opts ...grpc.CallOption) (*IndexedResponse, error)

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

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

+ func NewSharedMemoryClient(cc grpc.ClientConnInterface) SharedMemoryClient

+ type SharedMemoryServer interface

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

+ Indexed func(context.Context, *IndexedRequest) (*IndexedResponse, error)

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

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

+ type UnimplementedSharedMemoryServer struct

+ func (*UnimplementedSharedMemoryServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

+ func (*UnimplementedSharedMemoryServer) Indexed(ctx context.Context, req *IndexedRequest) (*IndexedResponse, error)

+ func (*UnimplementedSharedMemoryServer) Put(ctx context.Context, req *PutRequest) (*PutResponse, error)

+ func (*UnimplementedSharedMemoryServer) Remove(ctx context.Context, req *RemoveRequest) (*RemoveResponse, error)