- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 88 for connections (0.49 sec)
-
internal/event/target/amqp.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0) -
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) -
internal/event/target/mqtt.go
// be replayed when the mqtt connection is active. func (target *MQTTTarget) Save(eventData event.Event) error { if target.store != nil { return target.store.Put(eventData) } if err := target.init(); err != nil { return err } // Do not send if the connection is not active. _, err := target.isActive() if err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 8.2K bytes - Viewed (0) -
cmd/sts-errors.go
HTTPStatusCode: http.StatusBadRequest, }, ErrSTSInsecureConnection: { Code: "InsecureConnection", Description: "The request was made over a plain HTTP connection. A TLS connection is required.", HTTPStatusCode: http.StatusBadRequest, }, ErrSTSInvalidClientCertificate: { Code: "InvalidClientCertificate",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.8K 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) -
cmd/lock-rest-client_test.go
if err != nil { t.Fatal(err) } lkClient := newlockRESTClient(endpoint) if lkClient.IsOnline() { t.Fatalf("unexpected result. connection was online") } // Attempt all calls. _, err = lkClient.RLock(context.Background(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for Rlock to fail") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 2K 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) -
cmd/peer-rest-client.go
xhttp.DrainBody(respBody) return !isNetworkError(err) } var gridConn atomic.Pointer[grid.Connection] return &peerRESTClient{ host: peer, restClient: restClient, gridHost: gridHost, gridConn: func() *grid.Connection { // Lazy initialization of grid connection. // When we create this peer client, the grid connection is likely not yet initialized. if gridHost == "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
if !isErrVersionNotFound(err) && !isErrObjectNotFound(err) && !xnet.IsNetworkOrHostDown(err, false) { if !strings.Contains(err.Error(), "use of closed network connection") { transitionLogIf(t.ctx, fmt.Errorf("Transition to %s failed for %s/%s version:%s with %w", task.event.StorageClass, task.objInfo.Bucket, task.objInfo.Name, task.objInfo.VersionID, err)) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0)