accesslog

Documentation

Index

• Constants
• type Module
  • func NewModule() *Module
  • func (m *Module) Config() module.ConfigInterface
  • func (m *Module) Name() string
  • func (m *Module) NotifyStartSuccess()
  • func (m *Module) RequiredModules() []string
  • func (m *Module) Shutdown(ctx context.Context, mgr *module.Manager) error
  • func (m *Module) Start(ctx context.Context, mgr *module.Manager) error
• type Runner
  • func NewRunner(mgr *module.Manager, config *common.Config) (*Runner, error)
  • func (r *Runner) BuildNodeInfo(needs bool) *v3.EBPFAccessLogNodeInfo
  • func (r *Runner) Consume(kernels chan *common.KernelLog, protocols chan *common.ProtocolLog)
  • func (r *Runner) Start(ctx context.Context) error
  • func (r *Runner) Stop() error

Constants

const ModuleName = "access_log"

Types

type Module

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

func NewModule

func NewModule() *Module

func (*Module) Config

func (m *Module) Config() module.ConfigInterface

func (*Module) Name

func (m *Module) Name() string

func (*Module) NotifyStartSuccess

func (m *Module) NotifyStartSuccess()

func (*Module) RequiredModules

func (m *Module) RequiredModules() []string

func (*Module) Shutdown

func (m *Module) Shutdown(ctx context.Context, mgr *module.Manager) error

func (*Module) Start

func (m *Module) Start(ctx context.Context, mgr *module.Manager) error

type Runner

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

func NewRunner

func NewRunner(mgr *module.Manager, config *common.Config) (*Runner, error)

func (*Runner) BuildNodeInfo

func (r *Runner) BuildNodeInfo(needs bool) *v3.EBPFAccessLogNodeInfo

func (*Runner) Consume

func (r *Runner) Consume(kernels chan *common.KernelLog, protocols chan *common.ProtocolLog)

func (*Runner) Start

func (r *Runner) Start(ctx context.Context) error

func (*Runner) Stop

func (r *Runner) Stop() error