protobuf

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Aug 10, 2018 License: Apache-2.0 Imports: 10 Imported by: 0

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

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 MarshalAny(message *any.Any) (interface{}, error)

func RegisterKVSServer

func RegisterKVSServer(s *grpc.Server, srv KVSServer)

func UnmarshalAny

func UnmarshalAny(instance interface{}, message *any.Any) error

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) Descriptor() ([]byte, []int)

func (*Document) GetBytes

func (m *Document) GetBytes() ([]byte, error)

func (*Document) GetFields

func (m *Document) GetFields() *google_protobuf.Any

func (*Document) GetFieldsBytes

func (m *Document) GetFieldsBytes() ([]byte, error)

func (*Document) GetFieldsMap

func (m *Document) GetFieldsMap() (map[string]interface{}, error)

func (*Document) GetId

func (m *Document) GetId() string

func (*Document) GetMap

func (m *Document) GetMap() (map[string]interface{}, error)

func (*Document) ProtoMessage

func (*Document) ProtoMessage()

func (*Document) Reset

func (m *Document) Reset()

func (*Document) SetBytes

func (m *Document) SetBytes(documentBytes []byte) error

func (*Document) SetMap

func (m *Document) SetMap(documentMap map[string]interface{}) error

func (*Document) String

func (m *Document) String() string

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

func NewKVSClient

func NewKVSClient(cc *grpc.ClientConn) KVSClient

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) Descriptor() ([]byte, []int)

func (*Metadata) GetBytes

func (m *Metadata) GetBytes() ([]byte, error)

func (*Metadata) GetGrpcAddress

func (m *Metadata) GetGrpcAddress() string

func (*Metadata) GetHttpAddress

func (m *Metadata) GetHttpAddress() string

func (*Metadata) GetMap

func (m *Metadata) GetMap() (map[string]interface{}, error)

func (*Metadata) ProtoMessage

func (*Metadata) ProtoMessage()

func (*Metadata) Reset

func (m *Metadata) Reset()

func (*Metadata) String

func (m *Metadata) String() string

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) Descriptor() ([]byte, []int)

func (*Peer) GetAddress

func (m *Peer) GetAddress() string

func (*Peer) GetBytes

func (m *Peer) GetBytes() ([]byte, error)

func (*Peer) GetLeader

func (m *Peer) GetLeader() bool

func (*Peer) GetMap

func (m *Peer) GetMap() (map[string]interface{}, error)

func (*Peer) GetMetadata

func (m *Peer) GetMetadata() *Metadata

func (*Peer) GetNodeId

func (m *Peer) GetNodeId() string

func (*Peer) ProtoMessage

func (*Peer) ProtoMessage()

func (*Peer) Reset

func (m *Peer) Reset()

func (*Peer) String

func (m *Peer) String() string

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) Descriptor() ([]byte, []int)

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()

func (*Proposal) Reset

func (m *Proposal) Reset()

func (*Proposal) String

func (m *Proposal) String() string

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL