Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 714 for Contexto (0.09 sec)

  1. cmd/site-replication-utils.go

    }
    
    func newSiteResyncMetrics(ctx context.Context) *siteResyncMetrics {
    	s := siteResyncMetrics{
    		resyncStatus:  make(map[string]SiteResyncStatus),
    		peerResyncMap: make(map[string]resyncState),
    	}
    	go s.save(ctx)
    	go s.init(ctx)
    	return &s
    }
    
    // init site resync metrics
    func (sm *siteResyncMetrics) init(ctx context.Context) {
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (1)
  2. internal/http/dial_others.go

    // DialContext is a function to make custom Dial for internode communications
    type DialContext func(ctx context.Context, network, address string) (net.Conn, error)
    
    // NewInternodeDialContext configures a custom dialer for internode communications
    func NewInternodeDialContext(dialTimeout time.Duration, _ TCPOptions) DialContext {
    	return func(ctx context.Context, network, addr string) (net.Conn, error) {
    		dialer := &net.Dialer{
    			Timeout: dialTimeout,
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Apr 24 04:08:47 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  3. internal/s3select/jstream/errors.go

    )
    
    type errPos [2]int // line number, byte offset where error occurred
    
    // DecoderError contains a detailed decoding error.
    type DecoderError struct {
    	msg       string // description of error
    	context   string // additional error context
    	pos       errPos
    	atChar    byte
    	readerErr error // underlying reader error, if any
    }
    
    // ReaderErr returns the underlying error.
    func (e DecoderError) ReaderErr() error { return e.readerErr }
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  4. cmd/consolelogger.go

    // the console logging pub sub system
    func NewConsoleLogger(ctx context.Context, w io.Writer) *HTTPConsoleLoggerSys {
    	return &HTTPConsoleLoggerSys{
    		pubsub:  pubsub.New[log.Info, madmin.LogMask](8),
    		console: console.New(w),
    		logBuf:  ring.New(defaultLogBufferCount),
    	}
    }
    
    // IsOnline always true in case of console logger
    func (sys *HTTPConsoleLoggerSys) IsOnline(_ context.Context) bool {
    	return true
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  5. internal/config/lambda/parse.go

    	"github.com/minio/pkg/v3/env"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    const (
    	logSubsys = "notify"
    )
    
    func logOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) {
    	logger.LogOnceIf(ctx, logSubsys, err, id, errKind...)
    }
    
    // ErrTargetsOffline - Indicates single/multiple target failures.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  6. build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/rules/UpgradePropertiesRuleSetup.java

        }
    
        @Override
        public void execute(ViolationCheckContext context) {
            List<UpgradedProperty> currentUpgradedProperties = UpgradedProperties.parse(params.get(CURRENT_UPGRADED_PROPERTIES_KEY));
            List<UpgradedProperty> baselineUpgradedProperties = UpgradedProperties.parse(params.get(BASELINE_UPGRADED_PROPERTIES_KEY));
            context.putUserData(CURRENT_ACCESSORS_OF_UPGRADED_PROPERTIES, diff(
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Mon Aug 19 15:30:48 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  7. cmd/warm-backend-azure.go

    	}
    
    	return resp.Body, nil
    }
    
    func (az *warmBackendAzure) Remove(ctx context.Context, object string, rv remoteVersionID) error {
    	_, err := az.clnt.DeleteBlob(ctx, az.Bucket, az.getDest(object), &azblob.DeleteBlobOptions{})
    	return azureToObjectError(err, az.Bucket, az.getDest(object))
    }
    
    func (az *warmBackendAzure) InUse(ctx context.Context) (bool, error) {
    	maxResults := int32(1)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 18:21:34 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  8. internal/bucket/bandwidth/reader.go

    package bandwidth
    
    import (
    	"context"
    	"io"
    	"math"
    )
    
    // MonitoredReader represents a throttled reader subject to bandwidth monitoring
    type MonitoredReader struct {
    	r        io.Reader
    	throttle *bucketThrottle
    	ctx      context.Context // request context
    	lastErr  error           // last error reported, if this non-nil all reads will fail.
    	m        *Monitor
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 12 14:57:31 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  9. cmd/handler-utils.go

    }
    
    // extractMetadataFromReq extracts metadata from HTTP header and HTTP queryString.
    func extractMetadataFromReq(ctx context.Context, r *http.Request) (metadata map[string]string, err error) {
    	return extractMetadata(ctx, textproto.MIMEHeader(r.Form), textproto.MIMEHeader(r.Header))
    }
    
    func extractMetadata(ctx context.Context, mimesHeader ...textproto.MIMEHeader) (metadata map[string]string, err error) {
    	metadata = make(map[string]string)
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  10. internal/http/server.go

    func (srv *Server) UseTLSConfig(cfg *tls.Config) *Server {
    	srv.TLSConfig = cfg
    	return srv
    }
    
    // UseBaseContext use custom base context for this HTTP *Server
    func (srv *Server) UseBaseContext(ctx context.Context) *Server {
    	srv.BaseContext = func(listener net.Listener) context.Context {
    		return ctx
    	}
    	return srv
    }
    
    // UseCustomLogger use customized logger for this HTTP *Server
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
Back to top