mapper

package
v0.2.2 Latest Latest
Warning

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

 Go to latest Published: May 7, 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 AwsAPIGatewayClient added in v0.2.1 

type AwsAPIGatewayClient interface {
	GetRestApis(
		ctx context.Context,
		params *apigateway.GetRestApisInput,
		optFns ...func(*apigateway.Options),
	) (*apigateway.GetRestApisOutput, error)
}

AwsAPIGatewayClient is abstract interface of *apigateway.Client.

type AwsAPIGatewayTagsMapper added in v0.2.0 

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

AwsAPIGatewayTagsMapper implements TagsMapper for AWS API Gateway.

func BuildAwsAPIGatewayTagsMapper added in v0.2.1 

func BuildAwsAPIGatewayTagsMapper(cache *goCache.Cache, client AwsAPIGatewayClient) AwsAPIGatewayTagsMapper

BuildAwsAPIGatewayTagsMapper builds AwsAPIGatewayTagsMapper from args.

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 AwsAutoScalingGroupClient added in v0.2.1 

type AwsAutoScalingGroupClient interface {
	DescribeAutoScalingGroups(
		ctx context.Context,
		params *autoscaling.DescribeAutoScalingGroupsInput,
		optFns ...func(*autoscaling.Options),
	) (*autoscaling.DescribeAutoScalingGroupsOutput, error)
}

AwsAutoScalingGroupClient is abstract interface of *autoscaling.Client.

type AwsAutoScalingGroupTagsMapper 

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

AwsAutoScalingGroupTagsMapper implements TagsMapper for AWS AutoScalingGroup.

func BuildAwsAutoScalingGroupTagsMapper added in v0.2.1 

func BuildAwsAutoScalingGroupTagsMapper(cache *goCache.Cache, client AwsAutoScalingGroupClient) AwsAutoScalingGroupTagsMapper

BuildAwsAutoScalingGroupTagsMapper builds AwsAutoScalingGroupTagsMapper from args.

func (AwsAutoScalingGroupTagsMapper) GetTagsMapping 

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

GetTagsMapping returns the latest tags mapping.

type AwsClbClient added in v0.2.1 

type AwsClbClient interface {
	DescribeLoadBalancers(
		ctx context.Context,
		params *elasticloadbalancing.DescribeLoadBalancersInput,
		optFns ...func(*elasticloadbalancing.Options),
	) (*elasticloadbalancing.DescribeLoadBalancersOutput, error)
	DescribeTags(
		ctx context.Context,
		params *elasticloadbalancing.DescribeTagsInput,
		optFns ...func(*elasticloadbalancing.Options),
	) (*elasticloadbalancing.DescribeTagsOutput, error)
}

AwsClbClient is abstract interface of *elasticloadbalancing.Client.

type AwsClbTagsMapper 

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

AwsClbTagsMapper implements TagsMapper for AWS CLB.

func BuildAwsClbTagsMapper added in v0.2.1 

func BuildAwsClbTagsMapper(cache *goCache.Cache, client AwsClbClient) AwsClbTagsMapper

BuildAwsClbTagsMapper builds AwsClbTagsMapper from args.

func (AwsClbTagsMapper) GetTagsMapping 

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

GetTagsMapping returns the latest tags mapping.

type AwsDynamoDBClient added in v0.2.1 

type AwsDynamoDBClient interface {
	DescribeTable(
		ctx context.Context,
		params *dynamodb.DescribeTableInput,
		optFns ...func(*dynamodb.Options),
	) (*dynamodb.DescribeTableOutput, error)
	ListTables(
		ctx context.Context,
		params *dynamodb.ListTablesInput,
		optFns ...func(*dynamodb.Options),
	) (*dynamodb.ListTablesOutput, error)
	ListTagsOfResource(
		ctx context.Context,
		params *dynamodb.ListTagsOfResourceInput,
		optFns ...func(*dynamodb.Options),
	) (*dynamodb.ListTagsOfResourceOutput, error)
}

AwsDynamoDBClient is abstract interface of *dynamodb.Client.

type AwsDynamoDBTagsMapper 

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

AwsDynamoDBTagsMapper implements TagsMapper for AWS DynamoDB.

func BuildAwsDynamoDBTagsMapper added in v0.2.1 

func BuildAwsDynamoDBTagsMapper(cache *goCache.Cache, client AwsDynamoDBClient) AwsDynamoDBTagsMapper

BuildAwsDynamoDBTagsMapper builds AwsDynamoDBTagsMapper from args.

func (AwsDynamoDBTagsMapper) GetTagsMapping 

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

GetTagsMapping returns the latest tags mapping.

type AwsElastiCacheClient added in v0.2.1 

