alb

Documentation

Index

• type Listener
  • func NewListener(annotations *config.Annotations, ingressID *string) []*Listener
  • func (l *Listener) Reconcile(lb *LoadBalancer) error
• type Listeners
  • func (ls Listeners) Find(listener *elbv2.Listener) int
  • func (ls Listeners) Reconcile(lb *LoadBalancer, tgs *TargetGroups) error
  • func (ls Listeners) StripCurrentState()
  • func (ls Listeners) StripDesiredState()
• type LoadBalancer
  • func NewLoadBalancer(clustername, namespace, ingressname, hostname string, ingressID *string, ...) *LoadBalancer
  • func (lb *LoadBalancer) Reconcile() error
• type LoadBalancers
  • func (l LoadBalancers) Find(lb *LoadBalancer) int
  • func (l LoadBalancers) Reconcile() (LoadBalancers, error)
  • func (l LoadBalancers) StripDesiredState()
• type ResourceRecordSet
  • func NewResourceRecordSet(hostname *string, ingressID *string) *ResourceRecordSet
  • func (r *ResourceRecordSet) PopulateFromLoadBalancer(lb *elbv2.LoadBalancer)
  • func (r *ResourceRecordSet) Reconcile(lb *LoadBalancer) error
• type Rule
  • func NewRule(path extensions.HTTPIngressPath, ingressID *string) *Rule
  • func (r *Rule) Equals(target *elbv2.Rule) bool
  • func (r *Rule) Reconcile(lb *LoadBalancer, l *Listener) error
• type Rules
  • func (r Rules) Find(rule *elbv2.Rule) int
  • func (r Rules) Reconcile(lb *LoadBalancer, l *Listener) error
  • func (r Rules) StripCurrentState()
  • func (r Rules) StripDesiredState()
• type TargetGroup
  • func NewTargetGroup(annotations *config.Annotations, tags util.Tags, ...) *TargetGroup
  • func (tg *TargetGroup) Reconcile(lb *LoadBalancer) error
• type TargetGroups
  • func (t TargetGroups) Find(tg *TargetGroup) int
  • func (t TargetGroups) LookupBySvc(svc string) int
  • func (t TargetGroups) Reconcile(lb *LoadBalancer) error
  • func (t TargetGroups) StripDesiredState()

Types

type Listener

type Listener struct {
	IngressID       *string
	CurrentListener *elbv2.Listener
	DesiredListener *elbv2.Listener
	Rules           Rules
	// contains filtered or unexported fields
}

Listener contains the relevant ID, Rules, and current/desired Listeners

func NewListener

func NewListener(annotations *config.Annotations, ingressID *string) []*Listener

NewListener returns a new alb.Listener based on the parameters provided.

func (*Listener) Reconcile

func (l *Listener) Reconcile(lb *LoadBalancer) error

Reconcile compares the current and desired state of this Listener instance. Comparison results in no action, the creation, the deletion, or the modification of an AWS listener to satisfy the ingress's current state.

type Listeners

type Listeners []*Listener

Listeners is a slice of Listener pointers

func (Listeners) Find

func (ls Listeners) Find(listener *elbv2.Listener) int

Find returns the position of the listener, returning -1 if unfound.

func (Listeners) Reconcile

func (ls Listeners) Reconcile(lb *LoadBalancer, tgs *TargetGroups) error

Reconcile kicks off the state synchronization for every Listener in this Listeners instances.

func (Listeners) StripCurrentState

func (ls Listeners) StripCurrentState()

StripCurrentState takes all listeners and sets their CurrentListener to nil. Most commonly used when an ELB must be re-created fully. When the deletion of the ELB occurs, the listeners attached are also deleted, thus the ingress controller must know they no longer exist.

Additionally, since Rules are also removed its Listener is, this also calles StripDesiredState on the Rules attached to each listener.

func (Listeners) StripDesiredState

func (ls Listeners) StripDesiredState()

StripDesiredState removes the DesiredListener from all Listeners in the slice.

type LoadBalancer

type LoadBalancer struct {
	ID                  *string
	IngressID           *string // Same Id as ingress object this comes from.
	Hostname            *string
	CurrentLoadBalancer *elbv2.LoadBalancer // current version of load balancer in AWS
	DesiredLoadBalancer *elbv2.LoadBalancer // current version of load balancer in AWS
	ResourceRecordSet   *ResourceRecordSet
	TargetGroups        TargetGroups
	Listeners           Listeners
	CurrentTags         util.Tags
	DesiredTags         util.Tags
	Deleted             bool // flag representing the LoadBalancer instance was fully deleted.
	LastRulePriority    int64
}

LoadBalancer contains the overarching configuration for the ALB

func NewLoadBalancer

func NewLoadBalancer(clustername, namespace, ingressname, hostname string, ingressID *string, annotations *config.Annotations, tags util.Tags) *LoadBalancer

NewLoadBalancer returns a new alb.LoadBalancer based on the parameters provided.

func (*LoadBalancer) Reconcile

func (lb *LoadBalancer) Reconcile() error

Reconcile compares the current and desired state of this LoadBalancer instance. Comparison results in no action, the creation, the deletion, or the modification of an AWS ELBV2 (ALB) to satisfy the ingress's current state.

type LoadBalancers

type LoadBalancers []*LoadBalancer

LoadBalancers is a slice of LoadBalancer pointers

