Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 32 for control (0.2 sec)

  1. cmd/acl-handlers.go

    	"net/http"
    
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/mux"
    	"github.com/minio/pkg/v2/policy"
    )
    
    // Data types used for returning dummy access control
    // policy XML, these variables shouldn't be used elsewhere
    // they are only defined to be used in this file alone.
    type grantee struct {
    	XMLNS       string `xml:"xmlns:xsi,attr"`
    	XMLXSI      string `xml:"xsi:type,attr"`
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 8.4K bytes
    - Viewed (0)
  2. internal/logger/console.go

    	quiet(msg string, args ...interface{})
    	pretty(msg string, args ...interface{})
    }
    
    func consoleLog(console Logger, msg string, args ...interface{}) {
    	switch {
    	case jsonFlag:
    		// Strip escape control characters from json message
    		msg = ansiRE.ReplaceAllLiteralString(msg, "")
    		console.json(msg, args...)
    	case quietFlag:
    		if len(msg) != 0 && len(args) == 0 {
    			args = append(args, msg)
    			msg = "%s"
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  3. docs/metrics/prometheus/README.md

    Prometheus sets the `Host` header to `domain:port` as part of HTTP operations against the MinIO metrics endpoint. For MinIO deployments behind a load balancer, reverse proxy, or other control plane (HAProxy, nginx, pfsense, opnsense, etc.), ensure the network service supports routing these requests to the deployment.
    
    ### 6. Configure Grafana
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 15:49:30 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  4. internal/http/check_port_linux.go

    // It is possible to have a disconnected client in this tiny window of time.
    func CheckPortAvailability(host, port string, opts TCPOptions) (err error) {
    	lc := &net.ListenConfig{
    		Control: func(network, address string, c syscall.RawConn) error {
    			c.Control(func(fdPtr uintptr) {
    				if opts.Interface != "" {
    					// When interface is specified look for specifically port availability on
    					// the specified interface if any.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 03 21:12:25 GMT 2023
    - 1.9K bytes
    - Viewed (0)
  5. internal/grid/msg.go

    	OpMuxServerMsg
    
    	// OpUnblockSrvMux contains a message that a server mux is unblocked with one.
    	// Only Stateful streams has flow control.
    	OpUnblockSrvMux
    
    	// OpUnblockClMux contains a message that a client mux is unblocked with one.
    	// Only Stateful streams has flow control.
    	OpUnblockClMux
    
    	// OpAckMux acknowledges a mux was created.
    	OpAckMux
    
    	// OpRequest is a single request + response.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 28 19:22:29 GMT 2023
    - 7.3K bytes
    - Viewed (0)
  6. internal/logger/utils.go

    import (
    	"context"
    	"errors"
    	"fmt"
    	"net/http"
    	"regexp"
    	"runtime"
    
    	"github.com/minio/minio/internal/color"
    )
    
    var ansiRE = regexp.MustCompile("(\x1b[^m]*m)")
    
    // Print ANSI Control escape
    func ansiEscape(format string, args ...interface{}) {
    	Esc := "\x1b"
    	fmt.Printf("%s%s", Esc, fmt.Sprintf(format, args...))
    }
    
    func ansiMoveRight(n int) {
    	if runtime.GOOS == "windows" {
    		return
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Aug 04 23:10:08 GMT 2022
    - 1.7K bytes
    - Viewed (0)
  7. internal/http/listener.go

    	listenErrs = make([]error, len(serverAddrs))
    
    	// Unix listener with special TCP options.
    	listenCfg := net.ListenConfig{
    		Control: setTCPParametersFn(opts),
    	}
    
    	for i, serverAddr := range serverAddrs {
    		l, e := listenCfg.Listen(ctx, "tcp", serverAddr)
    		if e != nil {
    			if opts.Trace != nil {
    				opts.Trace(fmt.Sprint("listenCfg.Listen: ", e))
    			}
    
    			listenErrs[i] = e
    			continue
    		}
    
    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)
  8. docs/bucket/lifecycle/DESIGN.md

    ### Transition Status
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 4.3K bytes
    - Viewed (0)
  9. internal/logger/target/kafka/kafka_scram_client_contrib.go

    Anis Eleuch <******@****.***> 1699502641 -0800
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.3K bytes
    - Viewed (1)
  10. internal/event/target/testdata/contrib/nats_tls_client_cert.conf

    port: 14226
    net: localhost
    
    tls {
        cert_file:  "./testdata/contrib/certs/nats_server_cert.pem"
        key_file:   "./testdata/contrib/certs/nats_server_key.pem"
        ca_file:   "./testdata/contrib/certs/root_ca_cert.pem"
        verify_and_map: true
    }
    authorization {
        ADMIN = {
            publish = ">"
            subscribe = ">"
        }
        users = [
            {user: "CN=localhost,OU=Client,O=MinIO,C=CA", permissions: $ADMIN}
        ]
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 426 bytes
    - Viewed (0)
Back to top