execution

Documentation

Index

• func CommandPatch(command ...string) v1beta1.PodTemplateSpec
• func RestartPatch() v1beta1.PodTemplateSpec
• func Setup(mgr manager.Manager) error
• type NamespacedTask
  • func (task NamespacedTask) GetNamespace() string
• type Option
  • func WithLogger(l logr.Logger) Option
  • func WithScheme(s *runtime.Scheme) Option
• type Reconciler
  • func NewReconciler(client client.Client, opts ...Option) *Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
• type Stack
  • func NewStack(maxSize int) *Stack
  • func (s *Stack) Empty() bool
  • func (s *Stack) Pop() v1beta1.DagTask
  • func (s *Stack) Push(task v1beta1.DagTask)

Functions

func CommandPatch

func CommandPatch(command ...string) v1beta1.PodTemplateSpec

func RestartPatch

func RestartPatch() v1beta1.PodTemplateSpec

func Setup

func Setup(mgr manager.Manager) error

Types

type NamespacedTask

type NamespacedTask struct {
	*v1beta1.DagTask
	Namespace string
}

func (NamespacedTask) GetNamespace

func (task NamespacedTask) GetNamespace() string

type Option

type Option func(r *Reconciler)

func WithLogger

func WithLogger(l logr.Logger) Option

func WithScheme

func WithScheme(s *runtime.Scheme) Option

type Reconciler

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

func NewReconciler

func NewReconciler(client client.Client, opts ...Option) *Reconciler

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

type Stack

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

func NewStack

func NewStack(maxSize int) *Stack

func (*Stack) Empty

func (s *Stack) Empty() bool

func (*Stack) Pop

func (s *Stack) Pop() v1beta1.DagTask

func (*Stack) Push

func (s *Stack) Push(task v1beta1.DagTask)