func (LoadBalancers) Find

func (l LoadBalancers) Find(lb *LoadBalancer) int

Find returns the position of the lb parameter within the LoadBalancers slice, -1 if it is not found

func (LoadBalancers) Reconcile

func (l LoadBalancers) Reconcile() (LoadBalancers, error)

Reconcile calls for state synchronization (comparison of current and desired) for the load balancer and its resource record set, target group(s), and listener(s).

func (LoadBalancers) StripDesiredState

func (l LoadBalancers) StripDesiredState()

StripDesiredState removes the DesiredLoadBalancers from a LoadBalancers slice

type ResourceRecordSet

type ResourceRecordSet struct {
	IngressID                *string
	ZoneID                   *string
	Resolveable              bool
	CurrentResourceRecordSet *route53.ResourceRecordSet
	DesiredResourceRecordSet *route53.ResourceRecordSet
}

ResourceRecordSet contains the relevant Route 53 zone id for the host name along with the current and desired state.

func NewResourceRecordSet

func NewResourceRecordSet(hostname *string, ingressID *string) *ResourceRecordSet

NewResourceRecordSet returns a new route53.ResourceRecordSet based on the LoadBalancer provided.

func (*ResourceRecordSet) PopulateFromLoadBalancer

func (r *ResourceRecordSet) PopulateFromLoadBalancer(lb *elbv2.LoadBalancer)

PopulateFromLoadBalancer configures the DesiredResourceRecordSet with values from a n elbv2.LoadBalancer

func (*ResourceRecordSet) Reconcile

func (r *ResourceRecordSet) Reconcile(lb *LoadBalancer) error

Reconcile compares the current and desired state of this ResourceRecordSet instance. Comparison results in no action, the creation, the deletion, or the modification of Route 53 resource record set to satisfy the ingress's current state.

type Rule

type Rule struct {
	IngressID   *string
	SvcName     string
	CurrentRule *elbv2.Rule
	DesiredRule *elbv2.Rule
	// contains filtered or unexported fields
}

Rule contains a current/desired Rule

func NewRule

func NewRule(path extensions.HTTPIngressPath, ingressID *string) *Rule

NewRule returns an alb.Rule based on the provided parameters.

func (*Rule) Equals

func (r *Rule) Equals(target *elbv2.Rule) bool

Equals returns true if the two CurrentRule and target rule are the same Does not compare priority, since this is not supported by the ingress spec

func (*Rule) Reconcile

func (r *Rule) Reconcile(lb *LoadBalancer, l *Listener) error

Reconcile compares the current and desired state of this Rule instance. Comparison results in no action, the creation, the deletion, or the modification of an AWS Rule to satisfy the ingress's current state.

type Rules

type Rules []*Rule

Rules contains a slice of Rules

func (Rules) Find

func (r Rules) Find(rule *elbv2.Rule) int

Find returns the position in the Rules slice of the rule parameter

func (Rules) Reconcile

func (r Rules) Reconcile(lb *LoadBalancer, l *Listener) error

Reconcile kicks off the state synchronization for every Rule in this Rules slice.

func (Rules) StripCurrentState

func (r Rules) StripCurrentState()

StripCurrentState removes the CurrentRule reference from all Rule instances. Most commonly used when the Listener it related to has been deleted.

func (Rules) StripDesiredState

func (r Rules) StripDesiredState()

StripDesiredState removes the DesiredListener from all Rules in the slice.

type TargetGroup

type TargetGroup struct {
	ID                 *string
	IngressID          *string
	SvcName            string
	CurrentTags        util.Tags
	DesiredTags        util.Tags
	CurrentTargets     util.AWSStringSlice
	DesiredTargets     util.AWSStringSlice
	CurrentTargetGroup *elbv2.TargetGroup
	DesiredTargetGroup *elbv2.TargetGroup
	// contains filtered or unexported fields
}

TargetGroup contains the current/desired tags & targetgroup for the ALB

func NewTargetGroup

func NewTargetGroup(annotations *config.Annotations, tags util.Tags, clustername, loadBalancerID *string, port *int64, ingressID *string, svcName string) *TargetGroup

NewTargetGroup returns a new alb.TargetGroup based on the parameters provided.

func (*TargetGroup) Reconcile

func (tg *TargetGroup) Reconcile(lb *LoadBalancer) error

Reconcile compares the current and desired state of this TargetGroup instance. Comparison results in no action, the creation, the deletion, or the modification of an AWS target group to satisfy the ingress's current state.

type TargetGroups

type TargetGroups []*TargetGroup

TargetGroups is a slice of TargetGroup pointers

func (TargetGroups) Find

func (t TargetGroups) Find(tg *TargetGroup) int

Find returns the position of a TargetGroup by its ID, returning -1 if unfound.

func (TargetGroups) LookupBySvc

func (t TargetGroups) LookupBySvc(svc string) int

LookupBySvc returns the position of a TargetGroup by its SvcName, returning -1 if unfound.

func (TargetGroups) Reconcile

func (t TargetGroups) Reconcile(lb *LoadBalancer) error

Reconcile kicks off the state synchronization for every target group inside this TargetGroups instance.

func (TargetGroups) StripDesiredState

func (t TargetGroups) StripDesiredState()

StripDesiredState removes the DesiredTags, DesiredTargetGroup, and DesiredTargets from all TargetGroups