type AwsElastiCacheClient interface {
	DescribeCacheClusters(
		ctx context.Context,
		params *elasticache.DescribeCacheClustersInput,
		optFns ...func(*elasticache.Options),
	) (*elasticache.DescribeCacheClustersOutput, error)
	ListTagsForResource(
		ctx context.Context,
		params *elasticache.ListTagsForResourceInput,
		optFns ...func(*elasticache.Options),
	) (*elasticache.ListTagsForResourceOutput, error)
}

AwsElastiCacheClient is abstract interface of *elasticache.Client.

type AwsElastiCacheTagsMapper 

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

AwsElastiCacheTagsMapper implements TagsMapper for AWS ElastiCache.

func BuildAwsElastiCacheTagsMapper added in v0.2.1 

func BuildAwsElastiCacheTagsMapper(cache *goCache.Cache, client AwsElastiCacheClient) AwsElastiCacheTagsMapper

BuildAwsElastiCacheTagsMapper builds AwsElastiCacheTagsMapper from args.

func (AwsElastiCacheTagsMapper) GetTagsMapping 

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

GetTagsMapping returns the latest tags mapping.

type AwsElbClient added in v0.2.1 

type AwsElbClient interface {
	DescribeLoadBalancers(
		ctx context.Context,
		params *elasticloadbalancingv2.DescribeLoadBalancersInput,
		optFns ...func(*elasticloadbalancingv2.Options),
	) (*elasticloadbalancingv2.DescribeLoadBalancersOutput, error)
	DescribeTags(
		ctx context.Context,
		params *elasticloadbalancingv2.DescribeTagsInput,
		optFns ...func(*elasticloadbalancingv2.Options),
	) (*elasticloadbalancingv2.DescribeTagsOutput, error)
}

AwsElbClient is abstract interface of *elasticloadbalancingv2.Client.

type AwsElbTagsMapper 

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

AwsElbTagsMapper implements TagsMapper for AWS ALB/NLB.

func BuildAwsElbTagsMapper added in v0.2.1 

func BuildAwsElbTagsMapper(cache *goCache.Cache, client AwsElbClient) AwsElbTagsMapper

BuildAwsElbTagsMapper builds AwsElbTagsMapper from args.

func (AwsElbTagsMapper) GetTagsMapping 

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

GetTagsMapping returns the latest tags mapping.

type AwsFirehoseClient added in v0.2.1 

type AwsFirehoseClient interface {
	ListDeliveryStreams(
		ctx context.Context,
		params *firehose.ListDeliveryStreamsInput,
		optFns ...func(*firehose.Options),
	) (*firehose.ListDeliveryStreamsOutput, error)
	ListTagsForDeliveryStream(
		ctx context.Context,
		params *firehose.ListTagsForDeliveryStreamInput,
		optFns ...func(*firehose.Options),
	) (*firehose.ListTagsForDeliveryStreamOutput, error)
}

AwsFirehoseClient is abstract interface of *firehose.Client.

type AwsFirehoseTagsMapper added in v0.2.0 

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

AwsFirehoseTagsMapper implements TagsMapper for AWS Firehose.

func BuildAwsFirehoseTagsMapper added in v0.2.1 

func BuildAwsFirehoseTagsMapper(cache *goCache.Cache, client AwsFirehoseClient) AwsFirehoseTagsMapper

BuildAwsFirehoseTagsMapper builds AwsFirehoseTagsMapper from args.

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 AwsKinesisClient added in v0.2.1 

type AwsKinesisClient interface {
	ListStreams(
		ctx context.Context,
		params *kinesis.ListStreamsInput,
		optFns ...func(*kinesis.Options),
	) (*kinesis.ListStreamsOutput, error)
	ListTagsForStream(
		ctx context.Context,
		params *kinesis.ListTagsForStreamInput,
		optFns ...func(*kinesis.Options),
	) (*kinesis.ListTagsForStreamOutput, error)
}

AwsKinesisClient is abstract interface of *kinesis.Client.

type AwsKinesisTagsMapper 

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

AwsKinesisTagsMapper implements TagsMapper for AWS Kinesis.

func BuildAwsKinesisTagsMapper added in v0.2.1 

func BuildAwsKinesisTagsMapper(cache *goCache.Cache, client AwsKinesisClient) AwsKinesisTagsMapper

BuildAwsKinesisTagsMapper builds AwsKinesisTagsMapper from args.

func (AwsKinesisTagsMapper) GetTagsMapping 

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

GetTagsMapping returns the latest tags mapping.

type AwsOpenSearchServiceClient added in v0.2.1 

type AwsOpenSearchServiceClient interface {
	ListDomainNames(
		ctx context.Context,
		params *elasticsearchservice.ListDomainNamesInput,
		optFns ...func(*elasticsearchservice.Options),
	) (*elasticsearchservice.ListDomainNamesOutput, error)
	DescribeElasticsearchDomains(
		ctx context.Context,
		params *elasticsearchservice.DescribeElasticsearchDomainsInput,
		optFns ...func(*elasticsearchservice.Options),
	) (*elasticsearchservice.DescribeElasticsearchDomainsOutput, error)
	ListTags(
		ctx context.Context,
		params *elasticsearchservice.ListTagsInput,
		optFns ...func(*elasticsearchservice.Options),
	) (*elasticsearchservice.ListTagsOutput, error)
}

