ping

package

v0.33.36-tx-error-mess... Latest Latest Go to latest Published: Oct 1, 2025 License: AGPL-3.0 Imports: 14 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/onflow/flow-go

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Engine
- func New(log zerolog.Logger, idProvider module.IdentityProvider, ...) (*Engine, error)
- func (e *Engine) Done() <-chan struct{}
- func (e *Engine) Ready() <-chan struct{}

Constants ¶

View Source

const PingInterval = time.Minute

View Source

const PingTimeout = time.Second * 4

PingTimeout is maximum time to wait for a ping reply from a remote node

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Engine ¶

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

func New ¶

func New(
	log zerolog.Logger,
	idProvider module.IdentityProvider,
	idTranslator p2p.IDTranslator,
	me module.Local,
	metrics module.PingMetrics,
	pingEnabled bool,
	nodeInfoFile string,
	pingService network.PingService,
) (*Engine, error)

func (*Engine) Done ¶

func (e *Engine) Done() <-chan struct{}

Done returns a done channel that is closed once the engine has fully stopped. For the ingestion engine, it only waits for all submit goroutines to end.

func (*Engine) Ready ¶

func (e *Engine) Ready() <-chan struct{}

Ready returns a ready channel that is closed once the engine has fully started. For the ingestion engine, we consider the engine up and running upon initialization.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL