- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 33 for ApplyOptions (0.2 sec)
-
pkg/controller/clusterroleaggregation/clusterroleaggregation_controller.go
clusterRoleApply := rbacv1ac.ClusterRole(name). WithRules(toApplyPolicyRules(newPolicyRules)...) opts := metav1.ApplyOptions{FieldManager: "clusterrole-aggregation-controller", Force: true} _, err := c.clusterRoleClient.ClusterRoles().Apply(ctx, clusterRoleApply, opts) return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8K bytes - Viewed (0) -
platforms/jvm/testing-jvm/src/main/java/org/gradle/api/tasks/testing/Test.java
* @since 3.5 */ public void useJUnit(Action<? super JUnitOptions> testFrameworkConfigure) { useJUnit(); applyOptions(JUnitOptions.class, testFrameworkConfigure); } /** * Specifies that JUnit Platform should be used to discover and execute the tests. * <p>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 42.6K bytes - Viewed (0) -
operator/cmd/mesh/operator-init.go
l.LogAndFatal(err) } installerScope.Debugf("Installing operator charts with the following values:\n%s", vals) installerScope.Debugf("Using the following manifest to install operator:\n%s\n", mstr) opts := &applyOptions{ DryRun: args.DryRun, } // If CR was passed, we must create a namespace for it and install CR into it. customResource, istioNamespace, err := getCRAndNamespaceFromFile(oiArgs.inFilename, l) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 01:18:49 UTC 2024 - 6.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/fake/fake_example.go
} // Apply takes the given apply declarative configuration, applies it and returns the applied example. func (c *FakeExamples) Apply(ctx context.Context, example *crv1.ExampleApplyConfiguration, opts metav1.ApplyOptions) (result *v1.Example, err error) { if example == nil { return nil, fmt.Errorf("example provided to Apply must not be nil") } data, err := json.Marshal(example) if err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 5.5K bytes - Viewed (0) -
pkg/controller/testutil/test_utils.go
} return &updatedNode, nil } // Apply applies a NodeApplyConfiguration to a Node in the fake store. func (m *FakeNodeHandler) Apply(ctx context.Context, node *v1apply.NodeApplyConfiguration, opts metav1.ApplyOptions) (*v1.Node, error) { patchOpts := opts.ToPatchOptions() data, err := json.Marshal(node) if err != nil { return nil, err } name := node.Name if name == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 15.6K bytes - Viewed (0) -
pkg/controlplane/controller/defaultservicecidr/default_servicecidr_controller.go
svcApply := networkingapiv1alpha1apply.ServiceCIDR(DefaultServiceCIDRName).WithStatus(svcApplyStatus) if _, errApply := c.client.NetworkingV1alpha1().ServiceCIDRs().ApplyStatus(context.Background(), svcApply, metav1.ApplyOptions{FieldManager: controllerName, Force: true}); errApply != nil { klog.Infof("error updating default ServiceCIDR status: %v", errApply)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/kube/kubetypes/types.go
WriteAPI[T] } // ApplyAPI exposes a generic API for a client go type for apply operations. type ApplyAPI[T runtime.Object, TA runtime.Object] interface { Apply(ctx context.Context, secret TA, opts metav1.ApplyOptions) (result T, err error) } // FullAPI exposes a generic API for a client go type for all operations. // Note each type can also have per-type specific "Expansions" not covered here.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
WithLastTransitionTime(metav1.Now())) svcApply := networkingapiv1alpha1apply.ServiceCIDR(cidr.Name).WithStatus(svcApplyStatus) _, err = c.client.NetworkingV1alpha1().ServiceCIDRs().ApplyStatus(ctx, svcApply, metav1.ApplyOptions{FieldManager: controllerName, Force: true}) return err } // If there are no IPAddress depending on this ServiceCIDR is safe to remove it,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/generated.pb.go
var xxx_messageInfo_APIVersions proto.InternalMessageInfo func (m *ApplyOptions) Reset() { *m = ApplyOptions{} } func (*ApplyOptions) ProtoMessage() {} func (*ApplyOptions) Descriptor() ([]byte, []int) { return fileDescriptor_a8431b6e0aeeb761, []int{5} } func (m *ApplyOptions) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *ApplyOptions) 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 - 281.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
applyOptions := metav1.ApplyOptions{FieldManager: asFieldManager, Force: true} // the condition field in fsStatusUpdate holds the new condition we want to update. // TODO: this will break when we have multiple conditions for a flowschema _, err := client.ApplyStatus(context.TODO(), toFlowSchemaApplyConfiguration(fsu), applyOptions) return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (1)