Documentation
¶
Index ¶
- func CreateAddonTPRs(host string, kclient kubernetes.Interface) error
- func CreatePlan3PRs(host string, kclient kubernetes.Interface) error
- func CreatePlatformRoles(kclient kubernetes.Interface)
- func CreateReleaseTPRs(host string, kclient kubernetes.Interface) error
- type AppManagerController
- type BuildController
- type Config
- type DeployerController
- type NamespaceController
- type ReleaseController
- type ResourceAllocatorCtrl
- type TaskQueue
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateAddonTPRs ¶
func CreateAddonTPRs(host string, kclient kubernetes.Interface) error
CreateAddonTPRs generates the third party resource required for interacting with addons
func CreatePlan3PRs ¶
func CreatePlan3PRs(host string, kclient kubernetes.Interface) error
CreatePlan3PRs generates the third party resource required for interacting with Service Plans
func CreatePlatformRoles ¶
func CreatePlatformRoles(kclient kubernetes.Interface)
CreatePlatformRoles initialize the needed roles for the platform
func CreateReleaseTPRs ¶
func CreateReleaseTPRs(host string, kclient kubernetes.Interface) error
CreateReleaseTPRs generates the third party resource required for interacting with releases
Types ¶
type AppManagerController ¶
type AppManagerController struct {
// contains filtered or unexported fields
}
AppManagerController controller
func NewAppManagerController ¶
func NewAppManagerController(dpInf, planInf cache.SharedIndexInformer, client kubernetes.Interface) *AppManagerController
NewAppManagerController creates a ResourceAllocatorCtrl
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
ClusterName 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 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