- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for connection (0.2 sec)
-
internal/http/listener.go
ClientReadTimeout time.Duration // When the net.Conn is idle for more than WriteTimeout duration, we close the connection on the client proactively. ClientWriteTimeout time.Duration SendBufSize int // SO_SNDBUF size for the socket connection, NOTE: this sets server and client connection
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
internal/event/target/postgresql.go
if f != event.NamespaceFormat && f != event.AccessFormat { return fmt.Errorf("unrecognized format value") } } if p.ConnectionString != "" { // No pq API doesn't help to validate connection string // prior connection, so no validation for now. } else { // Some fields need to be specified when ConnectionString is unspecified if p.Port == "" { return fmt.Errorf("unspecified port") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K bytes - Viewed (0) -
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) -
internal/grid/grid_test.go
} errFatal(h1.Register(local, handler1)) errFatal(h2.Register(local, handler2)) errFatal(h1.Register(remote, handler1)) errFatal(h2.Register(remote, handler2)) // local to remote connection remoteConn := local.Connection(remoteHost) const testPayload = "Hello Grid World!" start := time.Now() req := testRequest{Num: 1, String: testPayload} resp, err := h1.Call(context.Background(), remoteConn, &req)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
cmd/storage-rest-client.go
case strings.Contains(err.Error(), http.ErrServerClosed.Error()): return true // Corner case, the server closed the connection with a keep-alive timeout // some requests are not retried internally, such as POST request with written body case strings.Contains(err.Error(), "server closed idle connection"): return true } return false } // Converts network error to storageErr. This function is
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
internal/rest/client.go
const DefaultTimeout = 10 * time.Second const ( offline = iota online closed ) // NetworkError - error type in case of errors related to http/transport // for ex. connection refused, connection reset, dns resolution failure etc. // All errors returned by storage-rest-server (ex errFileNotFound, errDiskNotFound) are not considered to be network errors. type NetworkError struct { Err error }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
internal/config/identity/ldap/config.go
isEnableFlagExplicitlySet = true l.LDAP.Enabled, err = config.ParseBool(v) if err != nil { return l, err } } l.stsExpiryDuration = defaultLDAPExpiry // LDAP connection configuration if v := getCfgVal(ServerInsecure); v != "" { l.LDAP.ServerInsecure, err = config.ParseBool(v) if err != nil { return l, err } } if v := getCfgVal(ServerStartTLS); v != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 7.9K bytes - Viewed (2) -
internal/grid/handlers.go
func (h *SingleHandler[Req, Resp]) AllowCallRequestPool(b bool) *SingleHandler[Req, Resp] { h.callReuseReq = b return h } // IgnoreNilConn will ignore nil connections when calling. // This will make Call return nil instead of ErrDisconnected when the connection is nil. // This may only be set ONCE before use. func (h *SingleHandler[Req, Resp]) IgnoreNilConn() *SingleHandler[Req, Resp] { if h.ignoreNilConn {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
cmd/common-main.go
ReloadCertEvents: reloadCertEvents, RootCAs: rootCAs, } } KMS, err := kms.NewWithConfig(kmsConf, KMSLogger{}) if err != nil { logger.Fatal(err, "Unable to initialize a connection to KES as specified by the shell environment") } // Try to generate a data encryption key. Only try to create key if this fails. // This implicitly checks that we can communicate to KES.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
cmd/format-erasure.go
}, index) } // Wait for the routines to finish. return reduceWriteQuorumErrs(ctx, g.Wait(), nil, len(storageDisks)) } // relinquishes the underlying connection for all storage disks. func closeStorageDisks(storageDisks ...StorageAPI) { var wg sync.WaitGroup for _, disk := range storageDisks { if disk == nil { continue } wg.Add(1)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0)