Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateCRD ¶
func CreateCRD(clientset apiextensionsclient.Interface) error
CreateCRD provision the Custom Resource Definition and wait until the API is ready to interact it with
Types ¶
type AppManagerController ¶
type AppManagerController struct {
// contains filtered or unexported fields
}
AppManagerController controller
func NewAppManagerController ¶
func NewAppManagerController( dpInf, planInf cache.SharedIndexInformer, client kubernetes.Interface, defaultDomain string) *AppManagerController
NewAppManagerController creates a new AppManagerController
func (*AppManagerController) Run ¶
func (c *AppManagerController) Run(workers int, stopc <-chan struct{})
Run the controller.
type BuildController ¶
type BuildController struct {
// contains filtered or unexported fields
}
BuildController controller
func NewBuildController ¶
func NewBuildController( config *Config, releaseInf cache.SharedIndexInformer, sysClient clientset.CoreInterface, kclient kubernetes.Interface) *BuildController
NewBuildController creates a new BuilderController
func (*BuildController) Run ¶
func (b *BuildController) Run(workers int, stopc <-chan struct{})
Run the controller.
type Config ¶
type Config struct {
Host string
GitReleaseHost string
TLSInsecure bool
TLSConfig rest.TLSClientConfig
SlugBuildImage string
SlugRunnerImage string
PlatformJWTSecret string
ClusterName string
DefaultDomain string
DebugBuild bool
}
Config defines configuration parameters for the Operator.
func (*Config) IsValidStorageType ¶
IsValidStorageType check if it's valid storage type
type DeployerController ¶
type DeployerController struct {
// contains filtered or unexported fields
}
DeployerController controller
func NewDeployerController ¶
func NewDeployerController( config *Config, podInf, dpInf, relInf cache.SharedIndexInformer, sysClient clientset.CoreInterface, kclient kubernetes.Interface) *DeployerController
NewDeployerController creates a new DeployerController
func (*DeployerController) Run ¶
func (d *DeployerController) Run(workers int, stopc <-chan struct{})
Run the controller.
type NamespaceController ¶
type NamespaceController struct {
// contains filtered or unexported fields
}
NamespaceController controller
func NewNamespaceController ¶
func NewNamespaceController(nsInf, spInf cache.SharedIndexInformer, kclient kubernetes.Interface, sysClient clientset.CoreInterface) *NamespaceController
NewNamespaceController creates a NamespaceController
func (*NamespaceController) Run ¶
func (c *NamespaceController) Run(workers int, stopc <-chan struct{})
Run the controller.
type ReleaseController ¶
type ReleaseController struct {
// contains filtered or unexported fields
}
ReleaseController controller
func NewReleaseController ¶
func NewReleaseController(releaseInf, dpInf cache.SharedIndexInformer, sysClient clientset.CoreInterface, kclient kubernetes.Interface) *ReleaseController
NewReleaseController creates a new ReleaseController
func (*ReleaseController) Run ¶
func (r *ReleaseController) Run(workers int, stopc <-chan struct{})
Run the controller.
type ResourceAllocatorCtrl ¶
type ResourceAllocatorCtrl struct {
// contains filtered or unexported fields
}
ResourceAllocatorCtrl controller
func NewResourceAllocatorCtrl ¶
func NewResourceAllocatorCtrl(dpInf, spInf cache.SharedIndexInformer, client kubernetes.Interface, sysClient clientset.CoreInterface) *ResourceAllocatorCtrl
NewResourceAllocatorCtrl creates a ResourceAllocatorCtrl
func (*ResourceAllocatorCtrl) Run ¶
func (c *ResourceAllocatorCtrl) Run(workers int, stopc <-chan struct{})
Run the controller.
type SecretController ¶
type SecretController struct {
// contains filtered or unexported fields
}
SecretController generates dynamic secrets through namespaces. It manages secrets which have specific expiration time, usually used for machine-to-machine communication with limited access throughout the platform
func NewSecretController ¶
func NewSecretController(nsInf, skInf cache.SharedIndexInformer, client kubernetes.Interface, jwtSecret string) *SecretController
NewSecretController creates a new SecretController
func (*SecretController) Run ¶
func (c *SecretController) Run(workers int, stopc <-chan struct{})
Run the controller.
type TaskQueue ¶
type TaskQueue struct {
// contains filtered or unexported fields
}
TaskQueue manages a work queue through an independent worker that invokes the given sync function for every work item inserted.
func NewTaskQueue ¶
NewTaskQueue creates a new task queue with the given sync function. The sync function is called for every element inserted into the queue.
Source Files
Directories