scheduler

Documentation

Overview

Package scheduler provides default implementation for basic scheduler tasks.

Index

• type FakeAction
  • func (f *FakeAction) CanPause() bool
  • func (f *FakeAction) CanStop() bool
  • func (f *FakeAction) GetName() string
  • func (f *FakeAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error
  • func (f *FakeAction) ProvidesProgress() bool
  • func (f *FakeAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (jobs.ActionMessage, error)
• type FakeUsersAction
  • func (f *FakeUsersAction) CanPause() bool
  • func (f *FakeUsersAction) CanStop() bool
  • func (f *FakeUsersAction) GetName() string
  • func (f *FakeUsersAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error
  • func (f *FakeUsersAction) ProvidesProgress() bool
  • func (f *FakeUsersAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (jobs.ActionMessage, error)
• type PruneJobsAction
  • func (c *PruneJobsAction) GetName() string
  • func (c *PruneJobsAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error
  • func (c *PruneJobsAction) Run(ctx context.Context, channels *actions.RunnableChannels, ...) (jobs.ActionMessage, error)

Types

type FakeAction

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

func (*FakeAction) CanPause

func (f *FakeAction) CanPause() bool

Implement ControllableAction

func (*FakeAction) CanStop

func (f *FakeAction) CanStop() bool

Implement ControllableAction

func (*FakeAction) GetName

func (f *FakeAction) GetName() string

GetName returns this action unique identifier

func (*FakeAction) Init

func (f *FakeAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error

Init passes parameters to the action

func (*FakeAction) ProvidesProgress

func (f *FakeAction) ProvidesProgress() bool

ProvidesProgress mocks ProgressProviderAction interface method

func (*FakeAction) Run

func (f *FakeAction) Run(ctx context.Context, channels *actions.RunnableChannels, input jobs.ActionMessage) (jobs.ActionMessage, error)

Run the actual action code

type FakeUsersAction

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

func (*FakeUsersAction) CanPause

func (f *FakeUsersAction) CanPause() bool

Implement ControllableAction

func (*FakeUsersAction) CanStop

func (f *FakeUsersAction) CanStop() bool

Implement ControllableAction

func (*FakeUsersAction) GetName

func (f *FakeUsersAction) GetName() string

GetName returns this action unique identifier

func (*FakeUsersAction) Init

func (f *FakeUsersAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error

Init passes parameters to the action

func (*FakeUsersAction) ProvidesProgress

func (f *FakeUsersAction) ProvidesProgress() bool

ProvidesProgress mocks ProgressProviderAction interface method

func (*FakeUsersAction) Run

func (f *FakeUsersAction) Run(ctx context.Context, channels *actions.RunnableChannels, input jobs.ActionMessage) (jobs.ActionMessage, error)

Run the actual action code

type PruneJobsAction

type PruneJobsAction struct{}

func (*PruneJobsAction) GetName

func (c *PruneJobsAction) GetName() string

GetName returns this action unique identifier

func (*PruneJobsAction) Init

func (c *PruneJobsAction) Init(job *jobs.Job, cl client.Client, action *jobs.Action) error

Init passes parameters to the action

func (*PruneJobsAction) Run

func (c *PruneJobsAction) Run(ctx context.Context, channels *actions.RunnableChannels, input jobs.ActionMessage) (jobs.ActionMessage, error)

Run the actual action code