routing

Jan 23, 2023

Changes in this version

+ func ConstructHTTPRouter(endpoint string, peerID string, addrs []string, privKey string) (routing.Routing, error)

+ type ExtraHTTPParams struct

+ Addrs []string

+ PeerID string

+ PrivKeyB64 string

Oct 4, 2022

Changes in this version

+ func Parse(routers config.Routers, methods config.Methods, extraDHT *ExtraDHTParams, ...) (routing.Routing, error)

+ type Composer struct

+ FindPeersRouter routing.Routing

+ FindProvidersRouter routing.Routing

+ GetValueRouter routing.Routing

+ ProvideRouter routing.Routing

+ PutValueRouter routing.Routing

+ func (c *Composer) Bootstrap(ctx context.Context) error

+ func (c *Composer) FindPeer(ctx context.Context, pid peer.ID) (peer.AddrInfo, error)

+ func (c *Composer) FindProvidersAsync(ctx context.Context, cid cid.Cid, count int) <-chan peer.AddrInfo

+ func (c *Composer) GetValue(ctx context.Context, key string, opts ...routing.Option) ([]byte, error)

+ func (c *Composer) Provide(ctx context.Context, cid cid.Cid, provide bool) error

+ func (c *Composer) ProvideMany(ctx context.Context, keys []multihash.Multihash) error

+ func (c *Composer) PutValue(ctx context.Context, key string, val []byte, opts ...routing.Option) error

+ func (c *Composer) Ready() bool

+ func (c *Composer) SearchValue(ctx context.Context, key string, opts ...routing.Option) (<-chan []byte, error)

+ type ExtraDHTParams struct

+ BootstrapPeers []peer.AddrInfo

+ Context context.Context

+ Datastore datastore.Batching

+ Host host.Host

+ Validator record.Validator

+ type ExtraReframeParams struct

+ Addrs []string

+ PeerID string

+ PrivKeyB64 string

+ type ProvideManyRouter interface

Jul 21, 2022

Changes in this version

+ func GetPriority(params map[string]string) int

+ func NewParamNeededErr(param, routing string) error

+ func RoutingFromConfig(c config.Router) (routing.Routing, error)

+ type ParamNeededError struct

+ ParamName string

+ RouterType string

+ func (e *ParamNeededError) Error() string

+ type ProvideMany interface

+ ProvideMany func(ctx context.Context, keys []multihash.Multihash) error

+ Ready func() bool

+ type ProvideManyWrapper struct

+ func (pmw *ProvideManyWrapper) ProvideMany(ctx context.Context, keys []multihash.Multihash) error

+ func (pmw *ProvideManyWrapper) Ready() bool

+ type RouterTypeNotFoundError struct

+ RouterType string

+ func (e *RouterTypeNotFoundError) Error() string

+ type Tiered struct

+ func (ds Tiered) ProvideMany() ProvideMany

+ type TieredRouter interface

+ ProvideMany func() ProvideMany

Oct 19, 2015

Changes in this version

type IpfsRouting

+ GetValues func(c context.Context, k key.Key, count int) ([]RecvdVal, error)

+ type RecvdVal struct

+ From peer.ID

+ Val []byte

Apr 22, 2015

Changes in this version

+ func GetPublicKey(r IpfsRouting, ctx context.Context, pkhash []byte) (ci.PubKey, error)

+ func KeyForPublicKey(id peer.ID) u.Key

+ type PubKeyFetcher interface

+ GetPublicKey func(context.Context, peer.ID) (ci.PubKey, error)

Feb 27, 2015

Changes in this version

+ var ErrNotFound = errors.New("routing: not found")

+ type IpfsRouting interface

+ Bootstrap func(context.Context) error

+ FindPeer func(context.Context, peer.ID) (peer.PeerInfo, error)

+ FindProvidersAsync func(context.Context, u.Key, int) <-chan peer.PeerInfo

+ GetValue func(context.Context, u.Key) ([]byte, error)

+ Ping func(context.Context, peer.ID) (time.Duration, error)

+ Provide func(context.Context, u.Key) error

+ PutValue func(context.Context, u.Key, []byte) error