gsharedmemoryproto

package
v1.4.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 13, 2021 License: BSD-3-Clause Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterSharedMemoryServer 

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

Types

type Batch 

type Batch struct {
	Puts                 []*BatchPut    `protobuf:"bytes,1,rep,name=puts,proto3" json:"puts,omitempty"`
	Deletes              []*BatchDelete `protobuf:"bytes,2,rep,name=deletes,proto3" json:"deletes,omitempty"`
	Id                   int64          `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Batch) Descriptor 

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

func (*Batch) GetDeletes 

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

func (*Batch) GetId 

func (m *Batch) GetId() int64

func (*Batch) GetPuts 

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

func (*Batch) ProtoMessage 

func (*Batch) ProtoMessage()

func (*Batch) Reset 

func (m *Batch) Reset()

func (*Batch) String 

func (m *Batch) String() string

func (*Batch) XXX_DiscardUnknown 

func (m *Batch) XXX_DiscardUnknown()

func (*Batch) XXX_Marshal 

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

func (*Batch) XXX_Merge 

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

func (*Batch) XXX_Size 

func (m *Batch) XXX_Size() int

func (*Batch) XXX_Unmarshal 

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

type BatchDelete 

type BatchDelete struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchDelete) Descriptor 

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

func (*BatchDelete) GetKey 

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

func (*BatchDelete) ProtoMessage 

func (*BatchDelete) ProtoMessage()

func (*BatchDelete) Reset 

func (m *BatchDelete) Reset()

func (*BatchDelete) String 

func (m *BatchDelete) String() string

func (*BatchDelete) XXX_DiscardUnknown 

func (m *BatchDelete) XXX_DiscardUnknown()

func (*BatchDelete) XXX_Marshal 

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

func (*BatchDelete) XXX_Merge 

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

func (*BatchDelete) XXX_Size 

func (m *BatchDelete) XXX_Size() int

func (*BatchDelete) XXX_Unmarshal 

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

type BatchPut 

type BatchPut struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchPut) Descriptor 

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

func (*BatchPut) GetKey 

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

func (*BatchPut) GetValue 

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

func (*BatchPut) ProtoMessage 

func (*BatchPut) ProtoMessage()

func (*BatchPut) Reset 

func (m *BatchPut) Reset()

func (*BatchPut) String 

func (m *BatchPut) String() string

func (*BatchPut) XXX_DiscardUnknown 

func (m *BatchPut) XXX_DiscardUnknown()

func (*BatchPut) XXX_Marshal 

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

func (*BatchPut) XXX_Merge 

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

func (*BatchPut) XXX_Size 

func (m *BatchPut) XXX_Size() int

func (*BatchPut) XXX_Unmarshal 

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

type Element 

type Element struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	Traits               [][]byte `protobuf:"bytes,3,rep,name=Traits,proto3" json:"Traits,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Element) Descriptor 

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

func (*Element) GetKey 

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

func (*Element) GetTraits 

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

func (*Element) GetValue 

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

func (*Element) ProtoMessage 

func (*Element) ProtoMessage()

func (*Element) Reset 

func (m *Element) Reset()

func (*Element) String 

func (m *Element) String() string

func (*Element) XXX_DiscardUnknown 

func (m *Element) XXX_DiscardUnknown()

func (*Element) XXX_Marshal 

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

func (*Element) XXX_Merge 

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

func (*Element) XXX_Size 

func (m *Element) XXX_Size() int

func (*Element) XXX_Unmarshal 

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

type GetRequest 

type GetRequest struct {
	PeerChainID          []byte   `protobuf:"bytes,1,opt,name=peerChainID,proto3" json:"peerChainID,omitempty"`
	Keys                 [][]byte `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	Id                   int64    `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	Continues            bool     `protobuf:"varint,4,opt,name=continues,proto3" json:"continues,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetContinues 

func (m *GetRequest) GetContinues() bool

func (*GetRequest) GetId 

func (m *GetRequest) GetId() int64

func (*GetRequest) GetKeys 

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

func (*GetRequest) GetPeerChainID 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type GetResponse 

type GetResponse struct {
	Values               [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	Continues            bool     `protobuf:"varint,2,opt,name=continues,proto3" json:"continues,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetContinues 

func (m *GetResponse) GetContinues() bool

func (*GetResponse) GetValues 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

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

func (*GetResponse) XXX_Merge 

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

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

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

type IndexedRequest 

type IndexedRequest struct {
	PeerChainID          []byte   `protobuf:"bytes,1,opt,name=peerChainID,proto3" json:"peerChainID,omitempty"`
	Traits               [][]byte `protobuf:"bytes,2,rep,name=traits,proto3" json:"traits,omitempty"`
	StartTrait           []byte   `protobuf:"bytes,3,opt,name=startTrait,proto3" json:"startTrait,omitempty"`
	StartKey             []byte   `protobuf:"bytes,4,opt,name=startKey,proto3" json:"startKey,omitempty"`
	Limit                int32    `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	Id                   int64    `protobuf:"varint,6,opt,name=id,proto3" json:"id,omitempty"`
	Continues            bool     `protobuf:"varint,7,opt,name=continues,proto3" json:"continues,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IndexedRequest) Descriptor 

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

func (*IndexedRequest) GetContinues 

func (m *IndexedRequest) GetContinues() bool

func (*IndexedRequest) GetId 

func (m *IndexedRequest) GetId() int64

func (*IndexedRequest) GetLimit 

func (m *IndexedRequest) GetLimit() int32

func (*IndexedRequest) GetPeerChainID 

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

func (*IndexedRequest) GetStartKey 

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

func (*IndexedRequest) GetStartTrait 

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

func (*IndexedRequest) GetTraits 

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

func (*IndexedRequest) ProtoMessage 

func (*IndexedRequest) ProtoMessage()

func (*IndexedRequest) Reset 

func (m *IndexedRequest) Reset()

func (*IndexedRequest) String 

func (m *IndexedRequest) String() string

func (*IndexedRequest) XXX_DiscardUnknown 

func (m *IndexedRequest) XXX_DiscardUnknown()

func (*IndexedRequest) XXX_Marshal 

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

func (*IndexedRequest) XXX_Merge 

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

func (*IndexedRequest) XXX_Size 

func (m *IndexedRequest) XXX_Size() int

func (*IndexedRequest) XXX_Unmarshal 

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

type IndexedResponse 

type IndexedResponse struct {
	Values               [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	LastTrait            []byte   `protobuf:"bytes,2,opt,name=lastTrait,proto3" json:"lastTrait,omitempty"`
	LastKey              []byte   `protobuf:"bytes,3,opt,name=lastKey,proto3" json:"lastKey,omitempty"`
	Continues            bool     `protobuf:"varint,4,opt,name=continues,proto3" json:"continues,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IndexedResponse) Descriptor 

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

func (*IndexedResponse) GetContinues 

func (m *IndexedResponse) GetContinues() bool

func (*IndexedResponse) GetLastKey 

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

func (*IndexedResponse) GetLastTrait 

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

func (*IndexedResponse) GetValues 

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

func (*IndexedResponse) ProtoMessage 

func (*IndexedResponse) ProtoMessage()

func (*IndexedResponse) Reset 

func (m *IndexedResponse) Reset()

func (*IndexedResponse) String 

func (m *IndexedResponse) String() string

func (*IndexedResponse) XXX_DiscardUnknown 

func (m *IndexedResponse) XXX_DiscardUnknown()

func (*IndexedResponse) XXX_Marshal 

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

func (*IndexedResponse) XXX_Merge 

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

func (*IndexedResponse) XXX_Size 

func (m *IndexedResponse) XXX_Size() int

func (*IndexedResponse) XXX_Unmarshal 

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

type PutRequest 

type PutRequest struct {
	PeerChainID          []byte     `protobuf:"bytes,1,opt,name=peerChainID,proto3" json:"peerChainID,omitempty"`
	Elems                []*Element `protobuf:"bytes,2,rep,name=elems,proto3" json:"elems,omitempty"`
	Batches              []*Batch   `protobuf:"bytes,3,rep,name=batches,proto3" json:"batches,omitempty"`
	Id                   int64      `protobuf:"varint,4,opt,name=id,proto3" json:"id,omitempty"`
	Continues            bool       `protobuf:"varint,5,opt,name=continues,proto3" json:"continues,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*PutRequest) Descriptor 

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

func (*PutRequest) GetBatches 

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

func (*PutRequest) GetContinues 

func (m *PutRequest) GetContinues() bool

func (*PutRequest) GetElems 

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

func (*PutRequest) GetId 

func (m *PutRequest) GetId() int64

func (*PutRequest) GetPeerChainID 

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

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset 

func (m *PutRequest) Reset()

func (*PutRequest) String 

func (m *PutRequest) String() string

func (*PutRequest) XXX_DiscardUnknown 

func (m *PutRequest) XXX_DiscardUnknown()

func (*PutRequest) XXX_Marshal 

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

func (*PutRequest) XXX_Merge 

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

func (*PutRequest) XXX_Size 

func (m *PutRequest) XXX_Size() int

func (*PutRequest) XXX_Unmarshal 

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

type PutResponse 

type PutResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PutResponse) Descriptor 

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

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) Reset 

func (m *PutResponse) Reset()

func (*PutResponse) String 

func (m *PutResponse) String() string

func (*PutResponse) XXX_DiscardUnknown 

func (m *PutResponse) XXX_DiscardUnknown()

func (*PutResponse) XXX_Marshal 

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

func (*PutResponse) XXX_Merge 

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

func (*PutResponse) XXX_Size 

func (m *PutResponse) XXX_Size() int

func (*PutResponse) XXX_Unmarshal 

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

type RemoveRequest 

type RemoveRequest struct {
	PeerChainID          []byte   `protobuf:"bytes,1,opt,name=peerChainID,proto3" json:"peerChainID,omitempty"`
	Keys                 [][]byte `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	Batches              []*Batch `protobuf:"bytes,3,rep,name=batches,proto3" json:"batches,omitempty"`
	Id                   int64    `protobuf:"varint,4,opt,name=id,proto3" json:"id,omitempty"`
	Continues            bool     `protobuf:"varint,5,opt,name=continues,proto3" json:"continues,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveRequest) Descriptor 

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

func (*RemoveRequest) GetBatches 

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

func (*RemoveRequest) GetContinues 

func (m *RemoveRequest) GetContinues() bool

func (*RemoveRequest) GetId 

func (m *RemoveRequest) GetId() int64

func (*RemoveRequest) GetKeys 

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

func (*RemoveRequest) GetPeerChainID 

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

func (*RemoveRequest) ProtoMessage 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) Reset 

func (m *RemoveRequest) Reset()

func (*RemoveRequest) String 

func (m *RemoveRequest) String() string

func (*RemoveRequest) XXX_DiscardUnknown 

func (m *RemoveRequest) XXX_DiscardUnknown()

func (*RemoveRequest) XXX_Marshal 

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

func (*RemoveRequest) XXX_Merge 

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

func (*RemoveRequest) XXX_Size 

func (m *RemoveRequest) XXX_Size() int

func (*RemoveRequest) XXX_Unmarshal 

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

type RemoveResponse 

type RemoveResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveResponse) Descriptor 

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

func (*RemoveResponse) ProtoMessage 

func (*RemoveResponse) ProtoMessage()

func (*RemoveResponse) Reset 

func (m *RemoveResponse) Reset()

func (*RemoveResponse) String 

func (m *RemoveResponse) String() string

func (*RemoveResponse) XXX_DiscardUnknown 

func (m *RemoveResponse) XXX_DiscardUnknown()

func (*RemoveResponse) XXX_Marshal 

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

func (*RemoveResponse) XXX_Merge 

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

func (*RemoveResponse) XXX_Size 

func (m *RemoveResponse) XXX_Size() int

func (*RemoveResponse) XXX_Unmarshal 

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

type SharedMemoryClient 

type SharedMemoryClient interface {
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Indexed(ctx context.Context, in *IndexedRequest, opts ...grpc.CallOption) (*IndexedResponse, error)
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error)
}

SharedMemoryClient is the client API for SharedMemory service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSharedMemoryClient 

func NewSharedMemoryClient(cc grpc.ClientConnInterface) SharedMemoryClient

type SharedMemoryServer 

type SharedMemoryServer interface {
	Put(context.Context, *PutRequest) (*PutResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Indexed(context.Context, *IndexedRequest) (*IndexedResponse, error)
	Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
}

SharedMemoryServer is the server API for SharedMemory service.

type UnimplementedSharedMemoryServer 

type UnimplementedSharedMemoryServer struct {
}

UnimplementedSharedMemoryServer can be embedded to have forward compatible implementations.

func (*UnimplementedSharedMemoryServer) Get 

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

func (*UnimplementedSharedMemoryServer) Indexed 

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

func (*UnimplementedSharedMemoryServer) Put 

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

func (*UnimplementedSharedMemoryServer) Remove 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.