beater

Documentation

Index

• Constants
• func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)
• type Cloudwatchlogsbeat
  • func (beat *Cloudwatchlogsbeat) Run(b *beat.Beat) error
  • func (beat *Cloudwatchlogsbeat) Stop()

Constants

const DefaultAWSRegion = "eu-west-1"

Functions

func New

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

Creates a new cloudwatchlogsbeat

Types

type Cloudwatchlogsbeat

type Cloudwatchlogsbeat struct {
	// Used to terminate process
	Done chan struct{}
	// cwl params
	Params *cwl.Params
	// the monitoring manager
	Manager *cwl.GroupManager
}

Our cloud beat

func (*Cloudwatchlogsbeat) Run

func (beat *Cloudwatchlogsbeat) Run(b *beat.Beat) error

Runs continuously our cloud beat

func (*Cloudwatchlogsbeat) Stop

func (beat *Cloudwatchlogsbeat) Stop()

Stops beat client