caik8s_impl

var ClusterResourceInitialStateProviderTask = gcpcommon.NewCAIInitialResourceStateProviderTask(
	taskid.NewImplementationID(k8saudit.InitialResourceStateProviderRef, "cai"),
	caik8s.ClusterResourceTaskIDs,
	extractK8sIdentity,
	initialResourceStateKey,
	extractK8sResourceBody,
	func(states []gcpcommon.CAIActiveAssetState[*k8saudit.ResourceIdentity]) k8saudit.InitialResourceStateProvider {
		return buildCAIInitialResourceStateProvider(states)
	},
)

var ClusterResourceSuite = gcpcommon.NewCAITaskSuite(gcpcommon.CAITaskSuiteConfig[*k8saudit.ResourceIdentity]{
	TaskIDs: caik8s.ClusterResourceTaskIDs,
	FetcherDependencies: []coretask.Dependency{
		k8scommon.ClusterIdentityTaskID.Ref(),
		k8scommon.InputKindFilterTaskID.Ref(),
		k8scommon.InputNamespaceFilterTaskID.Ref(),
	},
	ResolveSearchTarget: resolveClusterResourceSearchTarget,
	PreprocessRawMap:    preprocessK8sTemporalAssetMap,
	ExtractIdentity:     extractK8sIdentity,
	IdentityGroupKey: func(identity *k8saudit.ResourceIdentity) string {
		return identity.String()
	},
	FormatLogSummary: formatClusterResourceLogSummary,
	MapperDependencies: []coretask.Dependency{
		k8scommon.ClusterIdentityTaskID.Ref(),
	},
	MapInitialRevision: mapClusterResourceInitialRevision,
})

var GKEResourceInitialStateProviderTask = gcpcommon.NewCAIInitialResourceStateProviderTask(
	taskid.NewImplementationID(gkeapiaudit.InitialResourceStateProviderRef, "cai"),
	caik8s.GKEResourceTaskIDs,
	extractGKEIdentity,
	gkeIdentityGroupKey,
	extractGKEResourceBody,
	func(states []gcpcommon.CAIActiveAssetState[gkeResourceIdentity]) gkeapiaudit.InitialResourceStateProvider {
		return buildCAIGKEInitialResourceStateProvider(states)
	},
)

var GKEResourceSuite = gcpcommon.NewCAITaskSuite(gcpcommon.CAITaskSuiteConfig[gkeResourceIdentity]{
	TaskIDs: caik8s.GKEResourceTaskIDs,
	FetcherDependencies: []coretask.Dependency{
		k8scommon.ClusterIdentityTaskID.Ref(),
	},
	ResolveSearchTarget: resolveGKEResourceSearchTarget,
	ExtractIdentity:     extractGKEIdentity,
	IdentityGroupKey:    gkeIdentityGroupKey,
	FormatLogSummary:    formatGKEResourceLogSummary,
	MapperDependencies: []coretask.Dependency{
		k8scommon.ClusterIdentityTaskID.Ref(),
		caik8s.GKEResourceTaskIDs.RawLog.Ref(),
	},
	MapInitialRevision: mapGKEResourceInitialRevision,
})