Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. internal/config/config.go

    		}
    	}
    	return scanner.Err()
    }
    
    // ContextKeyString is type(string) for contextKey
    type ContextKeyString string
    
    // ContextKeyForTargetFromConfig - key for context for target from config
    const ContextKeyForTargetFromConfig = ContextKeyString("ContextKeyForTargetFromConfig")
    
    // ParseConfigTargetID - read all targetIDs from reader
    func ParseConfigTargetID(r io.Reader) (ids map[string]bool, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  2. cmd/admin-handlers-config-kv.go

    	if err != nil {
    		return
    	}
    
    	tgts, err := config.ParseConfigTargetID(bytes.NewReader(kvBytes))
    	if err != nil {
    		return
    	}
    	ctx = context.WithValue(ctx, config.ContextKeyForTargetFromConfig, tgts)
    	if verr := validateConfig(ctx, result.Cfg, result.SubSys); verr != nil {
    		err = badConfigErr{Err: verr}
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  3. internal/config/notify/parse.go

    	targetList, err := fetchSubSysTargets(ctx, cfg, subSys, transport)
    	if err != nil {
    		return err
    	}
    
    	for _, target := range targetList {
    		defer target.Close()
    	}
    
    	tgts, ok := ctx.Value(config.ContextKeyForTargetFromConfig).(map[string]bool)
    	if !ok {
    		tgts = make(map[string]bool)
    	}
    	for _, target := range targetList {
    		if tgts[target.ID().ID] {
    			// When target set should be online
    			yes, err := target.IsActive()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
Back to top