mirror of
https://github.com/kyverno/kyverno.git
synced 2025-03-10 01:46:55 +00:00
26 lines
703 B
Go
26 lines
703 B
Go
|
package policyStatus
|
||
|
|
|
||
|
|
import v1 "github.com/nirmata/kyverno/pkg/api/kyverno/v1"
|
||
|
|
|
||
|
|
type generatedResourceCount struct {
|
||
|
|
sync *Sync
|
||
|
|
generateRequest v1.GenerateRequest
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *Sync) UpdatePolicyStatusWithGeneratedResourceCount(generateRequest v1.GenerateRequest) {
|
||
|
|
s.listener <- &generatedResourceCount{
|
||
|
|
sync: s,
|
||
|
|
generateRequest: generateRequest,
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func (vc *generatedResourceCount) updateStatus() {
|
||
|
|
vc.sync.cache.mutex.Lock()
|
||
|
|
status := vc.sync.cache.data[vc.generateRequest.Spec.Policy]
|
||
|
|
|
||
|
|
status.ResourcesGeneratedCount += len(vc.generateRequest.Status.GeneratedResources)
|
||
|
|
|
||
|
|
vc.sync.cache.data[vc.generateRequest.Spec.Policy] = status
|
||
|
|
vc.sync.cache.mutex.Unlock()
|
||
|
|
}
|