pb

package
v0.0.0-...-5b1c8cb Latest Latest
Warning

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

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

Documentation

Overview

Package pb is a generated protocol buffer package.

It is generated from these files: 

pb/copycat.proto

It has these top-level messages: 

TestCat
Id128
RaftIdQueryRequest
RaftIdQueryResponse
DataStructureIdRequest
DataStructureIdResponse
RaftPeer
HostedItems
DataStructureMetadata
StepReq
StepResp
StartRaftRequest
StartRaftResponse
StopRaftRequest
StopRaftResponse
AddRaftRequest
AddRaftResponse

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCopycat = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCopycat   = fmt.Errorf("proto: integer overflow")
)
View Source 
var GossipQueryNames_name = map[int32]string{
	0: "RaftIdQuery",
	1: "DataStructureIdQuery",
}
View Source 
var GossipQueryNames_value = map[string]int32{
	"RaftIdQuery":          0,
	"DataStructureIdQuery": 1,
}

Functions

func RegisterCopyCatServiceServer 

func RegisterCopyCatServiceServer(s *grpc.Server, srv CopyCatServiceServer)

func RegisterRaftTransportServiceServer 

func RegisterRaftTransportServiceServer(s *grpc.Server, srv RaftTransportServiceServer)

Types

type AddRaftRequest 

type AddRaftRequest struct {
	NewRaftId      uint64 `protobuf:"varint,1,opt,name=NewRaftId,proto3" json:"NewRaftId,omitempty"`
	ExistingRaftId uint64 `protobuf:"varint,2,opt,name=ExistingRaftId,proto3" json:"ExistingRaftId,omitempty"`
}

func (*AddRaftRequest) Descriptor 

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

func (*AddRaftRequest) Marshal 

func (m *AddRaftRequest) Marshal() (dAtA []byte, err error)

func (*AddRaftRequest) MarshalTo 

func (m *AddRaftRequest) MarshalTo(dAtA []byte) (int, error)

func (*AddRaftRequest) ProtoMessage 

func (*AddRaftRequest) ProtoMessage()

func (*AddRaftRequest) Reset 

func (m *AddRaftRequest) Reset()

func (*AddRaftRequest) Size 

func (m *AddRaftRequest) Size() (n int)

func (*AddRaftRequest) String 

func (m *AddRaftRequest) String() string

func (*AddRaftRequest) Unmarshal 

func (m *AddRaftRequest) Unmarshal(dAtA []byte) error

type AddRaftResponse 

type AddRaftResponse struct {
}

func (*AddRaftResponse) Descriptor 

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

func (*AddRaftResponse) Marshal 

func (m *AddRaftResponse) Marshal() (dAtA []byte, err error)

func (*AddRaftResponse) MarshalTo 

func (m *AddRaftResponse) MarshalTo(dAtA []byte) (int, error)

func (*AddRaftResponse) ProtoMessage 

func (*AddRaftResponse) ProtoMessage()

func (*AddRaftResponse) Reset 

func (m *AddRaftResponse) Reset()

func (*AddRaftResponse) Size 

func (m *AddRaftResponse) Size() (n int)

func (*AddRaftResponse) String 

func (m *AddRaftResponse) String() string

func (*AddRaftResponse) Unmarshal 

func (m *AddRaftResponse) Unmarshal(dAtA []byte) error

type CopyCatServiceClient 

type CopyCatServiceClient interface {
	StartRaft(ctx context.Context, in *StartRaftRequest, opts ...grpc.CallOption) (*StartRaftResponse, error)
	StopRaft(ctx context.Context, in *StopRaftRequest, opts ...grpc.CallOption) (*StopRaftResponse, error)
	AddVoterToRaftGroup(ctx context.Context, in *AddRaftRequest, opts ...grpc.CallOption) (*AddRaftResponse, error)
	AddLearnerToRaftGroup(ctx context.Context, in *AddRaftRequest, opts ...grpc.CallOption) (*AddRaftResponse, error)
}

func NewCopyCatServiceClient 

func NewCopyCatServiceClient(cc *grpc.ClientConn) CopyCatServiceClient

type CopyCatServiceServer 

