Versions in this module Expand all Collapse all v0 v0.2.0 Mar 13, 2019 v0.1.0 Jul 23, 2018 Changes in this version + var ErrInvalidOperation = errors.New("invalid operation") + var ErrInvalidProtectionMode = errors.New("invalid protection mode") + var ErrUnknownNode = errors.New("unknown node: no addresses available") + var Participants = &view.View + var PrivateCoordinatedConfigPID = protocol.ID("/indigo/node/bootstrap/private/coordinated/config/v1.0.0") + var PrivateCoordinatedProposePID = protocol.ID("/indigo/node/bootstrap/private/coordinated/propose/v1.0.0") + var PrivateCoordinatorHandshakePID = protocol.ID("/indigo/node/bootstrap/private/coordinator/handshake/v1.0.0") + var PrivateCoordinatorProposePID = protocol.ID("/indigo/node/bootstrap/private/coordinator/propose/v1.0.0") + var PrivateCoordinatorVotePID = protocol.ID("/indigo/node/bootstrap/private/coordinator/vote/v1.0.0") + func Disconnect(ctx context.Context, host ihost.Host, peerID peer.ID) + func DisconnectUnauthorized(ctx context.Context, host ihost.Host, networkConfig protector.NetworkConfig) + type CoordinatedHandler struct + func (h *CoordinatedHandler) Accept(ctx context.Context, peerID peer.ID) error + func (h *CoordinatedHandler) AddNode(ctx context.Context, peerID peer.ID, addr multiaddr.Multiaddr, info []byte) error + func (h *CoordinatedHandler) Close(ctx context.Context) + func (h *CoordinatedHandler) CompleteBootstrap(context.Context) error + func (h *CoordinatedHandler) HandleConfigUpdate(ctx context.Context, span *monitoring.Span, stream inet.Stream, ...) error + func (h *CoordinatedHandler) HandlePropose(ctx context.Context, span *monitoring.Span, stream inet.Stream, ...) error + func (h *CoordinatedHandler) Handshake(ctx context.Context) error + func (h *CoordinatedHandler) Reject(ctx context.Context, peerID peer.ID) error + func (h *CoordinatedHandler) RemoveNode(ctx context.Context, peerID peer.ID) error + type CoordinatorHandler struct + func (h *CoordinatorHandler) Accept(ctx context.Context, peerID peer.ID) error + func (h *CoordinatorHandler) AddNode(ctx context.Context, peerID peer.ID, addr multiaddr.Multiaddr, info []byte) error + func (h *CoordinatorHandler) Close(ctx context.Context) + func (h *CoordinatorHandler) CompleteBootstrap(ctx context.Context) error + func (h *CoordinatorHandler) HandleHandshake(ctx context.Context, span *monitoring.Span, stream inet.Stream, ...) error + func (h *CoordinatorHandler) HandlePropose(ctx context.Context, span *monitoring.Span, stream inet.Stream, ...) error + func (h *CoordinatorHandler) HandleVote(ctx context.Context, span *monitoring.Span, stream inet.Stream, ...) error + func (h *CoordinatorHandler) Handshake(ctx context.Context) error + func (h *CoordinatorHandler) Reject(ctx context.Context, peerID peer.ID) error + func (h *CoordinatorHandler) RemoveNode(ctx context.Context, peerID peer.ID) error + func (h *CoordinatorHandler) SendNetworkConfig(ctx context.Context) + func (h *CoordinatorHandler) SendProposal(ctx context.Context, req *proposal.Request) + func (h *CoordinatorHandler) ValidateSender(ctx context.Context, peerID peer.ID) error + type Handler interface + Accept func(context.Context, peer.ID) error + AddNode func(context.Context, peer.ID, multiaddr.Multiaddr, []byte) error + Close func(context.Context) + CompleteBootstrap func(context.Context) error + Handshake func(context.Context) error + Reject func(context.Context, peer.ID) error + RemoveNode func(context.Context, peer.ID) error + func New(host ihost.Host, streamProvider streamutil.Provider, ...) (Handler, error) + func NewCoordinatedHandler(host ihost.Host, streamProvider streamutil.Provider, ...) Handler + func NewCoordinatorHandler(host ihost.Host, streamProvider streamutil.Provider, ...) Handler + type PublicNetworkHandler struct + func (h *PublicNetworkHandler) Accept(context.Context, peer.ID) error + func (h *PublicNetworkHandler) AddNode(context.Context, peer.ID, multiaddr.Multiaddr, []byte) error + func (h *PublicNetworkHandler) Close(context.Context) + func (h *PublicNetworkHandler) CompleteBootstrap(context.Context) error + func (h *PublicNetworkHandler) Handshake(context.Context) error + func (h *PublicNetworkHandler) Reject(context.Context, peer.ID) error + func (h *PublicNetworkHandler) RemoveNode(context.Context, peer.ID) error
Go to main page