pb

package
v0.0.0-...-40e4417 Latest Latest
Warning

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

 Go to latest Published: Dec 29, 2017 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

Package pb is a generated protocol buffer package.

It is generated from these files: 

common.proto
meta.proto
raft.proto

It has these top-level messages: 

Result
Node
MetaAddMetaNodeReq
MetaAddMetaNodeResp
DataNode
RaftGroup
RaftAddGroup
RaftAddGroupResp
RaftMessage
RaftGroupMessage
RaftMessageResponse
RaftGroupMessageResponse

Index

Constants

This section is empty.

Variables

View Source 
var ResultCode_name = map[int32]string{
	0:      "ResultCodeOK",
	1:      "ResultCodeUnknown",
	2:      "ResultCodeInternal",
	100001: "ResultCodeRaftDuplicateGroupID",
}
View Source 
var ResultCode_value = map[string]int32{
	"ResultCodeOK":                   0,
	"ResultCodeUnknown":              1,
	"ResultCodeInternal":             2,
	"ResultCodeRaftDuplicateGroupID": 100001,
}

Functions

func RegisterMetaServer 

func RegisterMetaServer(s *grpc.Server, srv MetaServer)

func RegisterRaftServer 

func RegisterRaftServer(s *grpc.Server, srv RaftServer)

Types

type DataNode 

type DataNode struct {
	Id      uint64 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address" json:"address,omitempty"`
}

func (*DataNode) Descriptor 

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

func (*DataNode) GetAddress 

func (m *DataNode) GetAddress() string

func (*DataNode) GetId 

func (m *DataNode) GetId() uint64

func (*DataNode) ProtoMessage 

func (*DataNode) ProtoMessage()

func (*DataNode) Reset 

func (m *DataNode) Reset()

func (*DataNode) String 

func (m *DataNode) String() string

type MetaAddMetaNodeReq 

type MetaAddMetaNodeReq struct {
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes" json:"nodes,omitempty"`
}

func (*MetaAddMetaNodeReq) Descriptor 

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

func (*MetaAddMetaNodeReq) GetNodes 

func (m *MetaAddMetaNodeReq) GetNodes() []*Node

func (*MetaAddMetaNodeReq) ProtoMessage 

func (*MetaAddMetaNodeReq) ProtoMessage()

func (*MetaAddMetaNodeReq) Reset 

func (m *MetaAddMetaNodeReq) Reset()

func (*MetaAddMetaNodeReq) String 

func (m *MetaAddMetaNodeReq) String() string

type MetaAddMetaNodeResp 

type MetaAddMetaNodeResp struct {
	Results []*Result `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
}

func (*MetaAddMetaNodeResp) Descriptor 

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

func (*MetaAddMetaNodeResp) GetResults 

func (m *MetaAddMetaNodeResp) GetResults() []*Result

func (*MetaAddMetaNodeResp) ProtoMessage 

func (*MetaAddMetaNodeResp) ProtoMessage()

func (*MetaAddMetaNodeResp) Reset 

func (m *MetaAddMetaNodeResp) Reset()

func (*MetaAddMetaNodeResp) String 

func (m *MetaAddMetaNodeResp) String() string

type MetaClient 

type MetaClient interface {
	AddMetaNode(ctx context.Context, in *MetaAddMetaNodeReq, opts ...grpc.CallOption) (*MetaAddMetaNodeResp, error)
}

func NewMetaClient 

func NewMetaClient(cc *grpc.ClientConn) MetaClient

type MetaServer 

type MetaServer interface {
	AddMetaNode(context.Context, *MetaAddMetaNodeReq) (*MetaAddMetaNodeResp, error)
}

type Node 

type Node struct {
	Id      uint64 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Context []byte `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"`
}

func (*Node) Descriptor 

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

func (*Node) GetContext 

func (m *Node) GetContext() []byte

func (*Node) GetId 

func (m *Node) GetId() uint64

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) String 

func (m *Node) String() string

type RaftAddGroup 

type RaftAddGroup struct {
	Group *RaftGroup `protobuf:"bytes,1,opt,name=group" json:"group,omitempty"`
}

func (*RaftAddGroup) Descriptor 

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

func (*RaftAddGroup) GetGroup 

func (m *RaftAddGroup) GetGroup() *RaftGroup

func (*RaftAddGroup) ProtoMessage 

func (*RaftAddGroup) ProtoMessage()

func (*RaftAddGroup) Reset 

func (m *RaftAddGroup) Reset()

func (*RaftAddGroup) String 

func (m *RaftAddGroup) String() string

type RaftAddGroupResp 

