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
Source Files
Click to show internal directories.
Click to hide internal directories.