Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 161 - 170 of 208 for Connections (0.07 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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 fills
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 4.9K bytes
    - Click Count (1)
  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
    	}
    
    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)
  6. 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(t.Context(), dsync.LockArgs{})
    	if err == nil {
    		t.Fatal("Expected for Rlock to fail")
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 2K bytes
    - Click Count (0)
  7. build-logic-commons/publishing/src/main/kotlin/gradlebuild.publish-defaults.gradle.kts

                        name = "The Gradle team"
                        organization = "Gradle Inc."
                        organizationUrl = "https://gradle.org"
                    }
                }
                scm {
                    connection = "scm:git:git://github.com/gradle/gradle.git"
                    developerConnection = "scm:git:ssh://github.com:gradle/gradle.git"
                    url = "https://github.com/gradle/gradle"
                }
            }
        }
    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)
  8. 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)
  9. 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)
  10. 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)
Back to Top