killyd

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

type Channels map[string]ChannelsMeta

type ChannelsMeta struct {
	Name          string
	Address       string
	MysqlAddress  string
	Addresses     []string
	MysqlInterval int
	Interval      int
	Username      string
	Password      string
	Db            string
}

type Config struct {
	Database struct {
		User     string `json:"user"`
		Password string `json:"password"`
		Address  string `json:"address"`
		Name     string `json:"name"`
	} `json:"database"`
	Interval int `json:"interval"` // in seconds
}

type Consumer interface {
	UnPause()
	Pause()
	Close() error
	TimedOutMessage()
	Empty()
}

type Daemon struct {
	SendData TidbEvent

	Config *Config

	ExitChan chan int

	sync.Mutex
	// contains filtered or unexported fields
}

type KILLYD struct {
	sync.RWMutex

	Meta Meta
	// contains filtered or unexported fields
}

type Logger lg.Logger

type Meta struct {
	Topics map[string]Channels
}

type Options struct {
	LogLevel  string `flag:"log-level"`
	LogPrefix string `flag:"log-prefix"`
	Verbose   bool   `flag:"verbose"`
	Logger    Logger

	Timeout      int
	WorkSize     int
	SendWorkSize int
	// contains filtered or unexported fields
}

type TCPMessage struct {
	Cmd  string   `json:"cmd,omitempty"`
	Args []string `json:"args,omitempty"`
	// Id is used to associate requests & responses
	ID   int         `json:"id,omitempty"`
	Data interface{} `json:"data,omitempty"`
}

type Table struct {
	Name    string     `json:"name"`
	Columns []string   `json:"columns"`
	Data    [][]string `json:"data"`
}

type TidbEvent struct {
	TidbConnections  string
	TidbAvailHosts   []string
	TikvAvailHosts   []string
	PdAvailHosts     []string
	TidbUnavailHosts []string
	TikvUnavailHosts []string
	PdUnavailHosts   []string
	TidbNum          string
	TikvNum          string
	PdNum            string
	Totalcap         string
	Totalavail       string
	EveryTikvStatus  interface{}
	sync.RWMutex
}

type Topic struct {
	sync.RWMutex
	// contains filtered or unexported fields
}