s3ion

package
v0.0.0-...-62343dc Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 8, 2022 License: MIT Imports: 41 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type S3IonClient 

type S3IonClient struct {
	Bucket     string
	PathPrefix string
	S3Client   *s3.Client
	FilesLock  sync.Mutex
	Files      map[string]*S3IonFile
}

func NewS3IonClient 

func NewS3IonClient(client *s3.Client, bucket string) *S3IonClient

func (*S3IonClient) CloseAll 

func (c *S3IonClient) CloseAll(ctx context.Context) error

func (*S3IonClient) CloseResource 

func (c *S3IonClient) CloseResource(ctx context.Context, cloud, service, resource string, reportDate time.Time) error

func (*S3IonClient) GetResourceFile 

func (c *S3IonClient) GetResourceFile(cloud, service, resource string, reportDateUnixMilli int64) *S3IonFile

type S3IonFile 

type S3IonFile struct {
	FileKey  string
	Bucket   string
	Buffer   *bytes.Buffer
	Encoder  *ion.Encoder
	Lock     sync.Mutex
	S3Client *s3.Client
}

func (*S3IonFile) Close 

func (f *S3IonFile) Close(ctx context.Context) error

type S3IonWriterDAO 

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

func NewS3IonWriterDAO 

func NewS3IonWriterDAO(s3Client *awsS3.Client, bucket string, maxRetries int) *S3IonWriterDAO

func (*S3IonWriterDAO) Finish 

func (dao *S3IonWriterDAO) Finish(ctx context.Context) error

func (*S3IonWriterDAO) PutAwsACMCertificates 

func (dao *S3IonWriterDAO) PutAwsACMCertificates(ctx context.Context, resources []*acm.Certificate) error

func (*S3IonWriterDAO) PutAwsApiGatewayRestApis 

func (dao *S3IonWriterDAO) PutAwsApiGatewayRestApis(ctx context.Context, resources []*apigateway.RestApi) error

func (*S3IonWriterDAO) PutAwsApiGatewayV2Apis 

func (dao *S3IonWriterDAO) PutAwsApiGatewayV2Apis(ctx context.Context, resources []*apigatewayv2.Api) error

func (*S3IonWriterDAO) PutAwsApplicationAutoScalingScalingPolicies 

func (dao *S3IonWriterDAO) PutAwsApplicationAutoScalingScalingPolicies(ctx context.Context, resources []*applicationautoscaling.ScalingPolicy) error

func (*S3IonWriterDAO) PutAwsAthenaDataCatalogs 

func (dao *S3IonWriterDAO) PutAwsAthenaDataCatalogs(ctx context.Context, resources []*athena.DataCatalog) error

func (*S3IonWriterDAO) PutAwsAthenaDatabases 

func (dao *S3IonWriterDAO) PutAwsAthenaDatabases(ctx context.Context, resources []*athena.Database) error

func (*S3IonWriterDAO) PutAwsAthenaWorkGroups 

func (dao *S3IonWriterDAO) PutAwsAthenaWorkGroups(ctx context.Context, resources []*athena.WorkGroup) error

func (*S3IonWriterDAO) PutAwsAutoScalingAutoScalingGroups 

func (dao *S3IonWriterDAO) PutAwsAutoScalingAutoScalingGroups(ctx context.Context, resources []*autoscaling.AutoScalingGroup) error

func (*S3IonWriterDAO) PutAwsAutoScalingLaunchConfigurations 

func (dao *S3IonWriterDAO) PutAwsAutoScalingLaunchConfigurations(ctx context.Context, resources []*autoscaling.LaunchConfiguration) error

func (*S3IonWriterDAO) PutAwsBackupBackupPlans 

func (dao *S3IonWriterDAO) PutAwsBackupBackupPlans(ctx context.Context, resources []*backup.BackupPlan) error

func (*S3IonWriterDAO) PutAwsBackupBackupVaults 

func (dao *S3IonWriterDAO) PutAwsBackupBackupVaults(ctx context.Context, resources []*backup.BackupVault) error

func (*S3IonWriterDAO) PutAwsCloudFormationStacks 

