Documentation ¶
Index ¶
- func PubsubRouter(mctx helpers.MetricsCtx, lc fx.Lifecycle, in p2pPSRoutingIn) (p2pRouterOut, *namesys.PubsubValueStore, error)
- func RcPinning(bstore blockstore.Blockstore, dserv ipld.DAGService, repo repo.Repo) pin.Pinner
- func RegisterPinnerMetrics()
- type WrappedPinner
- func (p *WrappedPinner) CheckIfPinned(ctx context.Context, cids ...cid.Cid) ([]pin.Pinned, error)
- func (p *WrappedPinner) DirectKeys(ctx context.Context) <-chan pin.StreamedCid
- func (p *WrappedPinner) DirectKeysWithCount(ctx context.Context) <-chan *rcpinner.StreamedCidWithCount
- func (p *WrappedPinner) Flush(ctx context.Context) error
- func (p *WrappedPinner) GetCount(ctx context.Context, c cid.Cid, recursive bool) (uint16, error)
- func (p *WrappedPinner) InternalPins(ctx context.Context) <-chan pin.StreamedCid
- func (p *WrappedPinner) IsPinned(ctx context.Context, c cid.Cid) (string, bool, error)
- func (p *WrappedPinner) IsPinnedWithType(ctx context.Context, c cid.Cid, mode pin.Mode) (string, bool, error)
- func (p *WrappedPinner) Pin(ctx context.Context, node ipld.Node, recursive bool) error
- func (p *WrappedPinner) PinWithMode(ctx context.Context, cid cid.Cid, mode pin.Mode) error
- func (p *WrappedPinner) RecursiveKeys(ctx context.Context) <-chan pin.StreamedCid
- func (p *WrappedPinner) RecursiveKeysWithCount(ctx context.Context) <-chan *rcpinner.StreamedCidWithCount
- func (p *WrappedPinner) TotalPinnedCount() int64
- func (p *WrappedPinner) Unpin(ctx context.Context, cid cid.Cid, recursive bool) error
- func (p *WrappedPinner) Update(ctx context.Context, from cid.Cid, to cid.Cid, unpin bool) error
- func (p *WrappedPinner) UpdateCounts(ctx context.Context, incs []*rcpinner.UpdateCount, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PubsubRouter ¶
func PubsubRouter( mctx helpers.MetricsCtx, lc fx.Lifecycle, in p2pPSRoutingIn, ) (p2pRouterOut, *namesys.PubsubValueStore, error)
func RcPinning ¶
func RcPinning( bstore blockstore.Blockstore, dserv ipld.DAGService, repo repo.Repo, ) pin.Pinner
RcPinning creates new pinner which tells GC which blocks should be kept.
func RegisterPinnerMetrics ¶
func RegisterPinnerMetrics()
Types ¶
type WrappedPinner ¶
func GetRcPinner ¶
func GetRcPinner(v pin.Pinner) *WrappedPinner
func (*WrappedPinner) CheckIfPinned ¶
func (*WrappedPinner) DirectKeys ¶
func (p *WrappedPinner) DirectKeys( ctx context.Context, ) <-chan pin.StreamedCid
func (*WrappedPinner) DirectKeysWithCount ¶
func (p *WrappedPinner) DirectKeysWithCount( ctx context.Context, ) <-chan *rcpinner.StreamedCidWithCount
func (*WrappedPinner) InternalPins ¶
func (p *WrappedPinner) InternalPins( ctx context.Context, ) <-chan pin.StreamedCid
func (*WrappedPinner) IsPinnedWithType ¶
func (*WrappedPinner) PinWithMode ¶
func (*WrappedPinner) RecursiveKeys ¶
func (p *WrappedPinner) RecursiveKeys( ctx context.Context, ) <-chan pin.StreamedCid
func (*WrappedPinner) RecursiveKeysWithCount ¶
func (p *WrappedPinner) RecursiveKeysWithCount( ctx context.Context, ) <-chan *rcpinner.StreamedCidWithCount
func (*WrappedPinner) TotalPinnedCount ¶
func (p *WrappedPinner) TotalPinnedCount() int64
func (*WrappedPinner) Unpin ¶
func (p *WrappedPinner) Unpin( ctx context.Context, cid cid.Cid, recursive bool, ) error
func (*WrappedPinner) Update ¶
func (p *WrappedPinner) Update( ctx context.Context, from cid.Cid, to cid.Cid, unpin bool, ) error
func (*WrappedPinner) UpdateCounts ¶
func (p *WrappedPinner) UpdateCounts( ctx context.Context, incs []*rcpinner.UpdateCount, decs []*rcpinner.UpdateCount, ) error
Click to show internal directories.
Click to hide internal directories.