hooks

Documentation

Index

• type CommandMatchData
  • func NewCommandMatchesData(cmc chan *execevent.KprobeEvent, NumOfWorkers int, ...) *CommandMatchData
• type CommandMatchesWorker
  • func NewCommandMatchesWorker(commandMatchData *CommandMatchData, log *zap.Logger) *CommandMatchesWorker
  • func (pm *CommandMatchesWorker) Invoke()
• type K8sAPICallHook
• type K8sFileConfigChangeHook
• type PacketMatchData
  • func NewPacketMatchData(rm *matches.RouteMatches, pmc chan *netevent.HTTPNetData, ...) *PacketMatchData
• type PacketMatchesWorker
  • func NewPacketMatchesWorker(pmd *PacketMatchData, log *zap.Logger) *PacketMatchesWorker
  • func (pm *PacketMatchesWorker) Invoke()

Types

type CommandMatchData

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

CommandMatchData encapsulate command worker properties

func NewCommandMatchesData

func NewCommandMatchesData(cmc chan *execevent.KprobeEvent, NumOfWorkers int, fsMatches *matches.FSMatches, uiChan chan model.K8sConfigFileChangeEvent, hook K8sFileConfigChangeHook) *CommandMatchData

NewCommandMatchesData return new command instance

type CommandMatchesWorker

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

CommandMatchesWorker instance which match command data to specific pattern

func NewCommandMatchesWorker

func NewCommandMatchesWorker(commandMatchData *CommandMatchData, log *zap.Logger) *CommandMatchesWorker

NewCommandMatchesWorker return new command instance

func (*CommandMatchesWorker) Invoke

func (pm *CommandMatchesWorker) Invoke()

Invoke invoke packet matches workers

type K8sAPICallHook

type K8sAPICallHook struct {
	Plugins []plugin.Symbol
	Plug    *uplugin.PluginLoader
}

K8sAPICallHook hold the plugin symbol for K8s API Call Hook

type K8sFileConfigChangeHook

type K8sFileConfigChangeHook struct {
	Plugins []plugin.Symbol
	Plug    *uplugin.PluginLoader
}

K8sFileConfigChangeHook hold the plugin symbol for K8s File Config Change Hook

type PacketMatchData

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

PacketMatchData encapsulate packet worker properties

func NewPacketMatchData

func NewPacketMatchData(rm *matches.RouteMatches, pmc chan *netevent.HTTPNetData, validationCache map[string]*specs.API, numOfWorkers int, uichan chan model.K8sAPICallEvent, plugin K8sAPICallHook) *PacketMatchData

NewPacketMatchData return new packet data

type PacketMatchesWorker

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

PacketMatchesWorker instance which match packet data to specific pattern

func NewPacketMatchesWorker

func NewPacketMatchesWorker(pmd *PacketMatchData, log *zap.Logger) *PacketMatchesWorker

NewPacketMatchesWorker return new packet instance

func (*PacketMatchesWorker) Invoke

func (pm *PacketMatchesWorker) Invoke()

Invoke invoke packet matches workers