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 {}