controllers

Documentation

Index

• func GeneratePipelineController(k8sConfig *rest.Config, namespace string, pachydermAddress string) (controller.Controller, error)
• func GenerateReplicationController(k8sConfig *rest.Config, adargaclient *adargaclients.Clientset, ...) (controller.Controller, error)
• func MergeController(adargaClient *adargaclients.Clientset, ...) (bool, error)

Functions

func GeneratePipelineController

func GeneratePipelineController(k8sConfig *rest.Config, namespace string, pachydermAddress string) (controller.Controller, error)

func GenerateReplicationController

func GenerateReplicationController(k8sConfig *rest.Config, adargaclient *adargaclients.Clientset, namespace string) (controller.Controller, error)

func MergeController

func MergeController(adargaClient *adargaclients.Clientset, replicationController *corev1.ReplicationController, namespace string, k8scli kubernetes.Clientset, logger *zap.Logger) (bool, error)

matches a PachydermPipeline pipeline object to a replicationController. returns true if the controller has an owner. If it doesnt, it will find one and join, then return true. if none is found.. most probably a manually deployed pipe, so returns false but no error raised.