node

Documentation

Index

• type Config
• type NetworkType
  • func (i NetworkType) String() string
• type Node
  • func NewNode(config Config) (*Node, error)
• type Server
  • func (s *Server) AppendEntries(ctx context.Context, request *protos.AppendEntriesRequest) (*protos.AppendEntriesResponse, error)
  • func (s *Server) InstallSnapshot(ctx context.Context, request *protos.InstallSnapshotRequest) (*protos.InstallSnapshotResponse, error)
  • func (s *Server) RequestVote(ctx context.Context, request *protos.RequestVoteRequest) (*protos.RequestVoteResponse, error)
  • func (s *Server) TimeoutNow(ctx context.Context, request *protos.TimeoutNowRequest) (*protos.TimeoutNowResponse, error)
• type Transport
  • func (t Transport) AppendEntries(id raft.ServerID, target raft.ServerAddress, args *raft.AppendEntriesRequest, ...) error
  • func (t Transport) AppendEntriesPipeline(id raft.ServerID, target raft.ServerAddress) (raft.AppendPipeline, error)
  • func (t Transport) Consumer() <-chan raft.RPC
  • func (t Transport) DecodePeer(bytes []byte) raft.ServerAddress
  • func (t Transport) EncodePeer(id raft.ServerID, addr raft.ServerAddress) []byte
  • func (t Transport) InstallSnapshot(id raft.ServerID, target raft.ServerAddress, args *raft.InstallSnapshotRequest, ...) error
  • func (t Transport) LocalAddr() raft.ServerAddress
  • func (t Transport) RequestVote(id raft.ServerID, target raft.ServerAddress, args *raft.RequestVoteRequest, ...) error
  • func (t Transport) SetHeartbeatHandler(cb func(rpc raft.RPC))
  • func (t Transport) TimeoutNow(id raft.ServerID, target raft.ServerAddress, args *raft.TimeoutNowRequest, ...) error

Types

type Config

type Config struct {
	Peers             []string
	NetworkType       NetworkType
	ListenAddress     string
	ConnectionTimeout time.Duration
}

type NetworkType

type NetworkType uint8

const (
	Unknown NetworkType = iota
	Udp
	Tcp
	Unix
)

func (NetworkType) String

func (i NetworkType) String() string

type Node

type Node struct {
	// contains filtered or unexported fields
}

func NewNode

func NewNode(config Config) (*Node, error)

type Server

type Server struct {
	// contains filtered or unexported fields
}

func (*Server) AppendEntries

func (s *Server) AppendEntries(ctx context.Context, request *protos.AppendEntriesRequest) (*protos.AppendEntriesResponse, error)

func (*Server) InstallSnapshot

func (s *Server) InstallSnapshot(ctx context.Context, request *protos.InstallSnapshotRequest) (*protos.InstallSnapshotResponse, error)

func (*Server) RequestVote

func (s *Server) RequestVote(ctx context.Context, request *protos.RequestVoteRequest) (*protos.RequestVoteResponse, error)

func (*Server) TimeoutNow

func (s *Server) TimeoutNow(ctx context.Context, request *protos.TimeoutNowRequest) (*protos.TimeoutNowResponse, error)

type Transport

type Transport struct {
	// contains filtered or unexported fields
}

func (Transport) AppendEntries

func (t Transport) AppendEntries(id raft.ServerID, target raft.ServerAddress, args *raft.AppendEntriesRequest, resp *raft.AppendEntriesResponse) error

func (Transport) AppendEntriesPipeline

func (t Transport) AppendEntriesPipeline(id raft.ServerID, target raft.ServerAddress) (raft.AppendPipeline, error)

func (Transport) Consumer

func (t Transport) Consumer() <-chan raft.RPC

func (Transport) DecodePeer

func (t Transport) DecodePeer(bytes []byte) raft.ServerAddress

func (Transport) EncodePeer

func (t Transport) EncodePeer(id raft.ServerID, addr raft.ServerAddress) []byte

func (Transport) InstallSnapshot

func (t Transport) InstallSnapshot(id raft.ServerID, target raft.ServerAddress, args *raft.InstallSnapshotRequest, resp *raft.InstallSnapshotResponse, data io.Reader) error

func (Transport) LocalAddr

func (t Transport) LocalAddr() raft.ServerAddress

func (Transport) RequestVote

func (t Transport) RequestVote(id raft.ServerID, target raft.ServerAddress, args *raft.RequestVoteRequest, resp *raft.RequestVoteResponse) error

func (Transport) SetHeartbeatHandler

func (t Transport) SetHeartbeatHandler(cb func(rpc raft.RPC))

func (Transport) TimeoutNow

func (t Transport) TimeoutNow(id raft.ServerID, target raft.ServerAddress, args *raft.TimeoutNowRequest, resp *raft.TimeoutNowResponse) error