forwarder

package
v0.33.25-fetch-collection Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 29, 2024 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Forwarder

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

Forwarder forwards all requests to a set of upstream access nodes or observers

func NewForwarder

func NewForwarder(identities flow.IdentityList, connectionFactory connection.ConnectionFactory) (*Forwarder, error)

func (*Forwarder) FaultTolerantClient

func (f *Forwarder) FaultTolerantClient() (access.AccessAPIClient, io.Closer, error)

FaultTolerantClient implements an upstream connection that reconnects on errors a reasonable amount of time.

type Upstream added in v0.33.1

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

Upstream is a container for an individual upstream containing the id, client and closer for it

Jump to

Keyboard shortcuts

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