kubernetes/pkg/controller/bootstrap/tokencleaner.go

type TokenCleanerOptions …

// DefaultTokenCleanerOptions returns a set of default options for creating a
// TokenCleaner
func DefaultTokenCleanerOptions() TokenCleanerOptions { … }

type TokenCleaner …

// NewTokenCleaner returns a new *NewTokenCleaner.
func NewTokenCleaner(cl clientset.Interface, secrets coreinformers.SecretInformer, options TokenCleanerOptions) (*TokenCleaner, error) { … }

// Run runs controller loops and returns when they are done
func (tc *TokenCleaner) Run(ctx context.Context) { … }

func (tc *TokenCleaner) enqueueSecrets(obj interface{ … }

// worker runs a thread that dequeues secrets, handles them, and marks them done.
func (tc *TokenCleaner) worker(ctx context.Context) { … }

// processNextWorkItem deals with one key off the queue.  It returns false when it's time to quit.
func (tc *TokenCleaner) processNextWorkItem(ctx context.Context) bool { … }

func (tc *TokenCleaner) syncFunc(ctx context.Context, key string) error { … }

func (tc *TokenCleaner) evalSecret(ctx context.Context, o interface{ … }