client

Documentation

Index

• type Client
  • func New(baseURL string, options ...Option) (*Client, error)
  • func (c *Client) Find(ctx context.Context, m multihash.Multihash) (*model.FindResponse, error)
  • func (c *Client) FindBatch(ctx context.Context, mhs []multihash.Multihash) (*model.FindResponse, error)
  • func (c *Client) GetProvider(ctx context.Context, providerID peer.ID) (*model.ProviderInfo, error)
  • func (c *Client) GetStats(ctx context.Context) (*model.Stats, error)
  • func (c *Client) ListProviders(ctx context.Context) ([]*model.ProviderInfo, error)
• type DHStoreAPI
• type DHashClient
  • func NewDHashClient(stiURL string, options ...Option) (*DHashClient, error)
  • func (c *DHashClient) Find(ctx context.Context, mh multihash.Multihash) (*model.FindResponse, error)
  • func (c *DHashClient) FindAsync(ctx context.Context, mh multihash.Multihash, ...) error
• type Interface
• type Option
  • func WithClient(c *http.Client) Option
  • func WithDHStoreAPI(dhsAPI DHStoreAPI) Option
  • func WithDHStoreURL(u string) Option
  • func WithPcacheTTL(ttl time.Duration) Option

Types

type Client

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

Client is an http client for the indexer find API

func New

func New(baseURL string, options ...Option) (*Client, error)

New creates a new find HTTP client.

func (*Client) Find

func (c *Client) Find(ctx context.Context, m multihash.Multihash) (*model.FindResponse, error)

Find looks up content entries by multihash.

func (*Client) FindBatch

func (c *Client) FindBatch(ctx context.Context, mhs []multihash.Multihash) (*model.FindResponse, error)

FindBatch looks up content entries for a batch of multihashes

func (*Client) GetProvider

func (c *Client) GetProvider(ctx context.Context, providerID peer.ID) (*model.ProviderInfo, error)

func (*Client) GetStats

func (c *Client) GetStats(ctx context.Context) (*model.Stats, error)

func (*Client) ListProviders

func (c *Client) ListProviders(ctx context.Context) ([]*model.ProviderInfo, error)

type DHStoreAPI

type DHStoreAPI interface {
	// FindMultihash does a dh-multihash lookup and returns a
	// model.FindResponse with EncryptedMultihashResults.
	FindMultihash(context.Context, multihash.Multihash) ([]model.EncryptedMultihashResult, error)
	// FindMetadata takes a value-key-hash, does a metadata lookup, and returns
	// encrypted metadata.
	FindMetadata(context.Context, []byte) ([]byte, error)
}

DHStoreAPI defines multihash and metadata find functions. The default implementation defines functions to do this over HTTP. A replacement implementation that implements the interface can optionally be provided when creating a DHashClient.

type DHashClient

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

DHashClient is a client that does double-hashed lookups on a dhstore. By default, it does multihash and metadata lookups over HTTP. If given a DHStoreAPI, it can do the lookups any the underlying implementation defined.

func NewDHashClient

func NewDHashClient(stiURL string, options ...Option) (*DHashClient, error)

NewDHashClient instantiates a new client that uses Reader Privacy API for querying data. It requires more roundtrips to fulfill one query however it also protects the user from a passive observer. dhstoreURL specifies the URL of the double hashed store that can respond to find encrypted multihash and find encrypted metadata requests.

func (*DHashClient) Find

func (c *DHashClient) Find(ctx context.Context, mh multihash.Multihash) (*model.FindResponse, error)

Find launches FindAsync in a separate go routine and assembles the result into FindResponse as if it was a synchronous invocation.

func (*DHashClient) FindAsync

func (c *DHashClient) FindAsync(ctx context.Context, mh multihash.Multihash, resChan chan<- model.ProviderResult) error

FindAsync implements double hashed lookup workflow. FindAsync returns results on resChan until there are no more results or error. When finished, resChan is closed and the error or nil is returned.

type Interface

type Interface interface {
	// Find queries for provider content records for a single multihash.
	Find(context.Context, multihash.Multihash) (*model.FindResponse, error)
	// FindBatch queries for provider content records for a batch of multihashes.
	FindBatch(context.Context, []multihash.Multihash) (*model.FindResponse, error)

	// GetProvider gets information about the provider identified by peer.ID.
	GetProvider(context.Context, peer.ID) (*model.ProviderInfo, error)
	// ListPrividers gets information about all providers known to the indexer.
	ListProviders(ctx context.Context) ([]*model.ProviderInfo, error)

	// GetStats get statistics for indexer.
	GetStats(context.Context) (*model.Stats, error)
}

Interface is the interface implemented by all find clients.

type Option

type Option func(*config) error

Option is a function that sets a value in a config.

func WithClient

func WithClient(c *http.Client) Option

WithClient allows creation of the http client using an underlying network round tripper / client.

func WithDHStoreAPI

func WithDHStoreAPI(dhsAPI DHStoreAPI) Option

WithDHStoreAPI configures an interface to use for doing multihash and metadata lookups with dhstore. If this is not configured, then dhstore lookups are done using the dhstoreURL.

func WithDHStoreURL

func WithDHStoreURL(u string) Option

WithDHStoreURL allows specifying different URLs for dhstore (/multihash and /metadata endpoints) and storetheindex (/providers endpoint). This might be useful as dhstore and storetheindex are different services that might not necessarily be behind the same URL. However the data from both of them is required to assemble results.

func WithPcacheTTL

func WithPcacheTTL(ttl time.Duration) Option

WithPcacheTTL sets the providers-cache entry time-to-live duration.