forwarder

Documentation

Index

• type Forwarder
  • func NewForwarder(identities flow.IdentityList, timeout time.Duration, maxMsgSize uint) (*Forwarder, error)
  • func (f *Forwarder) FaultTolerantClient() (access.AccessAPIClient, error)

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, timeout time.Duration, maxMsgSize uint) (*Forwarder, error)

func (*Forwarder) FaultTolerantClient

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

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