Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 248 for isServer (0.27 sec)

  1. cni/pkg/nodeagent/server.go

    	err = cniServer.Start()
    	if err != nil {
    		return nil, fmt.Errorf("error starting cni server: %w", err)
    	}
    	s.cniServerStopFunc = cniServer.Stop
    
    	return s, nil
    }
    
    func (s *Server) Ready() {
    	s.isReady.Store(true)
    }
    
    func (s *Server) NotReady() {
    	s.isReady.Store(false)
    }
    
    // buildKubeClient creates the kube client
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  2. cmd/server-main.go

    		Hidden: true,
    	},
    	cli.StringFlag{
    		Name:   "log-prefix",
    		Usage:  "specify the log prefix name for the server log",
    		EnvVar: "MINIO_LOG_PREFIX",
    		Hidden: true,
    	},
    }
    
    var serverCmd = cli.Command{
    	Name:   "server",
    	Usage:  "start object storage server",
    	Flags:  append(ServerFlags, GlobalFlags...),
    	Action: serverMain,
    	CustomHelpTemplate: `NAME:
      {{.HelpName}} - {{.Usage}}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (4)
  3. cmd/peer-rest-server.go

    	subrouter.Methods(http.MethodPost).Path(peerRESTVersionPrefix + peerRESTMethodDevNull).HandlerFunc(h(server.DevNull))
    
    	logger.FatalIf(consoleLogRPC.RegisterNoInput(gm, server.ConsoleLogHandler), "unable to register handler")
    	logger.FatalIf(deleteBucketMetadataRPC.Register(gm, server.DeleteBucketMetadataHandler), "unable to register handler")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  4. cmd/bootstrap-peer-server.go

    func registerBootstrapRESTHandlers(gm *grid.Manager) {
    	server := &bootstrapRESTServer{}
    	logger.FatalIf(serverVerifyHandler.Register(gm, server.VerifyHandler), "unable to register handler")
    }
    
    // client to talk to bootstrap NEndpoints.
    type bootstrapRESTClient struct {
    	gridConn *grid.Connection
    }
    
    // Verify function verifies the server config.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    							continue
    						}
    					} else {
    						r = io.NopCloser(bytes.NewBuffer([]byte{}))
    					}
    					// Keep disk path instead of ID, to ensure that the downloaded zip file can be
    					// easily automated with `minio server hostname{1...n}/disk{1...m}`.
    					err = fn(r, disk.Hostname(), disk.Endpoint().Path, pathJoin(volume, si.Name), si)
    					r.Close()
    					if err != nil {
    						return err
    					}
    				}
    			}
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  6. compat/maven-settings-builder/src/main/java/org/apache/maven/settings/crypto/DefaultSettingsDecrypter.java

            List<SettingsProblem> problems = new ArrayList<>();
    
            List<Server> servers = new ArrayList<>();
    
            for (Server server : request.getServers()) {
                server = server.clone();
    
                String password = server.getPassword();
                if (securityDispatcher.isAnyEncryptedString(password)) {
                    try {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/server_test.go

    	podIP := netip.MustParseAddr("99.9.9.1")
    	podIPs := []netip.Addr{podIP}
    
    	server := &fakeServer{}
    	server.On("AddPodToMesh",
    		fakeCtx,
    		pod,
    		podIPs,
    		"",
    	).Return(nil)
    
    	server.Start(fakeCtx)
    
    	fakeIPSetDeps := ipset.FakeNLDeps()
    	set := ipset.IPSet{V4Name: "foo-v4", Prefix: "foo", Deps: fakeIPSetDeps}
    
    	m := getFakeDPWithIPSet(server, fakeClientSet, set)
    	expectPodAddedToIPSet(fakeIPSetDeps, podIP, pod.ObjectMeta)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  8. compat/maven-model-builder/src/test/java/org/apache/maven/model/path/DefaultUrlNormalizerTest.java

            assertEquals("http://server.org/dir", normalize("http://server.org/dir"));
            assertEquals("http://server.org/dir/", normalize("http://server.org/dir/"));
        }
    
        @Test
        void testRemovalOfParentRefs() {
            assertEquals("http://server.org/child", normalize("http://server.org/parent/../child"));
            assertEquals("http://server.org/child", normalize("http://server.org/grand/parent/../../child"));
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  9. impl/maven-core/src/main/java/org/apache/maven/internal/aether/DefaultRepositorySystemSessionFactory.java

            for (Server server : decrypted.getServers()) {
                AuthenticationBuilder authBuilder = new AuthenticationBuilder();
                authBuilder.addUsername(server.getUsername()).addPassword(server.getPassword());
                authBuilder.addPrivateKey(server.getPrivateKey(), server.getPassphrase());
                authSelector.add(server.getId(), authBuilder.build());
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  10. compat/maven-artifact/src/main/java/org/apache/maven/repository/Proxy.java

        public static final String PROXY_HTTP = "HTTP";
    
        /**
         * Proxy server host
         */
        private String host;
    
        /**
         * Username used to access the proxy server
         */
        private String userName;
    
        /**
         * Password associated with the proxy server
         */
        private String password;
    
        /**
         * Proxy server port
         */
        private int port;
    
        /**
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 4K bytes
    - Viewed (0)
Back to top