kubernetes/plugin/pkg/admission/eventratelimit/limitenforcer.go

const defaultCacheSize …

type limitEnforcer …

func newLimitEnforcer(config eventratelimitapi.Limit, clock flowcontrol.Clock) (*limitEnforcer, error) { … }

func (enforcer *limitEnforcer) accept(attr admission.Attributes) error { … }

func getServerKey(attr admission.Attributes) string { … }

// getNamespaceKey returns a cache key that is based on the namespace of the event request
func getNamespaceKey(attr admission.Attributes) string { … }

// getUserKey returns a cache key that is based on the user of the event request
func getUserKey(attr admission.Attributes) string { … }

// getSourceAndObjectKey returns a cache key that is based on the source+object of the event
func getSourceAndObjectKey(attr admission.Attributes) string { … }