- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for upsert (0.17 sec)
-
operator/cmd/mesh/manifest_shared_test.go
var interceptorFunc = interceptor.Funcs{Patch: func( ctx context.Context, clnt client.WithWatch, obj client.Object, patch client.Patch, opts ...client.PatchOption, ) error { // Apply patches are supposed to upsert, but fake client fails if the object doesn't exist, // if an apply patch occurs for an object that doesn't yet exist, create it. if patch.Type() != types.ApplyPatchType { return clnt.Patch(ctx, obj, patch, opts...) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
istioctl/pkg/tag/generate_test.go
Revision: "default", } _, err := Generate(context.TODO(), fakeClient, opts, "istio-system") assert.NoError(t, err) wh, err := fakeClient.Kube().AdmissionregistrationV1().MutatingWebhookConfigurations(). Get(context.Background(), "istio-sidecar-injector", metav1.GetOptions{}) assert.NoError(t, err) assertFunc(t, wh.Webhooks, defaultWh.Webhooks) } func TestGenerateOptions(t *testing.T) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:49 GMT 2024 - 12.1K bytes - Viewed (0) -
cni/pkg/install/install_test.go
"context" "os" "path/filepath" "sync/atomic" "testing" "time" "istio.io/istio/cni/pkg/config" testutils "istio.io/istio/pilot/test/util" "istio.io/istio/pkg/file" "istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/util/sets" ) func TestCheckInstall(t *testing.T) { cases := []struct { name string expectedFailure bool cniConfigFilename string cniConfName string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 11.1K bytes - Viewed (0) -
istioctl/pkg/describe/describe_test.go
"istio.io/client-go/pkg/apis/networking/v1alpha3" "istio.io/istio/istioctl/pkg/cli" "istio.io/istio/istioctl/pkg/util/configdump" "istio.io/istio/pilot/test/util" "istio.io/istio/pkg/test/util/assert" ) // execAndK8sConfigTestCase lets a test case hold some Envoy, Istio, and Kubernetes configuration type execAndK8sConfigTestCase struct { k8sConfigs []runtime.Object // Canned K8s configuration
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Mar 28 09:54:01 GMT 2024 - 30.4K bytes - Viewed (0) -
common-protos/k8s.io/api/apps/v1beta2/generated.proto
// one StatefulSet to another. // If set, replica indices will be in the range: // [.spec.ordinals.start, .spec.ordinals.start + .spec.replicas). // If unset, defaults to 0. Replica indices will be in the range: // [0, .spec.replicas). // +optional optional int32 start = 1; } // StatefulSetPersistentVolumeClaimRetentionPolicy describes the policy used for PVCs
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 36.4K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
// allow overriding for tests netnsRunner func(fdable NetnsFd, toRun func() error) error hostsideProbeIPSet ipset.IPSet } var _ MeshDataplane = &NetServer{} func newNetServer(ztunnelServer ZtunnelServer, podNsMap *podNetnsCache, iptablesConfigurator *iptables.IptablesConfigurator, podNs PodNetnsFinder, probeSet ipset.IPSet, ) *NetServer { return &NetServer{ ztunnelServer: ztunnelServer, currentPodSnapshot: podNsMap,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
istioctl/pkg/workload/workload_test.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "istio.io/istio/istioctl/pkg/cli" "istio.io/istio/pilot/test/util" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/test/util/assert" ) var fakeCACert = []byte("fake-CA-cert") var ( defaultYAML = `apiVersion: networking.istio.io/v1alpha3 kind: WorkloadGroup metadata: name: foo namespace: bar spec: metadata: {}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 16:59:05 GMT 2024 - 14.6K bytes - Viewed (0) -
common-protos/k8s.io/api/storage/v1beta1/generated.proto
// compares the MaximumVolumeSize against the requested size of pending volumes // to filter out unsuitable nodes. If MaximumVolumeSize is unset, it falls back // to a comparison against the less precise Capacity. If that is also unset, // the scheduler assumes that capacity is insufficient and tries some other // node. message CSIStorageCapacity {
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 24.9K bytes - Viewed (0) -
common-protos/k8s.io/api/batch/v1/generated.proto
// manualSelector controls generation of pod labels and pod selectors. // Leave `manualSelector` unset unless you are certain what you are doing. // When false or unset, the system pick labels unique to this job // and appends those labels to the pod template. When true, // the user is responsible for picking unique labels and specifying // the selector. Failure to pick a unique label may cause this
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 21.1K bytes - Viewed (0) -
architecture/ambient/ztunnel.md
To unwrap the first layer, we terminate TLS. As part of this, we need to pick the correct certificate to serve on behalf of the destination workload. As discussed in [HBONE](#hbone), this is based on the destination IP. Additionally, we enforce the peer has a valid mesh identity (but do not assert _which_ identity, yet). Next, we terminate the CONNECT.
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 25 22:35:16 GMT 2024 - 16.6K bytes - Viewed (0)