Documentation
¶
Index ¶
- func GetAwsAPIGatewayClient(ctx context.Context) (*apigateway.Client, error)
- func GetAwsAutoScalingGroupClient(ctx context.Context) (*autoscaling.Client, error)
- func GetAwsClbClient(ctx context.Context) (*elasticloadbalancing.Client, error)
- func GetAwsDynamoDBClient(ctx context.Context) (*dynamodb.Client, error)
- func GetAwsElastiCacheClient(ctx context.Context) (*elasticache.Client, error)
- func GetAwsElbClient(ctx context.Context) (*elasticloadbalancingv2.Client, error)
- func GetAwsFirehoseClient(ctx context.Context) (*firehose.Client, error)
- func GetAwsKinesisClient(ctx context.Context) (*kinesis.Client, error)
- func GetAwsOpenSearchServiceClient(ctx context.Context) (*elasticsearchservice.Client, error)
- func GetAwsRdsClient(ctx context.Context) (*rds.Client, error)
- func GetAwsSnsClient(ctx context.Context) (*sns.Client, error)
- func GetAwsSqsClient(ctx context.Context) (*sqs.Client, error)
- func GetAwsStepFunctionClient(ctx context.Context) (*sfn.Client, error)
- type AwsAPIGatewayClient
- type AwsAPIGatewayTagsMapper
- type AwsAutoScalingGroupClient
- type AwsAutoScalingGroupTagsMapper
- type AwsClbClient
- type AwsClbTagsMapper
- type AwsDynamoDBClient
- type AwsDynamoDBTagsMapper
- type AwsElastiCacheClient
- type AwsElastiCacheTagsMapper
- type AwsElbClient
- type AwsElbTagsMapper
- type AwsFirehoseClient
- type AwsFirehoseTagsMapper
- type AwsKinesisClient
- type AwsKinesisTagsMapper
- type AwsOpenSearchServiceClient
- type AwsOpenSearchServiceTagsMapper
- type AwsRdsClient
- type AwsRdsTagsMapper
- type AwsSnsClient
- type AwsSnsTagsMapper
- type AwsSqsClient
- type AwsSqsTagsMapper
- type AwsStepFunctionClient
- type AwsStepFunctionTagsMapper
- type Tags
- type TagsMapper
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 ¶
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
GetAwsFirehoseClient returns AWS Firehose client.
func GetAwsKinesisClient ¶
GetAwsKinesisClient returns AWS Kinesis client.
func GetAwsOpenSearchServiceClient ¶
func GetAwsOpenSearchServiceClient(ctx context.Context) (*elasticsearchservice.Client, error)
GetAwsOpenSearchServiceClient returns AWS OpenSearch Service client.
func GetAwsRdsClient ¶
GetAwsRdsClient returns AWS RDS client.
func GetAwsSnsClient ¶ added in v0.2.0
GetAwsSnsClient returns AWS SNS client.
func GetAwsSqsClient ¶
GetAwsSqsClient returns AWS SQS 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
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 ¶
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 ¶
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 ¶
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 ¶
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
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 ¶
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 ¶
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
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 ¶
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 ¶
GetTagsMapping returns the latest tags mapping.
type TagsMapper ¶
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.