Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 28 for topo (0.18 sec)

  1. cni/pkg/cmd/root.go

    			log.Errorf("Failed to start up UDS Log Server: %v", err)
    			return
    		}
    
    		// Creates a basic health endpoint server that reports health status
    		// based on atomic flag, as set by installer
    		// TODO nodeagent watch server should affect this too, and drop atomic flag
    		installDaemonReady, watchServerReady := nodeagent.StartHealthServer()
    
    		if cfg.InstallConfig.AmbientEnabled {
    			// Start ambient controller
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.5K bytes
    - Viewed (0)
  2. cni/pkg/util/podutil.go

    	constants.AmbientRedirection,
    	constants.AmbientRedirectionEnabled,
    ))
    
    var annotationRemovePatch = []byte(fmt.Sprintf(
    	`{"metadata":{"annotations":{"%s":null}}}`,
    	constants.AmbientRedirection,
    ))
    
    // TODO: we should use the upstream istio version of this function.
    // PodRedirectionEnabled determines if a pod should or should not be configured
    // to have traffic redirected thru the node proxy.
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Wed May 01 18:04:40 GMT 2024
    - 4.1K bytes
    - Viewed (0)
  3. cmd/iam-store.go

    	if !ok {
    		if err := store.loadMappedPolicyWithRetry(context.TODO(), name, regUser, false, c.iamUserPolicyMap, 3); err != nil && !errors.Is(err, errNoSuchPolicy) {
    			return nil, time.Time{}, err
    		}
    
    		mp, ok = c.iamUserPolicyMap.Load(name)
    		if !ok {
    			// Since user "name" could be a parent user of an STS account, we look up
    			// mappings for those too.
    			mp, ok = c.iamSTSPolicyMap.Load(name)
    			if !ok {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  4. cni/pkg/util/podutil_test.go

    		},
    		{
    			name: "pod has sidecar and namespace has ambient enabled",
    			args: args{
    				namespace: namespaceWithAmbientEnabledLabel,
    				pod:       podWithSidecar,
    			},
    			want: false,
    		},
    		// TODO: when there exists a means for users to signal the intent to exclude a pod from ambient without requiring the use of
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Wed May 01 18:04:40 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  5. docs/en/docs/release-notes.md

    * ✏ Fix typo in `docs/en/docs/tutorial/query-params-str-validations.md`. PR [#9272](https://github.com/tiangolo/fastapi/pull/9272) by [@nicornk](https://github.com/nicornk).
    * ✏ Fix typo/bug in inline code example in `docs/en/docs/tutorial/query-params-str-validations.md`. PR [#9273](https://github.com/tiangolo/fastapi/pull/9273) by [@tim-habitat](https://github.com/tim-habitat).
    Plain Text
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Sun Apr 28 00:28:00 GMT 2024
    - 385.5K bytes
    - Viewed (1)
  6. cni/README.md

    1. Check k8s pod namespace against exclusion list (plugin config)
        - Config must exclude namespace that Istio control-plane is installed in (TODO: this may change, exclude at pod level is sufficient and we may want Istiod and other istio components to use ambient too)
        - If excluded, ignore the pod and return prevResult
    1. Setup redirect rules for the pods:
        - Get the port list from pods definition, as well as annotations.
    Plain Text
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.3K bytes
    - Viewed (0)
  7. cmd/xl-storage.go

    		dataUsageBucket,           // creates .minio.sys/buckets
    		minioConfigBucket,         // creates .minio.sys/config
    	}
    	// Attempt to create MinIO internal buckets.
    	return disk.MakeVolBulk(context.TODO(), volumes...)
    }
    
    // Initialize a new storage disk.
    func newXLStorage(ep Endpoint, cleanUp bool) (s *xlStorage, err error) {
    	immediatePurgeQueue := 100000
    	if globalIsTesting || globalIsCICD {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  8. cni/pkg/iptables/iptables.go

    	// -A POSTROUTING -p tcp -j ISTIO_POSTRT
    	iptablesBuilder.AppendRule(
    		iptableslog.UndefinedCommand, iptablesconstants.POSTROUTING, iptablesconstants.NAT,
    		"-j", ChainHostPostrouting,
    	)
    
    	// TODO BML I don't think we need UDP? TCP healthcheck redir should catch everything.
    
    	// This is effectively an analog for Istio's old-style podSpec-based health check rewrites.
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 19.6K bytes
    - Viewed (0)
  9. doc/README.md

    then an `api/next` file with the line
    
        pkg net/http, function F #12345
    
    should have a corresponding file named `doc/next/6-stdlib/99-minor/net/http/12345.md`.
    At a minimum, that file should contain either a full sentence or a TODO,
    ideally referring to a person with the responsibility to complete the note.
    
    Use the following forms in your markdown:
    
    	[http.Request]                     # symbol documentation; auto-linked as in Go doc strings
    Plain Text
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Apr 26 21:24:36 GMT 2024
    - 1.9K bytes
    - Viewed (0)
  10. cni/cmd/istio-cni/main.go

    		// We don't need a timeout here because underlying the log pkg already handles it.
    		// this may fail, but it should be safe to ignore according
    		// to https://github.com/uber-go/zap/issues/328
    		_ = log.Sync()
    	}()
    
    	// TODO: implement plugin version
    	funcs := skel.CNIFuncs{
    		Add:   plugin.CmdAdd,
    		Del:   plugin.CmdDelete,
    		Check: plugin.CmdCheck,
    	}
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 13:56:46 GMT 2024
    - 1.9K bytes
    - Viewed (0)
Back to top