layer

Documentation

Index

• Variables
• func NewGossipLayer(name string, logger *zap.Logger, userConfig config.Config, meta pb.NodeMeta) *layer
• func NewRaftLayer(logger *zap.Logger, userConfig config.Config, discovery DiscoveryProvider) (*raftlayer, error)
• func SyncToken(members []*pb.NodeService) string
• type DiscoveryProvider

Variables

var (
	ErrBootstrappedNodeFound = errors.New("bootstrapped node found")
)

Functions

func NewGossipLayer

func NewGossipLayer(name string, logger *zap.Logger, userConfig config.Config, meta pb.NodeMeta) *layer

func NewRaftLayer

func NewRaftLayer(logger *zap.Logger, userConfig config.Config, discovery DiscoveryProvider) (*raftlayer, error)

func SyncToken

func SyncToken(members []*pb.NodeService) string

Types

type DiscoveryProvider

type DiscoveryProvider interface {
	DialAddress(service, id string, f func(*grpc.ClientConn) error) error
	Peers() peers.PeerStore
}