const policyRefreshIntervalDefault … var policyRefreshInterval … type policySource … type paramInfo … type compiledPolicyEntry … type PolicyHook … var _ … func NewPolicySource[P runtime.Object, B runtime.Object, E Evaluator]( policyInformer cache.SharedIndexInformer, bindingInformer cache.SharedIndexInformer, newPolicyAccessor func(P) PolicyAccessor, newBindingAccessor func(B) BindingAccessor, compiler func(P) E, paramInformerFactory informers.SharedInformerFactory, dynamicClient dynamic.Interface, restMapper meta.RESTMapper, ) Source[PolicyHook[P, B, E]] { … } // SetPolicyRefreshIntervalForTests allows the refresh interval to be overridden during tests. // This should only be called from tests. func SetPolicyRefreshIntervalForTests(interval time.Duration) func() { … } func (s *policySource[P, B, E]) Run(ctx context.Context) error { … } func (s *policySource[P, B, E]) UpstreamHasSynced() bool { … } // HasSynced implements Source. func (s *policySource[P, B, E]) HasSynced() bool { … } // Hooks implements Source. func (s *policySource[P, B, E]) Hooks() []PolicyHook[P, B, E] { … } func (s *policySource[P, B, E]) refreshPolicies() { … } func (s *policySource[P, B, E]) notify() { … } // calculatePolicyData calculates the list of policies and bindings for each // policy. If there is an error in generation, it will return the error and // the partial list of policies that were able to be generated. Policies that // have an error will have a non-nil ConfigurationError field, but still be // included in the result. // // This function caches the result of the intermediate compilations func (s *policySource[P, B, E]) calculatePolicyData() ([]PolicyHook[P, B, E], error) { … } // ensureParamsForPolicyLocked ensures that the informer for the paramKind is // started and returns the informer and the scope of the paramKind. // // Must be called under write lock func (s *policySource[P, B, E]) ensureParamsForPolicyLocked(paramSource *schema.GroupVersionKind) (informers.GenericInformer, meta.RESTScope, error) { … } // For testing func (s *policySource[P, B, E]) getParamInformer(param schema.GroupVersionKind) (informers.GenericInformer, meta.RESTScope) { … } // compilePolicyLocked compiles the policy and returns the evaluator for it. // If the policy has not changed since the last compilation, it will return // the cached evaluator. // // Must be called under write lock func (s *policySource[P, B, E]) compilePolicyLocked(policySpec P) E { … }
Codebase Browser
kubernetes