type CopyCatServiceServer interface {
	StartRaft(context.Context, *StartRaftRequest) (*StartRaftResponse, error)
	StopRaft(context.Context, *StopRaftRequest) (*StopRaftResponse, error)
	AddVoterToRaftGroup(context.Context, *AddRaftRequest) (*AddRaftResponse, error)
	AddLearnerToRaftGroup(context.Context, *AddRaftRequest) (*AddRaftResponse, error)
}

type DataStructureIdRequest 

type DataStructureIdRequest struct {
	DataStructureId *Id128 `protobuf:"bytes,1,opt,name=DataStructureId" json:"DataStructureId,omitempty"`
}

func (*DataStructureIdRequest) Descriptor 

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

func (*DataStructureIdRequest) Marshal 

func (m *DataStructureIdRequest) Marshal() (dAtA []byte, err error)

func (*DataStructureIdRequest) MarshalTo 

func (m *DataStructureIdRequest) MarshalTo(dAtA []byte) (int, error)

func (*DataStructureIdRequest) ProtoMessage 

func (*DataStructureIdRequest) ProtoMessage()

func (*DataStructureIdRequest) Reset 

func (m *DataStructureIdRequest) Reset()

func (*DataStructureIdRequest) Size 

func (m *DataStructureIdRequest) Size() (n int)

func (*DataStructureIdRequest) String 

func (m *DataStructureIdRequest) String() string

func (*DataStructureIdRequest) Unmarshal 

func (m *DataStructureIdRequest) Unmarshal(dAtA []byte) error

type DataStructureIdResponse 

type DataStructureIdResponse struct {
	Peers []*RaftPeer `protobuf:"bytes,1,rep,name=peers" json:"peers,omitempty"`
}

func (*DataStructureIdResponse) Descriptor 

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

func (*DataStructureIdResponse) Marshal 

func (m *DataStructureIdResponse) Marshal() (dAtA []byte, err error)

func (*DataStructureIdResponse) MarshalTo 

func (m *DataStructureIdResponse) MarshalTo(dAtA []byte) (int, error)

func (*DataStructureIdResponse) ProtoMessage 

func (*DataStructureIdResponse) ProtoMessage()

func (*DataStructureIdResponse) Reset 

func (m *DataStructureIdResponse) Reset()

func (*DataStructureIdResponse) Size 

func (m *DataStructureIdResponse) Size() (n int)

func (*DataStructureIdResponse) String 

func (m *DataStructureIdResponse) String() string

func (*DataStructureIdResponse) Unmarshal 

func (m *DataStructureIdResponse) Unmarshal(dAtA []byte) error

type DataStructureMetadata 

type DataStructureMetadata struct {
	RaftId      uint64 `protobuf:"varint,1,opt,name=RaftId,proto3" json:"RaftId,omitempty"`
	NumReplicas int32  `protobuf:"varint,2,opt,name=NumReplicas,proto3" json:"NumReplicas,omitempty"`
}

func (*DataStructureMetadata) Descriptor 

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

func (*DataStructureMetadata) Marshal 

func (m *DataStructureMetadata) Marshal() (dAtA []byte, err error)

func (*DataStructureMetadata) MarshalTo 

func (m *DataStructureMetadata) MarshalTo(dAtA []byte) (int, error)

func (*DataStructureMetadata) ProtoMessage 

func (*DataStructureMetadata) ProtoMessage()

func (*DataStructureMetadata) Reset 

func (m *DataStructureMetadata) Reset()

func (*DataStructureMetadata) Size 

func (m *DataStructureMetadata) Size() (n int)

func (*DataStructureMetadata) String 

func (m *DataStructureMetadata) String() string

func (*DataStructureMetadata) Unmarshal 

func (m *DataStructureMetadata) Unmarshal(dAtA []byte) error

type GossipQueryNames 

type GossipQueryNames int32
const (
	RaftIdQuery          GossipQueryNames = 0
	DataStructureIdQuery GossipQueryNames = 1
)

func (GossipQueryNames) EnumDescriptor 

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

func (GossipQueryNames) String 

func (x GossipQueryNames) String() string

type HostedItems 

