networkevent

package

Go to main page

Versions in this module

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

Changes in this version

type Event

+ func RequestPieceEvent(h core.InfoHash, self core.PeerID, peer core.PeerID, piece int) *Event

type Name

+ const RequestPiece

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

+ func Sort(events []*Event)

+ type Config struct

+ Enabled bool

+ LogPath string

+ type Event struct

+ Bitfield []bool

+ ConnCapacity int

+ DurationMS int64

+ Name Name

+ Peer string

+ Piece int

+ Self string

+ Time time.Time

+ Torrent string

+ func AddActiveConnEvent(h core.InfoHash, self core.PeerID, peer core.PeerID) *Event

+ func AddTorrentEvent(h core.InfoHash, self core.PeerID, b *bitset.BitSet, connCapacity int) *Event

+ func BlacklistConnEvent(h core.InfoHash, self core.PeerID, peer core.PeerID, dur time.Duration) *Event

+ func DropActiveConnEvent(h core.InfoHash, self core.PeerID, peer core.PeerID) *Event

+ func Filter(events []*Event, names ...Name) []*Event

+ func ReceivePieceEvent(h core.InfoHash, self core.PeerID, peer core.PeerID, piece int) *Event

+ func StripTimestamps(events []*Event) []*Event

+ func TorrentCancelledEvent(h core.InfoHash, self core.PeerID) *Event

+ func TorrentCompleteEvent(h core.InfoHash, self core.PeerID) *Event

+ func (e *Event) JSON() string

+ type Name string

+ const AddActiveConn

+ const AddTorrent

+ const BlacklistConn

+ const DropActiveConn

+ const ReceivePiece

+ const TorrentCancelled

+ const TorrentComplete

+ type Producer interface

+ Close func() error

+ Produce func(e *Event)

+ func NewProducer(config Config) (Producer, error)

+ type TestProducer struct

+ func NewTestProducer() *TestProducer

+ func (p *TestProducer) Close() error

+ func (p *TestProducer) Events() []*Event

+ func (p *TestProducer) Produce(e *Event)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL