- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for NewConfig (0.08 sec)
-
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) -
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) -
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) -
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) -
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) -
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)