beater

Documentation

Index

• func New(b *beat.Beat, rawConfig *common.Config) (beat.Beater, error)
• type ConfigSettings
• type ConnConfig
  • func (c *ConnConfig) Validate() error
• type Connbeat
  • func (cb *Connbeat) Cleanup(b *beat.Beat) error
  • func (cb *Connbeat) Pipe(connectionListener <-chan connections.FullConnection, ...) error
  • func (cb *Connbeat) Run(b *beat.Beat) error
  • func (cb *Connbeat) Stop()
• type ContainerInfo

Functions

func New

func New(b *beat.Beat, rawConfig *common.Config) (beat.Beater, error)

Types

type ConfigSettings

type ConfigSettings struct {
	Connbeat ConnConfig `config:"connbeat"`
}

type ConnConfig

type ConnConfig struct {
	ExposeProcessInfo       bool          `config:"expose_process_info"`
	ExposeCmdline           bool          `config:"expose_cmdline"`
	ExposeEnviron           bool          `config:"expose_environ"`
	ConnectionAggregation   time.Duration `config:"aggregation"`
	LocalConnectionsEnabled bool          `config:"enable_local_connections"`
	DockerEnabled           bool          `config:"enable_docker"`
	DockerEnvironment       []string      `config:"docker_environment"`
	TcpDiagEnabled          bool          `config:"enable_tcp_diag"`
	PollInterval            time.Duration `config:"poll_interval"`
}

func (*ConnConfig) Validate

func (c *ConnConfig) Validate() error

type Connbeat

type Connbeat struct {
	ConnConfig ConfigSettings
	// contains filtered or unexported fields
}

func (*Connbeat) Cleanup

func (cb *Connbeat) Cleanup(b *beat.Beat) error

func (*Connbeat) Pipe

func (cb *Connbeat) Pipe(connectionListener <-chan connections.FullConnection, serverConnectionListener <-chan connections.ServerConnection) error

func (*Connbeat) Run

func (cb *Connbeat) Run(b *beat.Beat) error

func (*Connbeat) Stop

func (cb *Connbeat) Stop()

type ContainerInfo

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