inspectiontaskbase

type CacheableTaskResult[T any] struct {
	// Value is the value used previous run.
	Value T
	// DependencyDigest is a string representation of digest of its inputs.
	// Task must generate a different value for the different combination of the input and task should compare the current digest generated from the current inputs and the previous value digest, then it should return the previous value only when the digest is not changed.
	DependencyDigest string
}

type GroupedLogIngester[T any] interface {
	// RawLogTask returns the task reference that provides the raw logs to ingest.
	RawLogTask() taskid.TaskReference[[]*log.Log]
	// GroupedLogTask returns a reference to the task that provides the grouped logs.
	GroupedLogTask() taskid.TaskReference[LogGroupMap]
	// Dependencies returns additional task dependencies of the ingester.
	Dependencies() []coretask.Dependency
	// PassCount returns the number of pre-processing passes to perform on each group.
	PassCount() int
	// PreProcessLogByGroup is called during a pre-processing pass for each log in a group.
	// The passIndex is 0-indexed and ranges from 0 to PassCount()-1.
	PreProcessLogByGroup(ctx context.Context, passIndex int, l *log.Log, prevGroupData T) (T, error)
	// ProcessLogByGroup is called for each log entry in a group to customize log metadata.
	// The prevGroupData is the returned value from the last processed log in the same group.
	ProcessLogByGroup(ctx context.Context, l *log.Log, prevGroupData T) (*khifilev6.LogChangeSet, T, error)
}

type InspectionTaskFunc[T any] = func(ctx context.Context, taskMode inspectioncore.InspectionTaskModeType) (T, error)

type LogFilterFunc = func(ctx context.Context, log *log.Log) bool

type LogGroup struct {
	Group string
	Logs  []*log.Log
}

type LogGroupMap = map[string]*LogGroup

type LogGrouperFunc = func(ctx context.Context, log *log.Log) string

type LogIngester interface {
	// RawLogTask returns the task reference that provides the raw logs to ingest.
	RawLogTask() taskid.TaskReference[[]*log.Log]
	// Dependencies returns additional task dependencies of the ingester.
	Dependencies() []coretask.Dependency
	// ProcessLog is called for each log entry to customize log metadata (summary, severity, timestamp, etc.).
	ProcessLog(ctx context.Context, l *log.Log) (*khifilev6.LogChangeSet, error)
}

type LogToTimelineMapper[T any] interface {
	// LogIngesterTask is one of prerequisite task of LogToTimelineMapper ingesting logs before processing with this mapper.
	LogIngesterTask() taskid.TaskReference[struct{}]
	// Dependencies are the additional references used in timeline mapper.
	Dependencies() []coretask.Dependency
	// GroupedLogTask returns a reference to the task that provides the grouped logs.
	GroupedLogTask() taskid.TaskReference[LogGroupMap]
	// PassCount returns the number of pre-processing passes to perform on each group.
	PassCount() int
	// PreProcessLogByGroup is called during a pre-processing pass for each log in a group.
	// The passIndex is 0-indexed and ranges from 0 to PassCount()-1.
	PreProcessLogByGroup(ctx context.Context, passIndex int, l *log.Log, prevGroupData T) (T, error)
	// ProcessLogByGroup is called for each log entry to stage mutations via TimelineChangeSet.
	// The prevGroupData is the returned value from the last processed log in the same group.
	ProcessLogByGroup(ctx context.Context, l *log.Log, prevGroupData T) (*khifilev6.TimelineChangeSet, T, error)
}

type SinglePassGroupedIngesterBase[T any] struct{}

type SinglePassMapperBase[T any] struct{}

type StatelessMapperBase struct{}