indexerlookup

Documentation

Index

• type IndexerCandidateSource
  • func NewCandidateSource(o ...Option) (*IndexerCandidateSource, error)
  • func (idxf *IndexerCandidateSource) FindCandidates(ctx context.Context, c cid.Cid, cb func(types.RetrievalCandidate)) error
• type Option
  • func WithAsyncResultsChanBuffer(i int) Option
  • func WithHttpClient(c *http.Client) Option
  • func WithHttpClientTimeout(t time.Duration) Option
  • func WithHttpEndpoint(e *url.URL) Option
  • func WithHttpUserAgent(a string) Option
  • func WithIpfsDhtCascade(b bool) Option
  • func WithLegacyCascade(b bool) Option

Types

type IndexerCandidateSource

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

func NewCandidateSource

func NewCandidateSource(o ...Option) (*IndexerCandidateSource, error)

func (*IndexerCandidateSource) FindCandidates

func (idxf *IndexerCandidateSource) FindCandidates(ctx context.Context, c cid.Cid, cb func(types.RetrievalCandidate)) error

type Option

type Option func(*options) error

func WithAsyncResultsChanBuffer

func WithAsyncResultsChanBuffer(i int) Option

WithAsyncResultsChanBuffer sets the channel buffer returned by IndexerCandidateSource.FindCandidates. Defaults to 1 if unspecified.

func WithHttpClient

func WithHttpClient(c *http.Client) Option

WithHttpClient sets the http.Client used to contact the indexer. Defaults to http.DefaultClient if unspecified.

func WithHttpClientTimeout

func WithHttpClientTimeout(t time.Duration) Option

WithHttpClientTimeout sets the timeout for the HTTP requests sent to the indexer. Defaults to one minute if unspecified.

func WithHttpEndpoint

func WithHttpEndpoint(e *url.URL) Option

WithHttpEndpoint sets the indexer HTTP API endpoint. Defaults to https://cid.contact if unspecified.

func WithHttpUserAgent

func WithHttpUserAgent(a string) Option

WithHttpUserAgent sets the User-Agent header value when contacting the indexer HTTP API. Setting this option to empty string will disable inclusion of User-Agent header. Defaults to "lassie" if unspecified.

func WithIpfsDhtCascade

func WithIpfsDhtCascade(b bool) Option

WithIpfsDhtCascade sets weather to cascade lookups onto the IPFS DHT. Enabled by default if unspecified.

func WithLegacyCascade

func WithLegacyCascade(b bool) Option

WithLegacyCascade sets weather to cascade finds legacy providers connecting only over bitswap Enabled by default if unspecified.