metadata

Documentation

Index

• Variables
• 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 ProcessCache
  • func NewProcessCache() *ProcessCache
  • func (c *ProcessCache) AddItem(exec event.ProcessExec)
  • func (c *ProcessCache) AddItemWithContext(exec event.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
)

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 ProcessCache

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

func NewProcessCache

func NewProcessCache() *ProcessCache

func (*ProcessCache) AddItem

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

func (*ProcessCache) AddItemWithContext

func (c *ProcessCache) AddItemWithContext(exec event.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