type HostedItems struct {
	DataStructureIdToMetadata map[string]*DataStructureMetadata `` /* 177-byte string literal not displayed */
}

func (*HostedItems) Descriptor 

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

func (*HostedItems) Marshal 

func (m *HostedItems) Marshal() (dAtA []byte, err error)

func (*HostedItems) MarshalTo 

func (m *HostedItems) MarshalTo(dAtA []byte) (int, error)

func (*HostedItems) ProtoMessage 

func (*HostedItems) ProtoMessage()

func (*HostedItems) Reset 

func (m *HostedItems) Reset()

func (*HostedItems) Size 

func (m *HostedItems) Size() (n int)

func (*HostedItems) String 

func (m *HostedItems) String() string

func (*HostedItems) Unmarshal 

func (m *HostedItems) Unmarshal(dAtA []byte) error

type Id128 

type Id128 struct {
	Upper uint64 `protobuf:"varint,1,opt,name=Upper,proto3" json:"Upper,omitempty"`
	Lower uint64 `protobuf:"varint,2,opt,name=Lower,proto3" json:"Lower,omitempty"`
}

func (*Id128) Descriptor 

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

func (*Id128) Marshal 

func (m *Id128) Marshal() (dAtA []byte, err error)

func (*Id128) MarshalTo 

func (m *Id128) MarshalTo(dAtA []byte) (int, error)

func (*Id128) ProtoMessage 

func (*Id128) ProtoMessage()

func (*Id128) Reset 

func (m *Id128) Reset()

func (*Id128) Size 

func (m *Id128) Size() (n int)

func (*Id128) String 

func (m *Id128) String() string

func (*Id128) Unmarshal 

func (m *Id128) Unmarshal(dAtA []byte) error

type RaftIdQueryRequest 

type RaftIdQueryRequest struct {
	RaftId uint64 `protobuf:"varint,1,opt,name=RaftId,proto3" json:"RaftId,omitempty"`
}

func (*RaftIdQueryRequest) Descriptor 

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

func (*RaftIdQueryRequest) Marshal 

func (m *RaftIdQueryRequest) Marshal() (dAtA []byte, err error)

func (*RaftIdQueryRequest) MarshalTo 

func (m *RaftIdQueryRequest) MarshalTo(dAtA []byte) (int, error)

func (*RaftIdQueryRequest) ProtoMessage 

func (*RaftIdQueryRequest) ProtoMessage()

func (*RaftIdQueryRequest) Reset 

func (m *RaftIdQueryRequest) Reset()

func (*RaftIdQueryRequest) Size 

func (m *RaftIdQueryRequest) Size() (n int)

func (*RaftIdQueryRequest) String 

func (m *RaftIdQueryRequest) String() string

func (*RaftIdQueryRequest) Unmarshal 

func (m *RaftIdQueryRequest) Unmarshal(dAtA []byte) error

type RaftIdQueryResponse 

type RaftIdQueryResponse struct {
	Peer *RaftPeer `protobuf:"bytes,1,opt,name=peer" json:"peer,omitempty"`
}

func (*RaftIdQueryResponse) Descriptor 

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

func (*RaftIdQueryResponse) Marshal 

func (m *RaftIdQueryResponse) Marshal() (dAtA []byte, err error)

func (*RaftIdQueryResponse) MarshalTo 

func (m *RaftIdQueryResponse) MarshalTo(dAtA []byte) (int, error)

func (*RaftIdQueryResponse) ProtoMessage 

func (*RaftIdQueryResponse) ProtoMessage()

func (*RaftIdQueryResponse) Reset 

func (m *RaftIdQueryResponse) Reset()

func (*RaftIdQueryResponse) Size 

func (m *RaftIdQueryResponse) Size() (n int)

func (*RaftIdQueryResponse) String 

func (m *RaftIdQueryResponse) String() string

func (*RaftIdQueryResponse) Unmarshal 

func (m *RaftIdQueryResponse) Unmarshal(dAtA []byte) error

type RaftPeer 

type RaftPeer struct {
	RaftId      uint64 `protobuf:"varint,1,opt,name=RaftId,proto3" json:"RaftId,omitempty"`
	PeerAddress string `protobuf:"bytes,2,opt,name=PeerAddress,proto3" json:"PeerAddress,omitempty"`
}

