component

Jan 29, 2024

Changes in this version

+ const MaxRetry

+ var ErrComponentStart = errs.NewCodeError(componentStartErrCode, "ComponentStartErr")

+ var ErrConfig = errs.NewCodeError(configErrCode, "Config file is incorrect")

+ func CheckKafka(kafkaStu *Kafka) (string, sarama.Client, error)

+ func CheckMinio(minioStu *Minio) (string, error)

+ func CheckMongo(mongoStu *Mongo) (string, error)

+ func CheckMySQL(mysqlStu *MySQL) (string, error)

+ func CheckRedis(redisStu *Redis) (string, error)

+ func CheckZookeeper(zkStu *Zookeeper) (string, error)

+ func ErrStr(err error, str string) error

+ func ErrorPrint(s string)

+ func SuccessPrint(s string)

+ func WarningPrint(s string)

+ type Kafka struct

+ Addr []string

+ Password string

+ Username string

+ type Minio struct

+ AccessKeyID string

+ ApiURL string

+ Endpoint string

+ SecretAccessKey string

+ SignEndpoint string

+ UseSSL string

+ type Mongo struct

+ Address []string

+ Database string

+ MaxPoolSize int

+ Password string

+ URL string

+ Username string

+ type MySQL struct

+ Address []string

+ Database string

+ Password string

+ Username string

+ type Redis struct

+ Address []string

+ Password string

+ Username string

+ type Zookeeper struct

+ Password string

+ Schema string

+ Username string

+ ZkAddr []string