Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewConfig (0.12 sec)

  1. internal/logger/config.go

    	HTTP         map[string]http.Config  `json:"http"`
    	AuditWebhook map[string]http.Config  `json:"audit"`
    	AuditKafka   map[string]kafka.Config `json:"audit_kafka"`
    }
    
    // NewConfig - initialize new logger config.
    func NewConfig() Config {
    	cfg := Config{
    		// Console logging is on by default
    		Console: Console{
    			Enabled: true,
    		},
    		HTTP:         make(map[string]http.Config),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 20 16:02:50 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  2. internal/event/target/kafka.go

    }
    
    func (target *KafkaTarget) initKafka() error {
    	if os.Getenv("_MINIO_KAFKA_DEBUG") != "" {
    		sarama.DebugLogger = log.Default()
    	}
    
    	args := target.args
    
    	config := sarama.NewConfig()
    	if args.Version != "" {
    		kafkaVersion, err := sarama.ParseKafkaVersion(args.Version)
    		if err != nil {
    			target.loggerOnce(context.Background(), err, target.ID().String())
    			return err
    		}
    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

    	}
    	return err
    }
    
    // Init initialize kafka target
    func (h *Target) init() error {
    	if os.Getenv("_MINIO_KAFKA_DEBUG") != "" {
    		sarama.DebugLogger = log.Default()
    	}
    
    	sconfig := sarama.NewConfig()
    	if h.kconfig.Version != "" {
    		kafkaVersion, err := sarama.ParseKafkaVersion(h.kconfig.Version)
    		if err != nil {
    			return err
    		}
    		sconfig.Version = kafkaVersion
    	}
    
    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/event/target/nsq.go

    	}
    	return nil
    }
    
    func (target *NSQTarget) init() error {
    	return target.initOnce.Do(target.initNSQ)
    }
    
    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
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  5. cmd/tier.go

    	}
    
    	return pReader, opts, nil
    }
    
    // Reload updates config by reloading remote tier config from config store.
    func (config *TierConfigMgr) Reload(ctx context.Context, objAPI ObjectLayer) error {
    	newConfig, err := loadTierConfig(ctx, objAPI)
    
    	config.Lock()
    	defer config.Unlock()
    
    	switch err {
    	case nil:
    		break
    	case errConfigNotFound: // nothing to reload
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  6. docs/debugging/xl-meta/main.go

    							}
    							for offset < len(splitDataShards) {
    								newConfig := false
    								for shardIdx, shard := range splitFilled[:k] {
    									if shardConfig[shardIdx] != shard[offset] {
    										newConfig = true
    										break
    									}
    								}
    								if newConfig {
    									if offset > startOffset && reconstructAbleConfig {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
Back to top