func (*RaftPeer) Descriptor 

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

func (*RaftPeer) Marshal 

func (m *RaftPeer) Marshal() (dAtA []byte, err error)

func (*RaftPeer) MarshalTo 

func (m *RaftPeer) MarshalTo(dAtA []byte) (int, error)

func (*RaftPeer) ProtoMessage 

func (*RaftPeer) ProtoMessage()

func (*RaftPeer) Reset 

func (m *RaftPeer) Reset()

func (*RaftPeer) Size 

func (m *RaftPeer) Size() (n int)

func (*RaftPeer) String 

func (m *RaftPeer) String() string

func (*RaftPeer) Unmarshal 

func (m *RaftPeer) Unmarshal(dAtA []byte) error

type RaftTransportServiceClient 

type RaftTransportServiceClient interface {
	Step(ctx context.Context, opts ...grpc.CallOption) (RaftTransportService_StepClient, error)
}

func NewRaftTransportServiceClient 

func NewRaftTransportServiceClient(cc *grpc.ClientConn) RaftTransportServiceClient

type RaftTransportServiceServer 

type RaftTransportServiceServer interface {
	Step(RaftTransportService_StepServer) error
}

type RaftTransportService_StepClient 

type RaftTransportService_StepClient interface {
	Send(*StepReq) error
	Recv() (*StepResp, error)
	grpc.ClientStream
}

type RaftTransportService_StepServer 

type RaftTransportService_StepServer interface {
	Send(*StepResp) error
	Recv() (*StepReq, error)
	grpc.ServerStream
}

type StartRaftRequest 

type StartRaftRequest struct {
	DataStructureId *Id128      `protobuf:"bytes,1,opt,name=DataStructureId" json:"DataStructureId,omitempty"`
	RaftIdToUse     uint64      `protobuf:"varint,2,opt,name=RaftIdToUse,proto3" json:"RaftIdToUse,omitempty"`
	AllRaftPeers    []*RaftPeer `protobuf:"bytes,3,rep,name=AllRaftPeers" json:"AllRaftPeers,omitempty"`
}

func (*StartRaftRequest) Descriptor 

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

func (*StartRaftRequest) Marshal 

func (m *StartRaftRequest) Marshal() (dAtA []byte, err error)

func (*StartRaftRequest) MarshalTo 

func (m *StartRaftRequest) MarshalTo(dAtA []byte) (int, error)

func (*StartRaftRequest) ProtoMessage 

func (*StartRaftRequest) ProtoMessage()

func (*StartRaftRequest) Reset 

func (m *StartRaftRequest) Reset()

func (*StartRaftRequest) Size 

func (m *StartRaftRequest) Size() (n int)

func (*StartRaftRequest) String 

func (m *StartRaftRequest) String() string

func (*StartRaftRequest) Unmarshal 

func (m *StartRaftRequest) Unmarshal(dAtA []byte) error

type StartRaftResponse 

type StartRaftResponse struct {
	RaftId      uint64 `protobuf:"varint,1,opt,name=RaftId,proto3" json:"RaftId,omitempty"`
	RaftAddress string `protobuf:"bytes,2,opt,name=RaftAddress,proto3" json:"RaftAddress,omitempty"`
}

func (*StartRaftResponse) Descriptor 

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

func (*StartRaftResponse) Marshal 

func (m *StartRaftResponse) Marshal() (dAtA []byte, err error)

func (*StartRaftResponse) MarshalTo 

func (m *StartRaftResponse) MarshalTo(dAtA []byte) (int, error)

func (*StartRaftResponse) ProtoMessage 

func (*StartRaftResponse) ProtoMessage()

func (*StartRaftResponse) Reset 

func (m *StartRaftResponse) Reset()

func (*StartRaftResponse) Size 

func (m *StartRaftResponse) Size() (n int)

func (*StartRaftResponse) String 

func (m *StartRaftResponse) String() string

func (*StartRaftResponse) Unmarshal 

func (m *StartRaftResponse) Unmarshal(dAtA []byte) error

type StepReq 

type StepReq struct {
	Message *raftpb.Message `protobuf:"bytes,1,opt,name=Message" json:"Message,omitempty"`
}

