kubernetes/pkg/controller/certificates/rootcacertpublisher/publisher.go

const RootCACertConfigMapName …

const DescriptionAnnotation …

const Description …

func init() { … }

// NewPublisher construct a new controller which would manage the configmap
// which stores certificates in each namespace. It will make sure certificate
// configmap exists in each namespace.
func NewPublisher(cmInformer coreinformers.ConfigMapInformer, nsInformer coreinformers.NamespaceInformer, cl clientset.Interface, rootCA []byte) (*Publisher, error) { … }

type Publisher …

// Run starts process
func (c *Publisher) Run(ctx context.Context, workers int) { … }

func (c *Publisher) configMapDeleted(obj interface{ … }

func (c *Publisher) configMapUpdated(_, newObj interface{ … }

func (c *Publisher) namespaceAdded(obj interface{ … }

func (c *Publisher) namespaceUpdated(oldObj interface{ … }

func (c *Publisher) runWorker(ctx context.Context) { … }

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

func (c *Publisher) syncNamespace(ctx context.Context, ns string) (err error) { … }

func convertToCM(obj interface{ … }