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

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

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

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.

Jump to

Keyboard shortcuts

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