statemachine

Documentation

Index

• type Executor
• type SFNExecutor
  • func NewSFNExecutor(cfg *config.Config, sess *session.Session) *SFNExecutor
  • func (sfne *SFNExecutor) RunningForAgent(agentName string) (int, error)
  • func (sfne *SFNExecutor) StartExecution(agentName string, job *api.Job, jsonData []byte) error

Types

type Executor

type Executor interface {
	RunningForAgent(agentName string) (int, error)
	StartExecution(agentName string, job *api.Job, jsonData []byte) error
}

Executor run background jobs to track a build job

type SFNExecutor

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

SFNExecutor run jobs in step functions

func NewSFNExecutor

func NewSFNExecutor(cfg *config.Config, sess *session.Session) *SFNExecutor

NewSFNExecutor create a new step function executor

func (*SFNExecutor) RunningForAgent

func (sfne *SFNExecutor) RunningForAgent(agentName string) (int, error)

RunningForAgent can we run anymore jobs for a given agent with a max of 1 concurrent job per agent

func (*SFNExecutor) StartExecution

func (sfne *SFNExecutor) StartExecution(agentName string, job *api.Job, jsonData []byte) error

StartExecution start a step function execution