metadata

Documentation

Index

• Variables
• func NewDummyNgInterface(index int, filter string) pcapgo.NgInterface
• func NewNgInterface(dev types.Device, filter string, index int) pcapgo.NgInterface
• type Connection
  • func GetCurrentConnects(ctx context.Context, pids []int, all bool) ([]Connection, error)
• type ContainerCache
  • func NewContainerCache(ctx context.Context, ...) (*ContainerCache, error)
  • func (c *ContainerCache) GetById(containerId string) types.Container
  • func (c *ContainerCache) GetByMntNs(mntNs int64) types.Container
  • func (c *ContainerCache) GetByName(containerName string) []types.Container
  • func (c *ContainerCache) GetByNetNs(ns int64) types.Container
  • func (c *ContainerCache) GetByPid(pid int) types.Container
  • func (c *ContainerCache) GetByPodName(name, namespace string) []types.Container
  • func (c *ContainerCache) GetPodByContainer(cr types.Container) types.Pod
• type DeviceCache
  • func NewDeviceCache(nscache *NetNsCache) *DeviceCache
  • func (d *DeviceCache) Add(netNsInode uint32, ifindex uint32, name string)
  • func (d *DeviceCache) GetByIfindex(ifindex int, netNsInode uint32) (types.Device, bool)
  • func (d *DeviceCache) GetDevices(devNames []string, netNsPaths []string) (*types.Interfaces, error)
  • func (d *DeviceCache) Start(ctx context.Context) error
• type NetNsCache
  • func NewNetNsCache() *NetNsCache
  • func (n *NetNsCache) Get(inodeId uint32) (*types.NetNs, error)
  • func (n *NetNsCache) GetCurrentNs() *types.NetNs
  • func (n *NetNsCache) GetOrFetchByPath(p string) (*types.NetNs, error)
  • func (n *NetNsCache) Start(ctx context.Context) error
• type ProcessCache
  • func NewProcessCache() *ProcessCache
  • func (c *ProcessCache) AddItem(exec types.ProcessExec)
  • func (c *ProcessCache) AddItemWithContext(exec types.ProcessExec, rawCtx types.PacketContext)
  • func (c *ProcessCache) Get(pid int, mntNs, netNs int, cgroupName string) types.PacketContext
  • func (c *ProcessCache) GetPidsByComm(name string) []int
  • func (c *ProcessCache) GetPidsByMntNsId(nsid int64) []int
  • func (c *ProcessCache) GetPidsByNetNsId(nsid int64) []int
  • func (c *ProcessCache) GetPidsByPidNsId(nsid int64) []int
  • func (c *ProcessCache) MarkDead(pid int)
  • func (c *ProcessCache) Start(ctx context.Context)
  • func (c *ProcessCache) WithContainerCache(cc *ContainerCache) *ProcessCache

Variables

var (
	HostMntNs int64
	HostPidNs int64
	HostNetNs int64
)

Functions

func NewDummyNgInterface

func NewDummyNgInterface(index int, filter string) pcapgo.NgInterface

func NewNgInterface

func NewNgInterface(dev types.Device, filter string, index int) pcapgo.NgInterface

Types

type Connection

type Connection struct {
	LocalIP   netip.Addr
	LocalPort int
	Pid       int
	MntNs     int64
	NetNs     int64
}

func GetCurrentConnects

func GetCurrentConnects(ctx context.Context, pids []int, all bool) ([]Connection, error)

type ContainerCache

type ContainerCache struct {
	// contains filtered or unexported fields
}

func NewContainerCache

func NewContainerCache(ctx context.Context,
	dockerEndpoint, containerdEndpoint, criRuntimeEndpoint string) (*ContainerCache, error)

func (*ContainerCache) GetById

func (c *ContainerCache) GetById(containerId string) types.Container

func (*ContainerCache) GetByMntNs

func (c *ContainerCache) GetByMntNs(mntNs int64) types.Container

func (*ContainerCache) GetByName

func (c *ContainerCache) GetByName(containerName string) []types.Container

func (*ContainerCache) GetByNetNs

func (c *ContainerCache) GetByNetNs(ns int64) types.Container

func (*ContainerCache) GetByPid

func (c *ContainerCache) GetByPid(pid int) types.Container

func (*ContainerCache) GetByPodName

func (c *ContainerCache) GetByPodName(name, namespace string) []types.Container

func (*ContainerCache) GetPodByContainer

func (c *ContainerCache) GetPodByContainer(cr types.Container) types.Pod

type DeviceCache

type DeviceCache struct {
	// contains filtered or unexported fields
}

func NewDeviceCache

func NewDeviceCache(nscache *NetNsCache) *DeviceCache

func (*DeviceCache) Add

func (d *DeviceCache) Add(netNsInode uint32, ifindex uint32, name string)

func (*DeviceCache) GetByIfindex

func (d *DeviceCache) GetByIfindex(ifindex int, netNsInode uint32) (types.Device, bool)

func (*DeviceCache) GetDevices

func (d *DeviceCache) GetDevices(devNames []string, netNsPaths []string) (*types.Interfaces, error)

func (*DeviceCache) Start

func (d *DeviceCache) Start(ctx context.Context) error

type NetNsCache

type NetNsCache struct {
	// contains filtered or unexported fields
}

func NewNetNsCache

func NewNetNsCache() *NetNsCache

func (*NetNsCache) Get

func (n *NetNsCache) Get(inodeId uint32) (*types.NetNs, error)

func (*NetNsCache) GetCurrentNs

func (n *NetNsCache) GetCurrentNs() *types.NetNs

func (*NetNsCache) GetOrFetchByPath

func (n *NetNsCache) GetOrFetchByPath(p string) (*types.NetNs, error)

func (*NetNsCache) Start

func (n *NetNsCache) Start(ctx context.Context) error

type ProcessCache

type ProcessCache struct {
	// contains filtered or unexported fields
}

func NewProcessCache

func NewProcessCache() *ProcessCache

func (*ProcessCache) AddItem

func (c *ProcessCache) AddItem(exec types.ProcessExec)

func (*ProcessCache) AddItemWithContext

func (c *ProcessCache) AddItemWithContext(exec types.ProcessExec, rawCtx types.PacketContext)

func (*ProcessCache) Get

func (c *ProcessCache) Get(pid int, mntNs, netNs int, cgroupName string) types.PacketContext

func (*ProcessCache) GetPidsByComm

func (c *ProcessCache) GetPidsByComm(name string) []int

func (*ProcessCache) GetPidsByMntNsId

func (c *ProcessCache) GetPidsByMntNsId(nsid int64) []int

func (*ProcessCache) GetPidsByNetNsId

func (c *ProcessCache) GetPidsByNetNsId(nsid int64) []int

func (*ProcessCache) GetPidsByPidNsId

func (c *ProcessCache) GetPidsByPidNsId(nsid int64) []int

func (*ProcessCache) MarkDead

func (c *ProcessCache) MarkDead(pid int)

func (*ProcessCache) Start

func (c *ProcessCache) Start(ctx context.Context)

func (*ProcessCache) WithContainerCache

func (c *ProcessCache) WithContainerCache(cc *ContainerCache) *ProcessCache