coord

Documentation

Overview

Package coord is a generated protocol buffer package.

It is generated from these files:

coord/proto/coord.proto

It has these top-level messages:

PeerInfo
PeerInfoList
RaftStep
ProcessRaftResponse

Index

• func RegisterCoordinateServer(s *grpc.Server, srv CoordinateServer)
• type CoordinateClient
  • func NewCoordinateClient(cc *grpc.ClientConn) CoordinateClient
• type CoordinateServer
• type Coordinate_EmitRaftStepClient
• type Coordinate_EmitRaftStepServer
• type PeerInfo
  • func (*PeerInfo) ProtoMessage()
  • func (m *PeerInfo) Reset()
  • func (m *PeerInfo) String() string
• type PeerInfoList
  • func (m *PeerInfoList) GetPeers() []*PeerInfo
  • func (*PeerInfoList) ProtoMessage()
  • func (m *PeerInfoList) Reset()
  • func (m *PeerInfoList) String() string
• type ProcessRaftResponse
  • func (*ProcessRaftResponse) ProtoMessage()
  • func (m *ProcessRaftResponse) Reset()
  • func (m *ProcessRaftResponse) String() string
• type RaftStep
  • func (*RaftStep) ProtoMessage()
  • func (m *RaftStep) Reset()
  • func (m *RaftStep) String() string

Functions

func RegisterCoordinateServer

func RegisterCoordinateServer(s *grpc.Server, srv CoordinateServer)

Types

type CoordinateClient

type CoordinateClient interface {
	// Process a raft step
	EmitRaftStep(ctx context.Context, opts ...grpc.CallOption) (Coordinate_EmitRaftStepClient, error)
	// Register into the cluster and get a list of peers
	Register(ctx context.Context, in *PeerInfo, opts ...grpc.CallOption) (*PeerInfoList, error)
}

func NewCoordinateClient

func NewCoordinateClient(cc *grpc.ClientConn) CoordinateClient

type CoordinateServer

type CoordinateServer interface {
	// Process a raft step
	EmitRaftStep(Coordinate_EmitRaftStepServer) error
	// Register into the cluster and get a list of peers
	Register(context.Context, *PeerInfo) (*PeerInfoList, error)
}

type Coordinate_EmitRaftStepClient

type Coordinate_EmitRaftStepClient interface {
	Send(*RaftStep) error
	Recv() (*RaftStep, error)
	grpc.ClientStream
}

type Coordinate_EmitRaftStepServer

type Coordinate_EmitRaftStepServer interface {
	Send(*RaftStep) error
	Recv() (*RaftStep, error)
	grpc.ServerStream
}

type PeerInfo

type PeerInfo struct {
	Id      uint64 `protobuf:"varint,1,opt" json:"Id,omitempty"`
	Address string `protobuf:"bytes,2,opt" json:"Address,omitempty"`
}

func (*PeerInfo) ProtoMessage

func (*PeerInfo) ProtoMessage()

func (*PeerInfo) Reset

func (m *PeerInfo) Reset()

func (*PeerInfo) String

func (m *PeerInfo) String() string

type PeerInfoList

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

func (*PeerInfoList) GetPeers

func (m *PeerInfoList) GetPeers() []*PeerInfo

func (*PeerInfoList) ProtoMessage

func (*PeerInfoList) ProtoMessage()

func (*PeerInfoList) Reset

func (m *PeerInfoList) Reset()

func (*PeerInfoList) String

func (m *PeerInfoList) String() string

type ProcessRaftResponse

type ProcessRaftResponse struct {
}

func (*ProcessRaftResponse) ProtoMessage

func (*ProcessRaftResponse) ProtoMessage()

func (*ProcessRaftResponse) Reset

func (m *ProcessRaftResponse) Reset()

func (*ProcessRaftResponse) String

func (m *ProcessRaftResponse) String() string

type RaftStep

type RaftStep struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

func (*RaftStep) ProtoMessage

func (*RaftStep) ProtoMessage()

func (*RaftStep) Reset

func (m *RaftStep) Reset()

func (*RaftStep) String

func (m *RaftStep) String() string