operator

Documentation

Index

• type Operator
  • func New(ctx context.Context, nsOp, nsCRD, nsPod string, ...) *Operator
  • func (c *Operator) GetCRDNamespace() string
  • func (c *Operator) GetContext() context.Context
  • func (c *Operator) GetPodNamespace() string
  • func (c *Operator) HasSynced() bool
  • func (c *Operator) Run(workerNum int) error

Types

type Operator

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

Operator for controlling CRD instances.

func New

func New(ctx context.Context, nsOp, nsCRD, nsPod string, kubeClient kubernetes.Interface, jinghzhuV1Client jinghzhuv1clientset.Interface) *Operator

New creates the CRD Operator. The parameter nsOp is the namespace where this Operator will run.

func (*Operator) GetCRDNamespace

func (c *Operator) GetCRDNamespace() string

GetCRDNamespace returns the namespace where Operator watchs the CRs.

func (*Operator) GetContext

func (c *Operator) GetContext() context.Context

GetContext retruns the context.

func (*Operator) GetPodNamespace

func (c *Operator) GetPodNamespace() string

GetPodNamespace returns the namespace where Operator process the worker Pods.

func (*Operator) HasSynced

func (c *Operator) HasSynced() bool

HasSynced is required for the cache.Controller interface.

func (*Operator) Run

func (c *Operator) Run(workerNum int) error

Run is the main entry to start CRD Operator.