forwarder

Documentation

Index

• type Forwarder
  • func NewForwarder(identities flow.IdentityList, connectionFactory connection.ConnectionFactory) (*Forwarder, error)
  • func (f *Forwarder) FaultTolerantClient() (access.AccessAPIClient, io.Closer, error)
• type Upstream

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

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

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