Functions — github.com/aws/zone-aware-controllers-for-k8s

hub / github.com/aws/zone-aware-controllers-for-k8s / functions

Functions188 in github.com/aws/zone-aware-controllers-for-k8s

⨍ Functions 188◇ Types & classes 24

↓ 1 callersFunctioncontextWithStatefulSetName

(ctx context.Context, name string)

e2e/zau/env_test.go:90

↓ 1 callersFunctioncontextWithZauName

(ctx context.Context, name string)

e2e/zau/env_test.go:94

↓ 1 callersFunctioncontextWithZdbName

(ctx context.Context, name string)

e2e/zdb/env_test.go:63

↓ 1 callersFunctioncountHealthyPods

Adapted from `DisruptionController.countHealthyPods()`: https://github.com/kubernetes/kubernetes/blob/d7123a65248/pkg/controller/disruption/disruption

controllers/zdb_controller.go:244

↓ 1 callersFunctioncreatePods

Create n number of pod replicas evenly distributed accross zones. Example: 3 replicas, 3 zones zone-1: [pod-0, pod-3, pod-6] zone-2: [pod-1, pod-4,

controllers/zau_controller_test.go:594

↓ 1 callersFunctioncreateStatefulSet

(replicas int32)

pkg/utils/pod_controller_finder_test.go:14

↓ 1 callersMethoddeletePods

(ctx context.Context, zau *opsv1.ZoneAwareUpdate, sts *apps.StatefulSet, pods []*v1.Pod, oldPodsCountMap map[

controllers/zau_controller.go:328

↓ 1 callersFunctiondeployHealthyImage

deployHealthyImage will upgrade the StatefulSet under test to a working container image

e2e/zau/faults_test.go:26

↓ 1 callersFunctiongetDeployedImages

getDeployedImages returns a list of the unique container images being run by statefulset pods

e2e/zau/zau_test.go:418

↓ 1 callersMethodgetDryRunOption

(req admission.Request)

webhooks/eviction_webhook.go:278

↓ 1 callersMethodgetExpectedPodCount

Adapted from `DisruptionController.getExpectedPodCount()`: https://github.com/kubernetes/kubernetes/blob/d7123a65248/pkg/controller/disruption/disrupt

controllers/zdb_controller.go:153

↓ 1 callersMethodgetExpectedScale

Adapted from `DisruptionController.getExpectedScale()`: https://github.com/kubernetes/kubernetes/blob/d7123a65248/pkg/controller/disruption/disruption

controllers/zdb_controller.go:276

↓ 1 callersFunctiongetNamespaceNames

(list corev1.NamespaceList)

e2e/zau/utils.go:7

↓ 1 callersFunctiongetOrdinal

(pod *v1.Pod)

controllers/zau_controller_test.go:606

↓ 1 callersFunctiongetPodNames

(list corev1.PodList)

e2e/zau/utils.go:15

↓ 1 callersMethodgetPodStatefulSet

(pod *v1.Pod)

controllers/zau_controller.go:426

↓ 1 callersMethodgetPodsForZdb

(ctx context.Context, zdb *opsv1.ZoneDisruptionBudget)

controllers/zdb_controller.go:130

↓ 1 callersMethodgetStatefulSetPods

(ctx context.Context, sts *apps.StatefulSet)

controllers/zau_controller.go:211

↓ 1 callersFunctiongetZauForStatefulSet

(c client.Client, logger logr.Logger, sts *apps.StatefulSet)

controllers/zau_controller.go:469

↓ 1 callersMethodgetZone

(ctx context.Context, pod *v1.Pod)

webhooks/eviction_webhook.go:264

↓ 1 callersMethodhandler

(ctx context.Context, req admission.Request)

webhooks/eviction_webhook.go:85

↓ 1 callersFunctionisDisruptedPod

(podName string, zdb *opsv1.ZoneDisruptionBudget)

webhooks/eviction_webhook.go:259

↓ 1 callersFunctionmakeAWSConfig

()

e2e/env.go:54

↓ 1 callersFunctionmakeEKSClient

(awsconf aws.Config)

e2e/env.go:63

↓ 1 callersFunctionpauseAlarmPatch

(alarm string)

e2e/zau/manifests.go:76

↓ 1 callersMethodpauseRollout

(ctx context.Context, zau *opsv1.ZoneAwareUpdate)

controllers/zau_controller.go:308

↓ 1 callersFunctionpodImagePatch

(image string)

e2e/faults.go:80

↓ 1 callersFunctionstatefulSetNameFromContext

(ctx context.Context)

e2e/zdb/env_test.go:75

↓ 1 callersFunctionstatefulsetImagePatch

(image string)

e2e/zau/manifests.go:60

↓ 1 callersMethodsync

Adapted from `DisruptionController.trySync()`: https://github.com/kubernetes/kubernetes/blob/d7123a652/pkg/controller/disruption/disruption.go#L588

controllers/zdb_controller.go:103

↓ 1 callersMethodupdateStatefulSetRevision

(ctx context.Context, sts *apps.StatefulSet)

controllers/zau_controller.go:251

↓ 1 callersMethodupdateStatus

Adapted from `DisruptionController.updatePdbStatus()`: https://github.com/kubernetes/kubernetes/blob/d7123a65248/pkg/controller/disruption/disruption.

controllers/zdb_controller.go:326

↓ 1 callersFunctionverifyGroupKind

(controllerRef *metav1.OwnerReference, expectedKind string, expectedGroups []string)

pkg/utils/pod_controller_finder.go:81

↓ 1 callersFunctionzdbNameFromContext

(ctx context.Context)

e2e/zdb/env_test.go:67

MethodAlarmState

(ctx context.Context, alarmName string)

controllers/zau_controller_test.go:26

FunctionCreatePodZoneMap

CreatePodZoneMap indexes all pods by zone and stores the index in context for faster lookup in tests

e2e/env.go:125

FunctionCreateTestNamespace

CreateTestNamespace creates a namespace with a random name. It is stored in the context so that the deleteTestNamespace routine can look it up and del

e2e/env.go:145

MethodDeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ZoneAwareUpdateSpec.

api/v1/zz_generated.deepcopy.go:103

MethodDeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ZoneAwareUpdateStatus.

api/v1/zz_generated.deepcopy.go:125

MethodDeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ZoneDisruptionBudgetSpec.

api/v1/zz_generated.deepcopy.go:209

MethodDeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ZoneDisruptionBudgetStatus.

api/v1/zz_generated.deepcopy.go:266

MethodDeepCopyObject

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

api/v1/zz_generated.deepcopy.go:53

MethodDeepCopyObject

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

api/v1/zz_generated.deepcopy.go:85

MethodDeepCopyObject

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

api/v1/zz_generated.deepcopy.go:154

MethodDeepCopyObject

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

api/v1/zz_generated.deepcopy.go:186

FunctionDeleteTestNamespace

DeleteTestNamespace looks up the test namespace from ctx and deletes it.

e2e/env.go:156

MethodDescribeAlarms

(ctx context.Context, params *cloudwatch.DescribeAlarmsInput, optFns ...func(*cloudwatch.Options))

controllers/zau_controller.go:59

MethodDescribeAlarms

(ctx context.Context, params *cloudwatch.DescribeAlarmsInput, optFns ...func(*cloudwatch.Options))

pkg/utils/alarm_status_provider_test.go:14

MethodHandle

(ctx context.Context, req admission.Request)

webhooks/eviction_webhook.go:74

MethodInjectDecoder

(d *admission.Decoder)

webhooks/eviction_webhook.go:80

MethodLen

()

pkg/utils/sort_map.go:12

MethodLess

(i, j int)

pkg/utils/sort_map.go:13

MethodReconcile

+kubebuilder:rbac:groups=zonecontrol.k8s.aws,resources=zonedisruptionbudgets,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=

controllers/zdb_controller.go:80

MethodReconcile

+kubebuilder:rbac:groups=zonecontrol.k8s.aws,resources=zoneawareupdates,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=zonec

controllers/zau_controller.go:85

FunctionResource

(resource string)

api/v1/groupversion_info.go:41

MethodSetupWithManager

SetupWithManager sets up the controller with the Manager.

controllers/zdb_controller.go:386

MethodSwap

(i, j int)

pkg/utils/sort_map.go:14

FunctionTestAPIs

(t *testing.T)

pkg/utils/pod_controller_finder_suite_test.go:23

FunctionTestAPIs

(t *testing.T)

pkg/podzone/helper_suite_test.go:26

FunctionTestAPIs

(t *testing.T)

webhooks/suite_test.go:60

FunctionTestCloudWatchAlarmStatusProvider

(t *testing.T)

pkg/utils/alarm_status_provider_test.go:18

FunctionTestController

(t *testing.T)

controllers/suite_test.go:54

FunctionTestControllersToStart

(t *testing.T)

main_test.go:10

FunctionTestE2EZauAttemptsDeployment

(t *testing.T)

e2e/zau/zau_test.go:70

FunctionTestE2EZauOverlappingDeployments

(t *testing.T)

e2e/zau/zau_test.go:209

FunctionTestE2EZauPausesDeployment

(t *testing.T)

e2e/zau/zau_test.go:98

FunctionTestE2EZauRollback

(t *testing.T)

e2e/zau/zau_test.go:167

FunctionTestE2EZauRolloutAlarm

Note: this test (and the operator) make some assumptions about infrastructure and the context of the test runner * Test runner environment must have A

e2e/zau/zau_test.go:262

FunctionTestE2EZauSimpleDeployment

(t *testing.T)

e2e/zau/zau_test.go:31

FunctionTestE2EZdbEviction

(t *testing.T)

e2e/zdb/zdb_test.go:24

FunctionTestGetNamespaceNames

(t *testing.T)

e2e/zau/utils_test.go:11

FunctionTestGetPodNames

(t *testing.T)

e2e/zau/utils_test.go:54

FunctionTestIsRunningAndReady

(t *testing.T)

pkg/utils/utils_test.go:11

FunctionTestIsSortMapByValue

(t *testing.T)

pkg/utils/sort_map_test.go:9

FunctionTestMain

(m *testing.M)

e2e/zdb/main_test.go:19

FunctionTestMain

(m *testing.M)

e2e/zau/main_test.go:19

FunctioncreateStatefulSet

createStatefulSet initializes a StatefulSet to use in controller tests

e2e/zdb/env_test.go:36

FunctioncreateStatefulSet

createStatefulSet instantiates a StatefulSet for controllers to target in tests

e2e/zau/env_test.go:24

FunctioncreateZAU

createZAU initializes a ZAU instance in the test namespace

e2e/zau/env_test.go:38

FunctioncreateZDB

createZDB initializes a ZDB instance in the test namespace

e2e/zdb/env_test.go:22

MethodfindZdbForPod

(obj client.Object)

controllers/zdb_controller.go:397

pkg/metrics/metrics.go:113

Functioninit

()

api/v1/zau_types.go:115

Functioninit

()

api/v1/zdb_types.go:110

FunctionkeyFunc

(obj interface{})

pkg/podzone/cache.go:22

Functionmain

()

main.go:69

FunctionwaitForHealthyEnvironment

waitForHealthyEnvironment confirms that tests are targeting a healthy environment

e2e/zau/env_test.go:52

← previous101–188 of 188, ranked by callers