service

Documentation

Index

• Constants
• func NewResourceStack(dp *appsv1.Deployment, svc *corev1.Service, baseName string, ...) *resourceStack
• type LoadBalancerExpectation
• type NLBIPTestStack
  • func (s *NLBIPTestStack) Cleanup(ctx context.Context, f *framework.Framework) error
  • func (s *NLBIPTestStack) Deploy(ctx context.Context, f *framework.Framework, svc *corev1.Service, ...) error
  • func (s *NLBIPTestStack) GetLoadBalancerIngressHostName() string
  • func (s *NLBIPTestStack) ScaleDeployment(ctx context.Context, f *framework.Framework, numReplicas int32) error
  • func (s *NLBIPTestStack) SendTrafficToLB(ctx context.Context, f *framework.Framework) error
  • func (s *NLBIPTestStack) UpdateServiceAnnotations(ctx context.Context, f *framework.Framework, svcAnnotations map[string]string) error
• type NLBInstanceTestStack
  • func (s *NLBInstanceTestStack) ApplyNodeLabels(ctx context.Context, f *framework.Framework, node *corev1.Node, ...) error
  • func (s *NLBInstanceTestStack) Cleanup(ctx context.Context, f *framework.Framework) error
  • func (s *NLBInstanceTestStack) DeleteServiceAnnotations(ctx context.Context, f *framework.Framework, annotationKeys []string) error
  • func (s *NLBInstanceTestStack) Deploy(ctx context.Context, f *framework.Framework, svcAnnotations map[string]string) error
  • func (s *NLBInstanceTestStack) GetLoadBalancerIngressHostName() string
  • func (s *NLBInstanceTestStack) GetWorkerNodes(ctx context.Context, f *framework.Framework) ([]corev1.Node, error)
  • func (s *NLBInstanceTestStack) ScaleDeployment(ctx context.Context, f *framework.Framework, numReplicas int32) error
  • func (s *NLBInstanceTestStack) UpdateServiceAnnotations(ctx context.Context, f *framework.Framework, svcAnnotations map[string]string) error
  • func (s *NLBInstanceTestStack) UpdateServiceTrafficPolicy(ctx context.Context, f *framework.Framework, ...) error
• type TargetGroupHC

Constants

const (
	ResourceTypeELBLoadBalancer = "elasticloadbalancing:loadbalancer"
)

Functions

func NewResourceStack

func NewResourceStack(dp *appsv1.Deployment, svc *corev1.Service, baseName string, enablePodReadinessGate bool) *resourceStack

Types

type LoadBalancerExpectation

type LoadBalancerExpectation struct {
	Name          string
	Type          string
	Scheme        string
	TargetType    string
	Listeners     map[string]string // listener port, protocol
	TargetGroups  map[string]string // target group port, protocol
	NumTargets    int
	TargetGroupHC *TargetGroupHC
}

type NLBIPTestStack

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

func (*NLBIPTestStack) Cleanup

func (s *NLBIPTestStack) Cleanup(ctx context.Context, f *framework.Framework) error

func (*NLBIPTestStack) Deploy

func (s *NLBIPTestStack) Deploy(ctx context.Context, f *framework.Framework, svc *corev1.Service, dp *appsv1.Deployment) error

func (*NLBIPTestStack) GetLoadBalancerIngressHostName

func (s *NLBIPTestStack) GetLoadBalancerIngressHostName() string

func (*NLBIPTestStack) ScaleDeployment

func (s *NLBIPTestStack) ScaleDeployment(ctx context.Context, f *framework.Framework, numReplicas int32) error

func (*NLBIPTestStack) SendTrafficToLB

func (s *NLBIPTestStack) SendTrafficToLB(ctx context.Context, f *framework.Framework) error

func (*NLBIPTestStack) UpdateServiceAnnotations

func (s *NLBIPTestStack) UpdateServiceAnnotations(ctx context.Context, f *framework.Framework, svcAnnotations map[string]string) error

type NLBInstanceTestStack

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

func (*NLBInstanceTestStack) ApplyNodeLabels

func (s *NLBInstanceTestStack) ApplyNodeLabels(ctx context.Context, f *framework.Framework, node *corev1.Node, labels map[string]string) error

func (*NLBInstanceTestStack) Cleanup

func (s *NLBInstanceTestStack) Cleanup(ctx context.Context, f *framework.Framework) error

func (*NLBInstanceTestStack) DeleteServiceAnnotations

func (s *NLBInstanceTestStack) DeleteServiceAnnotations(ctx context.Context, f *framework.Framework, annotationKeys []string) error

func (*NLBInstanceTestStack) Deploy

func (s *NLBInstanceTestStack) Deploy(ctx context.Context, f *framework.Framework, svcAnnotations map[string]string) error

func (*NLBInstanceTestStack) GetLoadBalancerIngressHostName

func (s *NLBInstanceTestStack) GetLoadBalancerIngressHostName() string

func (*NLBInstanceTestStack) GetWorkerNodes

func (s *NLBInstanceTestStack) GetWorkerNodes(ctx context.Context, f *framework.Framework) ([]corev1.Node, error)

func (*NLBInstanceTestStack) ScaleDeployment

func (s *NLBInstanceTestStack) ScaleDeployment(ctx context.Context, f *framework.Framework, numReplicas int32) error

func (*NLBInstanceTestStack) UpdateServiceAnnotations

func (s *NLBInstanceTestStack) UpdateServiceAnnotations(ctx context.Context, f *framework.Framework, svcAnnotations map[string]string) error

func (*NLBInstanceTestStack) UpdateServiceTrafficPolicy

func (s *NLBInstanceTestStack) UpdateServiceTrafficPolicy(ctx context.Context, f *framework.Framework, trafficPolicy corev1.ServiceExternalTrafficPolicyType) error

type TargetGroupHC

type TargetGroupHC struct {
	Protocol           string
	Path               string
	Port               string
	Interval           int64
	Timeout            int64
	HealthyThreshold   int64
	UnhealthyThreshold int64
}