dialer

package

v1.11.5-multi-arch Latest Latest Go to latest Published: Apr 10, 2024 License: BSD-3-Clause Imports: 8 Imported by: 19

Details

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

Repository

github.com/ava-labs/avalanchego

Links

Open Source Insights

Documentation ¶

Index ¶

type Config
type Dialer
- func NewDialer(network string, dialerConfig Config, log logging.Logger) Dialer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	ThrottleRps       uint32        `json:"throttleRps"`
	ConnectionTimeout time.Duration `json:"connectionTimeout"`
}

type Dialer ¶

type Dialer interface {
	// If [ctx] is canceled, gives up trying to connect to [ip]
	// and returns an error.
	Dial(ctx context.Context, ip ips.IPPort) (net.Conn, error)
}

Dialer attempts to create a connection with the provided IP/port pair

func NewDialer ¶

func NewDialer(network string, dialerConfig Config, log logging.Logger) Dialer

NewDialer returns a new Dialer that calls net.Dial with the provided network. [network] is the network passed into Dial. Should probably be "TCP". [dialerConfig.connectionTimeout] gives the timeout when dialing an IP. [dialerConfig.throttleRps] gives the max number of outgoing connection attempts/second. If [dialerConfig.throttleRps] == 0, outgoing connections aren't rate-limited.

Source Files ¶

View all Source files

dialer.go

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