Home
last modified time | relevance | path

Searched defs:StatefulSet (Results 1 – 25 of 525) sorted by relevance

12345678910>>...21

/dports/sysutils/kubectl/kubernetes-1.22.2/pkg/controller/statefulset/
H A Dstateful_set_utils.go87 func getPodName(set *apps.StatefulSet, ordinal int) string {
99 func isMemberOf(set *apps.StatefulSet, pod *v1.Pod) bool {
104 func identityMatches(set *apps.StatefulSet, pod *v1.Pod) bool {
114 func storageMatches(set *apps.StatefulSet, pod *v1.Pod) bool {
160 func updateStorage(set *apps.StatefulSet, pod *v1.Pod) {
184 func initIdentity(set *apps.StatefulSet, pod *v1.Pod) {
193 func updateIdentity(set *apps.StatefulSet, pod *v1.Pod) {
232 func allowsBurst(set *apps.StatefulSet) bool {
254 func newStatefulSetPod(set *apps.StatefulSet, ordinal int) *v1.Pod {
280 func Match(ss *apps.StatefulSet, history *apps.ControllerRevision) (bool, error) {
[all …]
H A Dstateful_set_control_test.go74 func burst(set *apps.StatefulSet) *apps.StatefulSet {
79 func setMinReadySeconds(set *apps.StatefulSet, minReadySeconds int32) *apps.StatefulSet {
124 func CreatesPods(t *testing.T, set *apps.StatefulSet, invariants invariantFunc) {
148 func ScalesUp(t *testing.T, set *apps.StatefulSet, invariants invariantFunc) {
176 func ScalesDown(t *testing.T, set *apps.StatefulSet, invariants invariantFunc) {
199 func ReplacesPods(t *testing.T, set *apps.StatefulSet, invariants invariantFunc) {
308 func CreatePodFailure(t *testing.T, set *apps.StatefulSet, invariants invariantFunc) {
336 func UpdatePodFailure(t *testing.T, set *apps.StatefulSet, invariants invariantFunc) {
2045 func scaleUpStatefulSetControl(set *apps.StatefulSet,
2161 func updateComplete(set *apps.StatefulSet, pods []*v1.Pod) bool {
[all …]
H A Dstateful_set_control.go41 UpdateStatefulSet(set *apps.StatefulSet, pods []*v1.Pod) (*apps.StatefulSetStatus, error)
44 ListRevisions(set *apps.StatefulSet) ([]*apps.ControllerRevision, error)
47 AdoptOrphanRevisions(set *apps.StatefulSet, revisions []*apps.ControllerRevision) error
H A Dstateful_pod_control.go44 CreateStatefulPod(set *apps.StatefulSet, pod *v1.Pod) error
49 UpdateStatefulPod(set *apps.StatefulSet, pod *v1.Pod) error
52 DeleteStatefulPod(set *apps.StatefulSet, pod *v1.Pod) error
/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e/framework/statefulset/
H A Dwait.go34 …WaitForRunning(c clientset.Interface, numPodsRunning, numPodsReady int32, ss *appsv1.StatefulSet) {
63 func WaitForState(c clientset.Interface, ss *appsv1.StatefulSet, until func(*appsv1.StatefulSet, *v…
79 func WaitForRunningAndReady(c clientset.Interface, numStatefulPods int32, ss *appsv1.StatefulSet) {
84 func WaitForPodReady(c clientset.Interface, set *appsv1.StatefulSet, podName string) (*appsv1.State…
100 func WaitForStatusReadyReplicas(c clientset.Interface, ss *appsv1.StatefulSet, expectedReplicas int…
125 func WaitForStatusAvailableReplicas(c clientset.Interface, ss *appsv1.StatefulSet, expectedReplicas…
150 func WaitForStatusReplicas(c clientset.Interface, ss *appsv1.StatefulSet, expectedReplicas int32) {
175 func Saturate(c clientset.Interface, ss *appsv1.StatefulSet) {
H A Drest.go64 func GetPodList(c clientset.Interface, ss *appsv1.StatefulSet) *v1.PodList {
145 func Scale(c clientset.Interface, ss *appsv1.StatefulSet, count int32) (*appsv1.StatefulSet, error)…
174 func UpdateReplicas(c clientset.Interface, ss *appsv1.StatefulSet, count int32) {
179 func Restart(c clientset.Interface, ss *appsv1.StatefulSet) {
191 func CheckHostname(c clientset.Interface, ss *appsv1.StatefulSet) error {
207 func CheckMount(c clientset.Interface, ss *appsv1.StatefulSet, mountPath string) error {
224 func CheckServiceName(ss *appsv1.StatefulSet, expectedServiceName string) error {
236 func ExecInStatefulPods(c clientset.Interface, ss *appsv1.StatefulSet, cmd string) error {
249 func update(c clientset.Interface, ns, name string, update func(ss *appsv1.StatefulSet)) *appsv1.St… func
/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e/apps/
H A Dwait.go33 func waitForPartitionedRollingUpdate(c clientset.Interface, set *appsv1.StatefulSet) (*appsv1.State…
87 func waitForStatus(c clientset.Interface, set *appsv1.StatefulSet) *appsv1.StatefulSet {
99 func waitForPodNotReady(c clientset.Interface, set *appsv1.StatefulSet, podName string) (*appsv1.St…
116 func waitForRollingUpdate(c clientset.Interface, set *appsv1.StatefulSet) (*appsv1.StatefulSet, *v1…
153 func waitForRunningAndNotReady(c clientset.Interface, numStatefulPods int32, ss *appsv1.StatefulSet…
H A Dstatefulset.go1372 func rollbackTest(c clientset.Interface, ns string, ss *appsv1.StatefulSet) {
1475 func confirmStatefulPodCount(c clientset.Interface, count int, ss *appsv1.StatefulSet, timeout time…
1499 func setHTTPProbe(ss *appsv1.StatefulSet) {
1504 func breakHTTPProbe(c clientset.Interface, ss *appsv1.StatefulSet) error {
1515 func breakPodHTTPProbe(ss *appsv1.StatefulSet, pod *v1.Pod) error {
1528 func restoreHTTPProbe(c clientset.Interface, ss *appsv1.StatefulSet) error {
1539 func restorePodHTTPProbe(ss *appsv1.StatefulSet, pod *v1.Pod) error {
1552 func deleteStatefulPodAtIndex(c clientset.Interface, index int, ss *appsv1.StatefulSet) {
1561 func getStatefulSetPodNameAtIndex(index int, ss *appsv1.StatefulSet) string {
/dports/net-mgmt/prometheus1/prometheus-1.8.2/vendor/k8s.io/client-go/pkg/apis/apps/v1beta1/
H A Dzz_generated.conversion.go52 func autoConvert_v1beta1_StatefulSet_To_apps_StatefulSet(in *StatefulSet, out *apps.StatefulSet, s …
63 func Convert_v1beta1_StatefulSet_To_apps_StatefulSet(in *StatefulSet, out *apps.StatefulSet, s conv…
67 func autoConvert_apps_StatefulSet_To_v1beta1_StatefulSet(in *apps.StatefulSet, out *StatefulSet, s …
78 func Convert_apps_StatefulSet_To_v1beta1_StatefulSet(in *apps.StatefulSet, out *StatefulSet, s conv…
/dports/net-mgmt/prometheus1/prometheus-1.8.2/vendor/k8s.io/client-go/pkg/apis/apps/
H A Dtypes.go32 type StatefulSet struct { struct
33 metav1.TypeMeta
35 metav1.ObjectMeta
39 Spec StatefulSetSpec
44 Status StatefulSetStatus
/dports/sysutils/kubectl/kubernetes-1.22.2/test/integration/statefulset/
H A Dutil.go199 func createSTSsPods(t *testing.T, clientSet clientset.Interface, stss []*appsv1.StatefulSet, pods […
221 func waitSTSStable(t *testing.T, clientSet clientset.Interface, sts *appsv1.StatefulSet) {
280 …tsClient typedappsv1.StatefulSetInterface, stsName string, updateFunc func(*appsv1.StatefulSet)) *…
297 func scaleSTS(t *testing.T, c clientset.Interface, sts *appsv1.StatefulSet, replicas int32) {
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/k8s.io/client-go/applyconfigurations/apps/v1beta2/
H A Dstatefulset.go41 func StatefulSet(name, namespace string) *StatefulSetApplyConfiguration { func
61 func ExtractStatefulSet(statefulSet *appsv1beta2.StatefulSet, fieldManager string) (*StatefulSetApp…
68 func ExtractStatefulSetStatus(statefulSet *appsv1beta2.StatefulSet, fieldManager string) (*Stateful…
72 func extractStatefulSet(statefulSet *appsv1beta2.StatefulSet, fieldManager string, subresource stri…
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/k8s.io/client-go/applyconfigurations/apps/v1/
H A Dstatefulset.go41 func StatefulSet(name, namespace string) *StatefulSetApplyConfiguration { func
61 func ExtractStatefulSet(statefulSet *apiappsv1.StatefulSet, fieldManager string) (*StatefulSetApply…
68 func ExtractStatefulSetStatus(statefulSet *apiappsv1.StatefulSet, fieldManager string) (*StatefulSe…
72 func extractStatefulSet(statefulSet *apiappsv1.StatefulSet, fieldManager string, subresource string…
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/k8s.io/client-go/applyconfigurations/apps/v1beta1/
H A Dstatefulset.go41 func StatefulSet(name, namespace string) *StatefulSetApplyConfiguration { func
61 func ExtractStatefulSet(statefulSet *appsv1beta1.StatefulSet, fieldManager string) (*StatefulSetApp…
68 func ExtractStatefulSetStatus(statefulSet *appsv1beta1.StatefulSet, fieldManager string) (*Stateful…
72 func extractStatefulSet(statefulSet *appsv1beta1.StatefulSet, fieldManager string, subresource stri…
/dports/net/traefik/traefik-2.6.1/vendor/k8s.io/client-go/applyconfigurations/apps/v1beta1/
H A Dstatefulset.go41 func StatefulSet(name, namespace string) *StatefulSetApplyConfiguration { func
61 func ExtractStatefulSet(statefulSet *appsv1beta1.StatefulSet, fieldManager string) (*StatefulSetApp…
68 func ExtractStatefulSetStatus(statefulSet *appsv1beta1.StatefulSet, fieldManager string) (*Stateful…
72 func extractStatefulSet(statefulSet *appsv1beta1.StatefulSet, fieldManager string, subresource stri…
/dports/net/traefik/traefik-2.6.1/vendor/k8s.io/client-go/applyconfigurations/apps/v1beta2/
H A Dstatefulset.go41 func StatefulSet(name, namespace string) *StatefulSetApplyConfiguration { func
61 func ExtractStatefulSet(statefulSet *appsv1beta2.StatefulSet, fieldManager string) (*StatefulSetApp…
68 func ExtractStatefulSetStatus(statefulSet *appsv1beta2.StatefulSet, fieldManager string) (*Stateful…
72 func extractStatefulSet(statefulSet *appsv1beta2.StatefulSet, fieldManager string, subresource stri…
/dports/net/traefik/traefik-2.6.1/vendor/k8s.io/client-go/applyconfigurations/apps/v1/
H A Dstatefulset.go41 func StatefulSet(name, namespace string) *StatefulSetApplyConfiguration { func
61 func ExtractStatefulSet(statefulSet *apiappsv1.StatefulSet, fieldManager string) (*StatefulSetApply…
68 func ExtractStatefulSetStatus(statefulSet *apiappsv1.StatefulSet, fieldManager string) (*StatefulSe…
72 func extractStatefulSet(statefulSet *apiappsv1.StatefulSet, fieldManager string, subresource string…
/dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/client-go/applyconfigurations/apps/v1beta2/
H A Dstatefulset.go41 func StatefulSet(name, namespace string) *StatefulSetApplyConfiguration { func
61 func ExtractStatefulSet(statefulSet *appsv1beta2.StatefulSet, fieldManager string) (*StatefulSetApp…
68 func ExtractStatefulSetStatus(statefulSet *appsv1beta2.StatefulSet, fieldManager string) (*Stateful…
72 func extractStatefulSet(statefulSet *appsv1beta2.StatefulSet, fieldManager string, subresource stri…
/dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/client-go/applyconfigurations/apps/v1beta1/
H A Dstatefulset.go41 func StatefulSet(name, namespace string) *StatefulSetApplyConfiguration { func
61 func ExtractStatefulSet(statefulSet *appsv1beta1.StatefulSet, fieldManager string) (*StatefulSetApp…
68 func ExtractStatefulSetStatus(statefulSet *appsv1beta1.StatefulSet, fieldManager string) (*Stateful…
72 func extractStatefulSet(statefulSet *appsv1beta1.StatefulSet, fieldManager string, subresource stri…
/dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/client-go/applyconfigurations/apps/v1/
H A Dstatefulset.go41 func StatefulSet(name, namespace string) *StatefulSetApplyConfiguration { func
61 func ExtractStatefulSet(statefulSet *apiappsv1.StatefulSet, fieldManager string) (*StatefulSetApply…
68 func ExtractStatefulSetStatus(statefulSet *apiappsv1.StatefulSet, fieldManager string) (*StatefulSe…
72 func extractStatefulSet(statefulSet *apiappsv1.StatefulSet, fieldManager string, subresource string…
/dports/www/grafana8/grafana-8.3.6/vendor/k8s.io/client-go/applyconfigurations/apps/v1beta2/
H A Dstatefulset.go41 func StatefulSet(name, namespace string) *StatefulSetApplyConfiguration { func
61 func ExtractStatefulSet(statefulSet *appsv1beta2.StatefulSet, fieldManager string) (*StatefulSetApp…
68 func ExtractStatefulSetStatus(statefulSet *appsv1beta2.StatefulSet, fieldManager string) (*Stateful…
72 func extractStatefulSet(statefulSet *appsv1beta2.StatefulSet, fieldManager string, subresource stri…
/dports/www/grafana8/grafana-8.3.6/vendor/k8s.io/client-go/applyconfigurations/apps/v1beta1/
H A Dstatefulset.go41 func StatefulSet(name, namespace string) *StatefulSetApplyConfiguration { func
61 func ExtractStatefulSet(statefulSet *appsv1beta1.StatefulSet, fieldManager string) (*StatefulSetApp…
68 func ExtractStatefulSetStatus(statefulSet *appsv1beta1.StatefulSet, fieldManager string) (*Stateful…
72 func extractStatefulSet(statefulSet *appsv1beta1.StatefulSet, fieldManager string, subresource stri…
/dports/www/grafana8/grafana-8.3.6/vendor/k8s.io/client-go/applyconfigurations/apps/v1/
H A Dstatefulset.go41 func StatefulSet(name, namespace string) *StatefulSetApplyConfiguration { func
61 func ExtractStatefulSet(statefulSet *apiappsv1.StatefulSet, fieldManager string) (*StatefulSetApply…
68 func ExtractStatefulSetStatus(statefulSet *apiappsv1.StatefulSet, fieldManager string) (*StatefulSe…
72 func extractStatefulSet(statefulSet *apiappsv1.StatefulSet, fieldManager string, subresource string…
/dports/sysutils/kubectl/kubernetes-1.22.2/pkg/registry/apps/statefulset/
H A Dstrategy.go117 func dropStatefulSetDisabledFields(newSS *apps.StatefulSet, oldSS *apps.StatefulSet) {
127 func minReadySecondsFieldsInUse(ss *apps.StatefulSet) bool {
/dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/prometheus/prometheus/vendor/k8s.io/client-go/kubernetes/typed/apps/v1beta1/
H A Dstatefulset.go40 Create(*v1beta1.StatefulSet) (*v1beta1.StatefulSet, error)
41 Update(*v1beta1.StatefulSet) (*v1beta1.StatefulSet, error)
42 UpdateStatus(*v1beta1.StatefulSet) (*v1beta1.StatefulSet, error)

12345678910>>...21