discovery

Documentation

Index

• type Discovery
  • func (c *Discovery) Join(ctx context.Context, in *pb.NodeRequest) (*pb.AckResponse, error)
  • func (c *Discovery) Leave(ctx context.Context, in *pb.NodeRequest) (*pb.AckResponse, error)
  • func (c *Discovery) Ping(ctx context.Context, in *pb.HealthCheckRequest) (*pb.HealthCheckResponse, error)
• type RaftServer
  • func (c *RaftServer) AppendEntries(ctx context.Context, in *pb.AppendEntriesRequest) (*pb.AppendEntriesResponse, error)
  • func (c *RaftServer) InstallSnapshot(ctx context.Context, in *pb.InstallSnapshotRequest) (*pb.InstallSnapshotResponse, error)
  • func (c *RaftServer) RequestVote(ctx context.Context, in *pb.RequestVoteRequest) (*pb.RequestVoteResponse, error)

Types

type Discovery

type Discovery struct {
}

func (*Discovery) Join

func (c *Discovery) Join(ctx context.Context, in *pb.NodeRequest) (*pb.AckResponse, error)

func (*Discovery) Leave

func (c *Discovery) Leave(ctx context.Context, in *pb.NodeRequest) (*pb.AckResponse, error)

func (*Discovery) Ping

func (c *Discovery) Ping(ctx context.Context, in *pb.HealthCheckRequest) (*pb.HealthCheckResponse, error)

type RaftServer

type RaftServer struct {
}

func (*RaftServer) AppendEntries

func (c *RaftServer) AppendEntries(ctx context.Context, in *pb.AppendEntriesRequest) (*pb.AppendEntriesResponse, error)

func (*RaftServer) InstallSnapshot

func (c *RaftServer) InstallSnapshot(ctx context.Context, in *pb.InstallSnapshotRequest) (*pb.InstallSnapshotResponse, error)

func (*RaftServer) RequestVote

func (c *RaftServer) RequestVote(ctx context.Context, in *pb.RequestVoteRequest) (*pb.RequestVoteResponse, error)