INNER CODE UNIT · Go

listTags

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

func listTags(ctx context.Context, stream string) ([]ktypes.Tag, error) {
	var tags []ktypes.Tag
	var lastTag string

	for {
		input := kinesis.ListTagsForStreamInput{
			StreamName: aws.String(stream),
		}

		if lastTag != "" {
			input.ExclusiveStartTagKey = aws.String(lastTag)
		}

		resp, err := kinesisC.ListTagsForStream(ctx, &input)
		if err != nil {
			return nil, err
		}

View source record →