component

Documentation

Index

• Constants
• func CheckKafka(kafkaStu *Kafka) (sarama.Client, error)
• func CheckMinio(minioStu *Minio) error
• func CheckMongo(mongoStu *Mongo) error
• func CheckRedis(redisStu *Redis) error
• func CheckZookeeper(zkStu *Zookeeper) error
• func ErrStr(err error, str string) error
• func ErrorPrint(s string)
• func SuccessPrint(s string)
• func WarningPrint(s string)
• type Kafka
• type Minio
• type Mongo
• type MySQL
• type Redis
• type Zookeeper

Constants

const (
	MaxRetry = 300
)

Functions

func CheckKafka

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

CheckKafka checks the Kafka connection

func CheckMinio

func CheckMinio(minioStu *Minio) error

CheckMinio checks the MinIO connection

func CheckMongo

func CheckMongo(mongoStu *Mongo) error

CheckMongo checks the MongoDB connection without retries

func CheckRedis

func CheckRedis(redisStu *Redis) error

CheckRedis checks the Redis connection

func CheckZookeeper

func CheckZookeeper(zkStu *Zookeeper) error

func ErrStr

func ErrStr(err error, str string) error

func ErrorPrint

func ErrorPrint(s string)

func SuccessPrint

func SuccessPrint(s string)

func WarningPrint

func WarningPrint(s string)

Types

type Kafka

type Kafka struct {
	Username string   `json:"username"`
	Password string   `json:"password"`
	Addr     []string `json:"addr"`
}

type Minio

type Minio struct {
	ApiURL          string `json:"apiURL"`
	Endpoint        string `json:"endpoint"`
	AccessKeyID     string `json:"accessKeyID"`
	SecretAccessKey string `json:"secretAccessKey"`
	SignEndpoint    string `json:"signEndpoint"`
	UseSSL          string `json:"useSSL"`
}

type Mongo

type Mongo struct {
	URL         string   `json:"url"`
	Address     []string `json:"address"`
	Database    string   `json:"database"`
	Username    string   `json:"username"`
	Password    string   `json:"password"`
	MaxPoolSize int      `json:"maxPoolSize"`
}

type MySQL

type MySQL struct {
	Address  []string `json:"address"`
	Username string   `json:"username"`
	Password string   `json:"password"`
	Database string   `json:"database"`
}

type Redis

type Redis struct {
	Address  []string `json:"address"`
	Username string   `json:"username"`
	Password string   `json:"password"`
}

type Zookeeper

type Zookeeper struct {
	Schema   string   `json:"schema"`
	ZkAddr   []string `json:"zkAddr"`
	Username string   `json:"username"`
	Password string   `json:"password"`
}