INNER CODE UNIT · Go

lastTag

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

		lastTag = *resp.Tags[len(resp.Tags)-1].Key

		if !*resp.HasMoreTags {
			break
		}
	}

	return tags, nil
}

func updateStream(ctx context.Context, stream string, shards int32) error {
	_, err := kinesisC.UpdateShardCount(ctx, &kinesis.UpdateShardCountInput{
		StreamName:       aws.String(stream),
		TargetShardCount: aws.Int32(shards),
		ScalingType:      ktypes.ScalingTypeUniformScaling,
	})
	if err != nil {
		return err

View source record →