cluster

Documentation

Index

• type GossipConfig
• type MultiNode
  • func NewMultiNode(config NodeConfig, ...) MultiNode
• 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 MultiNode

type MultiNode interface {
	Node(cluster string, config RaftConfig) Node
	Shutdown() error
}

func NewMultiNode

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

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)
	RunFromAppliedIndex(ctx context.Context, idx uint64)
	Shutdown() error
	Apply(context.Context, []byte) error
	Ready() <-chan struct{}
	Call(id uint64, f func(*grpc.ClientConn) error) error
	Index() uint64
}

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
}

type NodeRPCServer

type NodeRPCServer struct {
}

type RaftConfig

type RaftConfig struct {
	ExpectedNodeCount         int
	AppliedIndex              uint64
	DisableProposalForwarding bool
	LeaderFunc                func(context.Context) error
	Network                   NetworkConfig
	GetStateSnapshot          func() ([]byte, error)
	CommitApplier             raft.CommitApplier
	SnapshotApplier           raft.SnapshotApplier
}