aws

package
v0.12.0 Latest Latest
Warning

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

 Go to latest Published: Feb 13, 2024 License: MIT-0 Imports: 60 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AccountId 

func AccountId() string

func FormatError 

func FormatError(err error) error

Return cleaner error message for service API errors

func FormatErrorAsMessageOnly 

func FormatErrorAsMessageOnly(err error) error

Return cleaner error message for service API errors

func GetConfig 

func GetConfig() aws.Config

func Init 

func Init(awsProfile, awsRegion string, awsDebug, awsResponseBodyDebug bool)

func NewCloudwatchDimensionsFilter 

func NewCloudwatchDimensionsFilter(dimensions []string) []types.DimensionFilter

func NewEC2DescriptionFilter 

func NewEC2DescriptionFilter(description string) types.Filter

func NewEC2ElasticIpFilter 

func NewEC2ElasticIpFilter(eipId string) types.Filter

func NewEC2InstanceIdFilter 

func NewEC2InstanceIdFilter(instanceId string) types.Filter

func NewEC2InstanceStateFilter 

func NewEC2InstanceStateFilter(states []string) types.Filter

func NewEC2InstanceTypeFilter added in v0.11.0 

func NewEC2InstanceTypeFilter(instanceType string) types.Filter

func NewEC2InternetGatewayFilter 

func NewEC2InternetGatewayFilter(internetGatewayId string) types.Filter

func NewEC2InternetGatewayVpcFilter 

func NewEC2InternetGatewayVpcFilter(vpcId string) types.Filter

func NewEC2NatGatewayFilter 

func NewEC2NatGatewayFilter(natGatewayId string) types.Filter

func NewEC2NetworkAclFilter 

func NewEC2NetworkAclFilter(networkAclId string) types.Filter

func NewEC2NetworkInterfaceFilter 

func NewEC2NetworkInterfaceFilter(networkInterfaceId string) types.Filter

func NewEC2NetworkInterfaceInstanceFilter 

func NewEC2NetworkInterfaceInstanceFilter(instanceId string) types.Filter

func NewEC2NetworkInterfaceIpFilter 

func NewEC2NetworkInterfaceIpFilter(ipAddress string) types.Filter

func NewEC2PrefixListFilter 

func NewEC2PrefixListFilter(prefixListId string) types.Filter

func NewEC2RouteTableFilter 

func NewEC2RouteTableFilter(routeTableId string) types.Filter

func NewEC2SecurityGroupFilter 

func NewEC2SecurityGroupFilter(securityGroupId string) types.Filter

func NewEC2SecurityGroupRuleFilter 

func NewEC2SecurityGroupRuleFilter(securityGroupRuleId string) types.Filter

func NewEC2SubnetFilter 

func NewEC2SubnetFilter(subnetId string) types.Filter

func NewEC2TagKeyFilter 

func NewEC2TagKeyFilter(tagKey string) types.Filter

func NewEC2VpcEndpointFilter 

func NewEC2VpcEndpointFilter(vpcEndpointId string) types.Filter

func NewEC2VpcFilter 

func NewEC2VpcFilter(vpcId string) types.Filter

func Partition 

func Partition() string

func Region 

func Region() string

Types

type ACMClient 

type ACMClient struct {
	*acm.Client
}

func NewACMClient 

func NewACMClient() *ACMClient

func (*ACMClient) DeleteCertificate 

func (c *ACMClient) DeleteCertificate(arn string) error

func (*ACMClient) DescribeCertificate 

func (c *ACMClient) DescribeCertificate(arn string) (*types.CertificateDetail, error)

func (*ACMClient) ListCertificates 

func (c *ACMClient) ListCertificates() ([]types.CertificateSummary, error)

func (*ACMClient) RequestCertificate 

func (c *ACMClient) RequestCertificate(fqdn string, sans []string) (string, error)

type AMPClient 

type AMPClient struct {
	*amp.Client
}

func NewAMPClient 

func NewAMPClient() *AMPClient

func (*AMPClient) CreateWorkspace 

func (c *AMPClient) CreateWorkspace(alias string) (*amp.CreateWorkspaceOutput, error)

The CreateWorkspace operation creates a workspace. A workspace is a logical space dedicated to the storage and querying of Prometheus metrics. You can have one or more workspaces in each Region in your account.

func (*AMPClient) DeleteWorkspace 

func (c *AMPClient) DeleteWorkspace(id string) error

The DeleteWorkspace operation deletes an existing workspace.

func (*AMPClient) DescribeLoggingConfiguration 

func (c *AMPClient) DescribeLoggingConfiguration(workspaceId string) (*types.LoggingConfigurationMetadata, error)

The DescribeLoggingConfiguration operation returns complete information about the current logging configuration of the workspace.

func (*AMPClient) DescribeRuleGroupsNamespace 

func (c *AMPClient) DescribeRuleGroupsNamespace(name, workspaceId string) (*types.RuleGroupsNamespaceDescription, error)

The DescribeRuleGroupsNamespace operation returns complete information about one rule groups namespace. To retrieve a list of rule groups namespaces, use ListRuleGroupsNamespaces.

func (*AMPClient) DescribeWorkspace 

func (c *AMPClient) DescribeWorkspace(workspaceId string) (*types.WorkspaceDescription, error)

The DescribeWorkspace operation displays information about an existing workspace.

func (*AMPClient) ListRuleGroupsNamespaces 

func (c *AMPClient) ListRuleGroupsNamespaces(workspaceId string) ([]types.RuleGroupsNamespaceSummary, error)

The ListRuleGroupsNamespaces operation returns a list of rule groups namespaces in a workspace.

func (*AMPClient) ListWorkspaces 

func (c *AMPClient) ListWorkspaces(alias string) ([]types.WorkspaceSummary, error)

The ListWorkspaces operation lists all of the Amazon Managed Service for Prometheus workspaces in your account. This includes workspaces being created or deleted.

