cronhpa

Documentation

Index

• Variables
• func EnsureCRDCreated(client apiextensionsclient.Interface) (created bool, err error)
• type Controller
  • func NewController(kubeclientset kubernetes.Interface, cronhpaclientset clientset.Interface, ...) (*Controller, error)
  • func (c *Controller) GetEventRecorder() record.EventRecorder
  • func (c *Controller) Run(stopCh <-chan struct{}) error

Variables

var CRD = &extensionsobj.CustomResourceDefinition{
	ObjectMeta: metav1.ObjectMeta{
		Name: "cronhpas.extensions.tkestack.io",
	},
	TypeMeta: metav1.TypeMeta{
		Kind:       "CustomResourceDefinition",
		APIVersion: "apiextensions.k8s.io/v1beta1",
	},
	Spec: extensionsobj.CustomResourceDefinitionSpec{
		Group:   "extensions.tkestack.io",
		Version: "v1",
		Scope:   extensionsobj.ResourceScope("Namespaced"),
		Names: extensionsobj.CustomResourceDefinitionNames{
			Plural:   "cronhpas",
			Singular: "cronhpa",
			Kind:     "CronHPA",
			ListKind: "CronHPAList",
		},
	},
}

Functions

func EnsureCRDCreated

func EnsureCRDCreated(client apiextensionsclient.Interface) (created bool, err error)

Types

type Controller

type Controller struct {
	// contains filtered or unexported fields
}

Controller is the controller implementation for cronhpa resources

func NewController

func NewController(
	kubeclientset kubernetes.Interface,
	cronhpaclientset clientset.Interface,
	rootClientBuilder controllerpkg.ControllerClientBuilder) (*Controller, error)

NewController returns a new cronhpa controller

func (*Controller) GetEventRecorder

func (c *Controller) GetEventRecorder() record.EventRecorder

func (*Controller) Run

func (c *Controller) Run(stopCh <-chan struct{}) error