aws

Documentation

Index

• Constants
• func GetLBNameFromHostname(hostname string) (string, string, error)
• func GetRegionFromARN(arn string) string
• func Route53OwnerValue(clusterName, resource, ns, name string) string
• type AWS
  • func NewAWS(region string) (*AWS, error)
  • func (a *AWS) AddLBToEndpointGroup(ctx context.Context, endpointGroup *gatypes.EndpointGroup, lbName string, ...) (*string, time.Duration, error)
  • func (a *AWS) CleanupGlobalAccelerator(ctx context.Context, arn string) error
  • func (a *AWS) CleanupRecordSet(ctx context.Context, clusterName, resource, ns, name string) error
  • func (a *AWS) DescribeEndpointGroup(ctx context.Context, endpointGroupArn string) (*gatypes.EndpointGroup, error)
  • func (a *AWS) EnsureGlobalAcceleratorForIngress(ctx context.Context, ingress *networkingv1.Ingress, ...) (*string, bool, time.Duration, error)
  • func (a *AWS) EnsureGlobalAcceleratorForService(ctx context.Context, svc *corev1.Service, ...) (*string, bool, time.Duration, error)
  • func (a *AWS) EnsureRoute53ForIngress(ctx context.Context, ingress *networkingv1.Ingress, ...) (bool, time.Duration, error)
  • func (a *AWS) EnsureRoute53ForService(ctx context.Context, svc *corev1.Service, ...) (bool, time.Duration, error)
  • func (a *AWS) FindOwneredARecordSets(ctx context.Context, hostedZone *route53types.HostedZone, ownerValue string) ([]route53types.ResourceRecordSet, error)
  • func (a *AWS) GetEndpointGroup(ctx context.Context, listenerArn string) (*gatypes.EndpointGroup, error)
  • func (a *AWS) GetHostedZone(ctx context.Context, originalHostname string) (*route53types.HostedZone, error)
  • func (a *AWS) GetListener(ctx context.Context, acceleratorArn string) (*gatypes.Listener, error)
  • func (a *AWS) GetLoadBalancer(ctx context.Context, name string) (*elbv2types.LoadBalancer, error)
  • func (a *AWS) ListGlobalAcceleratorByHostname(ctx context.Context, hostname, clusterName string) ([]*gatypes.Accelerator, error)
  • func (a *AWS) ListGlobalAcceleratorByResource(ctx context.Context, clusterName, resource, ns, name string) ([]*gatypes.Accelerator, error)
  • func (a *AWS) RemoveLBFromEdnpointGroup(ctx context.Context, endpointGroup *gatypes.EndpointGroup, endpointId string) error
  • func (a *AWS) UpdateEndpointWeight(ctx context.Context, endpointGroup *gatypes.EndpointGroup, endpointId string, ...) error
• type IngressPort

Constants

const (
	ErrEndpointGroupNotFoundException = "EndpointGroupNotFoundException"
)

Functions

func GetLBNameFromHostname

func GetLBNameFromHostname(hostname string) (string, string, error)

func GetRegionFromARN

func GetRegionFromARN(arn string) string

func Route53OwnerValue

func Route53OwnerValue(clusterName, resource, ns, name string) string

Types

type AWS

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

func NewAWS

func NewAWS(region string) (*AWS, error)

func (*AWS) AddLBToEndpointGroup

func (a *AWS) AddLBToEndpointGroup(ctx context.Context, endpointGroup *gatypes.EndpointGroup, lbName string, ipPreserve bool, weight *int32) (*string, time.Duration, error)

func (*AWS) CleanupGlobalAccelerator

func (a *AWS) CleanupGlobalAccelerator(ctx context.Context, arn string) error

func (*AWS) CleanupRecordSet

func (a *AWS) CleanupRecordSet(ctx context.Context, clusterName, resource, ns, name string) error

func (*AWS) DescribeEndpointGroup

func (a *AWS) DescribeEndpointGroup(ctx context.Context, endpointGroupArn string) (*gatypes.EndpointGroup, error)

--------------------------------- EndpointGroup methods ---------------------------------

func (*AWS) EnsureGlobalAcceleratorForIngress

func (a *AWS) EnsureGlobalAcceleratorForIngress(
	ctx context.Context,
	ingress *networkingv1.Ingress,
	lbIngress *networkingv1.IngressLoadBalancerIngress,
	clusterName, lbName, region string,
) (*string, bool, time.Duration, error)

func (*AWS) EnsureGlobalAcceleratorForService

func (a *AWS) EnsureGlobalAcceleratorForService(
	ctx context.Context,
	svc *corev1.Service,
	lbIngress *corev1.LoadBalancerIngress,
	clusterName, lbName, region string,
) (*string, bool, time.Duration, error)

func (*AWS) EnsureRoute53ForIngress

func (a *AWS) EnsureRoute53ForIngress(
	ctx context.Context,
	ingress *networkingv1.Ingress,
	ingressLBIngress *networkingv1.IngressLoadBalancerIngress,
	hostnames []string,
	clusterName string,
) (bool, time.Duration, error)

func (*AWS) EnsureRoute53ForService

func (a *AWS) EnsureRoute53ForService(
	ctx context.Context,
	svc *corev1.Service,
	lbIngress *corev1.LoadBalancerIngress,
	hostnames []string,
	clusterName string,
) (bool, time.Duration, error)

func (*AWS) FindOwneredARecordSets

func (a *AWS) FindOwneredARecordSets(ctx context.Context, hostedZone *route53types.HostedZone, ownerValue string) ([]route53types.ResourceRecordSet, error)

func (*AWS) GetEndpointGroup

func (a *AWS) GetEndpointGroup(ctx context.Context, listenerArn string) (*gatypes.EndpointGroup, error)

func (*AWS) GetHostedZone

func (a *AWS) GetHostedZone(ctx context.Context, originalHostname string) (*route53types.HostedZone, error)

func (*AWS) GetListener

func (a *AWS) GetListener(ctx context.Context, acceleratorArn string) (*gatypes.Listener, error)

--------------------------------- Lstener methods ---------------------------------

func (*AWS) GetLoadBalancer

func (a *AWS) GetLoadBalancer(ctx context.Context, name string) (*elbv2types.LoadBalancer, error)

func (*AWS) ListGlobalAcceleratorByHostname

func (a *AWS) ListGlobalAcceleratorByHostname(ctx context.Context, hostname, clusterName string) ([]*gatypes.Accelerator, error)

func (*AWS) ListGlobalAcceleratorByResource

func (a *AWS) ListGlobalAcceleratorByResource(ctx context.Context, clusterName, resource, ns, name string) ([]*gatypes.Accelerator, error)

func (*AWS) RemoveLBFromEdnpointGroup

func (a *AWS) RemoveLBFromEdnpointGroup(ctx context.Context, endpointGroup *gatypes.EndpointGroup, endpointId string) error

func (*AWS) UpdateEndpointWeight

func (a *AWS) UpdateEndpointWeight(ctx context.Context, endpointGroup *gatypes.EndpointGroup, endpointId string, weight *int32) error

type IngressPort

type IngressPort struct {
	HTTP  int64 `json:"HTTP,omitempty"`
	HTTPS int64 `json:"HTTPS,omitempty"`
}