Documentation ¶
Index ¶
Constants ¶
View Source
const ( UnknownConnectionRole = iota ClientConnectionRole = iota ServerConnectionRole = iota )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Caretta ¶
type Caretta struct {
// contains filtered or unexported fields
}
func NewCaretta ¶
func NewCaretta() *Caretta
type ConnectionIdentifier ¶
type ConnectionIdentifier struct { Id uint32 Pid uint32 Tuple ConnectionTuple Role uint32 }
type ConnectionTuple ¶
type EbpfMap ¶
type EbpfMap struct {
// contains filtered or unexported fields
}
func (*EbpfMap) Iterate ¶
func (m *EbpfMap) Iterate() IEbpfMapIterator
type EbpfMapItertor ¶
type EbpfMapItertor struct {
// contains filtered or unexported fields
}
func (*EbpfMapItertor) Next ¶
func (it *EbpfMapItertor) Next(key interface{}, val interface{}) bool
type IEbpfMap ¶
type IEbpfMap interface { Lookup(interface{}, interface{}) error Iterate() IEbpfMapIterator Delete(interface{}) error }
type IEbpfMapIterator ¶
type IEbpfMapIterator interface {
Next(interface{}, interface{}) bool
}
type IPResolver ¶
type LinksTracer ¶
type LinksTracer struct {
// contains filtered or unexported fields
}
func NewTracer ¶
func NewTracer(resolver *k8s.K8sIPResolver) LinksTracer
initializes a LinksTracer object
func NewTracerWithObjs ¶
func NewTracerWithObjs(resolver IPResolver, connections IEbpfMap, probes Probes) LinksTracer
func (*LinksTracer) Start ¶
func (tracer *LinksTracer) Start() error
func (*LinksTracer) Stop ¶
func (tracer *LinksTracer) Stop() error
func (*LinksTracer) TracesPollingIteration ¶
func (tracer *LinksTracer) TracesPollingIteration(pastLinks map[NetworkLink]uint64) (map[NetworkLink]uint64, map[NetworkLink]uint64)
a single polling from the eBPF maps iterating the traces from the kernel-space, summing each network link
type NetworkLink ¶
type NetworkLink struct { Client caretta_k8s.Workload Server caretta_k8s.Workload ServerPort uint16 Role uint32 }
"final" type of link, like an edge on the graph
Click to show internal directories.
Click to hide internal directories.