controllers

Documentation

Index

• Constants
• type Client
• type JobReconciler
  • func (r *JobReconciler) Name() string
  • func (r *JobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *JobReconciler) SetupWithManager(mgr ctrl.Manager) error
• type Manager
• type MediaProcessingEntityReconciler
  • func (r *MediaProcessingEntityReconciler) GetClient(ref *meta.ObjectReference) (Client, bool)
  • func (r *MediaProcessingEntityReconciler) GetManager(ref *meta.ObjectReference) (Manager, bool)
  • func (r *MediaProcessingEntityReconciler) SetupWithManager(mgr ctrl.Manager) error
• type TaskReconciler
  • func (r *TaskReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)
  • func (r *TaskReconciler) SetupWithManager(mgr ctrl.Manager) error
• type WorkflowReconciler
  • func (r *WorkflowReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)
  • func (r *WorkflowReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	MediaProcessingEntityControllerName        = "nagare-media-engine-mediaprocessingentity-controller"
	ClusterMediaProcessingEntityControllerName = "nagare-media-engine-clustermediaprocessingentity-controller"
)

const (
	JobControllerName = "nagare-media-engine-job-controller"
)

const (
	TaskControllerName = "nagare-media-engine-task-controller"
)

const (
	WorkflowControllerName = "nagare-media-engine-workflow-controller"
)

Types

type Client

type Client interface {
	client.Client

	IsRemote() bool
	IsLocal() bool
	Namespace() string
}

type JobReconciler

type JobReconciler struct {
	client.Client
	APIReader client.Reader

	Config                   enginev1.WorkflowManagerConfiguration
	Scheme                   *runtime.Scheme
	EventChannel             chan<- event.GenericEvent
	MediaProcessingEntityRef *meta.ObjectReference
}

JobReconciler reconciles Job objects

func (*JobReconciler) Name

func (r *JobReconciler) Name() string

func (*JobReconciler) Reconcile

func (r *JobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*JobReconciler) SetupWithManager

func (r *JobReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type Manager

type Manager interface {
	manager.Manager

	IsRemote() bool
	IsLocal() bool
	Namespace() string
}

type MediaProcessingEntityReconciler

type MediaProcessingEntityReconciler struct {
	client.Client
	APIReader client.Reader

	Config          enginev1.WorkflowManagerConfiguration
	Scheme          *runtime.Scheme
	LocalRESTConfig *rest.Config
	ManagerOptions  manager.Options
	JobEventChannel chan<- event.GenericEvent
	// contains filtered or unexported fields
}

MediaProcessingEntityReconciler reconciles MediaProcessingEntities and ClusterMediaProcessingEntities objects

func (*MediaProcessingEntityReconciler) GetClient

func (r *MediaProcessingEntityReconciler) GetClient(ref *meta.ObjectReference) (Client, bool)

func (*MediaProcessingEntityReconciler) GetManager

func (r *MediaProcessingEntityReconciler) GetManager(ref *meta.ObjectReference) (Manager, bool)

func (*MediaProcessingEntityReconciler) SetupWithManager

func (r *MediaProcessingEntityReconciler) SetupWithManager(mgr ctrl.Manager) error

TODO: emit Kubernetes events SetupWithManager sets up the controller with the Manager.

type TaskReconciler

type TaskReconciler struct {
	client.Client
	APIReader client.Reader

	Config                          enginev1.WorkflowManagerConfiguration
	Scheme                          *runtime.Scheme
	JobEventChannel                 <-chan event.GenericEvent
	MediaProcessingEntityReconciler *MediaProcessingEntityReconciler
	// contains filtered or unexported fields
}

TaskReconciler reconciles a Task object

func (*TaskReconciler) Reconcile

func (r *TaskReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)

func (*TaskReconciler) SetupWithManager

func (r *TaskReconciler) SetupWithManager(mgr ctrl.Manager) error

TODO: emit Kubernetes events SetupWithManager sets up the controller with the Manager.

type WorkflowReconciler

type WorkflowReconciler struct {
	client.Client
	APIReader client.Reader

	Config enginev1.WorkflowManagerConfiguration
	Scheme *runtime.Scheme
}

WorkflowReconciler reconciles a Workflow object

func (*WorkflowReconciler) Reconcile

func (r *WorkflowReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)

func (*WorkflowReconciler) SetupWithManager

func (r *WorkflowReconciler) SetupWithManager(mgr ctrl.Manager) error

TODO: emit Kubernetes events SetupWithManager sets up the controller with the Manager.