type AutoscalingClient 

type AutoscalingClient struct {
	*autoscaling.Client
}

func NewAutoscalingClient 

func NewAutoscalingClient() *AutoscalingClient

func (*AutoscalingClient) DescribeAutoScalingGroups 

func (c *AutoscalingClient) DescribeAutoScalingGroups(name string) ([]types.AutoScalingGroup, error)

type CertificateValidationMetadataWaiter 

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

CertificateValidationMetadataWaiter defines the waiters for CertificateValidationMetadata

func (*CertificateValidationMetadataWaiter) Wait 

func (w *CertificateValidationMetadataWaiter) Wait(ctx context.Context, params *acm.DescribeCertificateInput, maxWaitDur time.Duration, optFns ...func(*CertificateValidationMetadataWaiterOptions)) error

Wait calls the waiter function for CertificateValidationMetadata waiter. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.

func (*CertificateValidationMetadataWaiter) WaitForOutput 

func (w *CertificateValidationMetadataWaiter) WaitForOutput(ctx context.Context, params *acm.DescribeCertificateInput, maxWaitDur time.Duration, optFns ...func(*CertificateValidationMetadataWaiterOptions)) (*acm.DescribeCertificateOutput, error)

WaitForOutput calls the waiter function for CertificateValidationMetadata waiter and returns the output of the successful operation. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.

type CertificateValidationMetadataWaiterOptions 

type CertificateValidationMetadataWaiterOptions acm.CertificateValidatedWaiterOptions

type CloudformationClient 

type CloudformationClient struct {
	*cloudformation.Client
}

func NewCloudformationClient 

func NewCloudformationClient() *CloudformationClient

func (*CloudformationClient) CreateStack 

func (c *CloudformationClient) CreateStack(stackName, templateBody string, params map[string]string, caps []types.Capability) error

func (*CloudformationClient) DeleteStack 

func (c *CloudformationClient) DeleteStack(stackName string) error

func (*CloudformationClient) DescribeStacks 

func (c *CloudformationClient) DescribeStacks(stackName string) ([]types.Stack, error)

type CloudtrailClient 

type CloudtrailClient struct {
	*cloudtrail.Client
	Region string
}

func NewCloudtrailClient 

func NewCloudtrailClient() *CloudtrailClient

func (*CloudtrailClient) GetTrail 

func (c *CloudtrailClient) GetTrail(trailNameOrArn string) (*types.Trail, error)

Returns settings information for a specified trail.

func (*CloudtrailClient) GetTrailStatus 

func (c *CloudtrailClient) GetTrailStatus(trailNameOrArn string) (*cloudtrail.GetTrailStatusOutput, error)

Returns a JSON-formatted list of information about the specified trail. Fields include information on delivery errors, Amazon SNS and Amazon S3 errors, and start and stop logging times for each trail.

func (*CloudtrailClient) ListTrails 

func (c *CloudtrailClient) ListTrails() ([]types.TrailInfo, error)

Lists trails that are in the current account.

func (*CloudtrailClient) LookupEvents 

func (c *CloudtrailClient) LookupEvents(insights bool, filters []types.LookupAttribute) ([]types.Event, error)

Looks up management events or CloudTrail Insights events that are captured by CloudTrail. You can look up events that occurred in a region within the last 90 days.

type CloudwatchClient 

type CloudwatchClient struct {
	*cloudwatch.Client
}

func NewCloudwatchClient 

func NewCloudwatchClient() *CloudwatchClient

func (*CloudwatchClient) DescribeAlarms added in v0.9.0 

func (c *CloudwatchClient) DescribeAlarms(namePrefix string) ([]types.CompositeAlarm, []types.MetricAlarm, error)

Retrieves the specified alarms. You can filter the results by specifying a prefix for the alarm name, the alarm state, or a prefix for any action.

func (*CloudwatchClient) ListMetrics 

func (c *CloudwatchClient) ListMetrics(dimensions []types.DimensionFilter, metricName, namespace string) ([]types.Metric, error)

List the specified metrics. You can use the returned metrics with GetMetricData or GetMetricStatistics to get statistical data.

type CloudwatchlogsClient 

type CloudwatchlogsClient struct {
	*cloudwatchlogs.Client
}

func NewCloudwatchlogsClient 

func NewCloudwatchlogsClient() *CloudwatchlogsClient

func (*CloudwatchlogsClient) CreateLogGroup 

func (c *CloudwatchlogsClient) CreateLogGroup(name string) (*cloudwatchlogs.CreateLogGroupOutput, error)

Creates a log group with the specified name.

func (*CloudwatchlogsClient) DeleteLogGroup 

func (c *CloudwatchlogsClient) DeleteLogGroup(name string) error

Deletes the specified log group and permanently deletes all the archived log events associated with the log group.

func (*CloudwatchlogsClient) DescribeLogGroups 

func (c *CloudwatchlogsClient) DescribeLogGroups(namePrefix string) ([]types.LogGroup, error)

Lists the specified log groups. You can list all your log groups or filter the results by prefix. The results are ASCII-sorted by log group name.

func (*CloudwatchlogsClient) DescribeLogStreams 

func (c *CloudwatchlogsClient) DescribeLogStreams(namePrefix, logGroupName string) ([]types.LogStream, error)

Lists the log streams for the specified log group. You can list all the log streams or filter the results by prefix. You can also control how the results are ordered.

func (*CloudwatchlogsClient) DescribeQueries 

func (c *CloudwatchlogsClient) DescribeQueries() ([]types.QueryInfo, error)

Returns a list of CloudWatch Logs Insights queries that are scheduled, running, or have been run recently in this account. You can request all queries or limit it to queries of a specific log group or queries with a certain status.

func (*CloudwatchlogsClient) GetLogEvents 