func (*StepReq) Descriptor 

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

func (*StepReq) Marshal 

func (m *StepReq) Marshal() (dAtA []byte, err error)

func (*StepReq) MarshalTo 

func (m *StepReq) MarshalTo(dAtA []byte) (int, error)

func (*StepReq) ProtoMessage 

func (*StepReq) ProtoMessage()

func (*StepReq) Reset 

func (m *StepReq) Reset()

func (*StepReq) Size 

func (m *StepReq) Size() (n int)

func (*StepReq) String 

func (m *StepReq) String() string

func (*StepReq) Unmarshal 

func (m *StepReq) Unmarshal(dAtA []byte) error

type StepResp 

type StepResp struct {
	Error string `protobuf:"bytes,1,opt,name=Error,proto3" json:"Error,omitempty"`
}

func (*StepResp) Descriptor 

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

func (*StepResp) Marshal 

func (m *StepResp) Marshal() (dAtA []byte, err error)

func (*StepResp) MarshalTo 

func (m *StepResp) MarshalTo(dAtA []byte) (int, error)

func (*StepResp) ProtoMessage 

func (*StepResp) ProtoMessage()

func (*StepResp) Reset 

func (m *StepResp) Reset()

func (*StepResp) Size 

func (m *StepResp) Size() (n int)

func (*StepResp) String 

func (m *StepResp) String() string

func (*StepResp) Unmarshal 

func (m *StepResp) Unmarshal(dAtA []byte) error

type StopRaftRequest 

type StopRaftRequest struct {
	RaftId uint64 `protobuf:"varint,1,opt,name=RaftId,proto3" json:"RaftId,omitempty"`
}

func (*StopRaftRequest) Descriptor 

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

func (*StopRaftRequest) Marshal 

func (m *StopRaftRequest) Marshal() (dAtA []byte, err error)

func (*StopRaftRequest) MarshalTo 

func (m *StopRaftRequest) MarshalTo(dAtA []byte) (int, error)

func (*StopRaftRequest) ProtoMessage 

func (*StopRaftRequest) ProtoMessage()

func (*StopRaftRequest) Reset 

func (m *StopRaftRequest) Reset()

func (*StopRaftRequest) Size 

func (m *StopRaftRequest) Size() (n int)

func (*StopRaftRequest) String 

func (m *StopRaftRequest) String() string

func (*StopRaftRequest) Unmarshal 

func (m *StopRaftRequest) Unmarshal(dAtA []byte) error

type StopRaftResponse 

type StopRaftResponse struct {
}

func (*StopRaftResponse) Descriptor 

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

func (*StopRaftResponse) Marshal 

func (m *StopRaftResponse) Marshal() (dAtA []byte, err error)

func (*StopRaftResponse) MarshalTo 

func (m *StopRaftResponse) MarshalTo(dAtA []byte) (int, error)

func (*StopRaftResponse) ProtoMessage 

func (*StopRaftResponse) ProtoMessage()

func (*StopRaftResponse) Reset 

func (m *StopRaftResponse) Reset()

func (*StopRaftResponse) Size 

func (m *StopRaftResponse) Size() (n int)

func (*StopRaftResponse) String 

func (m *StopRaftResponse) String() string

func (*StopRaftResponse) Unmarshal 

func (m *StopRaftResponse) Unmarshal(dAtA []byte) error

type TestCat 

type TestCat struct {
	M map[string]string `` /* 136-byte string literal not displayed */
}

func (*TestCat) Descriptor 

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

func (*TestCat) Marshal 

func (m *TestCat) Marshal() (dAtA []byte, err error)

func (*TestCat) MarshalTo 

func (m *TestCat) MarshalTo(dAtA []byte) (int, error)

func (*TestCat) ProtoMessage 

func (*TestCat) ProtoMessage()

func (*TestCat) Reset 

func (m *TestCat) Reset()

func (*TestCat) Size 

func (m *TestCat) Size() (n int)

func (*TestCat) String 

func (m *TestCat) String() string

func (*TestCat) Unmarshal 

func (m *TestCat) Unmarshal(dAtA []byte) 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.