autogen_aws_s3_inventory.go

//AUTOGENERATED CODE DO NOT EDIT
// This file is automatically generated from /internal/codegen/templates/aws_service_inventory_file.tmpl
package inventory

import (
	"context"

	"github.com/sheacloud/cloud-inventory/internal/db"
	"github.com/sheacloud/cloud-inventory/pkg/aws"
	"github.com/sheacloud/cloud-inventory/pkg/aws/s3"
)

func IngestAwsS3Buckets(ctx context.Context, dao db.WriterDAO, input *aws.AwsFetchInput) (*aws.AwsFetchOutputMetadata, error) {
	resources, metadata := s3.FetchBuckets(ctx, input)
	if resources != nil {
		err := dao.PutAwsS3Buckets(ctx, resources)
		if err != nil {
			return nil, err
		}
	}

	return metadata, nil
}