controller

func NewInformerFactory ¶

func NewInformerFactory(
	k8s kubernetes.Interface,
	namespace string,
	tags []string,
) (informers.SharedInformerFactory, error)

NewInformerFactory returns an informer factory configured to watch resources (pods, jobs) created by the scheduler. It matches pods that are labeled with a job uuid and the agent tags that the scheduler was configured with.

func Run ¶

func Run(
	ctx context.Context,
	logger *zap.Logger,
	k8sClient kubernetes.Interface,
	cfg *config.Config,
)