consumer

Documentation

Index

• type ExecEventConsumer
  • func NewExecEventConsumer(pcache *metadata.ProcessCache, workerNumber int) *ExecEventConsumer
  • func (c *ExecEventConsumer) Start(ctx context.Context, ch <-chan bpf.BpfExecEventT)
  • func (c *ExecEventConsumer) Stop()
• type ExitEventConsumer
  • func NewExitEventConsumer(pcache *metadata.ProcessCache, workerNumber int) *ExitEventConsumer
  • func (c *ExitEventConsumer) Start(ctx context.Context, ch <-chan bpf.BpfExitEventT)
  • func (c *ExitEventConsumer) Stop()
• type GoKeyLogEventConsumer
  • func NewGoKeyLogEventConsumer(workerNumber int, ws ...writer.KeyLogWriter) *GoKeyLogEventConsumer
  • func (c *GoKeyLogEventConsumer) Start(ctx context.Context, ch <-chan bpf.BpfGoKeylogEventT)
  • func (c *GoKeyLogEventConsumer) Stop()
• type PacketEventConsumer
  • func NewPacketEventConsumer(writers []writer.PacketWriter) *PacketEventConsumer
  • func (c *PacketEventConsumer) ProcessedCount() int
  • func (c *PacketEventConsumer) Start(ctx context.Context, ch <-chan bpf.BpfPacketEventWithPayloadT, ...)
  • func (c *PacketEventConsumer) Stop()
  • func (c *PacketEventConsumer) WithDelay(delay time.Duration) *PacketEventConsumer

Types

type ExecEventConsumer

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

func NewExecEventConsumer

func NewExecEventConsumer(pcache *metadata.ProcessCache, workerNumber int) *ExecEventConsumer

func (*ExecEventConsumer) Start

func (c *ExecEventConsumer) Start(ctx context.Context, ch <-chan bpf.BpfExecEventT)

func (*ExecEventConsumer) Stop

func (c *ExecEventConsumer) Stop()

type ExitEventConsumer

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

func NewExitEventConsumer

func NewExitEventConsumer(pcache *metadata.ProcessCache, workerNumber int) *ExitEventConsumer

func (*ExitEventConsumer) Start

func (c *ExitEventConsumer) Start(ctx context.Context, ch <-chan bpf.BpfExitEventT)

func (*ExitEventConsumer) Stop

func (c *ExitEventConsumer) Stop()

type GoKeyLogEventConsumer

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

func NewGoKeyLogEventConsumer

func NewGoKeyLogEventConsumer(workerNumber int, ws ...writer.KeyLogWriter) *GoKeyLogEventConsumer

func (*GoKeyLogEventConsumer) Start

func (c *GoKeyLogEventConsumer) Start(ctx context.Context, ch <-chan bpf.BpfGoKeylogEventT)

func (*GoKeyLogEventConsumer) Stop

func (c *GoKeyLogEventConsumer) Stop()

type PacketEventConsumer

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

func NewPacketEventConsumer

func NewPacketEventConsumer(writers []writer.PacketWriter) *PacketEventConsumer

func (*PacketEventConsumer) ProcessedCount

func (c *PacketEventConsumer) ProcessedCount() int

func (*PacketEventConsumer) Start

func (c *PacketEventConsumer) Start(ctx context.Context, ch <-chan bpf.BpfPacketEventWithPayloadT, maxPacketCount uint)

func (*PacketEventConsumer) Stop

func (c *PacketEventConsumer) Stop()

func (*PacketEventConsumer) WithDelay

func (c *PacketEventConsumer) WithDelay(delay time.Duration) *PacketEventConsumer