Documentation ¶
Index ¶
Constants ¶
View Source
const ( NamePrefix = "planter" PartOf = "Planter" ManagedBy = "Planter" OperatorImageName = "tliron/planter-operator" CacheDirectory = "/cache" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClusterClient ¶
type ClusterClient struct {
// contains filtered or unexported fields
}
func (*ClusterClient) Dynamic ¶
func (self *ClusterClient) Dynamic(namespace string) *kubernetesutil.Dynamic
type ClusterClients ¶
type ClusterClients struct {
// contains filtered or unexported fields
}
func (*ClusterClients) Get ¶
func (self *ClusterClients) Get(clusterName string) (*ClusterClient, error)
type Controller ¶
type Controller struct { Config *restpkg.Config Dynamic *kubernetesutil.Dynamic Kubernetes kubernetes.Interface Planter planterpkg.Interface Client *clientpkg.Client CachePath string StopChannel <-chan struct{} Processors *kubernetesutil.Processors Events record.EventRecorder KubernetesInformerFactory informers.SharedInformerFactory PlanterInformerFactory planterinformers.SharedInformerFactory Seeds planterlisters.SeedLister Context contextpkg.Context Log logging.Logger }
func NewController ¶
func NewController(context contextpkg.Context, toolName string, clusterRole string, namespace string, dynamic dynamicpkg.Interface, kubernetes kubernetes.Interface, apiExtensions apiextensionspkg.Interface, planter planterpkg.Interface, config *restpkg.Config, cachePath string, informerResyncPeriod time.Duration, stopChannel <-chan struct{}) *Controller
func (*Controller) NewClusterClient ¶
func (self *Controller) NewClusterClient(namespace string, clusterName string) (*ClusterClient, error)
func (*Controller) NewClusterClients ¶
func (self *Controller) NewClusterClients() *ClusterClients
func (*Controller) Run ¶
func (self *Controller) Run(concurrency uint, startup func()) error
Click to show internal directories.
Click to hide internal directories.