func (dao *S3IonWriterDAO) PutAwsCloudFormationStacks(ctx context.Context, resources []*cloudformation.Stack) error

func (*S3IonWriterDAO) PutAwsCloudFrontDistributions 

func (dao *S3IonWriterDAO) PutAwsCloudFrontDistributions(ctx context.Context, resources []*cloudfront.Distribution) error

func (*S3IonWriterDAO) PutAwsCloudTrailTrails 

func (dao *S3IonWriterDAO) PutAwsCloudTrailTrails(ctx context.Context, resources []*cloudtrail.Trail) error

func (*S3IonWriterDAO) PutAwsCloudWatchCompositeAlarms 

func (dao *S3IonWriterDAO) PutAwsCloudWatchCompositeAlarms(ctx context.Context, resources []*cloudwatch.CompositeAlarm) error

func (*S3IonWriterDAO) PutAwsCloudWatchLogsLogGroups 

func (dao *S3IonWriterDAO) PutAwsCloudWatchLogsLogGroups(ctx context.Context, resources []*cloudwatchlogs.LogGroup) error

func (*S3IonWriterDAO) PutAwsCloudWatchMetricAlarms 

func (dao *S3IonWriterDAO) PutAwsCloudWatchMetricAlarms(ctx context.Context, resources []*cloudwatch.MetricAlarm) error

func (*S3IonWriterDAO) PutAwsDynamoDBTables 

func (dao *S3IonWriterDAO) PutAwsDynamoDBTables(ctx context.Context, resources []*dynamodb.Table) error

func (*S3IonWriterDAO) PutAwsEC2Addresses 

func (dao *S3IonWriterDAO) PutAwsEC2Addresses(ctx context.Context, resources []*ec2.Address) error

func (*S3IonWriterDAO) PutAwsEC2DhcpOptions 

func (dao *S3IonWriterDAO) PutAwsEC2DhcpOptions(ctx context.Context, resources []*ec2.DhcpOptions) error

func (*S3IonWriterDAO) PutAwsEC2Images 

func (dao *S3IonWriterDAO) PutAwsEC2Images(ctx context.Context, resources []*ec2.Image) error

func (*S3IonWriterDAO) PutAwsEC2Instances 

func (dao *S3IonWriterDAO) PutAwsEC2Instances(ctx context.Context, resources []*ec2.Instance) error

func (*S3IonWriterDAO) PutAwsEC2InternetGateways 

func (dao *S3IonWriterDAO) PutAwsEC2InternetGateways(ctx context.Context, resources []*ec2.InternetGateway) error

func (*S3IonWriterDAO) PutAwsEC2ManagedPrefixLists 

func (dao *S3IonWriterDAO) PutAwsEC2ManagedPrefixLists(ctx context.Context, resources []*ec2.ManagedPrefixList) error

func (*S3IonWriterDAO) PutAwsEC2NatGateways 

func (dao *S3IonWriterDAO) PutAwsEC2NatGateways(ctx context.Context, resources []*ec2.NatGateway) error

func (*S3IonWriterDAO) PutAwsEC2NetworkAcls 

func (dao *S3IonWriterDAO) PutAwsEC2NetworkAcls(ctx context.Context, resources []*ec2.NetworkAcl) error

func (*S3IonWriterDAO) PutAwsEC2NetworkInterfaces 

func (dao *S3IonWriterDAO) PutAwsEC2NetworkInterfaces(ctx context.Context, resources []*ec2.NetworkInterface) error

func (*S3IonWriterDAO) PutAwsEC2PlacementGroups 

func (dao *S3IonWriterDAO) PutAwsEC2PlacementGroups(ctx context.Context, resources []*ec2.PlacementGroup) error

func (*S3IonWriterDAO) PutAwsEC2ReservedInstances 

func (dao *S3IonWriterDAO) PutAwsEC2ReservedInstances(ctx context.Context, resources []*ec2.ReservedInstances) error

func (*S3IonWriterDAO) PutAwsEC2RouteTables 

func (dao *S3IonWriterDAO) PutAwsEC2RouteTables(ctx context.Context, resources []*ec2.RouteTable) error

func (*S3IonWriterDAO) PutAwsEC2SecurityGroups 

