action

Documentation

Index

• type Job
  • func New(ctx context.Context, cli client.Client, meta v1alpha1.ActionMeta, ...) (*Job, error)
  • func (j *Job) AllowConcurrency() bool
  • func (j *Job) ID() string
  • func (j *Job) Run(ctx context.Context) error
  • func (j *Job) Type() string

Types

type Job

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

Job is the type of executor job.

func New

func New(ctx context.Context, cli client.Client, meta v1alpha1.ActionMeta, contextData map[string]interface{}) (*Job, error)

New creates a new job. It will fetch cached Action instance from Registry using provided ActionMeta. sourceType and event will be passed to the Action.Run method.

func (*Job) AllowConcurrency

func (j *Job) AllowConcurrency() bool

AllowConcurrency returns whether the job allows concurrency.

func (*Job) ID

func (j *Job) ID() string

ID return job id

func (*Job) Run

func (j *Job) Run(ctx context.Context) error

Run execute action

func (*Job) Type

func (j *Job) Type() string

Type return job type