Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for subSys (0.11 sec)

  1. internal/config/config.go

    func (c Config) Merge() Config {
    	cp := New()
    	for subSys, tgtKV := range c {
    		for tgt := range tgtKV {
    			ckvs := c[subSys][tgt]
    			for _, kv := range cp[subSys][Default] {
    				_, ok := c[subSys][tgt].Lookup(kv.Key)
    				if !ok {
    					ckvs.Set(kv.Key, kv.Value)
    				}
    			}
    			if _, ok := cp[subSys]; !ok {
    				rnSubSys, ok := renamedSubsys[subSys]
    				if !ok {
    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/config-current.go

    func GetHelp(subSys, key string, envOnly bool) (Help, error) {
    	if len(subSys) == 0 {
    		return Help{KeysHelp: config.HelpSubSysMap[subSys]}, nil
    	}
    	subSystemValue := strings.SplitN(subSys, config.SubSystemSeparator, 2)
    	if len(subSystemValue) == 0 {
    		return Help{}, config.Errorf("invalid number of arguments %s", subSys)
    	}
    
    	subSys = subSystemValue[0]
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 30.1K bytes
    - Viewed (0)
  3. internal/logger/config.go

    	if key != config.Default {
    		envName = envName + config.Default + key
    	}
    	return env.Get(envName, defaultValue)
    }
    
    func lookupLegacyConfigForSubSys(ctx context.Context, subSys string) Config {
    	cfg := NewConfig()
    	switch subSys {
    	case config.LoggerWebhookSubSys:
    		var loggerTargets []string
    		envs := env.List(legacyEnvLoggerHTTPEndpoint)
    		for _, k := range envs {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 20 16:02:50 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  4. internal/config/notify/parse.go

    func TestSubSysNotificationTargets(ctx context.Context, cfg config.Config, subSys string, transport *http.Transport) error {
    	if err := checkValidNotificationKeysForSubSys(subSys, cfg[subSys]); err != nil {
    		return err
    	}
    
    	targetList, err := fetchSubSysTargets(ctx, cfg, subSys, transport)
    	if err != nil {
    		return err
    	}
    
    	for _, target := range targetList {
    		defer target.Close()
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  5. cmd/admin-router.go

    		}
    
    		// Enable config help in all modes.
    		adminRouter.Methods(http.MethodGet).Path(adminVersion+"/help-config-kv").HandlerFunc(adminMiddleware(adminAPI.HelpConfigKVHandler, traceAllFlag)).Queries("subSys", "{subSys:.*}", "key", "{key:.*}")
    
    		// Config KV history operations.
    		if enableConfigOps {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 21 11:35:40 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  6. cmd/peer-rest-client.go

    }
    
    // SignalService - sends signal to peer nodes.
    func (client *peerRESTClient) SignalService(sig serviceSignal, subSys string, dryRun bool, execAt *time.Time) error {
    	values := grid.NewMSS()
    	values.Set(peerRESTSignal, strconv.Itoa(int(sig)))
    	values.Set(peerRESTDryRun, strconv.FormatBool(dryRun))
    	values.Set(peerRESTSubSys, subSys)
    	if execAt != nil {
    		values.Set(peerRESTExecAt, execAt.Format(time.RFC3339Nano))
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  7. cmd/peer-rest-server.go

    		if err != nil {
    			return np, grid.NewRemoteErr(err)
    		}
    		subSys := vars.Get(peerRESTSubSys)
    		// Apply dynamic values.
    		ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    		defer cancel()
    		if subSys == "" {
    			err = applyDynamicConfig(ctx, objAPI, srvCfg)
    		} else {
    			err = applyDynamicConfigForSubSys(ctx, objAPI, srvCfg, subSys)
    		}
    		if err != nil {
    			return np, grid.NewRemoteErr(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  8. cmd/notification.go

    func (sys *NotificationSys) SignalConfigReload(subSys string) []NotificationPeerErr {
    	ng := WithNPeers(len(sys.peerClients))
    	for idx, client := range sys.peerClients {
    		if client == nil {
    			continue
    		}
    		client := client
    		ng.Go(GlobalContext, func() error {
    			return client.SignalService(serviceReloadDynamic, subSys, false, nil)
    		}, idx, *client.host)
    	}
    	return ng.Wait()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  9. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/LookupInvoker.java

                terminal = ft.getTerminal();
            }
            List<String> subs = new ArrayList<>();
            subs.add("type=" + terminal.getType());
            if (terminal instanceof TerminalExt te) {
                subs.add("provider=" + te.getProvider().name());
            }
            if (terminal instanceof AbstractPosixTerminal pt) {
                subs.add("pty=" + pt.getPty().getClass().getName());
            }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 38K bytes
    - Viewed (0)
Back to top