type RaftAddGroupResp struct {
	Result *Result `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
}

func (*RaftAddGroupResp) Descriptor 

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

func (*RaftAddGroupResp) GetResult 

func (m *RaftAddGroupResp) GetResult() *Result

func (*RaftAddGroupResp) ProtoMessage 

func (*RaftAddGroupResp) ProtoMessage()

func (*RaftAddGroupResp) Reset 

func (m *RaftAddGroupResp) Reset()

func (*RaftAddGroupResp) String 

func (m *RaftAddGroupResp) String() string

type RaftClient 

type RaftClient interface {
	// add raft group
	AddGroup(ctx context.Context, in *RaftAddGroup, opts ...grpc.CallOption) (*RaftAddGroupResp, error)
	// process raft messages
	Message(ctx context.Context, in *RaftMessage, opts ...grpc.CallOption) (*RaftMessageResponse, error)
}

func NewRaftClient 

func NewRaftClient(cc *grpc.ClientConn) RaftClient

type RaftGroup 

type RaftGroup struct {
	Id   uint64      `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Node []*DataNode `protobuf:"bytes,2,rep,name=node" json:"node,omitempty"`
}

func (*RaftGroup) Descriptor 

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

func (*RaftGroup) GetId 

func (m *RaftGroup) GetId() uint64

func (*RaftGroup) GetNode 

func (m *RaftGroup) GetNode() []*DataNode

func (*RaftGroup) ProtoMessage 

func (*RaftGroup) ProtoMessage()

func (*RaftGroup) Reset 

func (m *RaftGroup) Reset()

func (*RaftGroup) String 

func (m *RaftGroup) String() string

type RaftGroupMessage 

type RaftGroupMessage struct {
	Id  uint64   `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Raw [][]byte `protobuf:"bytes,2,rep,name=raw,proto3" json:"raw,omitempty"`
}

func (*RaftGroupMessage) Descriptor 

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

func (*RaftGroupMessage) GetId 

func (m *RaftGroupMessage) GetId() uint64

func (*RaftGroupMessage) GetRaw 

func (m *RaftGroupMessage) GetRaw() [][]byte

func (*RaftGroupMessage) ProtoMessage 

func (*RaftGroupMessage) ProtoMessage()

func (*RaftGroupMessage) Reset 

func (m *RaftGroupMessage) Reset()

func (*RaftGroupMessage) String 

func (m *RaftGroupMessage) String() string

type RaftGroupMessageResponse 

type RaftGroupMessageResponse struct {
	Result *Result `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
}

func (*RaftGroupMessageResponse) Descriptor 

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

func (*RaftGroupMessageResponse) GetResult 

func (m *RaftGroupMessageResponse) GetResult() *Result

func (*RaftGroupMessageResponse) ProtoMessage 

func (*RaftGroupMessageResponse) ProtoMessage()

func (*RaftGroupMessageResponse) Reset 

func (m *RaftGroupMessageResponse) Reset()

func (*RaftGroupMessageResponse) String 

func (m *RaftGroupMessageResponse) String() string

type RaftMessage 

type RaftMessage struct {
	Message []*RaftGroupMessage `protobuf:"bytes,1,rep,name=message" json:"message,omitempty"`
}

func (*RaftMessage) Descriptor 

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

func (*RaftMessage) GetMessage 

func (m *RaftMessage) GetMessage() []*RaftGroupMessage

func (*RaftMessage) ProtoMessage 

func (*RaftMessage) ProtoMessage()

func (*RaftMessage) Reset 

func (m *RaftMessage) Reset()

func (*RaftMessage) String 

func (m *RaftMessage) String() string

type RaftMessageResponse 

type RaftMessageResponse struct {
	Response []*RaftGroupMessageResponse `protobuf:"bytes,1,rep,name=response" json:"response,omitempty"`
}

func (*RaftMessageResponse) Descriptor 

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

func (*RaftMessageResponse) GetResponse 

func (m *RaftMessageResponse) GetResponse() []*RaftGroupMessageResponse

func (*RaftMessageResponse) ProtoMessage 

func (*RaftMessageResponse) ProtoMessage()

func (*RaftMessageResponse) Reset 

func (m *RaftMessageResponse) Reset()

func (*RaftMessageResponse) String 

func (m *RaftMessageResponse) String() string

type RaftServer 

type RaftServer interface {
	// add raft group
	AddGroup(context.Context, *RaftAddGroup) (*RaftAddGroupResp, error)
	// process raft messages
	Message(context.Context, *RaftMessage) (*RaftMessageResponse, error)
}

type Result 

type Result struct {
	Code    ResultCode `protobuf:"varint,1,opt,name=code,enum=pb.ResultCode" json:"code,omitempty"`
	Message string     `protobuf:"bytes,2,opt,name=Message" json:"Message,omitempty"`
}

func (*Result) Descriptor 

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

func (*Result) GetCode 

func (m *Result) GetCode() ResultCode

func (*Result) GetMessage 

func (m *Result) GetMessage() string

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) Reset 

func (m *Result) Reset()

func (*Result) String 

func (m *Result) String() string

type ResultCode 

type ResultCode int32
const (
	ResultCode_ResultCodeOK                   ResultCode = 0
	ResultCode_ResultCodeUnknown              ResultCode = 1
	ResultCode_ResultCodeInternal             ResultCode = 2
	ResultCode_ResultCodeRaftDuplicateGroupID ResultCode = 100001
)

func (ResultCode) EnumDescriptor 

func (ResultCode) EnumDescriptor() ([]byte, []int)

func (ResultCode) String 

func (x ResultCode) String() string

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.