beater

Documentation

Index

• func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)
• func Read(c *net.UnixConn, buffer []byte) bool
• type Saltbeat
  • func (bt Saltbeat) Cleanup(b *beat.Beat) error
  • func (bt *Saltbeat) Run(b *beat.Beat) error
  • func (bt Saltbeat) Stop()

Functions

func New

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

func Read

func Read(c *net.UnixConn, buffer []byte) bool

Crazy way to detect if connections if REALY closed ( looks like calling bt.socketConnection.Close() doesn't mean that connections is realy closed)

Types

type Saltbeat

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

func (Saltbeat) Cleanup

func (bt Saltbeat) Cleanup(b *beat.Beat) error

func (*Saltbeat) Run

func (bt *Saltbeat) Run(b *beat.Beat) error

func (Saltbeat) Stop

func (bt Saltbeat) Stop()