Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for defaultPolicy (0.15 sec)

  1. pilot/pkg/networking/core/route/retry/retry_test.go

    				g.Expect(policy.RetryPriority).To(BeNil())
    				g.Expect(policy.HostSelectionRetryMaxAttempts).To(Equal(retry.DefaultPolicy().HostSelectionRetryMaxAttempts))
    				g.Expect(policy.RetryHostPredicate).To(Equal(retry.DefaultPolicy().RetryHostPredicate))
    			},
    		},
    		{
    			name: "TestRetryOnWithEmptyParts",
    			// Create a route with a retry policy with empty retry conditions configured.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/route/retry/retry.go

    	xdsfilters "istio.io/istio/pilot/pkg/xds/filters"
    )
    
    var defaultRetryPriorityTypedConfig = protoconv.MessageToAny(buildPreviousPrioritiesConfig())
    
    // DefaultPolicy gets a copy of the default retry policy.
    func DefaultPolicy() *route.RetryPolicy {
    	policy := defaultPolicy()
    	policy.RetryHostPredicate = []*route.RetryPolicy_RetryHostPredicate{
    		// to configure retries to prefer hosts that haven’t been attempted already,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 5K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/ambient/policies.go

    									},
    								},
    							},
    						},
    					},
    				},
    			},
    		}
    	}, krt.WithName("DefaultPolicy"))
    
    	// Policies contains all of the policies we will send down to clients
    	Policies := krt.JoinCollection([]krt.Collection[model.WorkloadAuthorization]{
    		AuthzDerivedPolicies,
    		PeerAuthDerivedPolicies,
    		DefaultPolicy.AsCollection(),
    		ImplicitWaypointPolicies,
    	}, krt.WithName("Policies"))
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 16:51:29 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  4. pkg/volume/csi/csi_mounter_test.go

    				t.Errorf("supportsFSGroup() = %v, want %v", got, tt.want)
    			}
    		})
    	}
    }
    
    func TestMounterGetFSGroupPolicy(t *testing.T) {
    	defaultPolicy := storage.ReadWriteOnceWithFSTypeFSGroupPolicy
    	testCases := []struct {
    		name                  string
    		defined               bool
    		expectedFSGroupPolicy storage.FSGroupPolicy
    	}{
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 50.1K bytes
    - Viewed (0)
Back to top