caretta

Jan 3, 2023

Changes in this version

+ const ClientConnectionRole

+ const ServerConnectionRole

+ const UnknownConnectionRole

+ type Caretta struct

+ func NewCaretta() *Caretta

+ func (caretta *Caretta) Start()

+ func (caretta *Caretta) Stop()

+ type ConnectionIdentifier struct

+ Id uint32

+ Pid uint32

+ Role uint32

+ Tuple ConnectionTuple

+ type ConnectionThroughputStats struct

+ BytesReceived uint64

+ BytesSent uint64

+ IsActive uint64

+ type ConnectionTuple struct

+ DstIp uint32

+ DstPort uint16

+ SrcIp uint32

+ SrcPort uint16

+ type EbpfMap struct

+ func (m *EbpfMap) Delete(key interface{}) error

+ func (m *EbpfMap) Iterate() IEbpfMapIterator

+ func (m *EbpfMap) Lookup(key interface{}, val interface{}) error

+ type EbpfMapItertor struct

+ func (it *EbpfMapItertor) Next(key interface{}, val interface{}) bool

+ type IEbpfMap interface

+ Delete func(interface{}) error

+ Iterate func() IEbpfMapIterator

+ Lookup func(interface{}, interface{}) error

+ type IEbpfMapIterator interface

+ Next func(interface{}, interface{}) bool

+ type IP uint32

+ func (ip IP) String() string

+ type IPResolver interface

+ ResolveIP func(string) k8s.Workload

+ StartWatching func() error

+ StopWatching func()

+ type LinksTracer struct

+ func NewTracer(resolver *k8s.K8sIPResolver) LinksTracer

+ func NewTracerWithObjs(resolver IPResolver, connections IEbpfMap, probes Probes) LinksTracer

+ func (tracer *LinksTracer) Start() error

+ func (tracer *LinksTracer) Stop() error

+ func (tracer *LinksTracer) TracesPollingIteration(pastLinks map[NetworkLink]uint64) (map[NetworkLink]uint64, map[NetworkLink]uint64)

+ type NetworkLink struct

+ Client caretta_k8s.Workload

+ Role uint32

+ Server caretta_k8s.Workload

+ ServerPort uint16

+ type Probes interface

+ UnloadProbes func() error