Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 46 for convention (0.16 sec)

  1. internal/grid/README.md

    From that individual connections will be spawned to each remote server, 
    or incoming requests will be hooked up to the appropriate connection.
    
    To get a connection to a specific server, use `Manager.Connection(host)` to get a connection to the specified host.
    From this connection individual requests can be made.
    
    Each handler, with optional subroutes can be registered with the manager using 
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  2. internal/http/server.go

    	DefaultMaxHeaderBytes = 1 * humanize.MiByte
    )
    
    // Server - extended http.Server supports multiple addresses to serve and enhanced connection handling.
    type Server struct {
    	http.Server
    	Addrs           []string      // addresses on which the server listens for new connection.
    	TCPOptions      TCPOptions    // all the configurable TCP conn specific configurable options.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  3. docs/throttle/README.md

    ```
    
    > NOTE: A zero value of `requests_max` means MinIO will automatically calculate requests based on available RAM size and that is the default behavior.
    
    ### Configuring connection (wait) deadline
    
    This value works in conjunction with max connection setting, setting this value allows for long waiting requests to quickly time out when there is no slot available to perform the request.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Feb 12 00:51:25 GMT 2022
    - 2.4K bytes
    - Viewed (0)
  4. internal/grid/trace.go

    // MSS, map[string]string types are preferred, but any struct with exported fields will work.
    type TraceParamsKey struct{}
    
    // traceRequests adds request tracing to the connection.
    func (c *Connection) traceRequests(p *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType]) {
    	c.trace = &tracer{
    		Publisher: p,
    		TraceType: madmin.TraceInternal,
    		Prefix:    "grid",
    		Local:     c.Local,
    		Remote:    c.Remote,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 02 22:54:54 GMT 2024
    - 4K bytes
    - Viewed (0)
  5. cmd/bootstrap-peer-server.go

    	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.
    func (client *bootstrapRESTClient) Verify(ctx context.Context, srcCfg *ServerSystemConfig) (err error) {
    	if newObjectLayerFn() != nil {
    		return nil
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  6. internal/event/target/webhook.go

    		}
    		return false, err
    	}
    	defer conn.Close()
    	return true, nil
    }
    
    // Save - saves the events to the store if queuestore is configured,
    // which will be replayed when the webhook connection is active.
    func (target *WebhookTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		return target.store.Put(eventData)
    	}
    	if err := target.init(); err != nil {
    		return err
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 20 22:40:07 GMT 2023
    - 8.5K bytes
    - Viewed (0)
  7. internal/grid/manager.go

    	}
    }
    
    // AuthFn should provide an authentication string for the given aud.
    type AuthFn func(aud string) string
    
    // Connection will return the connection for the specified host.
    // If the host does not exist nil will be returned.
    func (m *Manager) Connection(host string) *Connection {
    	return m.targets[host]
    }
    
    // RegisterSingleHandler will register a stateless handler that serves
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  8. internal/http/transports.go

    	// 		// frame will be carried out if no frame is received on the
    	// 		// connection. 5 minutes is sufficient time for any idle connection.
    	// 		trhttp2.ReadIdleTimeout = 5 * time.Minute
    	// 		// PingTimeout is the timeout after which the connection will be closed
    	// 		// if a response to Ping is not received.
    	// 		trhttp2.PingTimeout = dialTimeout
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  9. docs/ftp/README.md

    ```
    ftp> ls runner/chunkdocs/metadata
    229 Entering Extended Passive Mode (|||44269|)
    150 Opening ASCII mode data connection for file list
    -rwxrwxrwx 1 nobody nobody           45 Apr  1 06:13 chunkdocs/metadata
    226 Closing data connection, sent 75 bytes
    ftp> get
    (remote-file) runner/chunkdocs/metadata
    (local-file) test
    local: test remote: runner/chunkdocs/metadata
    229 Entering Extended Passive Mode (|||37785|)
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:15:45 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  10. internal/config/identity/ldap/help.go

    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         ServerInsecure,
    			Description: `allow plain text connection to AD/LDAP server` + defaultHelpPostfix(ServerInsecure),
    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         ServerStartTLS,
    			Description: `use StartTLS connection to AD/LDAP server` + defaultHelpPostfix(ServerStartTLS),
    			Optional:    true,
    			Type:        "on|off",
    		},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Jun 23 14:45:27 GMT 2023
    - 3.6K bytes
    - Viewed (0)
Back to top