Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for skip_verify (0.06 sec)

  1. internal/event/target/nsq.go

    type NSQArgs struct {
    	Enable      bool      `json:"enable"`
    	NSQDAddress xnet.Host `json:"nsqdAddress"`
    	Topic       string    `json:"topic"`
    	TLS         struct {
    		Enable     bool `json:"enable"`
    		SkipVerify bool `json:"skipVerify"`
    	} `json:"tls"`
    	QueueDir   string `json:"queueDir"`
    	QueueLimit uint64 `json:"queueLimit"`
    }
    
    // Validate NSQArgs fields
    func (n NSQArgs) Validate() error {
    	if !n.Enable {
    		return 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. internal/event/target/kafka.go

    	BatchCommitTimeout time.Duration `json:"batchCommitTimeout"`
    	TLS                struct {
    		Enable        bool               `json:"enable"`
    		RootCAs       *x509.CertPool     `json:"-"`
    		SkipVerify    bool               `json:"skipVerify"`
    		ClientAuth    tls.ClientAuthType `json:"clientAuth"`
    		ClientTLSCert string             `json:"clientTLSCert"`
    		ClientTLSKey  string             `json:"clientTLSKey"`
    	} `json:"tls"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  3. internal/logger/target/kafka/kafka.go

    	Topic   string      `json:"topic"`
    	Version string      `json:"version"`
    	TLS     struct {
    		Enable        bool               `json:"enable"`
    		RootCAs       *x509.CertPool     `json:"-"`
    		SkipVerify    bool               `json:"skipVerify"`
    		ClientAuth    tls.ClientAuthType `json:"clientAuth"`
    		ClientTLSCert string             `json:"clientTLSCert"`
    		ClientTLSKey  string             `json:"clientTLSKey"`
    	} `json:"tls"`
    	SASL struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  4. internal/logger/config.go

    			Version: getCfgVal(EnvKafkaVersion, k, kv.Get(KafkaVersion)),
    		}
    
    		kafkaArgs.TLS.Enable = getCfgVal(EnvKafkaTLS, k, kv.Get(KafkaTLS)) == config.EnableOn
    		kafkaArgs.TLS.SkipVerify = getCfgVal(EnvKafkaTLSSkipVerify, k, kv.Get(KafkaTLSSkipVerify)) == config.EnableOn
    		kafkaArgs.TLS.ClientAuth = tls.ClientAuthType(clientAuth)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 20 16:02:50 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  5. internal/config/notify/parse.go

    		if k != config.Default {
    			tlsClientTLSKeyEnv = tlsClientTLSKeyEnv + config.Default + k
    		}
    
    		kafkaArgs.TLS.Enable = env.Get(tlsEnableEnv, kv.Get(target.KafkaTLS)) == config.EnableOn
    		kafkaArgs.TLS.SkipVerify = env.Get(tlsSkipVerifyEnv, kv.Get(target.KafkaTLSSkipVerify)) == config.EnableOn
    		kafkaArgs.TLS.ClientAuth = tls.ClientAuthType(clientAuth)
    
    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