impl

type TaskLogEvent struct {
	Log    *tasklog.TaskLog `json:"log"`
	TaskId string           `json:"task_id"`
}

type TaskLogServiceImpl struct {
	ioc.ObjectImpl

	// 异步批量日志处理配置
	LogTopic                string `json:"log_topic" toml:"log_topic" yaml:"log_topic"`
	LogBatchIntervalSeconds int64  `json:"log_batch_interval_seconds" toml:"log_batch_interval_seconds" yaml:"log_batch_interval_seconds"`
	LogBatchSize            int    `json:"log_batch_size" toml:"log_batch_size" yaml:"log_batch_size"`
	// contains filtered or unexported fields
}