collector

Documentation

Index

• Variables
• type CloseCollector
  • func NewCloseCollector() *CloseCollector
  • func (c *CloseCollector) Start(_ *module.Manager, context *common.AccessLogContext) error
  • func (c *CloseCollector) Stop()
• type Collector
  • func Collectors() []Collector
• type ConnectCollector
  • func NewConnectCollector() *ConnectCollector
  • func (c *ConnectCollector) Start(_ *module.Manager, context *common.AccessLogContext) error
  • func (c *ConnectCollector) Stop()
• type L24Collector
  • func NewL24Collector() *L24Collector
  • func (c *L24Collector) Start(mgr *module.Manager, context *common.AccessLogContext) error
  • func (c *L24Collector) Stop()
• type ProcessCollector
  • func NewProcessCollector() *ProcessCollector
  • func (p *ProcessCollector) Start(_ *module.Manager, context *common.AccessLogContext) error
  • func (p *ProcessCollector) Stop()
• type ProcessExecuteEvent
• type TLSCollector
  • func NewTLSCollector() *TLSCollector
  • func (c *TLSCollector) OnNewProcessMonitoring(pid int32)
  • func (c *TLSCollector) OnProcessRemoved(pid int32)
  • func (c *TLSCollector) Start(_ *module.Manager, context *common.AccessLogContext) error
  • func (c *TLSCollector) Stop()
• type TransferCollector
  • func NewTransferCollector() *TransferCollector
  • func (t *TransferCollector) Start(_ *module.Manager, context *common.AccessLogContext) error
  • func (t *TransferCollector) Stop()
• type ZTunnelCollector
  • func NewZTunnelCollector(expireTime time.Duration) *ZTunnelCollector
  • func (z *ZTunnelCollector) ReadyToFlushConnection(connection *common.ConnectionInfo, _ events.Event)
  • func (z *ZTunnelCollector) Start(mgr *module.Manager, ctx *common.AccessLogContext) error
  • func (z *ZTunnelCollector) Stop()
• type ZTunnelLoadBalanceAddress
  • func (z *ZTunnelLoadBalanceAddress) String() string

Variables

var (
	// ZTunnelProcessFinderInterval is the interval to find ztunnel process
	ZTunnelProcessFinderInterval = time.Second * 30
	// ZTunnelTrackBoundSymbolPrefix is the prefix of the symbol name to track outbound connections in ztunnel process
	// ztunnel::proxy::connection_manager::ConnectionManager::track_outbound
	ZTunnelTrackBoundSymbolPrefix = "_ZN7ztunnel5proxy18connection_manager17ConnectionManager14track_outbound"
)

Types

type CloseCollector

type CloseCollector struct {
}

func NewCloseCollector

func NewCloseCollector() *CloseCollector

func (*CloseCollector) Start

func (c *CloseCollector) Start(_ *module.Manager, context *common.AccessLogContext) error

func (*CloseCollector) Stop

func (c *CloseCollector) Stop()

type Collector

type Collector interface {
	Start(mgr *module.Manager, context *common.AccessLogContext) error
	Stop()
}

func Collectors

func Collectors() []Collector

type ConnectCollector

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

func NewConnectCollector

func NewConnectCollector() *ConnectCollector

func (*ConnectCollector) Start

func (c *ConnectCollector) Start(_ *module.Manager, context *common.AccessLogContext) error

func (*ConnectCollector) Stop

func (c *ConnectCollector) Stop()

type L24Collector

type L24Collector struct {
}

func NewL24Collector

func NewL24Collector() *L24Collector

func (*L24Collector) Start

func (c *L24Collector) Start(mgr *module.Manager, context *common.AccessLogContext) error

func (*L24Collector) Stop

func (c *L24Collector) Stop()

type ProcessCollector

type ProcessCollector struct {
}

ProcessCollector Management all processes which needs to be monitored

func NewProcessCollector

func NewProcessCollector() *ProcessCollector

func (*ProcessCollector) Start

func (p *ProcessCollector) Start(_ *module.Manager, context *common.AccessLogContext) error

func (*ProcessCollector) Stop

func (p *ProcessCollector) Stop()

type ProcessExecuteEvent

type ProcessExecuteEvent struct {
	PID uint32
}

type TLSCollector

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

func NewTLSCollector

func NewTLSCollector() *TLSCollector

func (*TLSCollector) OnNewProcessMonitoring

func (c *TLSCollector) OnNewProcessMonitoring(pid int32)

func (*TLSCollector) OnProcessRemoved

func (c *TLSCollector) OnProcessRemoved(pid int32)

func (*TLSCollector) Start

func (c *TLSCollector) Start(_ *module.Manager, context *common.AccessLogContext) error

func (*TLSCollector) Stop

func (c *TLSCollector) Stop()

type TransferCollector

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

func NewTransferCollector

func NewTransferCollector() *TransferCollector

func (*TransferCollector) Start

func (t *TransferCollector) Start(_ *module.Manager, context *common.AccessLogContext) error

func (*TransferCollector) Stop

func (t *TransferCollector) Stop()

type ZTunnelCollector

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

ZTunnelCollector is a collector for ztunnel process in the Ambient Istio scenario

func NewZTunnelCollector

func NewZTunnelCollector(expireTime time.Duration) *ZTunnelCollector

func (*ZTunnelCollector) ReadyToFlushConnection

func (z *ZTunnelCollector) ReadyToFlushConnection(connection *common.ConnectionInfo, _ events.Event)

func (*ZTunnelCollector) Start

func (z *ZTunnelCollector) Start(mgr *module.Manager, ctx *common.AccessLogContext) error

func (*ZTunnelCollector) Stop

func (z *ZTunnelCollector) Stop()

type ZTunnelLoadBalanceAddress

type ZTunnelLoadBalanceAddress struct {
	IP   string
	Port uint16
}

func (*ZTunnelLoadBalanceAddress) String

func (z *ZTunnelLoadBalanceAddress) String() string