worker

Documentation

Index

• func AddToManager(ctx context.Context, mgr manager.Manager, ns, hostname, nodename string, ...) error
• type Controller
  • func NewController(ctx context.Context, mgr manager.Manager, executeChan chan *v1.Calculation, ...) *Controller
  • func (c *Controller) Run(stopCh <-chan struct{}) error
• type Operator
  • func NewMainOperator(ctx context.Context, hostname, nodename, namespace, workerPool, nfsPath string, ...) *Operator
  • func (op *Operator) Initialize() error
  • func (op *Operator) Run(stopCh <-chan struct{}) error

Functions

func AddToManager

func AddToManager(ctx context.Context, mgr manager.Manager, ns, hostname, nodename string, executeChan chan *v1.Calculation, workerPool, namespace string) error

Types

type Controller

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

func NewController

func NewController(
	ctx context.Context,
	mgr manager.Manager,
	executeChan chan *v1.Calculation,
	calcErrorChan chan string,
	stepUpdaterChan chan util.Result,
	hostname, nodename, namespace, workerPool string) *Controller

func (*Controller) Run

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

type Operator

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

func NewMainOperator

func NewMainOperator(ctx context.Context, hostname, nodename, namespace, workerPool, nfsPath string, cfg *rest.Config, grpcAddress string) *Operator

func (*Operator) Initialize

func (op *Operator) Initialize() error

func (*Operator) Run

func (op *Operator) Run(stopCh <-chan struct{}) error