cluster

Documentation

Index

• type GossipConfig
• type NetworkConfig
  • func (n NetworkConfig) AdvertizedAddress() string
• type Node
  • func NewNode(config NodeConfig, ...) Node
• type NodeConfig
• type NodeRPCServer
• type RaftConfig

Types

type GossipConfig

type GossipConfig struct {
	JoinList []string
	Network  NetworkConfig
}

type NetworkConfig

type NetworkConfig struct {
	AdvertizedHost string
	AdvertizedPort int
	ListeningPort  int
}

func (NetworkConfig) AdvertizedAddress

func (n NetworkConfig) AdvertizedAddress() string

type Node

type Node interface {
	Run(context.Context)
	Shutdown() error
	Apply(context.Context, []byte) error
	Commits() <-chan raft.Commit
	Snapshotter() <-chan *snap.Snapshotter
	Ready() <-chan struct{}
	Call(id uint64, f func(*grpc.ClientConn) error) error
}

func NewNode

func NewNode(config NodeConfig, dialer func(address string, opts ...grpc.DialOption) (*grpc.ClientConn, error), server *grpc.Server, logger *zap.Logger) Node

type NodeConfig

type NodeConfig struct {
	ID               uint64
	ServiceName      string
	DataDirectory    string
	GossipConfig     GossipConfig
	RaftConfig       RaftConfig
	GetStateSnapshot func() ([]byte, error)
}

type NodeRPCServer

type NodeRPCServer struct {
}

type RaftConfig

type RaftConfig struct {
	ExpectedNodeCount         int
	AppliedIndex              uint64
	DisableProposalForwarding bool
	LeaderFunc                func(context.Context) error
	Network                   NetworkConfig
}