controllers

Documentation

Index

• Variables
• type PipelineReconciler
  • func (r *PipelineReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PipelineReconciler) SetupWithManager(mgr ctrl.Manager) error
• type StepReconciler
  • func (r *StepReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *StepReconciler) SetupWithManager(mgr ctrl.Manager) error

Variables

var ErrorReasons = map[string]bool{

	"ContainerCreating":          false,
	"CrashLoopBackOff":           true,
	"CreateContainerConfigError": true,
	"CreateContainerError":       true,
	"ErrImagePull":               true,
	"ImagePullBackOff":           true,
	"InvalidImageName":           true,

	"Completed":          false,
	"ContainerCannotRun": true,
	"DeadlineExceeded":   true,
	"Error":              true,
	"OOMKilled":          true,
}

Types

type PipelineReconciler

type PipelineReconciler struct {
	client.Client
	Log             logr.Logger
	Scheme          *runtime.Scheme
	ContainerKiller containerkiller.Interface
}

PipelineReconciler reconciles a Pipeline object

func (*PipelineReconciler) Reconcile

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

+kubebuilder:rbac:groups=dataflow.argoproj.io,resources=pipelines,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=dataflow.argoproj.io,resources=pipelines/status,verbs=get;update;patch +kubebuilder:rbac:groups=dataflow.argoproj.io,resources=steps,verbs=get;watch;list;create +kubebuilder:rbac:groups=,resources=configmaps,verbs=create;get;delete +kubebuilder:rbac:groups=,resources=services,verbs=create;get;delete +kubebuilder:rbac:groups=apps,resources=statefulsets,verbs=create;get;delete +kubebuilder:rbac:groups=,resources=secrets,verbs=create;get;delete

func (*PipelineReconciler) SetupWithManager

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

type StepReconciler

type StepReconciler struct {
	client.Client
	Log             logr.Logger
	Scheme          *runtime.Scheme
	Recorder        record.EventRecorder
	ContainerKiller containerkiller.Interface
}

StepReconciler reconciles a Step object

func (*StepReconciler) Reconcile

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

+kubebuilder:rbac:groups=dataflow.argoproj.io,resources=steps,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=dataflow.argoproj.io,resources=steps/status,verbs=get;update;patch +kubebuilder:rbac:groups=,resources=pods,verbs=get;watch;list;create +kubebuilder:rbac:groups=,resources=services,verbs=get;watch;list;create +kubebuilder:rbac:groups="",resources=events,verbs=create;patch

func (*StepReconciler) SetupWithManager

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