commons

Documentation

Index

• func WaitForMinPeers(ctx WaitMinPeersCtx, validatorPk []byte, min int, start, limit time.Duration, ...) error
• type WaitMinPeersCtx

Functions

func WaitForMinPeers

func WaitForMinPeers(ctx WaitMinPeersCtx, validatorPk []byte, min int, start, limit time.Duration, stopAtLimit bool) error

WaitForMinPeers waits until min peers joined the validator's topic

Types

type WaitMinPeersCtx

type WaitMinPeersCtx struct {
	Ctx    context.Context
	Logger *zap.Logger
	Net    network.Network
}

WaitMinPeersCtx represents the context needed for WaitForMinPeers