Versions in this module Expand all Collapse all v0 v0.0.10 Apr 10, 2026 v0.0.9 Mar 17, 2026 Changes in this version + type TaskLogEvent struct + Log *tasklog.TaskLog + TaskId string + type TaskLogServiceImpl struct + LogBatchIntervalSeconds int64 + LogBatchSize int + LogTopic string + func (i *TaskLogServiceImpl) Close(ctx context.Context) + func (i *TaskLogServiceImpl) GetLogBufferSize() int + func (i *TaskLogServiceImpl) GetLogConsumerStats() map[string]interface{} + func (i *TaskLogServiceImpl) Init() error + func (i *TaskLogServiceImpl) Name() string + func (i *TaskLogServiceImpl) QueryTaskLog(ctx context.Context, in *tasklog.QueryTaskLogRequest) (*types.Set[*tasklog.TaskLog], error) + func (i *TaskLogServiceImpl) SaveTaskLog(ctx context.Context, in *tasklog.TaskLog) error
Go to main page