Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewContentRoutingClient ¶
func NewContentRoutingClient(c Client, opts ...option) *contentRouter
func WithMaxProvideBatchSize ¶
func WithMaxProvideBatchSize(max int) option
func WithMaxProvideConcurrency ¶
func WithMaxProvideConcurrency(max int) option
Types ¶
type Client ¶
type Client interface {
FindProviders(ctx context.Context, key cid.Cid) (iter.ResultIter[types.Record], error)
ProvideBitswap(ctx context.Context, keys []cid.Cid, ttl time.Duration) (time.Duration, error)
FindPeers(ctx context.Context, pid peer.ID) (peers iter.ResultIter[*types.PeerRecord], err error)
GetIPNS(ctx context.Context, name ipns.Name) (*ipns.Record, error)
PutIPNS(ctx context.Context, name ipns.Name, record *ipns.Record) error
}
Click to show internal directories.
Click to hide internal directories.