beater

package

v0.0.0-...-96c1714 Latest Latest Go to latest Published: Jun 14, 2016 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func ListAllLambdaFunctions(region string) ([]string, error)

func PartitionDateRange(start time.Time, end time.Time, interval int64) []dateRange

Given a date range and an interval, chunk the range into a sequence of ranges such that no single range exceeds maxDatapoints.

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

type Datapoints []cloudwatch.Datapoint

func (slice Datapoints) Len() int

func (slice Datapoints) Less(i, j int) bool

func (slice Datapoints) Swap(i, j int)

type Lambdabeat struct {
	CmdLineArgs CmdLineArgs
	// contains filtered or unexported fields
}

func New() *Lambdabeat

Creates beater

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

func (bt *Lambdabeat) Config(b *beat.Beat) error

func (bt *Lambdabeat) CreateEvents(fn string, end time.Time) ([]common.MapStr, error)

func (bt *Lambdabeat) FetchFunctionConfigs() error

func (bt *Lambdabeat) FetchFunctionMetric(fn string, metric string, end time.Time) (Datapoints, error)

func (bt *Lambdabeat) HandleFlags(b *beat.Beat) error

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

func (bt *Lambdabeat) RunBackfill() error

func (bt *Lambdabeat) RunPeriodic() error

func (bt *Lambdabeat) Setup(b *beat.Beat) error

func (bt *Lambdabeat) Stop()