Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for Kissling (0.14 sec)

  1. internal/event/config.go

    	type queue Queue
    	parsedQueue := queue{}
    	if err := d.DecodeElement(&parsedQueue, &start); err != nil {
    		return err
    	}
    
    	if len(parsedQueue.Events) == 0 {
    		return errors.New("missing event name(s)")
    	}
    
    	eventStringSet := set.NewStringSet()
    	for _, eventName := range parsedQueue.Events {
    		if eventStringSet.Contains(eventName.String()) {
    			return &ErrDuplicateEventName{eventName}
    		}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 16 17:28:29 GMT 2021
    - 8.4K bytes
    - Viewed (0)
  2. cmd/config.go

    			return nil, err
    		}
    	}
    
    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    	if err := json.Unmarshal(data, &srvCfg); err != nil {
    		return nil, err
    	}
    
    	// Add any missing entries
    	return srvCfg.Merge(), nil
    }
    
    // ConfigSys - config system.
    type ConfigSys struct{}
    
    // Init - initializes config system from config.json.
    func (sys *ConfigSys) Init(objAPI ObjectLayer) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Aug 23 10:07:06 GMT 2023
    - 6K bytes
    - Viewed (0)
  3. internal/config/config.go

    var deletedSubSysKeys = map[string][]string{
    	APISubSys: {apiReplicationWorkers, apiReplicationFailedWorkers},
    	// Add future sub-system deleted keys
    }
    
    // Merge - merges a new config with all the
    // missing values for default configs,
    // returns a config.
    func (c Config) Merge() Config {
    	cp := New()
    	for subSys, tgtKV := range c {
    		for tgt := range tgtKV {
    			ckvs := c[subSys][tgt]
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 37.3K bytes
    - Viewed (0)
Back to top