Documentation
¶
Index ¶
- func PinCIDsFromFile(ctx context.Context, file io.ReadSeeker, workers int, maxReqsPerSec int, ...) (successPinsCount uint64, failedPinsCount uint64, err error)
- func PinCIDsFromSource(ctx context.Context, workers int, maxReqsPerSec int, ...) (successPinsCount uint64, failedPinsCount uint64, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PinCIDsFromFile ¶
func PinCIDsFromFile(ctx context.Context, file io.ReadSeeker, workers int, maxReqsPerSec int, infuraShell *ipfsShell.Shell, failedPinsWriter ipfsPump.FailedBlocksWriter) (successPinsCount uint64, failedPinsCount uint64, err error)
PinCIDsFromFile will open the file, read a CID from each line separated by LB char and pin them in parallel with multiple workers via the pre-configured shell.
func PinCIDsFromSource ¶
func PinCIDsFromSource(ctx context.Context, workers int, maxReqsPerSec int, hasSourceShellListStreaming bool, sourceShell *ipfsShell.Shell, infuraShell *ipfsShell.Shell, failedPinsWriter ipfsPump.FailedBlocksWriter) (successPinsCount uint64, failedPinsCount uint64, err error)
PinCIDsFromSource iterates over all pins, filters Recursive + Direct, and pins then in parallel with multiple workers via the pre-configured shell.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.