func (dao *S3IonWriterDAO) PutAwsEC2SecurityGroups(ctx context.Context, resources []*ec2.SecurityGroup) error

func (*S3IonWriterDAO) PutAwsEC2Subnets 

func (dao *S3IonWriterDAO) PutAwsEC2Subnets(ctx context.Context, resources []*ec2.Subnet) error

func (*S3IonWriterDAO) PutAwsEC2TransitGatewayPeeringAttachments 

func (dao *S3IonWriterDAO) PutAwsEC2TransitGatewayPeeringAttachments(ctx context.Context, resources []*ec2.TransitGatewayPeeringAttachment) error

func (*S3IonWriterDAO) PutAwsEC2TransitGatewayRouteTables 

func (dao *S3IonWriterDAO) PutAwsEC2TransitGatewayRouteTables(ctx context.Context, resources []*ec2.TransitGatewayRouteTable) error

func (*S3IonWriterDAO) PutAwsEC2TransitGatewayVpcAttachments 

func (dao *S3IonWriterDAO) PutAwsEC2TransitGatewayVpcAttachments(ctx context.Context, resources []*ec2.TransitGatewayVpcAttachment) error

func (*S3IonWriterDAO) PutAwsEC2TransitGateways 

func (dao *S3IonWriterDAO) PutAwsEC2TransitGateways(ctx context.Context, resources []*ec2.TransitGateway) error

func (*S3IonWriterDAO) PutAwsEC2Volumes 

func (dao *S3IonWriterDAO) PutAwsEC2Volumes(ctx context.Context, resources []*ec2.Volume) error

func (*S3IonWriterDAO) PutAwsEC2VpcEndpoints 

func (dao *S3IonWriterDAO) PutAwsEC2VpcEndpoints(ctx context.Context, resources []*ec2.VpcEndpoint) error

func (*S3IonWriterDAO) PutAwsEC2VpcPeeringConnections 

func (dao *S3IonWriterDAO) PutAwsEC2VpcPeeringConnections(ctx context.Context, resources []*ec2.VpcPeeringConnection) error

func (*S3IonWriterDAO) PutAwsEC2Vpcs 

func (dao *S3IonWriterDAO) PutAwsEC2Vpcs(ctx context.Context, resources []*ec2.Vpc) error

func (*S3IonWriterDAO) PutAwsEC2VpnGateways 

func (dao *S3IonWriterDAO) PutAwsEC2VpnGateways(ctx context.Context, resources []*ec2.VpnGateway) error

func (*S3IonWriterDAO) PutAwsECRRepositories 

func (dao *S3IonWriterDAO) PutAwsECRRepositories(ctx context.Context, resources []*ecr.Repository) error

func (*S3IonWriterDAO) PutAwsECSClusters 

func (dao *S3IonWriterDAO) PutAwsECSClusters(ctx context.Context, resources []*ecs.Cluster) error

func (*S3IonWriterDAO) PutAwsECSServices 

func (dao *S3IonWriterDAO) PutAwsECSServices(ctx context.Context, resources []*ecs.Service) error

func (*S3IonWriterDAO) PutAwsECSTasks 

func (dao *S3IonWriterDAO) PutAwsECSTasks(ctx context.Context, resources []*ecs.Task) error

func (*S3IonWriterDAO) PutAwsEFSFileSystems 

func (dao *S3IonWriterDAO) PutAwsEFSFileSystems(ctx context.Context, resources []*efs.FileSystem) error

func (*S3IonWriterDAO) PutAwsElastiCacheCacheClusters 

func (dao *S3IonWriterDAO) PutAwsElastiCacheCacheClusters(ctx context.Context, resources []*elasticache.CacheCluster) error

func (*S3IonWriterDAO) PutAwsElasticLoadBalancingLoadBalancers 

func (dao *S3IonWriterDAO) PutAwsElasticLoadBalancingLoadBalancers(ctx context.Context, resources []*elasticloadbalancing.LoadBalancer) error

func (*S3IonWriterDAO) PutAwsElasticLoadBalancingV2LoadBalancers 

func (dao *S3IonWriterDAO) PutAwsElasticLoadBalancingV2LoadBalancers(ctx context.Context, resources []*elasticloadbalancingv2.LoadBalancer) error

