Versions in this module Expand all Collapse all v0 v0.9.2 Dec 28, 2018 v0.9.0 Dec 27, 2018 Changes in this version + const ErrResourceExists + const ErrSyncFailed + const MessageResourceExists + const MessageSyncFailed + type ClusterController struct + func NewClusterController(namespace string, kubeInformerFactory informers.SharedInformerFactory, ...) *ClusterController + func (cc *ClusterController) GetCluster() *clusterapi.DrcCluster + func (cc *ClusterController) GetK8Pipeline(namespace, pipelineName string) (*pipeapi.DrcPipeline, error) + func (cc *ClusterController) ListK8Pipelines(namespace string) ([]*pipeapi.DrcPipeline, error) + func (cc *ClusterController) Reset(pipeline *pipeapi.DrcPipeline) error + func (cc *ClusterController) Run(threadness int, stopCh <-chan struct{}) error + type Interface interface + GetCluster func() *clusterapi.DrcCluster + GetK8Pipeline func(namespace, pipelineName string) (*pipeapi.DrcPipeline, error) + ListK8Pipelines func(namespace string) ([]*pipeapi.DrcPipeline, error) + Reset func(pipeline *pipeapi.DrcPipeline) error + type PipelineManager struct + func (pm *PipelineManager) Reset(pipeline *api.DrcPipeline) error + func (pm *PipelineManager) Run(threadiness int, stopCh <-chan struct{}) error
Go to main page