mgr

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

type LogExportRunner struct {
	RunnerInfo
	// contains filtered or unexported fields
}

type Manager struct {
	ManagerConfig
	// contains filtered or unexported fields
}

type ManagerConfig struct {
	BindHost string `json:"bind_host"`
	Idc      string `json:"idc"`
	Zone     string `json:"zone"`
}

type MetricRunner struct {
	RunnerName string `json:"name"`
	// contains filtered or unexported fields
}

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

type Runner interface {
	Name() string
	Run()
	Stop()
	Cleaner() CleanInfo
	Status() RunnerStatus
}

type RunnerConfig struct {
	RunnerInfo
	Metric        []conf.MapConf `json:"metric"`
	ReaderConfig  conf.MapConf   `json:"reader"`
	CleanerConfig conf.MapConf   `json:"cleaner"`
	ParserConf    conf.MapConf   `json:"parser"`
	SenderConfig  []conf.MapConf `json:"senders"`
}

type RunnerInfo struct {
	RunnerName       string `json:"name"`
	CollectInterval  string `json:"collect_interval"` // metric runner收集的频率
	MaxBatchLen      int    `json:"batch_len"`        // 每个read batch的行数
	MaxBatchSize     int    `json:"batch_size"`       // 每个read batch的字节数
	MaxBatchInteval  int    `json:"batch_interval"`   // 最大发送时间间隔
	MaxBatchTryTimes int    `json:"batch_try_times"`  // 最大发送次数，小于等于0代表无限重试
}

type RunnerLag struct {
	Size   int64 `json:"size"`
	Files  int64 `json:"files"`
	Ftlags int64 `json:"ftlags"`
}

type RunnerStatus struct {
	Name        string                     `json:"name"`
	Logpath     string                     `json:"logpath"`
	Lag         RunnerLag                  `json:"lag,omitempty"`
	ParserStats utils.StatsInfo            `json:"parserStats,omitempty"`
	SenderStats map[string]utils.StatsInfo `json:"senderStats,omitempty"`
	Error       error                      `json:"error,omitempty"`
}