Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for movies (0.17 sec)

  1. docs/metrics/prometheus/README.md

    . . .
    ```
    
    Refer [Prometheus documentation](https://prometheus.io/docs/introduction/first_steps/) for more details.
    
    ### 2. Configure authentication type for Prometheus metrics
    
    MinIO supports two authentication modes for Prometheus either `jwt` or `public`, by default MinIO runs in `jwt` mode. To allow public access without authentication for prometheus metrics set environment as follows.
    
    ```
    export MINIO_PROMETHEUS_AUTH_TYPE="public"
    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)
  2. cmd/tier-last-day-stats.go

    	UpdatedAt time.Time
    }
    
    func (l *lastDayTierStats) addStats(ts tierStats) {
    	now := time.Now()
    	l.forwardTo(now)
    
    	nowIdx := now.Hour()
    	l.Bins[nowIdx] = l.Bins[nowIdx].add(ts)
    }
    
    // forwardTo moves time to t, clearing entries between last update and t.
    func (l *lastDayTierStats) forwardTo(t time.Time) {
    	if t.IsZero() {
    		t = time.Now()
    	}
    
    	since := t.Sub(l.UpdatedAt).Hours()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  3. internal/logger/target/kafka/kafka_scram_client_contrib.go

    		return err
    	}
    	x.ClientConversation = x.Client.NewConversation()
    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    // very first conversation step) and attempts to move the authentication
    // conversation forward.  It returns a string to be sent to the server or an
    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    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)
  4. internal/logger/console.go

    	// red banner along with the error message. Since the error
    	// message itself contains some colored text, we needed
    	// to use some ANSI control escapes to cursor color state
    	// and freely move in the screen.
    	for _, line := range strings.Split(errMsg, "\n") {
    		if len(line) == 0 {
    			// No more text to print, just quit.
    			break
    		}
    
    		for {
    			// Save the attributes of the current cursor helps
    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)
  5. internal/dsync/dsync-client_test.go

    		panic(err)
    	}
    
    	tr := &http.Transport{
    		Proxy:                 http.ProxyFromEnvironment,
    		MaxIdleConnsPerHost:   1024,
    		WriteBufferSize:       32 << 10, // 32KiB moving up from 4KiB default
    		ReadBufferSize:        32 << 10, // 32KiB moving up from 4KiB default
    		IdleConnTimeout:       15 * time.Second,
    		ResponseHeaderTimeout: 15 * time.Minute, // Set conservative timeouts for MinIO internode.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 20 17:36:09 GMT 2022
    - 4.4K bytes
    - Viewed (0)
  6. internal/http/transports.go

    		Proxy:                 http.ProxyFromEnvironment,
    		DialContext:           dialContext,
    		MaxIdleConnsPerHost:   maxIdleConnsPerHost,
    		WriteBufferSize:       64 << 10, // 64KiB moving up from 4KiB default
    		ReadBufferSize:        64 << 10, // 64KiB moving up from 4KiB default
    		IdleConnTimeout:       15 * time.Second,
    		ResponseHeaderTimeout: 15 * time.Minute, // Conservative timeout is the default (for MinIO internode)
    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)
  7. internal/logger/logrotate.go

    		// writes an error in JSON form to stderr, if we cannot
    		// compress.
    		if err := w.compress(); err != nil {
    			msg := fmt.Sprintf("unable to compress log file %v: %v, ignoring and moving on", w.f.Name(), err)
    			stdErrEnc.Encode(&log.Entry{
    				Level:   ErrorKind,
    				Message: msg,
    				Time:    time.Now().UTC(),
    				Trace:   &log.Trace{Message: msg},
    			})
    		}
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 11:38:40 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  8. cmd/site-replication-metrics.go

    	// Total Replica received
    	ReplicaCount int64                `json:"replicaCount"`
    	M            map[string]*SRStatus `json:"srStatusMap"`
    
    	movingAvgTicker *time.Ticker // Ticker for calculating moving averages
    	lock            sync.RWMutex // mutex for srStats
    }
    
    // SRStatus has replication stats at deployment level
    type SRStatus struct {
    	ReplicatedSize int64 `json:"completedReplicationSize"`
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 8.2K bytes
    - Viewed (0)
  9. internal/bucket/bandwidth/measurement.go

    }
    
    // exponentialMovingAverage calculates the exponential moving average
    func exponentialMovingAverage(beta, previousAvg, incrementAvg float64) float64 {
    	return (1-beta)*incrementAvg + beta*previousAvg
    }
    
    // getExpMovingAvgBytesPerSecond returns the exponential moving average for the bucket in bytes
    func (m *bucketMeasurement) getExpMovingAvgBytesPerSecond() float64 {
    	m.lock.Lock()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Jun 03 20:41:51 GMT 2023
    - 2.9K bytes
    - Viewed (0)
  10. internal/ioutil/discard.go

    	"io"
    )
    
    // Discard is just like io.Discard without the io.ReaderFrom compatible
    // implementation which is buggy on NUMA systems, we have to use a simpler
    // io.Writer implementation alone avoids also unnecessary buffer copies,
    // and as such incurred latencies.
    var Discard io.Writer = discard{}
    
    // discard is /dev/null for Golang.
    type discard struct{}
    
    func (discard) Write(p []byte) (int, error) {
    	return len(p), nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 1.3K bytes
    - Viewed (0)
Back to top