pump

type ChangeStateReq struct {
	NodeID string `json:"nodeID"`
	State  string `json:"state"`
}

type Config struct {
	*flag.FlagSet     `json:"-"`
	LogLevel          string `toml:"log-level" json:"log-level"`
	NodeID            string `toml:"node-id" json:"node-id"`
	ListenAddr        string `toml:"addr" json:"addr"`
	AdvertiseAddr     string `toml:"advertise-addr" json:"advertise-addr"`
	Socket            string `toml:"socket" json:"socket"`
	EtcdURLs          string `toml:"pd-urls" json:"pd-urls"`
	EtcdDialTimeout   time.Duration
	DataDir           string `toml:"data-dir" json:"data-dir"`
	HeartbeatInterval int    `toml:"heartbeat-interval" json:"heartbeat-interval"`
	// pump only stores binlog events whose ts >= current time - GC Time. The default unit is day
	GC       util.Duration   `toml:"gc" json:"gc"`
	LogFile  string          `toml:"log-file" json:"log-file"`
	Security security.Config `toml:"security" json:"security"`

	GenFakeBinlogInterval int `toml:"gen-binlog-interval" json:"gen-binlog-interval"`

	MetricsAddr     string
	MetricsInterval int

	Storage storage.Config `toml:"storage" json:"storage"`
	// contains filtered or unexported fields
}

type HTTPStatus struct {
	StatusMap  map[string]*node.Status `json:"status"`
	CommitTS   int64                   `json:"CommitTS"`
	CheckPoint pb.Pos                  `json:"Checkpoint"`
	ErrMsg     string                  `json:"ErrMsg"`
}

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