beater

Documentation

Index

• func ListAllLambdaFunctions(region string) ([]string, error)
• func PartitionDateRange(start time.Time, end time.Time, interval int64) []dateRange
• type CmdLineArgs
• type Datapoints
  • func (slice Datapoints) Len() int
  • func (slice Datapoints) Less(i, j int) bool
  • func (slice Datapoints) Swap(i, j int)
• type Lambdabeat
  • func New() *Lambdabeat
  • 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()

Functions

func ListAllLambdaFunctions

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

func PartitionDateRange

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.

Types

type CmdLineArgs

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

type Datapoints

type Datapoints []cloudwatch.Datapoint

func (Datapoints) Len

func (slice Datapoints) Len() int

func (Datapoints) Less

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

func (Datapoints) Swap

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

type Lambdabeat

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

func New

func New() *Lambdabeat

Creates beater

func (*Lambdabeat) Cleanup

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

func (*Lambdabeat) Config

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

func (*Lambdabeat) CreateEvents

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

func (*Lambdabeat) FetchFunctionConfigs

func (bt *Lambdabeat) FetchFunctionConfigs() error

func (*Lambdabeat) FetchFunctionMetric

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

func (*Lambdabeat) HandleFlags

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

func (*Lambdabeat) Run

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

func (*Lambdabeat) RunBackfill

func (bt *Lambdabeat) RunBackfill() error

func (*Lambdabeat) RunPeriodic

func (bt *Lambdabeat) RunPeriodic() error

func (*Lambdabeat) Setup

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

func (*Lambdabeat) Stop

func (bt *Lambdabeat) Stop()