Versions in this module Expand all Collapse all v0 v0.1.4 May 6, 2020 GO-2023-1505 GO-2023-1505: Arbitrary file read vulnerability in github.com/uber/kraken v0.1.3 Aug 26, 2019 GO-2023-1505 GO-2023-1505: Arbitrary file read vulnerability in github.com/uber/kraken v0.1.2 Apr 9, 2019 GO-2023-1505 GO-2023-1505: Arbitrary file read vulnerability in github.com/uber/kraken v0.1.1 Mar 11, 2019 GO-2023-1505 GO-2023-1505: Arbitrary file read vulnerability in github.com/uber/kraken v0.1.0 Feb 23, 2019 GO-2023-1505 GO-2023-1505: Arbitrary file read vulnerability in github.com/uber/kraken Changes in this version + const DefaultPolicy + const RarestFirstPolicy + type Manager struct + func NewManager(clk clock.Clock, timeout time.Duration, policy string, pipelineLimit int) (*Manager, error) + func (m *Manager) Clear(i int) + func (m *Manager) ClearPeer(peerID core.PeerID) + func (m *Manager) GetFailedRequests() []Request + func (m *Manager) MarkInvalid(peerID core.PeerID, i int) + func (m *Manager) MarkUnsent(peerID core.PeerID, i int) + func (m *Manager) PendingPieces(peerID core.PeerID) []int + func (m *Manager) ReservePieces(peerID core.PeerID, candidates *bitset.BitSet, ...) ([]int, error) + type Request struct + PeerID core.PeerID + Piece int + Status Status + type Status int + const StatusExpired + const StatusInvalid + const StatusPending + const StatusUnsent