Documentation
¶
Overview ¶
Package protobuf is a generated protocol buffer package.
It is generated from these files:
kvs.proto
It has these top-level messages:
Metadata JoinRequest JoinResponse LeaveRequest LeaveResponse Peer PeersResponse SnapshotResponse GetRequest GetResponse PutRequest PutResponse DeleteRequest DeleteResponse Document UpdateRequest BulkRequest BulkResponse SearchRequest SearchResponse Proposal
Index ¶
- Variables
- func MarshalAny(message *any.Any) (interface{}, error)
- func RegisterKVSServer(s *grpc.Server, srv KVSServer)
- func UnmarshalAny(instance interface{}, message *any.Any) error
- type BulkRequest
- type BulkResponse
- func (*BulkResponse) Descriptor() ([]byte, []int)
- func (m *BulkResponse) GetBytes() ([]byte, error)
- func (m *BulkResponse) GetDeleteCount() int32
- func (m *BulkResponse) GetMessage() string
- func (m *BulkResponse) GetPutCount() int32
- func (m *BulkResponse) GetSuccess() bool
- func (*BulkResponse) ProtoMessage()
- func (m *BulkResponse) Reset()
- func (m *BulkResponse) String() string
- type DeleteRequest
- type DeleteResponse
- func (*DeleteResponse) Descriptor() ([]byte, []int)
- func (m *DeleteResponse) GetBytes() ([]byte, error)
- func (m *DeleteResponse) GetMessage() string
- func (m *DeleteResponse) GetSuccess() bool
- func (*DeleteResponse) ProtoMessage()
- func (m *DeleteResponse) Reset()
- func (m *DeleteResponse) String() string
- type Document
- func (*Document) Descriptor() ([]byte, []int)
- func (m *Document) GetBytes() ([]byte, error)
- func (m *Document) GetFields() *google_protobuf.Any
- func (m *Document) GetFieldsBytes() ([]byte, error)
- func (m *Document) GetFieldsMap() (map[string]interface{}, error)
- func (m *Document) GetId() string
- func (m *Document) GetMap() (map[string]interface{}, error)
- func (*Document) ProtoMessage()
- func (m *Document) Reset()
- func (m *Document) SetBytes(documentBytes []byte) error
- func (m *Document) SetMap(documentMap map[string]interface{}) error
- func (m *Document) String() string
- type GetRequest
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)
- func (m *GetResponse) GetBytes() ([]byte, error)
- func (m *GetResponse) GetFields() *google_protobuf.Any
- func (m *GetResponse) GetFieldsMap() (map[string]interface{}, error)
- func (m *GetResponse) GetId() string
- func (m *GetResponse) GetMessage() string
- func (m *GetResponse) GetSuccess() bool
- func (*GetResponse) ProtoMessage()
- func (m *GetResponse) Reset()
- func (m *GetResponse) String() string
- type JoinRequest
- type JoinResponse
- type KVSClient
- type KVSServer
- type LeaveRequest
- type LeaveResponse
- type Metadata
- func (*Metadata) Descriptor() ([]byte, []int)
- func (m *Metadata) GetBytes() ([]byte, error)
- func (m *Metadata) GetGrpcAddress() string
- func (m *Metadata) GetHttpAddress() string
- func (m *Metadata) GetMap() (map[string]interface{}, error)
- func (*Metadata) ProtoMessage()
- func (m *Metadata) Reset()
- func (m *Metadata) String() string
- type Peer
- func (*Peer) Descriptor() ([]byte, []int)
- func (m *Peer) GetAddress() string
- func (m *Peer) GetBytes() ([]byte, error)
- func (m *Peer) GetLeader() bool
- func (m *Peer) GetMap() (map[string]interface{}, error)
- func (m *Peer) GetMetadata() *Metadata
- func (m *Peer) GetNodeId() string
- func (*Peer) ProtoMessage()
- func (m *Peer) Reset()
- func (m *Peer) String() string
- type PeersResponse
- func (*PeersResponse) Descriptor() ([]byte, []int)
- func (m *PeersResponse) GetBytes() ([]byte, error)
- func (m *PeersResponse) GetMessage() string
- func (m *PeersResponse) GetPeers() []*Peer
- func (m *PeersResponse) GetSuccess() bool
- func (*PeersResponse) ProtoMessage()
- func (m *PeersResponse) Reset()
- func (m *PeersResponse) String() string
- type Proposal
- type Proposal_Type
- type PutRequest
- func (*PutRequest) Descriptor() ([]byte, []int)
- func (m *PutRequest) GetFields() *google_protobuf.Any
- func (m *PutRequest) GetFieldsBytes() ([]byte, error)
- func (m *PutRequest) GetFieldsMap() (map[string]interface{}, error)
- func (m *PutRequest) GetId() string
- func (*PutRequest) ProtoMessage()
- func (m *PutRequest) Reset()
- func (m *PutRequest) String() string
- type PutResponse
- type SearchRequest
- func (*SearchRequest) Descriptor() ([]byte, []int)
- func (m *SearchRequest) GetSearchRequest() *google_protobuf.Any
- func (*SearchRequest) ProtoMessage()
- func (m *SearchRequest) Reset()
- func (m *SearchRequest) SetBytes(searchRequestBytes []byte) error
- func (m *SearchRequest) SetMap(searchRequestMap map[string]interface{}) error
- func (m *SearchRequest) String() string
- type SearchResponse
- func (*SearchResponse) Descriptor() ([]byte, []int)
- func (m *SearchResponse) GetBytes() ([]byte, error)
- func (m *SearchResponse) GetMessage() string
- func (m *SearchResponse) GetSearchResult() *google_protobuf.Any
- func (m *SearchResponse) GetSuccess() bool
- func (*SearchResponse) ProtoMessage()
- func (m *SearchResponse) Reset()
- func (m *SearchResponse) String() string
- type SnapshotResponse
- func (*SnapshotResponse) Descriptor() ([]byte, []int)
- func (m *SnapshotResponse) GetBytes() ([]byte, error)
- func (m *SnapshotResponse) GetMessage() string
- func (m *SnapshotResponse) GetSuccess() bool
- func (*SnapshotResponse) ProtoMessage()
- func (m *SnapshotResponse) Reset()
- func (m *SnapshotResponse) String() string
- type UpdateRequest
- func (*UpdateRequest) Descriptor() ([]byte, []int)
- func (m *UpdateRequest) GetBytes() ([]byte, error)
- func (m *UpdateRequest) GetDocument() *Document
- func (m *UpdateRequest) GetMap() (map[string]interface{}, error)
- func (m *UpdateRequest) GetType() UpdateRequest_Type
- func (*UpdateRequest) ProtoMessage()
- func (m *UpdateRequest) Reset()
- func (m *UpdateRequest) SetBytes(updateRequestBytes []byte) error
- func (m *UpdateRequest) SetMap(updateRequestMap map[string]interface{}) error
- func (m *UpdateRequest) String() string
- type UpdateRequest_Type
Constants ¶
This section is empty.
Variables ¶
View Source
var Proposal_Type_name = map[int32]string{
0: "NOOP",
1: "PUT",
2: "DELETE",
3: "BULK",
4: "JOIN",
5: "LEAVE",
}
View Source
var Proposal_Type_value = map[string]int32{
"NOOP": 0,
"PUT": 1,
"DELETE": 2,
"BULK": 3,
"JOIN": 4,
"LEAVE": 5,
}
View Source
var UpdateRequest_Type_name = map[int32]string{
0: "NOOP",
1: "PUT",
2: "DELETE",
}
View Source
var UpdateRequest_Type_value = map[string]int32{
"NOOP": 0,
"PUT": 1,
"DELETE": 2,
}
Functions ¶
func MarshalAny ¶
func RegisterKVSServer ¶
func UnmarshalAny ¶
Types ¶
type BulkRequest ¶
type BulkRequest struct {
BatchSize int32 `protobuf:"varint,1,opt,name=batch_size,json=batchSize" json:"batch_size,omitempty"`
UpdateRequests []*UpdateRequest `protobuf:"bytes,2,rep,name=update_requests,json=updateRequests" json:"update_requests,omitempty"`
}
func (*BulkRequest) Descriptor ¶
func (*BulkRequest) Descriptor() ([]byte, []int)
func (*BulkRequest) GetBatchSize ¶
func (m *BulkRequest) GetBatchSize() int32
func (*BulkRequest) GetUpdateRequests ¶
func (m *BulkRequest) GetUpdateRequests() []*UpdateRequest
func (*BulkRequest) ProtoMessage ¶
func (*BulkRequest) ProtoMessage()
func (*BulkRequest) Reset ¶
func (m *BulkRequest) Reset()
func (*BulkRequest) String ¶
func (m *BulkRequest) String() string
type BulkResponse ¶
type BulkResponse struct {
PutCount int32 `protobuf:"varint,1,opt,name=put_count,json=putCount" json:"put_count,omitempty"`
DeleteCount int32 `protobuf:"varint,2,opt,name=delete_count,json=deleteCount" json:"delete_count,omitempty"`
Success bool `protobuf:"varint,3,opt,name=success" json:"success,omitempty"`
Message string `protobuf:"bytes,4,opt,name=message" json:"message,omitempty"`
}
func (*BulkResponse) Descriptor ¶
func (*BulkResponse) Descriptor() ([]byte, []int)
func (*BulkResponse) GetBytes ¶
func (m *BulkResponse) GetBytes() ([]byte, error)
func (*BulkResponse) GetDeleteCount ¶
func (m *BulkResponse) GetDeleteCount() int32
func (*BulkResponse) GetMessage ¶
func (m *BulkResponse) GetMessage() string
func (*BulkResponse) GetPutCount ¶
func (m *BulkResponse) GetPutCount() int32
func (*BulkResponse) GetSuccess ¶
func (m *BulkResponse) GetSuccess() bool
func (*BulkResponse) ProtoMessage ¶
func (*BulkResponse) ProtoMessage()
func (*BulkResponse) Reset ¶
func (m *BulkResponse) Reset()
func (*BulkResponse) String ¶
func (m *BulkResponse) String() string
type DeleteRequest ¶
type DeleteRequest struct {
Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}
func (*DeleteRequest) Descriptor ¶
func (*DeleteRequest) Descriptor() ([]byte, []int)
func (*DeleteRequest) GetId ¶
func (m *DeleteRequest) GetId() string
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) Reset ¶
func (m *DeleteRequest) Reset()
func (*DeleteRequest) String ¶
func (m *DeleteRequest) String() string
type DeleteResponse ¶
type DeleteResponse struct {
Success bool `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
}
func (*DeleteResponse) Descriptor ¶
func (*DeleteResponse) Descriptor() ([]byte, []int)
func (*DeleteResponse) GetBytes ¶
func (m *DeleteResponse) GetBytes() ([]byte, error)
func (*DeleteResponse) GetMessage ¶
func (m *DeleteResponse) GetMessage() string
func (*DeleteResponse) GetSuccess ¶
func (m *DeleteResponse) GetSuccess() bool
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) Reset ¶
func (m *DeleteResponse) Reset()
func (*DeleteResponse) String ¶
func (m *DeleteResponse) String() string
type Document ¶
type Document struct {
Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
Fields *google_protobuf.Any `protobuf:"bytes,2,opt,name=fields" json:"fields,omitempty"`
}
func (*Document) Descriptor ¶
func (*Document) GetFields ¶
func (m *Document) GetFields() *google_protobuf.Any
func (*Document) GetFieldsBytes ¶
func (*Document) GetFieldsMap ¶
func (*Document) ProtoMessage ¶
func (*Document) ProtoMessage()
type GetRequest ¶
type GetRequest struct {
Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetId ¶
func (m *GetRequest) GetId() string
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) String ¶
func (m *GetRequest) String() string
type GetResponse ¶
type GetResponse struct {
Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
Fields *google_protobuf.Any `protobuf:"bytes,2,opt,name=fields" json:"fields,omitempty"`
Success bool `protobuf:"varint,3,opt,name=success" json:"success,omitempty"`
Message string `protobuf:"bytes,4,opt,name=message" json:"message,omitempty"`
}
func (*GetResponse) Descriptor ¶
func (*GetResponse) Descriptor() ([]byte, []int)
func (*GetResponse) GetBytes ¶
func (m *GetResponse) GetBytes() ([]byte, error)
func (*GetResponse) GetFields ¶
func (m *GetResponse) GetFields() *google_protobuf.Any
func (*GetResponse) GetFieldsMap ¶
func (m *GetResponse) GetFieldsMap() (map[string]interface{}, error)
func (*GetResponse) GetId ¶
func (m *GetResponse) GetId() string
func (*GetResponse) GetMessage ¶
func (m *GetResponse) GetMessage() string
func (*GetResponse) GetSuccess ¶
func (m *GetResponse) GetSuccess() bool
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) Reset ¶
func (m *GetResponse) Reset()
func (*GetResponse) String ¶
func (m *GetResponse) String() string
type JoinRequest ¶
type JoinRequest struct {
NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId" json:"node_id,omitempty"`
Address string `protobuf:"bytes,2,opt,name=address" json:"address,omitempty"`
Metadata *Metadata `protobuf:"bytes,3,opt,name=metadata" json:"metadata,omitempty"`
}
func (*JoinRequest) Descriptor ¶
func (*JoinRequest) Descriptor() ([]byte, []int)
func (*JoinRequest) GetAddress ¶
func (m *JoinRequest) GetAddress() string
func (*JoinRequest) GetMetadata ¶
func (m *JoinRequest) GetMetadata() *Metadata
func (*JoinRequest) GetNodeId ¶
func (m *JoinRequest) GetNodeId() string
func (*JoinRequest) ProtoMessage ¶
func (*JoinRequest) ProtoMessage()
func (*JoinRequest) Reset ¶
func (m *JoinRequest) Reset()
func (*JoinRequest) String ¶
func (m *JoinRequest) String() string
type JoinResponse ¶
type JoinResponse struct {
Success bool `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
}
func (*JoinResponse) Descriptor ¶
func (*JoinResponse) Descriptor() ([]byte, []int)
func (*JoinResponse) GetBytes ¶
func (m *JoinResponse) GetBytes() ([]byte, error)
func (*JoinResponse) GetMessage ¶
func (m *JoinResponse) GetMessage() string
func (*JoinResponse) GetSuccess ¶
func (m *JoinResponse) GetSuccess() bool
func (*JoinResponse) ProtoMessage ¶
func (*JoinResponse) ProtoMessage()
func (*JoinResponse) Reset ¶
func (m *JoinResponse) Reset()
func (*JoinResponse) String ¶
func (m *JoinResponse) String() string
type KVSClient ¶
type KVSClient interface {
Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error)
Leave(ctx context.Context, in *LeaveRequest, opts ...grpc.CallOption) (*LeaveResponse, error)
Peers(ctx context.Context, in *google_protobuf1.Empty, opts ...grpc.CallOption) (*PeersResponse, error)
Snapshot(ctx context.Context, in *google_protobuf1.Empty, opts ...grpc.CallOption) (*SnapshotResponse, error)
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
Bulk(ctx context.Context, in *BulkRequest, opts ...grpc.CallOption) (*BulkResponse, error)
Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
}
func NewKVSClient ¶
func NewKVSClient(cc *grpc.ClientConn) KVSClient
type KVSServer ¶
type KVSServer interface {
Join(context.Context, *JoinRequest) (*JoinResponse, error)
Leave(context.Context, *LeaveRequest) (*LeaveResponse, error)
Peers(context.Context, *google_protobuf1.Empty) (*PeersResponse, error)
Snapshot(context.Context, *google_protobuf1.Empty) (*SnapshotResponse, error)
Get(context.Context, *GetRequest) (*GetResponse, error)
Put(context.Context, *PutRequest) (*PutResponse, error)
Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
Bulk(context.Context, *BulkRequest) (*BulkResponse, error)
Search(context.Context, *SearchRequest) (*SearchResponse, error)
}
type LeaveRequest ¶
type LeaveRequest struct {
NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId" json:"node_id,omitempty"`
Address string `protobuf:"bytes,2,opt,name=address" json:"address,omitempty"`
}
func (*LeaveRequest) Descriptor ¶
func (*LeaveRequest) Descriptor() ([]byte, []int)
func (*LeaveRequest) GetAddress ¶
func (m *LeaveRequest) GetAddress() string
func (*LeaveRequest) GetNodeId ¶
func (m *LeaveRequest) GetNodeId() string
func (*LeaveRequest) ProtoMessage ¶
func (*LeaveRequest) ProtoMessage()
func (*LeaveRequest) Reset ¶
func (m *LeaveRequest) Reset()
func (*LeaveRequest) String ¶
func (m *LeaveRequest) String() string
type LeaveResponse ¶
type LeaveResponse struct {
Success bool `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
}
func (*LeaveResponse) Descriptor ¶
func (*LeaveResponse) Descriptor() ([]byte, []int)
func (*LeaveResponse) GetBytes ¶
func (m *LeaveResponse) GetBytes() ([]byte, error)
func (*LeaveResponse) GetMessage ¶
func (m *LeaveResponse) GetMessage() string
func (*LeaveResponse) GetSuccess ¶
func (m *LeaveResponse) GetSuccess() bool
func (*LeaveResponse) ProtoMessage ¶
func (*LeaveResponse) ProtoMessage()
func (*LeaveResponse) Reset ¶
func (m *LeaveResponse) Reset()
func (*LeaveResponse) String ¶
func (m *LeaveResponse) String() string
type Metadata ¶
type Metadata struct {
GrpcAddress string `protobuf:"bytes,2,opt,name=grpc_address,json=grpcAddress" json:"grpc_address,omitempty"`
HttpAddress string `protobuf:"bytes,3,opt,name=http_address,json=httpAddress" json:"http_address,omitempty"`
}
func (*Metadata) Descriptor ¶
func (*Metadata) GetGrpcAddress ¶
func (*Metadata) GetHttpAddress ¶
func (*Metadata) ProtoMessage ¶
func (*Metadata) ProtoMessage()
type Peer ¶
type Peer struct {
NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId" json:"node_id,omitempty"`
Address string `protobuf:"bytes,2,opt,name=address" json:"address,omitempty"`
Leader bool `protobuf:"varint,3,opt,name=leader" json:"leader,omitempty"`
Metadata *Metadata `protobuf:"bytes,4,opt,name=metadata" json:"metadata,omitempty"`
}
func (*Peer) Descriptor ¶
func (*Peer) GetAddress ¶
func (*Peer) GetMetadata ¶
func (*Peer) ProtoMessage ¶
func (*Peer) ProtoMessage()
type PeersResponse ¶
type PeersResponse struct {
Peers []*Peer `protobuf:"bytes,1,rep,name=peers" json:"peers,omitempty"`
Success bool `protobuf:"varint,2,opt,name=success" json:"success,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message" json:"message,omitempty"`
}
func (*PeersResponse) Descriptor ¶
func (*PeersResponse) Descriptor() ([]byte, []int)
func (*PeersResponse) GetBytes ¶
func (m *PeersResponse) GetBytes() ([]byte, error)
func (*PeersResponse) GetMessage ¶
func (m *PeersResponse) GetMessage() string
func (*PeersResponse) GetPeers ¶
func (m *PeersResponse) GetPeers() []*Peer
func (*PeersResponse) GetSuccess ¶
func (m *PeersResponse) GetSuccess() bool
func (*PeersResponse) ProtoMessage ¶
func (*PeersResponse) ProtoMessage()
func (*PeersResponse) Reset ¶
func (m *PeersResponse) Reset()
func (*PeersResponse) String ¶
func (m *PeersResponse) String() string
type Proposal ¶
type Proposal struct {
Type Proposal_Type `protobuf:"varint,1,opt,name=type,enum=protobuf.Proposal_Type" json:"type,omitempty"`
Data *google_protobuf.Any `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
}
func (*Proposal) Descriptor ¶
func (*Proposal) GetData ¶
func (m *Proposal) GetData() *google_protobuf.Any
func (*Proposal) GetType ¶
func (m *Proposal) GetType() Proposal_Type
func (*Proposal) ProtoMessage ¶
func (*Proposal) ProtoMessage()
type Proposal_Type ¶
type Proposal_Type int32
const ( Proposal_NOOP Proposal_Type = 0 Proposal_PUT Proposal_Type = 1 Proposal_DELETE Proposal_Type = 2 Proposal_BULK Proposal_Type = 3 Proposal_JOIN Proposal_Type = 4 Proposal_LEAVE Proposal_Type = 5 )
func (Proposal_Type) EnumDescriptor ¶
func (Proposal_Type) EnumDescriptor() ([]byte, []int)
func (Proposal_Type) String ¶
func (x Proposal_Type) String() string
type PutRequest ¶
type PutRequest struct {
Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
Fields *google_protobuf.Any `protobuf:"bytes,2,opt,name=fields" json:"fields,omitempty"`
}
func (*PutRequest) Descriptor ¶
func (*PutRequest) Descriptor() ([]byte, []int)
func (*PutRequest) GetFields ¶
func (m *PutRequest) GetFields() *google_protobuf.Any
func (*PutRequest) GetFieldsBytes ¶
func (m *PutRequest) GetFieldsBytes() ([]byte, error)
func (*PutRequest) GetFieldsMap ¶
func (m *PutRequest) GetFieldsMap() (map[string]interface{}, error)
func (*PutRequest) GetId ¶
func (m *PutRequest) GetId() string
func (*PutRequest) ProtoMessage ¶
func (*PutRequest) ProtoMessage()
func (*PutRequest) Reset ¶
func (m *PutRequest) Reset()
func (*PutRequest) String ¶
func (m *PutRequest) String() string
type PutResponse ¶
type PutResponse struct {
Success bool `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
}
func (*PutResponse) Descriptor ¶
func (*PutResponse) Descriptor() ([]byte, []int)
func (*PutResponse) GetBytes ¶
func (m *PutResponse) GetBytes() ([]byte, error)
func (*PutResponse) GetMessage ¶
func (m *PutResponse) GetMessage() string
func (*PutResponse) GetSuccess ¶
func (m *PutResponse) GetSuccess() bool
func (*PutResponse) ProtoMessage ¶
func (*PutResponse) ProtoMessage()
func (*PutResponse) Reset ¶
func (m *PutResponse) Reset()
func (*PutResponse) String ¶
func (m *PutResponse) String() string
type SearchRequest ¶
type SearchRequest struct {
SearchRequest *google_protobuf.Any `protobuf:"bytes,1,opt,name=search_request,json=searchRequest" json:"search_request,omitempty"`
}
func (*SearchRequest) Descriptor ¶
func (*SearchRequest) Descriptor() ([]byte, []int)
func (*SearchRequest) GetSearchRequest ¶
func (m *SearchRequest) GetSearchRequest() *google_protobuf.Any
func (*SearchRequest) ProtoMessage ¶
func (*SearchRequest) ProtoMessage()
func (*SearchRequest) Reset ¶
func (m *SearchRequest) Reset()
func (*SearchRequest) SetBytes ¶
func (m *SearchRequest) SetBytes(searchRequestBytes []byte) error
func (*SearchRequest) SetMap ¶
func (m *SearchRequest) SetMap(searchRequestMap map[string]interface{}) error
func (*SearchRequest) String ¶
func (m *SearchRequest) String() string
type SearchResponse ¶
type SearchResponse struct {
SearchResult *google_protobuf.Any `protobuf:"bytes,1,opt,name=search_result,json=searchResult" json:"search_result,omitempty"`
Success bool `protobuf:"varint,2,opt,name=success" json:"success,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message" json:"message,omitempty"`
}
func (*SearchResponse) Descriptor ¶
func (*SearchResponse) Descriptor() ([]byte, []int)
func (*SearchResponse) GetBytes ¶
func (m *SearchResponse) GetBytes() ([]byte, error)
func (*SearchResponse) GetMessage ¶
func (m *SearchResponse) GetMessage() string
func (*SearchResponse) GetSearchResult ¶
func (m *SearchResponse) GetSearchResult() *google_protobuf.Any
func (*SearchResponse) GetSuccess ¶
func (m *SearchResponse) GetSuccess() bool
func (*SearchResponse) ProtoMessage ¶
func (*SearchResponse) ProtoMessage()
func (*SearchResponse) Reset ¶
func (m *SearchResponse) Reset()
func (*SearchResponse) String ¶
func (m *SearchResponse) String() string
type SnapshotResponse ¶
type SnapshotResponse struct {
Success bool `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
}
func (*SnapshotResponse) Descriptor ¶
func (*SnapshotResponse) Descriptor() ([]byte, []int)
func (*SnapshotResponse) GetBytes ¶
func (m *SnapshotResponse) GetBytes() ([]byte, error)
func (*SnapshotResponse) GetMessage ¶
func (m *SnapshotResponse) GetMessage() string
func (*SnapshotResponse) GetSuccess ¶
func (m *SnapshotResponse) GetSuccess() bool
func (*SnapshotResponse) ProtoMessage ¶
func (*SnapshotResponse) ProtoMessage()
func (*SnapshotResponse) Reset ¶
func (m *SnapshotResponse) Reset()
func (*SnapshotResponse) String ¶
func (m *SnapshotResponse) String() string
type UpdateRequest ¶
type UpdateRequest struct {
Type UpdateRequest_Type `protobuf:"varint,1,opt,name=type,enum=protobuf.UpdateRequest_Type" json:"type,omitempty"`
Document *Document `protobuf:"bytes,2,opt,name=document" json:"document,omitempty"`
}
func (*UpdateRequest) Descriptor ¶
func (*UpdateRequest) Descriptor() ([]byte, []int)
func (*UpdateRequest) GetBytes ¶
func (m *UpdateRequest) GetBytes() ([]byte, error)
func (*UpdateRequest) GetDocument ¶
func (m *UpdateRequest) GetDocument() *Document
func (*UpdateRequest) GetMap ¶
func (m *UpdateRequest) GetMap() (map[string]interface{}, error)
func (*UpdateRequest) GetType ¶
func (m *UpdateRequest) GetType() UpdateRequest_Type
func (*UpdateRequest) ProtoMessage ¶
func (*UpdateRequest) ProtoMessage()
func (*UpdateRequest) Reset ¶
func (m *UpdateRequest) Reset()
func (*UpdateRequest) SetBytes ¶
func (m *UpdateRequest) SetBytes(updateRequestBytes []byte) error
func (*UpdateRequest) SetMap ¶
func (m *UpdateRequest) SetMap(updateRequestMap map[string]interface{}) error
func (*UpdateRequest) String ¶
func (m *UpdateRequest) String() string
type UpdateRequest_Type ¶
type UpdateRequest_Type int32
const ( UpdateRequest_NOOP UpdateRequest_Type = 0 UpdateRequest_PUT UpdateRequest_Type = 1 UpdateRequest_DELETE UpdateRequest_Type = 2 )
func (UpdateRequest_Type) EnumDescriptor ¶
func (UpdateRequest_Type) EnumDescriptor() ([]byte, []int)
func (UpdateRequest_Type) String ¶
func (x UpdateRequest_Type) String() string
Click to show internal directories.
Click to hide internal directories.