aws

Documentation

Index

• 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
• type IngressPort

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) (*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

type IngressPort

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