tcp_state

Documentation

Index

• Constants
• type BpfTcpEvent
• type TcpConnectEvent
  • func (e TcpConnectEvent) Type() string
• type TcpStateConfig
• type TcpStateConversion
  • func (e TcpStateConversion) String() string
• type TcpStateProg
  • func InitTcpStateProg(conf *TcpStateConfig) *TcpStateProg
  • func (tsp *TcpStateProg) Attach()
  • func (tsp *TcpStateProg) Close()
  • func (tsp *TcpStateProg) Consume(ctx context.Context, ch chan interface{})
  • func (tsp *TcpStateProg) InitMaps()
  • func (tsp *TcpStateProg) PopulateContainerPidsMap(newKeys, deletedKeys []uint32) error

Constants

const (
	BPF_EVENT_TCP_ESTABLISHED = iota + 1
	BPF_EVENT_TCP_CONNECT_FAILED
	BPF_EVENT_TCP_LISTEN
	BPF_EVENT_TCP_LISTEN_CLOSED
	BPF_EVENT_TCP_CLOSED
)

match with values in tcp_state.c

const (
	EVENT_TCP_ESTABLISHED    = "EVENT_TCP_ESTABLISHED"
	EVENT_TCP_CONNECT_FAILED = "EVENT_TCP_CONNECT_FAILED"
	EVENT_TCP_LISTEN         = "EVENT_TCP_LISTEN"
	EVENT_TCP_LISTEN_CLOSED  = "EVENT_TCP_LISTEN_CLOSED"
	EVENT_TCP_CLOSED         = "EVENT_TCP_CLOSED"
)

for user space

const TCP_CONNECT_EVENT = "tcp_connect_event"

Types

type BpfTcpEvent

type BpfTcpEvent struct {
	Fd        uint64
	Timestamp uint64
	Type      uint32
	Pid       uint32
	SPort     uint16
	DPort     uint16
	SAddr     [16]byte
	DAddr     [16]byte
}

padding to match the kernel struct

type TcpConnectEvent

type TcpConnectEvent struct {
	Fd        uint64
	Timestamp uint64
	Type_     string
	Pid       uint32
	SPort     uint16
	DPort     uint16
	SAddr     string
	DAddr     string
}

for user space

func (TcpConnectEvent) Type

func (e TcpConnectEvent) Type() string

type TcpStateConfig

type TcpStateConfig struct {
	BpfMapSize uint32 // specified in terms of os page size
}

type TcpStateConversion

type TcpStateConversion uint32

Custom type for the enumeration

func (TcpStateConversion) String

func (e TcpStateConversion) String() string

String representation of the enumeration values

type TcpStateProg

type TcpStateProg struct {
	ContainerPidMap *ebpf.Map // for filtering non-container pids on the node
	// contains filtered or unexported fields
}

var TcpState *TcpStateProg

func InitTcpStateProg

func InitTcpStateProg(conf *TcpStateConfig) *TcpStateProg

func (*TcpStateProg) Attach

func (tsp *TcpStateProg) Attach()

func (*TcpStateProg) Close

func (tsp *TcpStateProg) Close()

func (*TcpStateProg) Consume

func (tsp *TcpStateProg) Consume(ctx context.Context, ch chan interface{})

returns when program is detached

func (*TcpStateProg) InitMaps

func (tsp *TcpStateProg) InitMaps()

func (*TcpStateProg) PopulateContainerPidsMap

func (tsp *TcpStateProg) PopulateContainerPidsMap(newKeys, deletedKeys []uint32) error