func (c *CloudwatchlogsClient) GetLogEvents(logStreamName, logGroupName string) ([]types.OutputLogEvent, error)

Lists log events from the specified log stream. You can list all of the log events or filter using a time range. By default, this operation returns as many log events as can fit in a response size of 1MB (up to 10,000 log events).

func (*CloudwatchlogsClient) GetQueryResults 

func (c *CloudwatchlogsClient) GetQueryResults(queryId string) (*cloudwatchlogs.GetQueryResultsOutput, error)

Returns the results from the specified query. Only the fields requested in the query are returned, along with a @ptr field, which is the identifier for the log record. You can use the value of @ptr in a GetLogRecord operation to get the full log record.

func (*CloudwatchlogsClient) StartQuery 

func (c *CloudwatchlogsClient) StartQuery(logGroupName, queryString string, start, end time.Time) (string, error)

Schedules a query of a log group using CloudWatch Logs Insights. You specify the log group and time range to query and the query string to use.

type CognitoUserPoolClient added in v0.10.0 

type CognitoUserPoolClient struct {
	*cognitoidp.Client
}

func NewCognitoUserPoolClient added in v0.10.0 

func NewCognitoUserPoolClient() *CognitoUserPoolClient

func (*CognitoUserPoolClient) CreateUserPool added in v0.10.0 

func (c *CognitoUserPoolClient) CreateUserPool(name string) (*types.UserPoolType, error)

Creates a new Amazon Cognito user pool and sets the password policy for the pool.

func (*CognitoUserPoolClient) CreateUserPoolClient added in v0.10.0 

func (c *CognitoUserPoolClient) CreateUserPoolClient(oauthScopes, callbackUrls []string, clientName, userPoolID string) (*types.UserPoolClientType, error)

Creates the user pool client. When you create a new user pool client, token revocation is automatically activated.

func (*CognitoUserPoolClient) CreateUserPoolDomain added in v0.10.0 

func (c *CognitoUserPoolClient) CreateUserPoolDomain(domain, id string) (*cognitoidp.CreateUserPoolDomainOutput, error)

Creates a new domain for a user pool.

func (*CognitoUserPoolClient) DeleteUserPool added in v0.10.0 

func (c *CognitoUserPoolClient) DeleteUserPool(id string) error

Deletes the specified Amazon Cognito user pool.

func (*CognitoUserPoolClient) DeleteUserPoolClient added in v0.10.0 

func (c *CognitoUserPoolClient) DeleteUserPoolClient(clientID, userPoolID string) error

Allows the developer to delete the user pool client.

func (*CognitoUserPoolClient) DeleteUserPoolDomain added in v0.10.0 

func (c *CognitoUserPoolClient) DeleteUserPoolDomain(domain, userPoolID string) error

Deletes a domain for a user pool.

func (*CognitoUserPoolClient) DescribeUserPool added in v0.10.0 

func (c *CognitoUserPoolClient) DescribeUserPool(id string) (*types.UserPoolType, error)

Returns the configuration information and metadata of the specified user pool.

func (*CognitoUserPoolClient) DescribeUserPoolClient added in v0.10.0 

func (c *CognitoUserPoolClient) DescribeUserPoolClient(clientID, userPoolID string) (*types.UserPoolClientType, error)

Client method for returning the configuration information and metadata of the specified user pool app client.

func (*CognitoUserPoolClient) DescribeUserPoolDomain added in v0.10.0 

func (c *CognitoUserPoolClient) DescribeUserPoolDomain(domain string) (*types.DomainDescriptionType, error)

Gets information about a domain.

func (*CognitoUserPoolClient) ListUserPoolClients added in v0.10.0 

func (c *CognitoUserPoolClient) ListUserPoolClients(userPoolID string) ([]types.UserPoolClientDescription, error)

Lists the clients that have been created for the specified user pool.

func (*CognitoUserPoolClient) ListUserPools added in v0.10.0 

func (c *CognitoUserPoolClient) ListUserPools() ([]types.UserPoolDescriptionType, error)

Lists the user pools associated with an AWS account.

type DescribeQueriesAPIClient 

type DescribeQueriesAPIClient interface {
	DescribeQueries(context.Context, *cloudwatchlogs.DescribeQueriesInput, ...func(*cloudwatchlogs.Options)) (*cloudwatchlogs.DescribeQueriesOutput, error)
}

DescribeQueriesAPIClient is a client that implements the DescribeQueries operation.

type DescribeQueriesPaginator 

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

DescribeQueriesPaginator is a paginator for DescribeQueries

func NewDescribeQueriesPaginator 

func NewDescribeQueriesPaginator(client DescribeQueriesAPIClient, params *cloudwatchlogs.DescribeQueriesInput, optFns ...func(*DescribeQueriesPaginatorOptions)) *DescribeQueriesPaginator

NewDescribeQueriesPaginator returns a new DescribeQueriesPaginator

func (*DescribeQueriesPaginator) HasMorePages 

func (p *DescribeQueriesPaginator) HasMorePages() bool

HasMorePages returns a boolean indicating whether more pages are available

func (*DescribeQueriesPaginator) NextPage 

func (p *DescribeQueriesPaginator) NextPage(ctx context.Context, optFns ...func(*cloudwatchlogs.Options)) (*cloudwatchlogs.DescribeQueriesOutput, error)

NextPage retrieves the next DescribeQueries page.

type DescribeQueriesPaginatorOptions 

type DescribeQueriesPaginatorOptions struct {
	// Limits the number of returned queries to the specified number.
	MaxResults int32

	// Set to true if pagination should stop if the service returns a pagination token
	// that matches the most recent token provided to the service.
	StopOnDuplicateToken bool
}

DescribeQueriesPaginatorOptions is the paginator options for DescribeQueries

type DescribeWorkspaceAPIClient 

