Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 78 for colonne (0.24 sec)

  1. internal/config/lambda/event/targetidset.go

    type TargetIDSet map[TargetID]struct{}
    
    // IsEmpty returns true if the set is empty.
    func (set TargetIDSet) IsEmpty() bool {
    	return len(set) != 0
    }
    
    // Clone - returns copy of this set.
    func (set TargetIDSet) Clone() TargetIDSet {
    	setCopy := NewTargetIDSet()
    	for k, v := range set {
    		setCopy[k] = v
    	}
    	return setCopy
    }
    
    // add - adds TargetID to the set.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 1.9K bytes
    - Viewed (0)
  2. cmd/admin-handlers-idp-config.go

    		return
    	}
    
    	var cfgList []madmin.IDPListItem
    	var err error
    	switch idpCfgType {
    	case madmin.OpenidIDPCfg:
    		cfg := globalServerConfig.Clone()
    		cfgList, err = globalIAMSys.OpenIDConfig.GetConfigList(cfg)
    	case madmin.LDAPIDPCfg:
    		cfg := globalServerConfig.Clone()
    		cfgList, err = globalIAMSys.LDAPConfig.GetConfigList(cfg)
    
    	default:
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  3. internal/config/errors-utils.go

    // Err implements error so we can use it anywhere
    type Err struct {
    	msg    string
    	detail string
    	action string
    	hint   string
    }
    
    // Clone returns a new Err struct with the same information
    func (u Err) Clone() Err {
    	return Err{
    		msg:    u.msg,
    		detail: u.detail,
    		action: u.action,
    		hint:   u.hint,
    	}
    }
    
    // Error returns the error message
    func (u Err) Error() string {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 06 16:56:10 GMT 2023
    - 3.7K bytes
    - Viewed (0)
  4. internal/config/config.go

    // to operate on list of key values.
    type KVS []KV
    
    // Empty - return if kv is empty
    func (kvs KVS) Empty() bool {
    	return len(kvs) == 0
    }
    
    // Clone - returns a copy of the KVS
    func (kvs KVS) Clone() KVS {
    	return append(make(KVS, 0, len(kvs)), kvs...)
    }
    
    // GetWithDefault - returns default value if key not set
    func (kvs KVS) GetWithDefault(key string, defaultKVS KVS) string {
    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)
  5. internal/config/batch/batch.go

    // would wait before working on next object.
    func (opts Config) KeyRotationWait() time.Duration {
    	configMu.RLock()
    	defer configMu.RUnlock()
    
    	return opts.KeyRotationWorkersWait
    }
    
    // Clone returns a copy of Config value
    func (opts Config) Clone() Config {
    	configMu.RLock()
    	defer configMu.RUnlock()
    
    	return Config{
    		ReplicationWorkersWait: opts.ReplicationWorkersWait,
    		KeyRotationWorkersWait: opts.KeyRotationWorkersWait,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Dec 06 09:09:22 GMT 2023
    - 4.7K bytes
    - Viewed (0)
  6. internal/s3select/sql/statement.go

    		}
    
    		var kvs jstream.KVS
    		switch v := txedRec.(type) {
    		case jstream.KVS:
    			kvs = v
    
    		case []interface{}:
    			recs := make([]*Record, len(v))
    			for i, val := range v {
    				tmpRec := input.Clone(nil)
    				if err = tmpRec.Replace(val); err != nil {
    					return nil, err
    				}
    				recs[i] = &tmpRec
    			}
    			return recs, nil
    
    		default:
    			kvs = jstream.KVS{jstream.KV{Key: "_1", Value: v}}
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 09 17:19:11 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  7. internal/s3select/json/record.go

    	return nil, errors.New("not implemented here")
    }
    
    // Reset the record.
    func (r *Record) Reset() {
    	if len(r.KVS) > 0 {
    		r.KVS = r.KVS[:0]
    	}
    }
    
    // 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{}
    	}
    	if len(other.KVS) > 0 {
    		other.KVS = other.KVS[:0]
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 25 20:31:19 GMT 2022
    - 5.2K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/netns_linux.go

    	}
    	i, err := inodeForFd(n)
    	if err != nil {
    		n.Close()
    		return nil, err
    	}
    	return &NetnsWrapper{innerNetns: n, inode: i}, nil
    }
    
    func NetnsSet(n NetnsFd) error {
    	if err := unix.Setns(int(n.Fd()), unix.CLONE_NEWNET); err != nil {
    		return fmt.Errorf("Error switching to ns fd %v: %v", n.Fd(), err)
    	}
    	return nil
    }
    
    // inspired by netns.Do() but with an existing fd.
    func NetnsDo(fdable NetnsFd, toRun func() error) error {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Jan 31 10:05:36 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  9. internal/config/lambda/event/targetidset_test.go

    		{NewTargetIDSet(TargetID{"1", "webhook"}, TargetID{"2", "amqp"}), TargetID{"2", "webhook"}},
    	}
    
    	for i, testCase := range testCases {
    		result := testCase.set.Clone()
    
    		if !reflect.DeepEqual(result, testCase.set) {
    			t.Fatalf("test %v: result: expected: %v, got: %v", i+1, testCase.set, result)
    		}
    
    		result.add(testCase.targetIDToAdd)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 07 16:12:41 GMT 2023
    - 3.9K bytes
    - Viewed (0)
  10. internal/event/targetidset_test.go

    		{NewTargetIDSet(TargetID{"1", "webhook"}, TargetID{"2", "amqp"}), TargetID{"2", "webhook"}},
    	}
    
    	for i, testCase := range testCases {
    		result := testCase.set.Clone()
    
    		if !reflect.DeepEqual(result, testCase.set) {
    			t.Fatalf("test %v: result: expected: %v, got: %v", i+1, testCase.set, result)
    		}
    
    		result.add(testCase.targetIDToAdd)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 3.9K bytes
    - Viewed (0)
Back to top