logger

type EventBusPublisher interface {
	PublishTaskLog(testRunID, taskIndex uint64, taskName, taskID, level, message string, fields map[string]any)
}

type LogReader interface {
	GetLogEntries(from, limit uint64) []*db.TaskLog
	GetLogEntryCount() uint64
}

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

type ScopeOptions struct {
	Parent     logrus.FieldLogger
	BufferSize uint64
	FlushDelay time.Duration
	Database   *db.Database
	EventBus   EventBusPublisher
	TestRunID  uint64
	TaskID     uint64
	TaskName   string
	TaskRefID  string
}