kubernetes

type ConfigMapAdapter interface {
	// GetConfig return a single ConfigMap by name if exist
	GetConfig(ctx context.Context, name string) (*apiv1.ConfigMap, error)
	// WatchConfigs calls its ConfigMapCallback whenever a ConfigMap was added, modified or deleted
	WatchConfigs(ctx context.Context, cb ConfigMapCallback) error
}

type ConfigMapCallback = func(watch.EventType, *apiv1.ConfigMap)

type Mapper interface {
	// MapPolicyReport maps a map into a PolicyReport
	MapPolicyReport(reportMap map[string]interface{}) report.PolicyReport
	// SetPriorityMap updates the policy/status to priority mapping
	SetPriorityMap(map[string]string)
	// SyncPriorities when ConfigMap has changed
	SyncPriorities(ctx context.Context) error
	// FetchPriorities from ConfigMap
	FetchPriorities(ctx context.Context) error
}

type PolicyReportAdapter interface {
	WatchPolicyReports(ctx context.Context) (chan WatchEvent, error)
	GetFoundResources() map[string]string
}

type WatchEvent struct {
	Report report.PolicyReport
	Type   watch.EventType
}