Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 71 for reload (0.14 sec)

  1. cmd/tier-handlers.go

    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errTierReservedName), r.URL)
    		return
    	}
    
    	// Refresh from the disk in case we had missed notifications about edits from peers.
    	if err := globalTierConfigMgr.Reload(ctx, objAPI); err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	err = globalTierConfigMgr.Add(ctx, cfg, ignoreInUse)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 15 19:52:44 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  2. cmd/iam.go

    }
    
    // LoadUser - reloads a specific user from backend disks or etcd.
    func (sys *IAMSys) LoadUser(ctx context.Context, objAPI ObjectLayer, accessKey string, userType IAMUserType) error {
    	if !sys.Initialized() {
    		return errServerNotInitialized
    	}
    
    	return sys.store.UserNotificationHandler(ctx, accessKey, userType)
    }
    
    // LoadServiceAccount - reloads a specific service account from backend disks or etcd.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  3. cmd/bucket-targets.go

    	"github.com/minio/minio/internal/bucket/replication"
    	"github.com/minio/minio/internal/crypto"
    	"github.com/minio/minio/internal/kms"
    )
    
    const (
    	defaultHealthCheckDuration = 5 * time.Second
    	// default interval for reload of all remote target endpoints
    	defaultHealthCheckReloadDuration = 30 * time.Minute
    )
    
    type arnTarget struct {
    	Client      *TargetClient
    	lastRefresh time.Time
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  4. cmd/tier.go

    	}
    
    	return pReader, opts, nil
    }
    
    // Reload updates config by reloading remote tier config from config store.
    func (config *TierConfigMgr) Reload(ctx context.Context, objAPI ObjectLayer) error {
    	newConfig, err := loadTierConfig(ctx, objAPI)
    
    	config.Lock()
    	defer config.Unlock()
    
    	switch err {
    	case nil:
    		break
    	case errConfigNotFound: // nothing to reload
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  5. cmd/peer-rest-client.go

    	}))
    	return err
    }
    
    // LoadPolicy - reload a specific canned policy.
    func (client *peerRESTClient) LoadPolicy(policyName string) (err error) {
    	_, err = loadPolicyRPC.Call(context.Background(), client.gridConn(), grid.NewMSSWith(map[string]string{
    		peerRESTPolicy: policyName,
    	}))
    	return err
    }
    
    // LoadPolicyMapping - reload a specific policy mapping
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  6. docs/distributed/CONFIG.md

    ### TODO
    
    In subsequent releases we are planning to extend this to provide things like
    
    - Reload() of MinIO server arguments without fully restarting the process.
    
    - Expanding 1 node at a time by automating the process of creating a new pool
      and decommissioning to provide a functionality that smaller deployments
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  7. cmd/metacache-stream_test.go

    	entries, err = r.readN(0, false, true, false, "")
    	if err != nil {
    		t.Fatal(err, entries.len())
    	}
    	if entries.len() != len(want) {
    		t.Fatal("unexpected length:", entries.len(), "want:", len(want))
    	}
    
    	// Reload.
    	r = loadMetacacheSample(t)
    	defer r.Close()
    	entries, err = r.readN(0, false, true, false, "")
    	if err != nil {
    		t.Fatal(err, entries.len())
    	}
    	if entries.len() != len(want) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 15K bytes
    - Viewed (0)
  8. internal/s3select/simdj/record.go

    }
    
    // Reset the record.
    func (r *Record) Reset() {
    	r.object = simdjson.Object{}
    }
    
    // Clone the record and if possible use the destination provided.
    func (r *Record) Clone(dst sql.Record) sql.Record {
    	other, ok := dst.(*Record)
    	if !ok {
    		other = &Record{}
    	}
    	other.object = r.object
    	return other
    }
    
    // CloneTo clones the record to a json Record.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 5.4K bytes
    - Viewed (0)
  9. cmd/common-main.go

    			err = fmt.Errorf("Unable to load TLS certificate '%s,%s': %w", certFile, keyFile, err)
    			bootLogIf(GlobalContext, err, logger.ErrorKind)
    		}
    	}
    	secureConn = true
    
    	// Certs might be symlinks, reload them every 10 seconds.
    	manager.UpdateReloadDuration(10 * time.Second)
    
    	// syscall.SIGHUP to reload the certs.
    	manager.ReloadOnSignal(syscall.SIGHUP)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 35.8K bytes
    - Viewed (2)
  10. cmd/iam-etcd-store.go

    	r, err := ies.client.Get(cctx, iamConfigGroupsPrefix, etcd.WithPrefix(), etcd.WithKeysOnly())
    	if err != nil {
    		return err
    	}
    
    	groups := etcdKvsToSet(iamConfigGroupsPrefix, r.Kvs)
    
    	// Reload config for all groups.
    	for _, group := range groups.ToSlice() {
    		if err = ies.loadGroup(ctx, group, m); err != nil && err != errNoSuchGroup {
    			return err
    		}
    	}
    	return nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 13.6K bytes
    - Viewed (0)
Back to top