bootstrap

Documentation

Index

• Variables
• type AlertsMonitor
• type BootstrapClient
• type Broadcaster
• type Client
  • func NewClient(logger *zap.SugaredLogger, net Network) Client
  • func (c Client) GetConfiguration(ctx context.Context, nodes []*types.Node) (*types.Configuration, error)
  • func (c Client) Join(ctx context.Context, instanceID uint64, node, peer *types.Node) error
• type Network
• type Service
  • func New(logger *zap.SugaredLogger, nodeID uint64, ...) Service
  • func (s Service) Configuration() *types.Configuration
  • func (s Service) Join(ctx context.Context, instanceID uint64, node *types.Node) error

Variables

var (
	ErrOldConfiguration = errors.New("configuration is outdated")
	ErrNoConfiguraton   = errors.New("can't fetch configuration")
)

Types

type AlertsMonitor

type AlertsMonitor interface {
	Observe(context.Context, []*types.Message) error
}

type BootstrapClient

type BootstrapClient interface {
	Configuration(context.Context) (*types.Configuration, error)
	Join(context.Context, uint64, *types.Node) error
}

type Broadcaster

type Broadcaster interface {
	Send(context.Context, []*types.Message) error
}

type Client

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

func NewClient

func NewClient(logger *zap.SugaredLogger, net Network) Client

func (Client) GetConfiguration

func (c Client) GetConfiguration(ctx context.Context, nodes []*types.Node) (*types.Configuration, error)

func (Client) Join

func (c Client) Join(ctx context.Context, instanceID uint64, node, peer *types.Node) error

type Network

type Network interface {
	RegisterBootstrap(Service)
	BootstrapClient(context.Context, *types.Node) (BootstrapClient, error)
}

type Service

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

func New

func New(logger *zap.SugaredLogger,
	nodeID uint64,
	configuration *types.LastConfiguration,
	net Network,
	am AlertsMonitor,
	bf Broadcaster,
) Service

func (Service) Configuration

func (s Service) Configuration() *types.Configuration

func (Service) Join

func (s Service) Join(ctx context.Context, instanceID uint64, node *types.Node) error