AwsOpenSearchServiceClient is abstract interface of *elasticsearchservice.Client.

type AwsOpenSearchServiceTagsMapper 

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

AwsOpenSearchServiceTagsMapper implements TagsMapper for AWS OpenSearch Service.

func BuildAwsOpenSearchServiceTagsMapper added in v0.2.1 

func BuildAwsOpenSearchServiceTagsMapper(cache *goCache.Cache, client AwsOpenSearchServiceClient) AwsOpenSearchServiceTagsMapper

BuildAwsOpenSearchServiceTagsMapper builds AwsOpenSearchServiceTagsMapper from args.

func (AwsOpenSearchServiceTagsMapper) GetTagsMapping 

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

GetTagsMapping returns the latest tags mapping.

type AwsRdsClient added in v0.2.1 

type AwsRdsClient interface {
	DescribeDBInstances(
		ctx context.Context,
		params *rds.DescribeDBInstancesInput,
		optFns ...func(*rds.Options),
	) (*rds.DescribeDBInstancesOutput, error)
}

AwsRdsClient is abstract interface of *rds.Client.

type AwsRdsTagsMapper 

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

AwsRdsTagsMapper implements TagsMapper for AWS RDS.

func BuildAwsRdsTagsMapper added in v0.2.1 

func BuildAwsRdsTagsMapper(cache *goCache.Cache, client AwsRdsClient) AwsRdsTagsMapper

BuildAwsRdsTagsMapper builds AwsRdsTagsMapper from args.

func (AwsRdsTagsMapper) GetTagsMapping 

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

GetTagsMapping returns the latest tags mapping.

type AwsSnsClient added in v0.2.1 

type AwsSnsClient interface {
	ListTopics(
		ctx context.Context,
		params *sns.ListTopicsInput,
		optFns ...func(*sns.Options),
	) (*sns.ListTopicsOutput, error)
	ListTagsForResource(
		ctx context.Context,
		params *sns.ListTagsForResourceInput,
		optFns ...func(*sns.Options),
	) (*sns.ListTagsForResourceOutput, error)
}

AwsSnsClient is abstract interface of *sns.Client.

type AwsSnsTagsMapper added in v0.2.0 

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

AwsSnsTagsMapper implements TagsMapper for AWS SNS.

func BuildAwsSnsTagsMapper added in v0.2.1 

func BuildAwsSnsTagsMapper(cache *goCache.Cache, client AwsSnsClient) AwsSnsTagsMapper

BuildAwsSnsTagsMapper builds AwsSnsTagsMapper from args.

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 AwsSqsClient added in v0.2.1 

type AwsSqsClient interface {
	ListQueues(
		ctx context.Context,
		params *sqs.ListQueuesInput,
		optFns ...func(*sqs.Options),
	) (*sqs.ListQueuesOutput, error)
	ListQueueTags(
		ctx context.Context,
		params *sqs.ListQueueTagsInput,
		optFns ...func(*sqs.Options),
	) (*sqs.ListQueueTagsOutput, error)
}

AwsSqsClient is abstract interface of *sqs.Client.

type AwsSqsTagsMapper 

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

AwsSqsTagsMapper implements TagsMapper for AWS SQS.

func BuildAwsSqsTagsMapper added in v0.2.1 

func BuildAwsSqsTagsMapper(cache *goCache.Cache, client AwsSqsClient) AwsSqsTagsMapper

BuildAwsSqsTagsMapper builds AwsSqsTagsMapper from args.

func (AwsSqsTagsMapper) GetTagsMapping 

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

GetTagsMapping returns the latest tags mapping.

type AwsStepFunctionClient added in v0.2.1 

type AwsStepFunctionClient interface {
	ListStateMachines(
		ctx context.Context,
		params *sfn.ListStateMachinesInput,
		optFns ...func(*sfn.Options),
	) (*sfn.ListStateMachinesOutput, error)
	ListTagsForResource(
		ctx context.Context,
		params *sfn.ListTagsForResourceInput,
		optFns ...func(*sfn.Options),
	) (*sfn.ListTagsForResourceOutput, error)
}

AwsStepFunctionClient is abstract interface of *sfn.Client.

type AwsStepFunctionTagsMapper 

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

AwsStepFunctionTagsMapper implements TagsMapper for AWS StepFunction.

func BuildAwsStepFunctionTagsMapper added in v0.2.1 

func BuildAwsStepFunctionTagsMapper(cache *goCache.Cache, client AwsStepFunctionClient) AwsStepFunctionTagsMapper

BuildAwsStepFunctionTagsMapper builds AwsStepFunctionTagsMapper from args.

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.

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.