routinghelpers

Jul 25, 2023

Changes in this version

type ParallelRouter

+ DoNotWaitForSearchValue bool

Jun 8, 2023

Changes in this version

+ type ReadyAbleRouter interface

+ Ready func() bool

Jan 12, 2023

Changes in this version

+ type ComposableRouter interface

+ Routers func() []routing.Routing

Sep 16, 2022

Changes in this version

+ func NewComposableParallel(routers []*ParallelRouter) *composableParallel

+ func NewComposableSequential(routers []*SequentialRouter) *composableSequential

+ type ParallelRouter struct

+ ExecuteAfter time.Duration

+ IgnoreError bool

+ Router routing.Routing

+ Timeout time.Duration

+ type ProvideManyRouter interface

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

+ Ready func() bool

+ type SequentialRouter struct

+ IgnoreError bool

+ Router routing.Routing

+ Timeout time.Duration

Apr 6, 2020

Changes in this version

type LimitedValueStore

+ func (lvs *LimitedValueStore) Close() error

type Null

+ func (nr Null) Close() error

type Parallel

+ func (r Parallel) Close() error

type Tiered

+ func (r Tiered) Close() error

Mar 1, 2019

Changes in this version

+ type Bootstrap interface

+ Bootstrap func(ctx context.Context) error

+ type Compose struct

+ ContentRouting routing.ContentRouting

+ PeerRouting routing.PeerRouting

+ ValueStore routing.ValueStore

+ func (cr *Compose) Bootstrap(ctx context.Context) error

+ func (cr *Compose) FindPeer(ctx context.Context, p peer.ID) (pstore.PeerInfo, error)

+ func (cr *Compose) FindProvidersAsync(ctx context.Context, c cid.Cid, count int) <-chan pstore.PeerInfo

+ func (cr *Compose) GetPublicKey(ctx context.Context, p peer.ID) (ci.PubKey, error)

+ func (cr *Compose) GetValue(ctx context.Context, key string, opts ...ropts.Option) ([]byte, error)

+ func (cr *Compose) Provide(ctx context.Context, c cid.Cid, local bool) error

+ func (cr *Compose) PutValue(ctx context.Context, key string, value []byte, opts ...ropts.Option) error

+ func (cr *Compose) SearchValue(ctx context.Context, key string, opts ...ropts.Option) (<-chan []byte, error)

+ type LimitedValueStore struct

+ Namespaces []string

+ func (lvs *LimitedValueStore) Bootstrap(ctx context.Context) error

+ func (lvs *LimitedValueStore) GetPublicKey(ctx context.Context, p peer.ID) (ci.PubKey, error)

+ func (lvs *LimitedValueStore) GetValue(ctx context.Context, key string, opts ...ropts.Option) ([]byte, error)

+ func (lvs *LimitedValueStore) KeySupported(key string) bool

+ func (lvs *LimitedValueStore) PutValue(ctx context.Context, key string, value []byte, opts ...ropts.Option) error

+ func (lvs *LimitedValueStore) SearchValue(ctx context.Context, key string, opts ...ropts.Option) (<-chan []byte, error)

+ type Null struct

+ func (nr Null) Bootstrap(context.Context) error

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

+ func (nr Null) FindProvidersAsync(context.Context, cid.Cid, int) <-chan pstore.PeerInfo

+ func (nr Null) GetValue(context.Context, string, ...ropts.Option) ([]byte, error)

+ func (nr Null) Provide(context.Context, cid.Cid, bool) error

+ func (nr Null) PutValue(context.Context, string, []byte, ...ropts.Option) error

+ func (nr Null) SearchValue(ctx context.Context, key string, opts ...ropts.Option) (<-chan []byte, error)

+ type Parallel struct

+ Routers []routing.IpfsRouting

+ Validator record.Validator

+ func (r Parallel) Bootstrap(ctx context.Context) error

+ func (r Parallel) FindPeer(ctx context.Context, p peer.ID) (pstore.PeerInfo, error)

+ func (r Parallel) FindProvidersAsync(ctx context.Context, c cid.Cid, count int) <-chan pstore.PeerInfo

+ func (r Parallel) GetPublicKey(ctx context.Context, p peer.ID) (ci.PubKey, error)

+ func (r Parallel) GetValue(ctx context.Context, key string, opts ...ropts.Option) ([]byte, error)

+ func (r Parallel) Provide(ctx context.Context, c cid.Cid, local bool) error

+ func (r Parallel) PutValue(ctx context.Context, key string, value []byte, opts ...ropts.Option) error

+ func (r Parallel) SearchValue(ctx context.Context, key string, opts ...ropts.Option) (<-chan []byte, error)

+ type Tiered struct

+ Routers []routing.IpfsRouting

+ Validator record.Validator

+ func (r Tiered) Bootstrap(ctx context.Context) error

+ func (r Tiered) FindPeer(ctx context.Context, p peer.ID) (pstore.PeerInfo, error)

+ func (r Tiered) FindProvidersAsync(ctx context.Context, c cid.Cid, count int) <-chan pstore.PeerInfo

+ func (r Tiered) GetPublicKey(ctx context.Context, p peer.ID) (ci.PubKey, error)

+ func (r Tiered) GetValue(ctx context.Context, key string, opts ...ropts.Option) ([]byte, error)

+ func (r Tiered) Provide(ctx context.Context, c cid.Cid, local bool) error

+ func (r Tiered) PutValue(ctx context.Context, key string, value []byte, opts ...ropts.Option) error

+ func (r Tiered) SearchValue(ctx context.Context, key string, opts ...ropts.Option) (<-chan []byte, error)