socketinfo

Dec 7, 2020

Changes in this version

+ const StateClose — linux/amd64

+ const StateCloseWait — linux/amd64

+ const StateClosing — linux/amd64

+ const StateEstablished — linux/amd64

+ const StateFinWait1 — linux/amd64

+ const StateFinWait2 — linux/amd64

+ const StateLastAck — linux/amd64

+ const StateListen — linux/amd64

+ const StateSynRecv — linux/amd64

+ const StateSynSent — linux/amd64

+ const StateTimeWait — linux/amd64

+ const StateUnknown — linux/amd64

Nov 15, 2019

Changes in this version

+ func NewProbe(ctx tp.Context, bundle *probe.Bundle) (probe.Handler, error)

type ConnectionInfo

+ func (obj *ConnectionInfo) GetFieldBool(key string) (bool, error)

+ func (obj *ConnectionInfo) MatchBool(key string, predicate common.BoolPredicate) bool

+ func (obj *ConnectionInfo) MatchInt64(key string, predicate common.Int64Predicate) bool

+ func (obj *ConnectionInfo) MatchString(key string, predicate common.StringPredicate) bool

+ func (v *ConnectionInfo) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *ConnectionInfo) UnmarshalJSON(data []byte) error

+ func (v ConnectionInfo) MarshalEasyJSON(w *jwriter.Writer)

+ func (v ConnectionInfo) MarshalJSON() ([]byte, error)

Sep 12, 2019

Changes in this version

+ type ProbeHandler struct

+ func (s *ProbeHandler) Init(ctx tp.Context, bundle *probe.Bundle) (probe.Handler, error)

+ func (s *ProbeHandler) Start()

+ func (s *ProbeHandler) Stop()

+ type ProcProbe struct — linux/amd64

+ Ctx tp.Context

+ func NewProcProbe(ctx tp.Context) *ProcProbe

+ func (s *ProcProbe) MapTCP(srcAddr, dstAddr *net.TCPAddr) (src *ProcessInfo, dst *ProcessInfo)

+ func (s *ProcProbe) Start()

+ func (s *ProcProbe) Stop()

Dec 3, 2018

Changes in this version

type ConnectionInfo

+ func (c *ConnectionInfo) GetFieldKeys() []string

Apr 12, 2018

Changes in this version

+ func HashTuple(protocol flow.FlowProtocol, srcAddr net.IP, srcPort int64, dstAddr net.IP, ...) string

+ type ConnectionCache struct

+ func NewConnectionCache() *ConnectionCache

+ func (c *ConnectionCache) Get(protocol flow.FlowProtocol, srcIP net.IP, srcPort int, dstIP net.IP, ...) (interface{}, string)

+ func (c *ConnectionCache) Map(protocol flow.FlowProtocol, srcIP net.IP, srcPort int, dstIP net.IP, ...) (a *ProcessInfo, b *ProcessInfo)

+ func (c *ConnectionCache) MapTCP(srcAddr, dstAddr *net.TCPAddr) (a *ProcessInfo, b *ProcessInfo)

+ func (c *ConnectionCache) MapUDP(srcAddr, dstAddr *net.UDPAddr) (a *ProcessInfo, b *ProcessInfo)

+ func (c *ConnectionCache) Remove(protocol flow.FlowProtocol, srcAddr, dstAddr *net.TCPAddr)

+ func (c *ConnectionCache) Set(hash string, obj interface{})

+ type ConnectionInfo struct

+ LocalAddress string

+ LocalPort int64

+ Protocol flow.FlowProtocol

+ RemoteAddress string

+ RemotePort int64

+ State ConnectionState

+ func (c *ConnectionInfo) Decode(obj interface{}) error

+ func (c *ConnectionInfo) GetField(field string) (interface{}, error)

+ func (c *ConnectionInfo) GetFieldInt64(name string) (int64, error)

+ func (c *ConnectionInfo) GetFieldString(name string) (string, error)

+ func (c *ConnectionInfo) Hash() string

+ type ConnectionState string

+ type ProcSocketInfoProbe struct — linux/amd64

+ func NewProcSocketInfoProbe(g *graph.Graph, host *graph.Node) *ProcSocketInfoProbe

+ func NewSocketInfoProbe(g *graph.Graph, host *graph.Node) *ProcSocketInfoProbe

+ func (s *ProcSocketInfoProbe) MapTCP(srcAddr, dstAddr *net.TCPAddr) (src *ProcessInfo, dst *ProcessInfo)

+ func (s *ProcSocketInfoProbe) Start()

+ func (s *ProcSocketInfoProbe) Stop()

+ type ProcessInfo struct

+ Name string

+ Pid int64

+ Process string

+ type SocketInfoProbe struct — darwin/amd64, js/wasm, windows/amd64

+ func NewSocketInfoProbe(g *graph.Graph, host *graph.Node) *SocketInfoProbe

+ func (s *SocketInfoProbe) Start()

+ func (s *SocketInfoProbe) Stop()