func (*S3IonWriterDAO) PutAwsElasticLoadBalancingV2TargetGroups 

func (dao *S3IonWriterDAO) PutAwsElasticLoadBalancingV2TargetGroups(ctx context.Context, resources []*elasticloadbalancingv2.TargetGroup) error

func (*S3IonWriterDAO) PutAwsIAMGroups 

func (dao *S3IonWriterDAO) PutAwsIAMGroups(ctx context.Context, resources []*iam.Group) error

func (*S3IonWriterDAO) PutAwsIAMPolicies 

func (dao *S3IonWriterDAO) PutAwsIAMPolicies(ctx context.Context, resources []*iam.Policy) error

func (*S3IonWriterDAO) PutAwsIAMRoles 

func (dao *S3IonWriterDAO) PutAwsIAMRoles(ctx context.Context, resources []*iam.Role) error

func (*S3IonWriterDAO) PutAwsIAMUsers 

func (dao *S3IonWriterDAO) PutAwsIAMUsers(ctx context.Context, resources []*iam.User) error

func (*S3IonWriterDAO) PutAwsKMSKeys 

func (dao *S3IonWriterDAO) PutAwsKMSKeys(ctx context.Context, resources []*kms.Key) error

func (*S3IonWriterDAO) PutAwsLambdaFunctions 

func (dao *S3IonWriterDAO) PutAwsLambdaFunctions(ctx context.Context, resources []*lambda.Function) error

func (*S3IonWriterDAO) PutAwsRDSDBClusters 

func (dao *S3IonWriterDAO) PutAwsRDSDBClusters(ctx context.Context, resources []*rds.DBCluster) error

func (*S3IonWriterDAO) PutAwsRDSDBInstances 

func (dao *S3IonWriterDAO) PutAwsRDSDBInstances(ctx context.Context, resources []*rds.DBInstance) error

func (*S3IonWriterDAO) PutAwsRedshiftClusters 

func (dao *S3IonWriterDAO) PutAwsRedshiftClusters(ctx context.Context, resources []*redshift.Cluster) error

func (*S3IonWriterDAO) PutAwsRoute53HostedZones 

func (dao *S3IonWriterDAO) PutAwsRoute53HostedZones(ctx context.Context, resources []*route53.HostedZone) error

func (*S3IonWriterDAO) PutAwsS3Buckets 

func (dao *S3IonWriterDAO) PutAwsS3Buckets(ctx context.Context, resources []*s3.Bucket) error

func (*S3IonWriterDAO) PutAwsSNSSubscriptions 

func (dao *S3IonWriterDAO) PutAwsSNSSubscriptions(ctx context.Context, resources []*sns.Subscription) error

func (*S3IonWriterDAO) PutAwsSNSTopics 

func (dao *S3IonWriterDAO) PutAwsSNSTopics(ctx context.Context, resources []*sns.Topic) error

func (*S3IonWriterDAO) PutAwsSQSQueues 

func (dao *S3IonWriterDAO) PutAwsSQSQueues(ctx context.Context, resources []*sqs.Queue) error

func (*S3IonWriterDAO) PutAwsSSMParameters 

func (dao *S3IonWriterDAO) PutAwsSSMParameters(ctx context.Context, resources []*ssm.Parameter) error

func (*S3IonWriterDAO) PutAwsSecretsManagerSecrets 

func (dao *S3IonWriterDAO) PutAwsSecretsManagerSecrets(ctx context.Context, resources []*secretsmanager.Secret) error

func (*S3IonWriterDAO) PutAwsStorageGatewayGateways 

func (dao *S3IonWriterDAO) PutAwsStorageGatewayGateways(ctx context.Context, resources []*storagegateway.Gateway) error

func (*S3IonWriterDAO) WriteIngestionTimestamp 

func (dao *S3IonWriterDAO) WriteIngestionTimestamp(ctx context.Context, metadata *meta.IngestionTimestamp) error

func (*S3IonWriterDAO) WriteInventoryResults 

func (dao *S3IonWriterDAO) WriteInventoryResults(ctx context.Context, metadata *meta.InventoryResults) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.