type DescribeWorkspaceAPIClient interface {
	DescribeWorkspace(context.Context, *grafana.DescribeWorkspaceInput, ...func(*grafana.Options)) (*grafana.DescribeWorkspaceOutput, error)
}

DescribeWorkspaceAPIClient is a client that implements the DescribeWorkspace operation.

type EC2Client 

type EC2Client struct {
	*ec2.Client
}

func NewEC2Client 

func NewEC2Client() *EC2Client

func (*EC2Client) CreateTags 

func (c *EC2Client) CreateTags(resources []string, tags map[string]string) error

Adds or overwrites only the specified tags for the specified Amazon EC2 resource or resources. When you specify an existing tag key, the value is overwritten with the new value. Each resource can have a maximum of 50 tags. Each tag consists of a key and optional value. Tag keys must be unique per resource.

func (*EC2Client) DeleteSecurityGroup 

func (c *EC2Client) DeleteSecurityGroup(id string) error

Deletes a security group.

func (*EC2Client) DeleteVolume 

func (c *EC2Client) DeleteVolume(id string) error

Deletes the specified EBS volume. The volume must be in the available state (not attached to an instance).

func (*EC2Client) DescribeAddresses 

func (c *EC2Client) DescribeAddresses(filters []types.Filter) ([]types.Address, error)

Describes the specified Elastic IP addresses or all of your Elastic IP addresses.

func (*EC2Client) DescribeAvailabilityZones 

func (c *EC2Client) DescribeAvailabilityZones(name string, all bool) ([]types.AvailabilityZone, error)

Describes the Availability Zones, Local Zones, and Wavelength Zones that are available to you. If there is an event impacting a zone, you can use this request to view the state and any provided messages for that zone.

func (*EC2Client) DescribeInstanceTypes added in v0.11.0 

func (c *EC2Client) DescribeInstanceTypes(filters []types.Filter) ([]types.InstanceTypeInfo, error)

Describes the details of the instance types that are offered in a location. The results can be filtered by the attributes of the instance types.

func (*EC2Client) DescribeInstances 

func (c *EC2Client) DescribeInstances(filters []types.Filter) ([]types.Reservation, error)

Describes the specified instances or all instances.

func (*EC2Client) DescribeInternetGateways 

func (c *EC2Client) DescribeInternetGateways(filters []types.Filter) ([]types.InternetGateway, error)

Describes one or more of your internet gateways.

func (*EC2Client) DescribeManagedPrefixLists 

func (c *EC2Client) DescribeManagedPrefixLists(filters []types.Filter) ([]types.ManagedPrefixList, error)

Describes your managed prefix lists and any AWS-managed prefix lists. To view the entries for your prefix list, use GetManagedPrefixListEntries.

func (*EC2Client) DescribeNATGateways 

func (c *EC2Client) DescribeNATGateways(filters []types.Filter) ([]types.NatGateway, error)

Describes one or more of your NAT gateways.

func (*EC2Client) DescribeNetworkAcls 

func (c *EC2Client) DescribeNetworkAcls(filters []types.Filter) ([]types.NetworkAcl, error)

Describes one or more of your network ACLs.

func (*EC2Client) DescribeNetworkInterfaces 

func (c *EC2Client) DescribeNetworkInterfaces(filters []types.Filter) ([]types.NetworkInterface, error)

Describes one or more of your network interfaces.

func (*EC2Client) DescribeRouteTables 

func (c *EC2Client) DescribeRouteTables(filters []types.Filter) ([]types.RouteTable, error)

Describes one or more of your route tables.

func (*EC2Client) DescribeSecurityGroupRules 

func (c *EC2Client) DescribeSecurityGroupRules(id, securityGroupId string) ([]types.SecurityGroupRule, error)

Describes one or more of your security group rules.

func (*EC2Client) DescribeSecurityGroups 

func (c *EC2Client) DescribeSecurityGroups(filters []types.Filter, groupIds []string) ([]types.SecurityGroup, error)

Describes the specified security groups or all of your security groups.

func (*EC2Client) DescribeSubnets 

func (c *EC2Client) DescribeSubnets(filters []types.Filter) ([]types.Subnet, error)

Describes one or more of your subnets.

func (*EC2Client) DescribeTags 

func (c *EC2Client) DescribeTags(resources, tagsFilter []string) ([]types.TagDescription, error)

Describes the specified tags for your EC2 resources.

func (*EC2Client) DescribeVolumes 

func (c *EC2Client) DescribeVolumes(id string) ([]types.Volume, error)

Describes the specified EBS volumes or all of your EBS volumes.

func (*EC2Client) DescribeVpcEndpoints 

func (c *EC2Client) DescribeVpcEndpoints(filters []types.Filter) ([]types.VpcEndpoint, error)

Describes your VPC endpoints.

func (*EC2Client) DescribeVpcs 

func (c *EC2Client) DescribeVpcs(filters []types.Filter) ([]types.Vpc, error)

Describes one or more of your VPCs.

func (*EC2Client) GetManagedPrefixListEntries 

func (c *EC2Client) GetManagedPrefixListEntries(prefixListId string) ([]types.PrefixListEntry, error)

Gets information about the entries for a specified managed prefix list.

func (*EC2Client) TerminateInstances 

func (c *EC2Client) TerminateInstances(id string) error

Shuts down the specified instances. This operation is idempotent; if you terminate an instance more than once, each call succeeds.

type ECRClient 

type ECRClient struct {
	*ecr.Client
}

func NewECRClient 

func NewECRClient() *ECRClient

func (*ECRClient) DescribeRepositories 

func (c *ECRClient) DescribeRepositories(name string) ([]types.Repository, error)

type EKSClient 

type EKSClient struct {
	*eks.Client
}

func NewEKSClient 

func NewEKSClient() *EKSClient

func (*EKSClient) DescribeAddon 

func (c *EKSClient) DescribeAddon(clusterName, addonName string) (*types.Addon, error)

func (*EKSClient) DescribeAddonVersions 

func (c *EKSClient) DescribeAddonVersions(addonName, version string) ([]types.AddonInfo, error)

func (*EKSClient) DescribeCluster 

func (c *EKSClient) DescribeCluster(clusterName string) (*types.Cluster, error)

func (*EKSClient) DescribeFargateProfile 

func (c *EKSClient) DescribeFargateProfile(clusterName, profileName string) (*types.FargateProfile, error)

func (*EKSClient) DescribeNodegroup 

func (c *EKSClient) DescribeNodegroup(clusterName, nodegroupName string) (*types.Nodegroup, error)

func (*EKSClient) ListAddons 

func (c *EKSClient) ListAddons(clusterName string) ([]string, error)

func (*EKSClient) ListClusters 

func (c *EKSClient) ListClusters() ([]string, error)

func (*EKSClient) ListFargateProfiles 

func (c *EKSClient) ListFargateProfiles(clusterName string) ([]string, error)

func (*EKSClient) ListNodegroups 

func (c *EKSClient) ListNodegroups(clusterName string) ([]string, error)

func (*EKSClient) UpdateNodegroupConfig 

func (c *EKSClient) UpdateNodegroupConfig(clusterName, nodegroupName string, desired, min, max int) error

type ElasticloadbalancingClient 

type ElasticloadbalancingClient struct {
	*elasticloadbalancing.Client
}

func NewElasticloadbalancingClientv1 

func NewElasticloadbalancingClientv1() *ElasticloadbalancingClient

func (*ElasticloadbalancingClient) DeleteLoadBalancer 

func (c *ElasticloadbalancingClient) DeleteLoadBalancer(name string) error

func (*ElasticloadbalancingClient) DescribeLoadBalancers 

func (c *ElasticloadbalancingClient) DescribeLoadBalancers(name string) ([]types.LoadBalancerDescription, error)

type Elasticloadbalancingv2Client 

type Elasticloadbalancingv2Client struct {
	*elasticloadbalancingv2.Client
}

func NewElasticloadbalancingClientv2 

func NewElasticloadbalancingClientv2() *Elasticloadbalancingv2Client

func (*Elasticloadbalancingv2Client) CreateTargetGroup 

func (c *Elasticloadbalancingv2Client) CreateTargetGroup(name string, port int32, protocol, targetType, vpcId string) error

func (*Elasticloadbalancingv2Client) DeleteLoadBalancer 

func (c *Elasticloadbalancingv2Client) DeleteLoadBalancer(arn string) error

func (*Elasticloadbalancingv2Client) DeleteTargetGroup 

func (c *Elasticloadbalancingv2Client) DeleteTargetGroup(arn string) error

func (*Elasticloadbalancingv2Client) DescribeListeners 

func (c *Elasticloadbalancingv2Client) DescribeListeners(loadBalancerArn string) ([]types.Listener, error)

func (*Elasticloadbalancingv2Client) DescribeLoadBalancers 

func (c *Elasticloadbalancingv2Client) DescribeLoadBalancers(name string) ([]types.LoadBalancer, error)

func (*Elasticloadbalancingv2Client) DescribeRules 

func (c *Elasticloadbalancingv2Client) DescribeRules(listenerArn string, ruleArns []string) ([]types.Rule, error)

func (*Elasticloadbalancingv2Client) DescribeTargetGroups 

func (c *Elasticloadbalancingv2Client) DescribeTargetGroups(name, loadBalancerArn string) ([]types.TargetGroup, error)

func (*Elasticloadbalancingv2Client) DescribeTargetHealth 

func (c *Elasticloadbalancingv2Client) DescribeTargetHealth(arn, id string) ([]types.TargetHealthDescription, error)

type EventBridgeClient 

type EventBridgeClient struct {
	*eventbridge.Client
}

func NewEventBridgeClient 

func NewEventBridgeClient() *EventBridgeClient

func (*EventBridgeClient) ListRules 

func (c *EventBridgeClient) ListRules(namePrefix string) ([]types.Rule, error)

type GrafanaClient 

type GrafanaClient struct {
	*grafana.Client
}

func NewGrafanaClient 

func NewGrafanaClient() *GrafanaClient

func (*GrafanaClient) CreateWorkspace 

func (c *GrafanaClient) CreateWorkspace(name string, auth []string, roleArn string) (*types.WorkspaceDescription, error)

func (*GrafanaClient) DeleteWorkspace 

func (c *GrafanaClient) DeleteWorkspace(id string) error

func (*GrafanaClient) DescribeWorkspace 

func (c *GrafanaClient) DescribeWorkspace(id string) (*types.WorkspaceDescription, error)

func (*GrafanaClient) ListWorkspaces 

func (c *GrafanaClient) ListWorkspaces() ([]types.WorkspaceSummary, error)

func (*GrafanaClient) UpdateWorkspaceAuthentication 

func (c *GrafanaClient) UpdateWorkspaceAuthentication(id, samlMetadataUrl string) error

type IAMClient 

type IAMClient struct {
	*iam.Client
}

func NewIAMClient 

func NewIAMClient() *IAMClient

func (*IAMClient) CreateRole 

func (c *IAMClient) CreateRole(assumeRolePolicy, name, path string) (*types.Role, error)

Creates a new role for your AWS account.

func (*IAMClient) CreateServiceLinkedRole 

func (c *IAMClient) CreateServiceLinkedRole(name string) error

Creates an IAM role that is linked to a specific AWS service.

func (*IAMClient) DeleteRole 

func (c *IAMClient) DeleteRole(name string) error

Deletes the specified role. Unlike the AWS Management Console, when you delete a role programmatically, you must delete the items attached to the role manually, or the deletion fails.

func (*IAMClient) DeleteRolePolicy 

func (c *IAMClient) DeleteRolePolicy(roleName, policyName string) error

Deletes the specified inline policy that is embedded in the specified IAM role.

func (*IAMClient) DetachRolePolicy 

func (c *IAMClient) DetachRolePolicy(roleName, policyArn string) error

Removes the specified managed policy from the specified role.

func (*IAMClient) GetOpenIDConnectProvider 

func (c *IAMClient) GetOpenIDConnectProvider(arn string) (*iam.GetOpenIDConnectProviderOutput, error)

Returns information about the specified OpenID Connect (OIDC) provider resource object in IAM.

func (*IAMClient) GetPolicy 

func (c *IAMClient) GetPolicy(arn string) (*types.Policy, error)

Retrieves information about the specified managed policy, including the policy's default version and the total number of IAM users, groups, and roles to which the policy is attached

func (*IAMClient) GetPolicyVersion 

func (c *IAMClient) GetPolicyVersion(arn, version string) (*types.PolicyVersion, error)

Retrieves information about the specified version of the specified managed policy, including the policy document.

func (*IAMClient) GetRole 

func (c *IAMClient) GetRole(name string) (*types.Role, error)

Retrieves information about the specified role, including the role's path, GUID, ARN, and the role's trust policy that grants permission to assume the role.

func (*IAMClient) GetRolePolicy 

func (c *IAMClient) GetRolePolicy(policyName, roleName string) (string, error)

Retrieves the specified inline policy document that is embedded with the specified IAM role.

func (*IAMClient) ListAttachedRolePolicies 

func (c *IAMClient) ListAttachedRolePolicies(roleName string) ([]types.AttachedPolicy, error)

Lists all managed policies that are attached to the specified IAM role.

func (*IAMClient) ListOpenIDConnectProviders 

func (c *IAMClient) ListOpenIDConnectProviders() ([]types.OpenIDConnectProviderListEntry, error)

Lists information about the IAM OpenID Connect (OIDC) provider resource objects defined in the AWS account.

func (*IAMClient) ListPolicies 

func (c *IAMClient) ListPolicies(foo string) ([]types.Policy, error)

Lists all the managed policies that are available in your AWS account, including your own customer-defined managed policies and all AWS managed policies.

func (*IAMClient) ListRolePolicies 

func (c *IAMClient) ListRolePolicies(roleName string) ([]string, error)

Lists the names of the inline policies that are embedded in the specified IAM role.

func (*IAMClient) ListRoles 

func (c *IAMClient) ListRoles() ([]types.Role, error)

Lists the IAM roles that have the specified path prefix. If there are none, the operation returns an empty list.

func (*IAMClient) PutRolePolicy 

func (c *IAMClient) PutRolePolicy(roleName, policyName, policyDoc string) error

Adds or updates an inline policy document that is embedded in the specified IAM role.

type KMSClient 

type KMSClient struct {
	*kms.Client
}

func NewKMSClient 

func NewKMSClient() *KMSClient

func (*KMSClient) DescribeKey 

func (c *KMSClient) DescribeKey(keyId string) (*types.KeyMetadata, error)

func (*KMSClient) ListAliases 

func (c *KMSClient) ListAliases() ([]types.AliasListEntry, error)

func (*KMSClient) ListKeys 

func (c *KMSClient) ListKeys() ([]types.KeyListEntry, error)

type ListResourceRecordSetsAPIClient 

type ListResourceRecordSetsAPIClient interface {
	ListResourceRecordSets(context.Context, *route53.ListResourceRecordSetsInput, ...func(*route53.Options)) (*route53.ListResourceRecordSetsOutput, error)
}

ListResourceRecordSetsAPIClient is a client that implements the ListResourceRecordSets operation.

type ListResourceRecordSetsPaginator 

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

ListResourceRecordSetsPaginator is a paginator for ListResourceRecordSets

func NewListResourceRecordSetsPaginator 

func NewListResourceRecordSetsPaginator(client ListResourceRecordSetsAPIClient, params *route53.ListResourceRecordSetsInput, optFns ...func(*ListResourceRecordSetsPaginatorOptions)) *ListResourceRecordSetsPaginator

NewListResourceRecordSetsPaginator returns a new ListResourceRecordSetsPaginator

func (*ListResourceRecordSetsPaginator) HasMorePages 

func (p *ListResourceRecordSetsPaginator) HasMorePages() bool

HasMorePages returns a boolean indicating whether more pages are available

func (*ListResourceRecordSetsPaginator) NextPage 

func (p *ListResourceRecordSetsPaginator) NextPage(ctx context.Context, optFns ...func(*route53.Options)) (*route53.ListResourceRecordSetsOutput, error)

NextPage retrieves the next ListResourceRecordSets page.

type ListResourceRecordSetsPaginatorOptions 

type ListResourceRecordSetsPaginatorOptions struct {
	// (Optional) The maximum number of resource record sets that you want Amazon Route 53 to
	// return. If you have more than maxitems resource record sets, the value of IsTruncated in
	// the response is true, and the value of NextMarker is the resource record set ID of the
	// first esource record set that Route 53 will return if you submit another request.
	Limit int32

	// Set to true if pagination should stop if the service returns a pagination token
	// that matches the most recent token provided to the service.
	StopOnDuplicateToken bool
}

ListResourceRecordSetsPaginatorOptions is the paginator options for ListResourceRecordSets

type ListRulesAPIClient 

type ListRulesAPIClient interface {
	ListRules(context.Context, *eventbridge.ListRulesInput, ...func(*eventbridge.Options)) (*eventbridge.ListRulesOutput, error)
}

ListRulesAPIClient is a client that implements the ListRules operation.

type ListRulesPaginator 

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

ListRulesPaginator is a paginator for ListRules

func NewListRulesPaginator 

func NewListRulesPaginator(client ListRulesAPIClient, params *eventbridge.ListRulesInput, optFns ...func(*ListRulesPaginatorOptions)) *ListRulesPaginator

NewListRulesPaginator returns a new ListRulesPaginator

func (*ListRulesPaginator) HasMorePages 

func (p *ListRulesPaginator) HasMorePages() bool

HasMorePages returns a boolean indicating whether more pages are available

func (*ListRulesPaginator) NextPage 

func (p *ListRulesPaginator) NextPage(ctx context.Context, optFns ...func(*eventbridge.Options)) (*eventbridge.ListRulesOutput, error)

NextPage retrieves the next ListRules page.

type ListRulesPaginatorOptions 

type ListRulesPaginatorOptions struct {
	// (Optional) The maximum number of results to return.
	Limit int32

	// Set to true if pagination should stop if the service returns a pagination token
	// that matches the most recent token provided to the service.
	StopOnDuplicateToken bool
}

ListRulesPaginatorOptions is the paginator options for ListRules

type OrganizationsClient 

type OrganizationsClient struct {
	*organizations.Client
}

func NewOrganizationsClient 

func NewOrganizationsClient() *OrganizationsClient

func (*OrganizationsClient) CreateOrganization 

func (c *OrganizationsClient) CreateOrganization() (*types.Organization, error)

func (*OrganizationsClient) DeleteOrganization 

func (c *OrganizationsClient) DeleteOrganization() error

func (*OrganizationsClient) DescribeOrganization 

func (c *OrganizationsClient) DescribeOrganization() (*types.Organization, error)

type QueryCompleteWaiter 

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

QueryCompleteWaiter defines the waiters for QueryComplete

func NewQueryCompleteWaiter 

func NewQueryCompleteWaiter(client DescribeQueriesAPIClient, optFns ...func(*QueryCompleteWaiterOptions)) *QueryCompleteWaiter

NewQueryCompleteWaiter constructs a QueryCompleteWaiter.

func (*QueryCompleteWaiter) Wait 

func (w *QueryCompleteWaiter) Wait(ctx context.Context, params *cloudwatchlogs.DescribeQueriesInput, queryId string, maxWaitDur time.Duration, optFns ...func(*QueryCompleteWaiterOptions)) error

Wait calls the waiter function for QueryComplete waiter. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.

func (*QueryCompleteWaiter) WaitForOutput 

func (w *QueryCompleteWaiter) WaitForOutput(ctx context.Context, params *cloudwatchlogs.DescribeQueriesInput, queryId string, maxWaitDur time.Duration, optFns ...func(*QueryCompleteWaiterOptions)) (*cloudwatchlogs.DescribeQueriesOutput, error)

WaitForOutput calls the waiter function for QueryComplete waiter and returns the output of the successful operation. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.

type QueryCompleteWaiterOptions 

type QueryCompleteWaiterOptions struct {

	// Set of options to modify how an operation is invoked. These apply to all
	// operations invoked for this client. Use functional options on operation call to
	// modify this list for per operation behavior.
	APIOptions []func(*middleware.Stack) error

	// MinDelay is the minimum amount of time to delay between retries. If unset,
	// QueryCompleteWaiter will use default minimum delay of 5 seconds. Note that
	// MinDelay must resolve to a value lesser than or equal to the MaxDelay.
	MinDelay time.Duration

	// MaxDelay is the maximum amount of time to delay between retries. If unset or set
	// to zero, QueryCompleteWaiter will use default max delay of 120 seconds. Note that
	// MaxDelay must resolve to value greater than or equal to the MinDelay.
	MaxDelay time.Duration

	// LogWaitAttempts is used to enable logging for waiter retry attempts
	LogWaitAttempts bool

	// Retryable is function that can be used to override the service defined
	// waiter-behavior based on operation output, or returned error. This function is
	// used by the waiter to decide if a state is retryable or a terminal state. By
	// default service-modeled logic will populate this option. This option can thus be
	// used to define a custom waiter state with fall-back to service-modeled waiter
	// state mutators.The function returns an error in case of a failure state. In case
	// of retry state, this function returns a bool value of true and nil error, while
	// in case of success it returns a bool value of false and nil error.
	Retryable func(context.Context, *cloudwatchlogs.DescribeQueriesInput, string, *cloudwatchlogs.DescribeQueriesOutput, error) (bool, error)
}

QueryCompleteWaiterOptions are waiter options for QueryCompleteWaiter

type Route53Client 

type Route53Client struct {
	*route53.Client
}

func NewRoute53Client 

func NewRoute53Client() *Route53Client

func (*Route53Client) ChangeResourceRecordSets 

func (c *Route53Client) ChangeResourceRecordSets(changeBatch *types.ChangeBatch, zoneId string) error

func (*Route53Client) GetHostedZone 

func (c *Route53Client) GetHostedZone(zoneId string) (*route53.GetHostedZoneOutput, error)

func (*Route53Client) ListHostedZones 

func (c *Route53Client) ListHostedZones() ([]types.HostedZone, error)

func (*Route53Client) ListHostedZonesByName 

func (c *Route53Client) ListHostedZonesByName(name string) ([]types.HostedZone, error)

func (*Route53Client) ListResourceRecordSets 

func (c *Route53Client) ListResourceRecordSets(zoneId string) ([]types.ResourceRecordSet, error)

type S3Client 

type S3Client struct {
	*s3.Client
}

func NewS3Client 

func NewS3Client() *S3Client

func (*S3Client) CreateBucket 

func (c *S3Client) CreateBucket(name, region string) error

func (*S3Client) GetBucketLocation 

func (c *S3Client) GetBucketLocation(name string) (types.BucketLocationConstraint, error)

func (*S3Client) ListBuckets 

func (c *S3Client) ListBuckets() ([]types.Bucket, error)

type SQSClient 

type SQSClient struct {
	*sqs.Client
}

func NewSQSClient 

func NewSQSClient() *SQSClient

func (*SQSClient) GetQueueAttributes 

func (c *SQSClient) GetQueueAttributes(queueUrl string) (map[string]string, error)

func (*SQSClient) GetQueueUrl 

func (c *SQSClient) GetQueueUrl(queueName string) (string, error)

func (*SQSClient) ListQueues 

func (c *SQSClient) ListQueues() ([]string, error)

type SSMClient 

type SSMClient struct {
	*ssm.Client
}

func NewSSMClient 

func NewSSMClient() *SSMClient

func (*SSMClient) DescribeInstanceInformation 

func (c *SSMClient) DescribeInstanceInformation(instanceId string) ([]types.InstanceInformation, error)

func (*SSMClient) DescribeSessions 

func (c *SSMClient) DescribeSessions(id, state string) ([]types.Session, error)

func (*SSMClient) Endpoint 

func (c *SSMClient) Endpoint() (aws.Endpoint, error)

func (*SSMClient) GetParameter 

func (c *SSMClient) GetParameter(name string) (*types.Parameter, error)

func (*SSMClient) StartSession 

func (c *SSMClient) StartSession(instanceId string) (*ssm.StartSessionOutput, error)

type VPCLatticeClient 

type VPCLatticeClient struct {
	*vpclattice.Client
}

func NewVPCLatticeClient 

func NewVPCLatticeClient() *VPCLatticeClient

func (*VPCLatticeClient) GetService 

func (c *VPCLatticeClient) GetService(id string) (*vpclattice.GetServiceOutput, error)

func (*VPCLatticeClient) GetServiceNetwork 

func (c *VPCLatticeClient) GetServiceNetwork(id string) (*vpclattice.GetServiceNetworkOutput, error)

func (*VPCLatticeClient) GetTargetGroup 

func (c *VPCLatticeClient) GetTargetGroup(id string) (*vpclattice.GetTargetGroupOutput, error)

func (*VPCLatticeClient) ListServiceNetworks 

func (c *VPCLatticeClient) ListServiceNetworks() ([]types.ServiceNetworkSummary, error)

func (*VPCLatticeClient) ListServices 

func (c *VPCLatticeClient) ListServices() ([]types.ServiceSummary, error)

func (*VPCLatticeClient) ListTargetGroups 

func (c *VPCLatticeClient) ListTargetGroups() ([]types.TargetGroupSummary, error)

type WaiterLogger 

type WaiterLogger struct {
	// Attempt is the current attempt to be logged
	Attempt int64
}

WaiterLogger is a Custom Logger middleware used by the waiter to log an attempt with a "."

func (WaiterLogger) AddLogger 

func (m WaiterLogger) AddLogger(stack *middleware.Stack) error

AddLogger is a helper util to add waiter logger after `SetLogger` middleware in

func (*WaiterLogger) HandleInitialize 

func (m *WaiterLogger) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
	out middleware.InitializeOutput, metadata middleware.Metadata, err error,
)

HandleInitialize performs handling of request in initialize stack step

func (*WaiterLogger) ID 

func (*WaiterLogger) ID() string

ID representing the Logger middleware

type WorkspaceActiveWaiter 

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

WorkspaceActiveWaiter defines the waiters for WorkspaceActive

func NewWorkspaceActiveWaiter 

func NewWorkspaceActiveWaiter(client DescribeWorkspaceAPIClient, optFns ...func(*WorkspaceActiveWaiterOptions)) *WorkspaceActiveWaiter

NewWorkspaceActiveWaiter constructs a WorkspaceActiveWaiter.

func (*WorkspaceActiveWaiter) Wait 

func (w *WorkspaceActiveWaiter) Wait(ctx context.Context, params *grafana.DescribeWorkspaceInput, maxWaitDur time.Duration, optFns ...func(*WorkspaceActiveWaiterOptions)) error

Wait calls the waiter function for WorkspaceActive waiter. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.

func (*WorkspaceActiveWaiter) WaitForOutput 

func (w *WorkspaceActiveWaiter) WaitForOutput(ctx context.Context, params *grafana.DescribeWorkspaceInput, maxWaitDur time.Duration, optFns ...func(*WorkspaceActiveWaiterOptions)) (*grafana.DescribeWorkspaceOutput, error)

WaitForOutput calls the waiter function for CertificateValidated waiter and returns the output of the successful operation. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.

type WorkspaceActiveWaiterOptions 

type WorkspaceActiveWaiterOptions struct {

	// Set of options to modify how an operation is invoked. These apply to all
	// operations invoked for this client. Use functional options on operation call to
	// modify this list for per operation behavior.
	APIOptions []func(*middleware.Stack) error

	// MinDelay is the minimum amount of time to delay between retries. If unset,
	// WorkspaceActiveWaiter will use default minimum delay of 60 seconds. Note
	// that MinDelay must resolve to a value lesser than or equal to the MaxDelay.
	MinDelay time.Duration

	// MaxDelay is the maximum amount of time to delay between retries. If unset or set
	// to zero, WorkspaceActiveWaiter will use default max delay of 120 seconds.
	// Note that MaxDelay must resolve to value greater than or equal to the MinDelay.
	MaxDelay time.Duration

	// LogWaitAttempts is used to enable logging for waiter retry attempts
	LogWaitAttempts bool

	// Retryable is function that can be used to override the service defined
	// waiter-behavior based on operation output, or returned error. This function is
	// used by the waiter to decide if a state is retryable or a terminal state. By
	// default service-modeled logic will populate this option. This option can thus be
	// used to define a custom waiter state with fall-back to service-modeled waiter
	// state mutators.The function returns an error in case of a failure state. In case
	// of retry state, this function returns a bool value of true and nil error, while
	// in case of success it returns a bool value of false and nil error.
	Retryable func(context.Context, *grafana.DescribeWorkspaceInput, *grafana.DescribeWorkspaceOutput, error) (bool, 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.