- Sort Score
- Num 10 results
- Language All
Results 161 - 170 of 208 for Connections (0.07 seconds)
-
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 { _, err := target.store.Put(eventData) return err } 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 }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 8.2K bytes - Click Count (0) -
LICENSE
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Sun Jan 12 10:32:39 GMT 2025 - 1.1K bytes - Click Count (0) -
internal/s3select/jstream/LICENSE
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Sep 23 19:35:41 GMT 2024 - 1.1K bytes - Click Count (0) -
cmd/admin-server-info.go
} else { if xnet.IsNetworkOrHostDown(err, false) { network[nodeName] = string(madmin.ItemOffline) } else if xnet.IsNetworkOrHostDown(err, true) { network[nodeName] = "connection attempt timedout" } } } } } var memstats runtime.MemStats runtime.ReadMemStats(&memstats) gcStats := debug.GCStats{ // If stats.PauseQuantiles is non-empty, ReadGCStats fillsCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 24 23:05:23 GMT 2024 - 4.9K bytes - Click Count (1) -
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 }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Oct 01 22:13:18 GMT 2024 - 8.4K bytes - Click Count (0) -
cmd/lock-rest-client_test.go
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 2K bytes - Click Count (0) -
build-logic-commons/publishing/src/main/kotlin/gradlebuild.publish-defaults.gradle.kts
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Thu Jul 17 16:12:44 GMT 2025 - 3.4K bytes - Click Count (0) -
internal/ringbuffer/LICENSE
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed May 15 00:11:04 GMT 2024 - 1K bytes - Click Count (0) -
docs/sts/tls.md
Now, the STS certificate-based authentication happens in 4 steps: - Client sends HTTP `POST` request over a TLS connection hitting the MinIO TLS STS API. - MinIO verifies that the client certificate is valid. - MinIO tries to find a policy that matches the `CN` of the client certificate.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 6K bytes - Click Count (1) -
docs/throttle/README.md
- limit the wait duration for each request in the queue These values are enabled using server's configuration or environment variables. ## Examples ### Configuring connection limit
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 16 08:43:49 GMT 2024 - 1.5K bytes - Click Count (1)