Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 357 for ENDPOINT (0.06 sec)

  1. internal/logger/target/console/console.go

    type Target struct {
    	output io.Writer
    }
    
    // Validate - validate if the tty can be written to
    func (c *Target) Validate() error {
    	return nil
    }
    
    // Endpoint returns the backend endpoint
    func (c *Target) Endpoint() string {
    	return ""
    }
    
    func (c *Target) String() string {
    	return "console"
    }
    
    // Send log message 'e' to console
    func (c *Target) Send(e interface{}) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  2. cmd/bucket-policy-handlers_test.go

    		// initialize HTTP NewRecorder, this records any mutations to response writer inside the handler.
    		recV4 := httptest.NewRecorder()
    		// construct HTTP request for PUT bucket policy endpoint.
    		reqV4, err := newTestSignedRequestV4(http.MethodPut, getPutPolicyURL("", testCase.bucketName),
    			int64(testCase.policyLen), testCase.bucketPolicyReader, testCase.accessKey, testCase.secretKey, nil)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  3. docs/distributed/decom.sh

    	exit 1
    fi
    
    s3-check-md5 -versions -access-key minioadmin -secret-key minioadmin -endpoint http://127.0.0.1:9001/ -bucket bucket2
    s3-check-md5 -versions -access-key minioadmin -secret-key minioadmin -endpoint http://127.0.0.1:9001/ -bucket versioned
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon May 27 19:17:46 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  4. istioctl/pkg/admin/istiodconfig_test.go

    		want    string
    		wantErr bool
    	}{
    		{
    			name:    "resetState.run() should throw an error if the /scopej endpoint is missing",
    			state:   &resetState{client: ctrzClientNoScopejHandler},
    			wantErr: true,
    		},
    		{
    			name: "logLevelState.run() should throw an error if the /scopej endpoint is missing",
    			state: &logLevelState{
    				client:         ctrzClientNoScopejHandler,
    				outputLogLevel: "test:debug",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 6.2K bytes
    - Viewed (0)
  5. cmd/admin-heal-ops.go

    	sync.RWMutex
    
    	// map of heal path to heal sequence
    	healSeqMap map[string]*healSequence // Indexed by endpoint
    	// keep track of the healing status of disks in the memory
    	//   false: the disk needs to be healed but no healing routine is started
    	//    true: the disk is currently healing
    	healLocalDisks map[Endpoint]bool
    	healStatus     map[string]healingTracker // Indexed by disk ID
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  6. cmd/admin-handlers-pools.go

    }
    
    func proxyDecommissionRequest(ctx context.Context, defaultEndPoint Endpoint, w http.ResponseWriter, r *http.Request) (proxy bool) {
    	host := env.Get("_MINIO_DECOM_ENDPOINT_HOST", defaultEndPoint.Host)
    	if host == "" {
    		return
    	}
    	for nodeIdx, proxyEp := range globalProxyEndpoints {
    		if proxyEp.Endpoint.Host == host && !proxyEp.IsLocal {
    			if proxyRequestByNodeIndex(ctx, w, r, nodeIdx) {
    				return true
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 00:22:30 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  7. internal/config/identity/openid/help.go

    			Optional:    true,
    			Type:        "string",
    		},
    		config.HelpKV{
    			Key:         ClaimUserinfo,
    			Description: `Enable fetching claims from UserInfo Endpoint for authenticated user` + defaultHelpPostfix(ClaimUserinfo),
    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         KeyCloakRealm,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 23 14:45:27 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  8. cmd/admin-handlers-users_test.go

    	}
    }
    
    func (s *TestSuiteIAM) iamSetup(c *check) {
    	var err error
    	// strip url scheme from endpoint
    	s.endpoint = strings.TrimPrefix(s.endPoint, "http://")
    	if s.secure {
    		s.endpoint = strings.TrimPrefix(s.endPoint, "https://")
    	}
    
    	s.adm, err = madmin.New(s.endpoint, s.accessKey, s.secretKey, s.secure)
    	if err != nil {
    		c.Fatalf("error creating admin client: %v", err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 47.3K bytes
    - Viewed (0)
  9. cmd/storage-interface.go

    	LastConn() time.Time
    
    	// Indicates if disk is local or not.
    	IsLocal() bool
    
    	// Returns hostname if disk is remote.
    	Hostname() string
    
    	// Returns the entire endpoint.
    	Endpoint() Endpoint
    
    	// Close the disk, mark it purposefully closed, only implemented for remote disks.
    	Close() error
    
    	// Returns the unique 'uuid' of this disk.
    	GetDiskID() (string, error)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  10. cmd/naughty-disk_test.go

    }
    
    func (d *naughtyDisk) LastConn() time.Time {
    	return d.disk.LastConn()
    }
    
    func (d *naughtyDisk) IsLocal() bool {
    	return d.disk.IsLocal()
    }
    
    func (d *naughtyDisk) Endpoint() Endpoint {
    	return d.disk.Endpoint()
    }
    
    func (d *naughtyDisk) Hostname() string {
    	return d.disk.Hostname()
    }
    
    func (d *naughtyDisk) Healing() *healingTracker {
    	return d.disk.Healing()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
Back to top