mapper

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Mar 1, 2022 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetAwsAPIGatewayClient added in v0.2.0

func GetAwsAPIGatewayClient(ctx context.Context) (*apigateway.Client, error)

GetAwsAPIGatewayClient returns AWS API Gateway client.

func GetAwsAutoScalingGroupClient

func GetAwsAutoScalingGroupClient(ctx context.Context) (*autoscaling.Client, error)

GetAwsAutoScalingGroupClient returns AWS AutoScalingGroup client.

func GetAwsClbClient

func GetAwsClbClient(ctx context.Context) (*elasticloadbalancing.Client, error)

GetAwsClbClient returns AWS CLB client.

func GetAwsDynamoDBClient

func GetAwsDynamoDBClient(ctx context.Context) (*dynamodb.Client, error)

GetAwsDynamoDBClient returns AWS DynamoDB client.

func GetAwsElastiCacheClient

func GetAwsElastiCacheClient(ctx context.Context) (*elasticache.Client, error)

GetAwsElastiCacheClient returns AWS ElastiCache client.

func GetAwsElbClient

func GetAwsElbClient(ctx context.Context) (*elasticloadbalancingv2.Client, error)

GetAwsElbClient returns AWS ALB/NLB client.

func GetAwsFirehoseClient added in v0.2.0

func GetAwsFirehoseClient(ctx context.Context) (*firehose.Client, error)

GetAwsFirehoseClient returns AWS Firehose client.

func GetAwsKinesisClient

func GetAwsKinesisClient(ctx context.Context) (*kinesis.Client, error)

GetAwsKinesisClient returns AWS Kinesis client.

func GetAwsOpenSearchServiceClient

func GetAwsOpenSearchServiceClient(ctx context.Context) (*elasticsearchservice.Client, error)

GetAwsOpenSearchServiceClient returns AWS OpenSearch Service client.

func GetAwsRdsClient

func GetAwsRdsClient(ctx context.Context) (*rds.Client, error)

GetAwsRdsClient returns AWS RDS client.

func GetAwsSnsClient added in v0.2.0

func GetAwsSnsClient(ctx context.Context) (*sns.Client, error)

GetAwsSnsClient returns AWS SNS client.

func GetAwsSqsClient

func GetAwsSqsClient(ctx context.Context) (*sqs.Client, error)

GetAwsSqsClient returns AWS SQS client.

func GetAwsStepFunctionClient

func GetAwsStepFunctionClient(ctx context.Context) (*sfn.Client, error)

GetAwsStepFunctionClient returns AWS StepFunction client.

Types

type AwsAPIGatewayTagsMapper added in v0.2.0

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

AwsAPIGatewayTagsMapper implements TagsMapper for AWS API Gateway.

func (AwsAPIGatewayTagsMapper) GetTagsMapping added in v0.2.0

func (tm AwsAPIGatewayTagsMapper) GetTagsMapping(ctx context.Context) (map[string]Tags, error)

GetTagsMapping returns the latest tags mapping.

type AwsAutoScalingGroupTagsMapper

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

AwsAutoScalingGroupTagsMapper implements TagsMapper for AWS AutoScalingGroup.

func (AwsAutoScalingGroupTagsMapper) GetTagsMapping

func (tm AwsAutoScalingGroupTagsMapper) GetTagsMapping(ctx context.Context) (map[string]Tags, error)

GetTagsMapping returns the latest tags mapping.

type AwsClbTagsMapper

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

AwsClbTagsMapper implements TagsMapper for AWS CLB.

func (AwsClbTagsMapper) GetTagsMapping

func (tm AwsClbTagsMapper) GetTagsMapping(ctx context.Context) (map[string]Tags, error)

GetTagsMapping returns the latest tags mapping.

type AwsDynamoDBTagsMapper

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

AwsDynamoDBTagsMapper implements TagsMapper for AWS DynamoDB.

func (AwsDynamoDBTagsMapper) GetTagsMapping

