Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for statefulsets (0.3 sec)

  1. pkg/controller/statefulset/stateful_set_control_test.go

    	simpleSetFn := func() *apps.StatefulSet {
    		statefulSet := newStatefulSet(3)
    		statefulSet.Spec.Ordinals = &apps.StatefulSetOrdinals{Start: int32(2)}
    		return statefulSet
    	}
    
    	testCases := []struct {
    		fn  func(*testing.T, *apps.StatefulSet, invariantFunc)
    		obj func() *apps.StatefulSet
    	}{
    		{CreatesPodsWithStartOrdinal, simpleSetFn},
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 19:01:47 UTC 2024
    - 108.7K bytes
    - Viewed (0)
  2. pkg/apis/apps/validation/validation_test.go

    	corevalidation "k8s.io/kubernetes/pkg/apis/core/validation"
    	"k8s.io/kubernetes/pkg/features"
    	"k8s.io/utils/ptr"
    )
    
    type statefulSetTweak func(ss *apps.StatefulSet)
    
    func mkStatefulSet(template *api.PodTemplate, tweaks ...statefulSetTweak) apps.StatefulSet {
    	ss := apps.StatefulSet{
    		ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
    		Spec: apps.StatefulSetSpec{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 111.9K bytes
    - Viewed (0)
  3. tests/integration/pilot/common/routing.go

    				//	from: vm,
    				//	to:   apps.StatefulSet.Match(echo.Cluster(vm.Config().Cluster.Config())),
    				//	host: fmt.Sprintf("%s-v1-0.%s.%s.svc", StatefulSetSvc, StatefulSetSvc, apps.Namespace.Name()),
    				//},
    				//vmCase{
    				//	name: "dns: VM to k8s statefulset instance FQDN",
    				//	from: vm,
    				//	to:   apps.StatefulSet.Match(echo.Cluster(vm.Config().Cluster.Config())),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 21:52:51 UTC 2024
    - 135.9K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/apps/v1beta1/generated.pb.go

    var xxx_messageInfo_ScaleStatus proto.InternalMessageInfo
    
    func (m *StatefulSet) Reset()      { *m = StatefulSet{} }
    func (*StatefulSet) ProtoMessage() {}
    func (*StatefulSet) Descriptor() ([]byte, []int) {
    	return fileDescriptor_2747f709ac7c95e7, []int{15}
    }
    func (m *StatefulSet) XXX_Unmarshal(b []byte) error {
    	return m.Unmarshal(b)
    }
    func (m *StatefulSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
    	b = b[:cap(b)]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 169.2K bytes
    - Viewed (0)
  5. staging/src/k8s.io/api/apps/v1/generated.pb.go

    func (m *StatefulSet) Reset()      { *m = StatefulSet{} }
    func (*StatefulSet) ProtoMessage() {}
    func (*StatefulSet) Descriptor() ([]byte, []int) {
    	return fileDescriptor_5b781835628d5338, []int{22}
    }
    func (m *StatefulSet) XXX_Unmarshal(b []byte) error {
    	return m.Unmarshal(b)
    }
    func (m *StatefulSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
    	b = b[:cap(b)]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 217.1K bytes
    - Viewed (0)
  6. staging/src/k8s.io/api/apps/v1beta2/generated.pb.go

    var xxx_messageInfo_ScaleStatus proto.InternalMessageInfo
    
    func (m *StatefulSet) Reset()      { *m = StatefulSet{} }
    func (*StatefulSet) ProtoMessage() {}
    func (*StatefulSet) Descriptor() ([]byte, []int) {
    	return fileDescriptor_c423c016abf485d4, []int{25}
    }
    func (m *StatefulSet) XXX_Unmarshal(b []byte) error {
    	return m.Unmarshal(b)
    }
    func (m *StatefulSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
    	b = b[:cap(b)]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 235.6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/testdata/swagger.json

              "type": "string"
            },
            "imagePullPolicy": {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 20 15:45:02 UTC 2024
    - 229.4K bytes
    - Viewed (0)
  8. pkg/printers/internalversion/printers_test.go

    	}
    }
    
    func TestPrintStatefulSet(t *testing.T) {
    	tests := []struct {
    		statefulSet apps.StatefulSet
    		options     printers.GenerateOptions
    		expected    []metav1.TableRow
    	}{
    		// Basic stateful set; no generate options.
    		{
    			statefulSet: apps.StatefulSet{
    				ObjectMeta: metav1.ObjectMeta{
    					Name:              "test1",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 218.6K bytes
    - Viewed (0)
  9. pkg/printers/internalversion/printers.go

    		r, err := printIngressClass(&list.Items[i], options)
    		if err != nil {
    			return nil, err
    		}
    		rows = append(rows, r...)
    	}
    	return rows, nil
    }
    
    func printStatefulSet(obj *apps.StatefulSet, options printers.GenerateOptions) ([]metav1.TableRow, error) {
    	row := metav1.TableRow{
    		Object: runtime.RawExtension{Object: obj},
    	}
    	desiredReplicas := obj.Spec.Replicas
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 128.3K bytes
    - Viewed (0)
  10. tensorflow/compiler/mlir/tensorflow/tests/side-effect-analysis-test.mlir

      }
      func.return
      // expected-remark@above {{ID: 25}}
      // expected-remark@above {{Sinks: {24}}}
    }
    
    // -----
    
    // Tests that the pass tracks control dependencies based on TF op registry
    // statefulness flag, for ops not yet defined in ODS.
    
    // CHECK-LABEL: func @tf_registry_ops
    func.func @tf_registry_ops(
      // expected-remark@above {{ID: 8}}
      %arg0: tensor<!tf_type.string>, %arg1: tensor<!tf_type.string>) {
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Dec 20 04:39:18 UTC 2023
    - 129.7K bytes
    - Viewed (0)
Back to top