Watch from Mapper example

example.go

type CRDToWatchMapper {
	c *Controller
}

func (m *CRDToWatchMapper) Map(obj handler.MapObject) []reconcile.Request {
	crdGvk := extractGVKFromCRD(obj.Object)
	m.c.Watch(
		createSourceForGVK(crdGvk),
		&handler.EnqueueRequestsFromMapFunc{ToRequests: &SBRRequestMapper{}},
	)
	return []reconcile.Request{}
}

func add() {

	// ...

	err := c.Watch(
		createSourceForGVK(v1.SchemeGroupVersion.WithKind("CustomResourceDefinition")), 
		&handler.EnqueueRequestsFromMapFunc{ToRequests: &CRDToWatchMapper{c: c}},
	)
	if err != nil {
		return err
	}

	// ...
}