taskrecord

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

type DefaultJSONCodec struct{}

type JobTestConfig struct {
	// InspectionType is the type of inspection to create (e.g. "gke").
	InspectionType string

	// InspectionFeatures is the list of feature IDs to enable (e.g. "khi.google.com/feature/gke-audit-log" or "ALL").
	InspectionFeatures []string

	// InspectionValues is the map of input parameters passed to the inspection runner.
	InspectionValues map[string]any

	// RecordedTasks specifies the upstream tasks to record during Record mode and replace with stubs in Replay mode.
	RecordedTasks []taskid.UntypedTaskReference

	// TargetTask optionally specifies a single downstream task under test.
	// When specified, it executes strictly non-concurrently and early terminates once complete.
	TargetTask taskid.UntypedTaskReference
}

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

type JobTestResult struct {
	// InspectionResult is the final inspection result store and metadata, if the inspection ran to completion.
	InspectionResult *coreinspection.InspectionRunResult

	// TaskRunner is the underlying task runner used during the run.
	TaskRunner coretask.TaskRunner
	// contains filtered or unexported fields
}

type LogListCodec struct{}

type TaskResultCodec interface {
	// Serialize converts the task result value into byte slice.
	Serialize(value any) ([]byte, error)

	// Deserialize converts the byte slice into the task result value.
	Deserialize(data []byte) (any, error)
}