Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 248 for serve (0.15 sec)

  1. cmd/routers.go

    	if globalIsDistErasure {
    		registerDistErasureRouters(router, endpointServerPools)
    	}
    
    	// Add Admin router, all APIs are enabled in server mode.
    	registerAdminRouter(router, true)
    
    	// Add healthCheck router
    	registerHealthCheckRouter(router)
    
    	// Add server metrics router
    	registerMetricsRouter(router)
    
    	// Add STS router always.
    	registerSTSRouter(router)
    
    	// Add KMS router
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 3.6K bytes
    - Viewed (1)
  2. cmd/bucket-listobjects-handlers.go

    	if errCode != ErrNone {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(errCode), r.URL)
    		return
    	}
    
    	// Validate the query params before beginning to serve the request.
    	if s3Error := validateListObjectsArgs(prefix, marker, delimiter, encodingType, maxkeys); s3Error != ErrNone {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 11.4K bytes
    - Viewed (0)
  3. cmd/healthcheck-handler.go

    		// take this server down, return appropriate error.
    		if opts.Maintenance {
    			writeResponse(w, http.StatusPreconditionFailed, nil, mimeNone)
    		} else {
    			writeResponse(w, http.StatusServiceUnavailable, nil, mimeNone)
    		}
    		return
    	}
    	writeResponse(w, http.StatusOK, nil, mimeNone)
    }
    
    // ReadinessCheckHandler checks whether MinIO is up and ready to serve requests.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 03 21:13:20 GMT 2024
    - 6.5K bytes
    - Viewed (0)
  4. internal/http/server.go

    func (srv *Server) UseReadHeaderTimeout(d time.Duration) *Server {
    	srv.ReadHeaderTimeout = d
    	return srv
    }
    
    // UseHandler configure final handler for this HTTP *Server
    func (srv *Server) UseHandler(h http.Handler) *Server {
    	srv.Handler = h
    	return srv
    }
    
    // UseTLSConfig pass configured TLSConfig for this HTTP *Server
    func (srv *Server) UseTLSConfig(cfg *tls.Config) *Server {
    	srv.TLSConfig = cfg
    	return srv
    }
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  5. cmd/generic-handlers.go

    		// performed at '/' resource should be routed by the muxer,
    		// the assumption is simply such that requests without a bucket
    		// in a federated setup cannot be proxied, so serve them at
    		// current server.
    		if bucket == "" {
    			h.ServeHTTP(w, r)
    			return
    		}
    
    		// MakeBucket requests should be handled at current endpoint
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 01:08:52 GMT 2024
    - 20.7K bytes
    - Viewed (0)
  6. cmd/sftp-server.go

    		},
    	}
    
    	sshConfig.AddHostKey(private)
    
    	handleSFTPSession := func(channel ssh.Channel, sconn *ssh.ServerConn) {
    		server := sftp.NewRequestServer(channel, NewSFTPDriver(sconn.Permissions), sftp.WithRSAllocator())
    		defer server.Close()
    		server.Serve()
    	}
    
    	sftpServer, err := xsftp.NewServer(&xsftp.Options{
    		PublicIP: publicIP,
    		Port:     port,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  7. cmd/crossdomain-xml-handler.go

    		}
    		// Look for 'crossdomain.xml' in the incoming request.
    		if r.URL.Path == crossDomainXMLEntity {
    			// Write the standard cross domain policy xml.
    			w.Write([]byte(cxml))
    			// Request completed, no need to serve to other handlers.
    			return
    		}
    		h.ServeHTTP(w, r)
    	})
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Mar 18 06:42:40 GMT 2024
    - 2.2K bytes
    - Viewed (0)
  8. cmd/server-main.go

    	return nil
    }
    
    var serverCmd = cli.Command{
    	Name:   "server",
    	Usage:  "start object storage server",
    	Flags:  append(ServerFlags, GlobalFlags...),
    	Action: serverMain,
    	CustomHelpTemplate: `NAME:
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 33K bytes
    - Viewed (1)
  9. cni/pkg/monitoring/monitoring.go

    		return
    	}
    	mux.Handle(path, exporter)
    	monitoringServer := &http.Server{
    		Handler: mux,
    	}
    	go func() {
    		if err = monitoringServer.Serve(listener); network.IsUnexpectedListenerError(err) {
    			log.Errorf("error running monitoring http server: %s", err)
    		}
    	}()
    	go func() {
    		<-stop
    		err := monitoringServer.Close()
    		log.Debugf("monitoring server terminated: %v", err)
    	}()
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jun 09 07:54:01 GMT 2023
    - 1.5K bytes
    - Viewed (0)
  10. cni/pkg/log/uds.go

    			log.Errorf("Error running UDS log server: %v", err)
    		}
    	}()
    
    	go func() {
    		<-stop
    		if err := l.loggingServer.Close(); err != nil {
    			log.Errorf("CNI log server terminated with error: %v", err)
    		} else {
    			log.Debug("CNI log server terminated")
    		}
    	}()
    
    	return nil
    }
    
    func (l *UDSLogger) handleLog(w http.ResponseWriter, req *http.Request) {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 01:05:12 GMT 2023
    - 3.3K bytes
    - Viewed (0)
Back to top