Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 37 for _methods_ (0.18 sec)

  1. cmd/endpoint-ellipses.go

    	"github.com/minio/pkg/v2/env"
    )
    
    // This file implements and supports ellipses pattern for
    // `minio server` command line arguments.
    
    // Endpoint set represents parsed ellipses values, also provides
    // methods to get the sets of endpoints.
    type endpointSet struct {
    	argPatterns []ellipses.ArgPattern
    	endpoints   []string   // Endpoints saved from previous GetEndpoints().
    	setIndexes  [][]uint64 // All the sets.
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  2. internal/event/target/elasticsearch.go

    	}
    
    	if target.store != nil {
    		store.StreamItems(target.store, target, target.quitCh, target.loggerOnce)
    	}
    
    	return target, nil
    }
    
    // ES Client definitions and methods
    
    type esClientV7 struct {
    	*elasticsearch7.Client
    }
    
    func newClientV7(args ElasticsearchArgs) (*esClientV7, error) {
    	// Client options
    	elasticConfig := elasticsearch7.Config{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 15K bytes
    - Viewed (0)
  3. internal/dsync/dsync-server_test.go

    		subrouter.Methods(http.MethodPost).Path("/v1/health").HandlerFunc(lockServer.HealthHandler)
    		subrouter.Methods(http.MethodPost).Path("/v1/refresh").HandlerFunc(lockServer.RefreshHandler)
    		subrouter.Methods(http.MethodPost).Path("/v1/lock").HandlerFunc(lockServer.LockHandler)
    		subrouter.Methods(http.MethodPost).Path("/v1/rlock").HandlerFunc(lockServer.RLockHandler)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jan 23 16:46:37 GMT 2023
    - 8.3K bytes
    - Viewed (0)
  4. cmd/storage-rest-server.go

    			subrouter.Methods(http.MethodPost).Path(storageRESTVersionPrefix + storageRESTMethodReadXL).HandlerFunc(h(server.ReadXLHandler))
    			subrouter.Methods(http.MethodPost).Path(storageRESTVersionPrefix + storageRESTMethodCreateFile).HandlerFunc(h(server.CreateFileHandler))
    			subrouter.Methods(http.MethodPost).Path(storageRESTVersionPrefix + storageRESTMethodReadFile).HandlerFunc(h(server.ReadFileHandler))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  5. src/cmd/asm/internal/lex/lex.go

    // Tokens; original spacing is lost but we don't need it.
    type TokenReader interface {
    	// Next returns the next token.
    	Next() ScanToken
    	// The following methods all refer to the most recent token returned by Next.
    	// Text returns the original string representation of the token.
    	Text() string
    	// File reports the source file name of the token.
    	File() string
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Tue Aug 29 18:31:05 GMT 2023
    - 4.1K bytes
    - Viewed (0)
  6. internal/lsync/lrwmutex.go

    func (lm *LRWMutex) ForceUnlock() {
    	lm.mu.Lock()
    	defer lm.mu.Unlock()
    
    	lm.ref = 0
    	lm.isWriteLock = false
    }
    
    // DRLocker returns a sync.Locker interface that implements
    // the Lock and Unlock methods by calling drw.RLock and drw.RUnlock.
    func (lm *LRWMutex) DRLocker() sync.Locker {
    	return (*drlocker)(lm)
    }
    
    type drlocker LRWMutex
    
    func (dr *drlocker) Lock()   { (*LRWMutex)(dr).RLock() }
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 4.8K bytes
    - Viewed (0)
  7. cmd/iam-store.go

    			cache.iamSTSPolicyMap.Store(k, v)
    			return true
    		})
    
    		cache.updatedAt = time.Now()
    	}
    
    	return nil
    }
    
    // IAMStoreSys contains IAMStorageAPI to add higher-level methods on the storage
    // layer.
    type IAMStoreSys struct {
    	IAMStorageAPI
    }
    
    // HasWatcher - returns if the storage system has a watcher.
    func (store *IAMStoreSys) HasWatcher() bool {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  8. cmd/kms-router.go

    		// KMS Status APIs
    		kmsRouter.Methods(http.MethodGet).Path(version + "/status").HandlerFunc(gz(httpTraceAll(kmsAPI.KMSStatusHandler)))
    		kmsRouter.Methods(http.MethodGet).Path(version + "/metrics").HandlerFunc(gz(httpTraceAll(kmsAPI.KMSMetricsHandler)))
    		kmsRouter.Methods(http.MethodGet).Path(version + "/apis").HandlerFunc(gz(httpTraceAll(kmsAPI.KMSAPIsHandler)))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Aug 19 14:37:53 GMT 2023
    - 4.5K bytes
    - Viewed (0)
  9. internal/jwt/parser.go

    	"github.com/buger/jsonparser"
    	"github.com/dustin/go-humanize"
    	jwtgo "github.com/golang-jwt/jwt/v4"
    	jsoniter "github.com/json-iterator/go"
    )
    
    // SigningMethodHMAC - Implements the HMAC-SHA family of signing methods signing methods
    // Expects key type of []byte for both signing and validation
    type SigningMethodHMAC struct {
    	Name       string
    	Hash       crypto.Hash
    	HasherPool sync.Pool
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue May 09 07:53:08 GMT 2023
    - 13.9K bytes
    - Viewed (0)
  10. internal/logger/console.go

    const ConsoleLoggerTgt = "console+http"
    
    // ExitFunc is called by Fatal() class functions, by default it calls os.Exit()
    var ExitFunc = os.Exit
    
    // Logger interface describes the methods that need to be implemented to satisfy the interface requirements.
    type Logger interface {
    	json(msg string, args ...interface{})
    	quiet(msg string, args ...interface{})
    	pretty(msg string, args ...interface{})
    }
    
    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)
Back to top