checker

type Config struct {
	*flag.FlagSet

	ClusterName string `toml:"cluster-name" json:"cluster-name"`

	EtcdURLs        string `toml:"etcd-urls" json:"etcd-urls"`
	EtcdDialTimeout time.Duration
	EtcdRootPath    string `toml:"etcd-root-path" json:"etcd-root-path"`
	EtcdUsername    string `toml:"etcd-username" json:"etcd-username"`
	EtcdPassword    string `toml:"etcd-password" json:"etcd-password"`

	MaxCounter int `toml:"max-counter" json:"max-counter"`

	LogLevel  string `toml:"log-level" json:"log-level"`
	LogFile   string `toml:"log-file" json:"log-file"`
	LogRotate string `toml:"log-rotate" json:"log-rotate"`

	DBConfig     types.DBConfig `toml:"db-config" json:"db-config"`
	RootUser     string         `toml:"root-user" json:"user"`
	RootPassword string         `toml:"root-password" json:"password"`

	IDContainerMapping map[string]string `toml:"id-container-mapping" json:"id-container-mapping"`
	ContainerAZMapping map[string]string `toml:"container-az-mapping" json:"container-az-mapping"`

	PartitionTemplate string `toml:"partition-template" json:"partition-template"`
	PartitionType     string `toml:"partition-type" json:"partition-type"`

	ChaosJob string
	// contains filtered or unexported fields
}

type DMLJob interface {
	Prepare(db *sql.DB) error
	RunDML(db *sql.DB, counter int) error
	Check(db *sql.DB) int
	GetInterval() time.Duration
	GetMaxCounter() int
	GetCheckWaitTime() time.Duration
}

type LongTxnJob struct{}

type Server struct {
	// contains filtered or unexported fields
}

type SimpleDMLJob struct{}

type Status struct {
	NodeID       string
	InternalHost string
	ExternalHost string
	IsAlive      bool
}