coord

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

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 interface {
	Send(*RaftStep) error
	Recv() (*RaftStep, error)
	grpc.ClientStream
}

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

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

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

type ProcessRaftResponse struct {
}

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