Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 602 for arg4 (0.07 sec)

  1. internal/event/target/nsq.go

    }
    
    func (target *NSQTarget) initNSQ() error {
    	args := target.args
    
    	config := nsq.NewConfig()
    	if args.TLS.Enable {
    		config.TlsV1 = true
    		config.TlsConfig = &tls.Config{
    			InsecureSkipVerify: args.TLS.SkipVerify,
    		}
    	}
    	target.config = config
    
    	producer, err := nsq.NewProducer(args.NSQDAddress.String(), config)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  2. cmd/config-migrate.go

    	}
    	for k, args := range cfg.Notify.NATS {
    		notify.SetNotifyNATS(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.NSQ {
    		notify.SetNotifyNSQ(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.PostgreSQL {
    		notify.SetNotifyPostgres(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.Redis {
    		notify.SetNotifyRedis(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.Webhook {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  3. tests/connpool_test.go

    func (c *wrapperTx) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error) {
    	c.conn.got = append(c.conn.got, query)
    	return c.Tx.ExecContext(ctx, query, args...)
    }
    
    func (c *wrapperTx) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error) {
    	c.conn.got = append(c.conn.got, query)
    	return c.Tx.QueryContext(ctx, query, args...)
    }
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Feb 06 02:54:40 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  4. build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java

        }
    
        private static class ExecResult {
            private final String[] args;
            private final int code;
            private final String stdout;
            private final String stderr;
    
            public ExecResult(String[] args, int code, String stdout, String stderr) {
                this.args = args;
                this.code = code;
                this.stdout = stdout;
                this.stderr = stderr;
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Mon Aug 19 15:07:24 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  5. istioctl/pkg/admin/admin.go

      istioctl admin log`,
    		Aliases: []string{"istiod"},
    		Args: func(cmd *cobra.Command, args []string) error {
    			if len(args) != 0 {
    				return fmt.Errorf("unknown subcommand %q", args[0])
    			}
    			return nil
    		},
    		RunE: func(cmd *cobra.Command, args []string) error {
    			cmd.HelpFunc()(cmd, args)
    			return nil
    		},
    	}
    
    	istiodLog := istiodLogCmd(ctx)
    	adminCmd.AddCommand(istiodLog)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  6. impl/maven-cli/src/main/java/org/apache/maven/cling/MavenEncCling.java

         */
        public static void main(String[] args) throws IOException {
            int exitCode = new MavenEncCling().run(args);
            System.exit(exitCode);
        }
    
        /**
         * ClassWorld Launcher "enhanced" entry point: returning exitCode and accepts Class World.
         */
        public static int main(String[] args, ClassWorld world) throws IOException {
            return new MavenEncCling(world).run(args);
        }
    
        public MavenEncCling() {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  7. istioctl/pkg/describe/describe_test.go

    	cases := []execAndK8sConfigTestCase{
    		{ // case 0
    			args:           []string{},
    			expectedString: "Describe resource and related Istio configuration",
    		},
    		{ // case 2 no pod
    			args:           strings.Split("pod", " "),
    			expectedString: "Error: expecting pod name",
    			wantException:  true, // "istioctl experimental inspect pod" should fail
    		},
    		{ // case 3 unknown pod
    			args:           strings.Split("po not-a-pod", " "),
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 20:04:20 UTC 2024
    - 30.8K bytes
    - Viewed (0)
  8. fess-crawler-lasta/src/main/resources/crawler/extractor.xml

    				]</arg>
    			<arg>pdfExtractor</arg>
    		</postConstruct>
    		<postConstruct name="addExtractor">
    			<arg>[
    				"application/x-lha",
    				"application/x-lharc"
    				]</arg>
    			<arg>lhaExtractor</arg>
    		</postConstruct>
    		<postConstruct name="addExtractor">
    			<arg>[
    				"message/rfc822"
    				]</arg>
    			<arg>emlExtractor</arg>
    		</postConstruct>
    		<postConstruct name="addExtractor">
    			<arg>[
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Aug 01 21:40:30 UTC 2020
    - 49K bytes
    - Viewed (0)
  9. internal/event/target/elasticsearch.go

    }
    
    func newClientV7(args ElasticsearchArgs) (*esClientV7, error) {
    	// Client options
    	elasticConfig := elasticsearch7.Config{
    		Addresses:  []string{args.URL.String()},
    		Transport:  args.Transport,
    		MaxRetries: 10,
    	}
    	// Set basic auth
    	if args.Username != "" && args.Password != "" {
    		elasticConfig.Username = args.Username
    		elasticConfig.Password = args.Password
    	}
    	// Create a client
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  10. docs/config/README.md

    #### Site
    
    ```
    KEY:
    site  label the server and its location
    
    ARGS:
    name     (string)    name for the site e.g. "cal-rack0"
    region   (string)    name of the location of the server e.g. "us-west-1"
    comment  (sentence)  optionally add a comment to this setting
    ```
    
    or environment variables
    
    ```
    KEY:
    site  label the server and its location
    
    ARGS:
    MINIO_SITE_NAME     (string)    name for the site e.g. "cal-rack0"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 17.9K bytes
    - Viewed (1)
Back to top