INNER CODE UNIT · Go

downscaleThreshold

brexhq/substation · cmd/aws/lambda/autoscale/main.go:291

	downscaleThreshold := kinesisThreshold - 0.35
	if err := updateDownscaleAlarm(ctx, stream, topicArn, downscaleThreshold, metrics); err != nil {
		return fmt.Errorf("handler: %v", err)
	}

	log.WithField("alarm", stream+"_downscale").WithField("stream", stream).WithField("count", newShards).Debug("Reset CloudWatch alarm.")

	upscaleThreshold := kinesisThreshold
	if err := updateUpscaleAlarm(ctx, stream, topicArn, upscaleThreshold, metrics); err != nil {
		return fmt.Errorf("handler: %v", err)
	}

	log.WithField("alarm", stream+"_upscale").WithField("stream", stream).WithField("count", newShards).Debug("Reset CloudWatch alarm.")

	return nil
}

func downscale(shards float64) int32 {

View source record →