layer

Documentation

Index

• func NewGossipLayer(name string, logger *zap.Logger, userConfig config.Config, meta pb.NodeMeta) *layer
• func NewRaftLayer(logger *zap.Logger, userConfig config.Config, discovery DiscoveryProvider) (types.RaftServiceLayer, error)
• type DiscoveryProvider

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) (types.RaftServiceLayer, error)

Types

type DiscoveryProvider

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