core

func (*Assigner) Allowed ¶

func (a *Assigner) Allowed(peerID peer.ID) bool

Allowed determines whether the assigner is accepting announce messages from the specified publisher.

func (*Assigner) Announce ¶

func (a *Assigner) Announce(ctx context.Context, nextCid cid.Cid, addrInfo peer.AddrInfo) error

Announce sends a direct announce message to the assigner. This publisher in the message will be assigned to one or more indexers.

func (*Assigner) Assigned ¶

func (a *Assigner) Assigned(peerID peer.ID) []int

Assigned returns the indexers that the given peer is assigned to.

func (*Assigner) Close ¶

func (a *Assigner) Close() error

Close shuts down the Subscriber.

func (*Assigner) IndexerAssignedCounts ¶

func (a *Assigner) IndexerAssignedCounts() []int

IndexerAssignedCounts returns a slice of counts, one for each indexer in the pool. Each count is the number of publishers assigned to the indexer. The position of each count corresponds to the position of the indexer in the pool.

func (*Assigner) InitDone ¶ added in v0.5.4

func (a *Assigner) InitDone() bool

func (*Assigner) OnAssignment ¶

func (a *Assigner) OnAssignment(pubID peer.ID) (<-chan int, context.CancelFunc)

OnAssignment returns a channel that reports the number of the indexer that the specified peer ID was assigned to, each time that peer is assigned to an indexer. The channel is closed when there are no more indexers required to assign the peer to. Multiple calls using the same pubID return the same channel.

The notification channel is closed when assignment is complete. A new channel will need to be created to receive notification of future assignments/handoff.

func (*Assigner) PollNow ¶ added in v0.5.5

func (a *Assigner) PollNow()

func (*Assigner) Presets ¶

func (a *Assigner) Presets(peerID peer.ID) []int

Presets returns preset indexer assignments for the given peer.