func (tm AwsDynamoDBTagsMapper) GetTagsMapping(ctx context.Context) (map[string]Tags, error)

GetTagsMapping returns the latest tags mapping.

type AwsElastiCacheTagsMapper

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

AwsElastiCacheTagsMapper implements TagsMapper for AWS ElastiCache.

func (AwsElastiCacheTagsMapper) GetTagsMapping

func (tm AwsElastiCacheTagsMapper) GetTagsMapping(ctx context.Context) (map[string]Tags, error)

GetTagsMapping returns the latest tags mapping.

type AwsElbTagsMapper

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

AwsElbTagsMapper implements TagsMapper for AWS ALB/NLB.

func (AwsElbTagsMapper) GetTagsMapping

func (tm AwsElbTagsMapper) GetTagsMapping(ctx context.Context) (map[string]Tags, error)

GetTagsMapping returns the latest tags mapping.

type AwsFirehoseTagsMapper added in v0.2.0

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

AwsFirehoseTagsMapper implements TagsMapper for AWS Firehose.

func (AwsFirehoseTagsMapper) GetTagsMapping added in v0.2.0

func (tm AwsFirehoseTagsMapper) GetTagsMapping(ctx context.Context) (map[string]Tags, error)

GetTagsMapping returns the latest tags mapping.

type AwsKinesisTagsMapper

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

AwsKinesisTagsMapper implements TagsMapper for AWS Kinesis.

func (AwsKinesisTagsMapper) GetTagsMapping

func (tm AwsKinesisTagsMapper) GetTagsMapping(ctx context.Context) (map[string]Tags, error)

GetTagsMapping returns the latest tags mapping.

type AwsOpenSearchServiceTagsMapper

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

AwsOpenSearchServiceTagsMapper implements TagsMapper for AWS OpenSearch Service.

func (AwsOpenSearchServiceTagsMapper) GetTagsMapping

func (tm AwsOpenSearchServiceTagsMapper) GetTagsMapping(ctx context.Context) (map[string]Tags, error)

GetTagsMapping returns the latest tags mapping.

type AwsRdsTagsMapper

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

AwsRdsTagsMapper implements TagsMapper for AWS RDS.

func (AwsRdsTagsMapper) GetTagsMapping

func (tm AwsRdsTagsMapper) GetTagsMapping(ctx context.Context) (map[string]Tags, error)

GetTagsMapping returns the latest tags mapping.

type AwsSnsTagsMapper added in v0.2.0

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

AwsSnsTagsMapper implements TagsMapper for AWS SNS.

func (AwsSnsTagsMapper) GetTagsMapping added in v0.2.0

func (tm AwsSnsTagsMapper) GetTagsMapping(ctx context.Context) (map[string]Tags, error)

GetTagsMapping returns the latest tags mapping.

type AwsSqsTagsMapper

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

AwsSqsTagsMapper implements TagsMapper for AWS SQS.

func (AwsSqsTagsMapper) GetTagsMapping

func (tm AwsSqsTagsMapper) GetTagsMapping(ctx context.Context) (map[string]Tags, error)

GetTagsMapping returns the latest tags mapping.

type AwsStepFunctionTagsMapper

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

AwsStepFunctionTagsMapper implements TagsMapper for AWS StepFunction.

func (AwsStepFunctionTagsMapper) GetTagsMapping

func (tm AwsStepFunctionTagsMapper) GetTagsMapping(ctx context.Context) (map[string]Tags, error)

GetTagsMapping returns the latest tags mapping.

type Tags

type Tags = []string

Tags represents resource tags.

type TagsMapper

type TagsMapper interface {
	GetTagsMapping(ctx context.Context) (map[string]Tags, error)
}

TagsMapper is an interface to fetch resources and map their ids and tags.

func BuildTagsMapper

func BuildTagsMapper(it datadog.IntegrationTarget) (TagsMapper, error)

BuildTagsMapper build the proper TagsMapper implementation.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL