aws

package
v0.0.0-...-f99fb5f Latest Latest
Warning

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

Go to latest
Published: Apr 15, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var NotFoundError error

Functions

This section is empty.

Types

type Client

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

func NewClient

func NewClient(ctx context.Context, logger *logrus.Logger) (*Client, error)

func (*Client) AddInboundAllowRuleByInstanceIPMatch

func (c *Client) AddInboundAllowRuleByInstanceIPMatch(ctx context.Context, account, region,
	vpcID string, securityGroupName string, instancesIPs []string, cidrsToAllow []string,
	protocolsAndPorts types.ProtocolsAndPorts) (securityGroupId string, instances []types.Instance, err error)

func (*Client) AddInboundAllowRuleByLabelsMatch

func (c *Client) AddInboundAllowRuleByLabelsMatch(ctx context.Context, account, region,
	vpcID string, securityGroupName string, labels map[string]string, cidrsToAllow []string,
	protocolsAndPorts types.ProtocolsAndPorts) (securityGroupId string, instances []types.Instance, err error)

func (*Client) AddInboundAllowRuleBySubnetMatch

func (c *Client) AddInboundAllowRuleBySubnetMatch(ctx context.Context, account, region,
	vpcID string, securityGroupName string, subnetCidrs []string, cidrsToAllow []string,
	protocolsAndPorts types.ProtocolsAndPorts) (securityGroupId string, instances []types.Instance, subnets []types.Subnet, err error)

func (*Client) AddInboundAllowRuleForLoadBalancerByDNS

func (c *Client) AddInboundAllowRuleForLoadBalancerByDNS(ctx context.Context,
	account, region string,
	loadBalancerDNS string,
	vpcID string,
	securityGroupName string,
	cidrsToAllow []string,
	protocolsAndPorts types.ProtocolsAndPorts,
) (loadBalancerId, securityGroupId string, err error)

func (*Client) AddInboundAllowRuleInVPC

func (c *Client) AddInboundAllowRuleInVPC(ctx context.Context, account, region string,
	vpcID string, cidrs []string, securityGroupName string, tags map[string]string) error

func (*Client) ConnectVPC

func (*Client) ConnectVPCs

func (c *Client) ConnectVPCs(ctx context.Context, input t.VPCConnectionParams) (t.VPCConnectionOutput, error)

func (*Client) DisconnectVPC

func (*Client) DisconnectVPCs

func (c *Client) DisconnectVPCs(ctx context.Context, input t.VPCDisconnectionParams) (t.VPCDisconnectionOutput, error)

func (*Client) GetCIDRsForLabels

func (c *Client) GetCIDRsForLabels(ctx context.Context, params *infrapb.GetCIDRsForLabelsRequest) ([]string, error)

func (*Client) GetIPsForLabels

func (c *Client) GetIPsForLabels(ctx context.Context, params *infrapb.GetIPsForLabelsRequest) ([]string, error)

func (*Client) GetInstancesForLabels

func (c *Client) GetInstancesForLabels(ctx context.Context, params *infrapb.GetInstancesForLabelsRequest) ([]types.Instance, error)

func (*Client) GetName

func (c *Client) GetName() string

func (*Client) GetSubnet

func (c *Client) GetSubnet(ctx context.Context, params *infrapb.GetSubnetRequest) (types.Subnet, error)

func (*Client) GetSyncTime

func (c *Client) GetSyncTime(id string) (types.SyncTime, error)

func (*Client) GetVPCIDForCIDR

func (c *Client) GetVPCIDForCIDR(ctx context.Context, params *infrapb.GetVPCIDForCIDRRequest) (string, error)

func (*Client) GetVPCIDWithTag

func (c *Client) GetVPCIDWithTag(ctx context.Context, params *infrapb.GetVPCIDWithTagRequest) (string, error)

func (*Client) ListACLs

func (c *Client) ListACLs(ctx context.Context, input *infrapb.ListACLsRequest) ([]types.ACL, error)

func (*Client) ListAccounts

func (c *Client) ListAccounts() []types.Account

func (*Client) ListClusters

func (c *Client) ListClusters(ctx context.Context, params *infrapb.ListCloudClustersRequest) ([]types.Cluster, error)

func (*Client) ListInstances

func (c *Client) ListInstances(ctx context.Context, params *infrapb.ListInstancesRequest) ([]types.Instance, error)

func (*Client) ListInternetGateways

func (c *Client) ListInternetGateways(ctx context.Context, params *infrapb.ListInternetGatewaysRequest) ([]types.IGW, error)

func (*Client) ListInternetGatewaysInRegion

func (c *Client) ListInternetGatewaysInRegion(client *ec2.Client, region string) ([]types.IGW, error)

func (*Client) ListNATGateways

func (c *Client) ListNATGateways(ctx context.Context, params *infrapb.ListNATGatewaysRequest) ([]types.NATGateway, error)

func (*Client) ListNATGatewaysInRegion

func (c *Client) ListNATGatewaysInRegion(client *ec2.Client, region string) ([]types.NATGateway, error)

func (*Client) ListRouteTables

func (c *Client) ListRouteTables(ctx context.Context, input *infrapb.ListRouteTablesRequest) ([]types.RouteTable, error)

func (*Client) ListRouters

func (c *Client) ListRouters(ctx context.Context, params *infrapb.ListRoutersRequest) ([]types.Router, error)

func (*Client) ListRoutersForRegion

func (c *Client) ListRoutersForRegion(client *ec2.Client, region string) ([]types.Router, error)

func (*Client) ListSecurityGroups

func (c *Client) ListSecurityGroups(ctx context.Context, input *infrapb.ListSecurityGroupsRequest) ([]types.SecurityGroup, error)

func (*Client) ListSubnets

func (c *Client) ListSubnets(ctx context.Context, params *infrapb.ListSubnetsRequest) ([]types.Subnet, error)

func (*Client) ListVPC

func (c *Client) ListVPC(ctx context.Context, params *infrapb.ListVPCRequest) ([]types.VPC, error)

func (*Client) RefreshInboundAllowRule

func (c *Client) RefreshInboundAllowRule(ctx context.Context,
	account, region string,
	securityGroupId string,
	cidrsToAdd []string,
	cidrsToRemove []string,
	destinationLabels map[string]string,
	destinationPrefixes []string,
	destinationVPCId string,
	protocolsAndPorts types.ProtocolsAndPorts) (instances []types.Instance, subnets []types.Subnet, err error)

func (*Client) RemoveInboundAllowRuleFromVPCByName

func (c *Client) RemoveInboundAllowRuleFromVPCByName(ctx context.Context, account, region, vpcID string, securityGroupID string) error

func (*Client) RemoveInboundAllowRuleRulesByTags

func (c *Client) RemoveInboundAllowRuleRulesByTags(ctx context.Context, account, region, vpcID, securityGroupName string, tags map[string]string) error

func (*Client) RemoveInboundAllowRulesFromVPCById

func (c *Client) RemoveInboundAllowRulesFromVPCById(ctx context.Context, account, region string,
	vpcId string, instanceIDs []string, loadBalancersIds []string, securityGroupId string) error

func (*Client) RetrieveClustersData

func (c *Client) RetrieveClustersData(ctx context.Context) ([]cluster.DiscoveredCluster, error)

Jump to

Keyboard shortcuts

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