endpointfinder

Documentation

Index

• Variables
• type EndpointFinder
  • func NewEndpointFinder(minerInfoFetcher MinerInfoFetcher, h host.Host, opts ...Option) *EndpointFinder
  • func (ef *EndpointFinder) FindHTTPEndpoints(ctx context.Context, sps []string) ([]peer.AddrInfo, error)
• type MinerInfoFetcher
• type Option
  • func WithErrorLruSize(size int) Option
  • func WithErrorLruTimeout(timeout time.Duration) Option
  • func WithLruSize(size int) Option
  • func WithLruTimeout(timeout time.Duration) Option

Variables

var ErrHTTPNotSupported = errors.New("provider does not support http")

ErrHTTPNotSupported indicates we were able to look up the provider and contact them, but they reported that they do not serve HTTP retrievals

Types

type EndpointFinder

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

EndpointFinder handles translating SP miner addresses to HTTP retrieval endpoints for those miners, use the chain and the SP retrieval transports protocol. It also caches records for performance

func NewEndpointFinder

func NewEndpointFinder(minerInfoFetcher MinerInfoFetcher, h host.Host, opts ...Option) *EndpointFinder

NewEndpointFinder returns a new instance of an EndpointFinder

func (*EndpointFinder) FindHTTPEndpoints

func (ef *EndpointFinder) FindHTTPEndpoints(ctx context.Context, sps []string) ([]peer.AddrInfo, error)

FindHTTPEndpoints finds http endpoints for a given set of providers

type MinerInfoFetcher

type MinerInfoFetcher interface {
	GetProviderInfo(ctx context.Context, provider string) (*replication.MinerInfo, error)
}

MinerInfoFetcher is an interface for looking up chain miner info from an SP name

type Option

type Option func(*config)

func WithErrorLruSize

func WithErrorLruSize(size int) Option

func WithErrorLruTimeout

func WithErrorLruTimeout(timeout time.Duration) Option

func WithLruSize

func WithLruSize(size int) Option

func WithLruTimeout

func WithLruTimeout(timeout time.Duration) Option