runner

Documentation

Index

• func GetStrategyForNode(node *Node) (ExecutionStrategy, error)
• type AllJobRunner
  • func (r *AllJobRunner) Run(job *domain.Job) error
• type AnyJobRunner
  • func (r *AnyJobRunner) Run(job *domain.Job) error
• type DispatchingRunner
  • func NewDispatchingRunner(nodes *container.NodeContainer, storage storage.StorageBackend, ...) *DispatchingRunner
  • func (d *DispatchingRunner) Run(job *domain.Job) error
• type GenericJobRunner
• type HealthChecker
  • func NewHealthChecker(config HealthCheckerConfiguration) HealthChecker
• type HealthCheckerConfiguration
• type JobRunner
  • func NewAllJobRunner(nodes *container.NodeContainer, storage storage.StorageBackend, ...) JobRunner
  • func NewAnyJobRunner(nodes *container.NodeContainer, storage storage.StorageBackend, ...) JobRunner
• type LocalExecutionStrategy
  • func (s *LocalExecutionStrategy) ExecuteCommand(job *domain.Job, report *domain.RunReportItem) error
  • func (s *LocalExecutionStrategy) HealthCheck() error
• type NodeDownError
  • func NewNodeDownError(node *Node, reason string, real error) NodeDownError
  • func (e NodeDownError) Error() string
• type NullExecutionStrategy
  • func (n *NullExecutionStrategy) ExecuteCommand(_ *Job, _ *RunReportItem) error
  • func (n *NullExecutionStrategy) HealthCheck() error
• type SshExecutionStrategy
  • func NewSshExecutionStrategy(node *Node) (*SshExecutionStrategy, error)
  • func (s *SshExecutionStrategy) ExecuteCommand(job *Job, report *RunReportItem) error
  • func (s *SshExecutionStrategy) HealthCheck() error

Functions

func GetStrategyForNode

func GetStrategyForNode(node *Node) (ExecutionStrategy, error)

Types

type AllJobRunner

type AllJobRunner GenericJobRunner

func (*AllJobRunner) Run

func (r *AllJobRunner) Run(job *domain.Job) error

type AnyJobRunner

type AnyJobRunner GenericJobRunner

func (*AnyJobRunner) Run

func (r *AnyJobRunner) Run(job *domain.Job) error

type DispatchingRunner

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

func NewDispatchingRunner

func NewDispatchingRunner(nodes *container.NodeContainer, storage storage.StorageBackend, health HealthChecker) *DispatchingRunner

func (*DispatchingRunner) Run

func (d *DispatchingRunner) Run(job *domain.Job) error

type GenericJobRunner

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

type HealthChecker

type HealthChecker interface {
	ScheduleHealthCheck(node *domain.Node)
}

func NewHealthChecker

func NewHealthChecker(config HealthCheckerConfiguration) HealthChecker

type HealthCheckerConfiguration

type HealthCheckerConfiguration interface {
	HealthCheckInterval() time.Duration
}

type JobRunner

type JobRunner interface {
	Run(job *domain.Job) error
}

func NewAllJobRunner

func NewAllJobRunner(nodes *container.NodeContainer, storage storage.StorageBackend, health HealthChecker) JobRunner

func NewAnyJobRunner

func NewAnyJobRunner(nodes *container.NodeContainer, storage storage.StorageBackend, health HealthChecker) JobRunner

type LocalExecutionStrategy

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

func (*LocalExecutionStrategy) ExecuteCommand

func (s *LocalExecutionStrategy) ExecuteCommand(job *domain.Job, report *domain.RunReportItem) error

func (*LocalExecutionStrategy) HealthCheck

func (s *LocalExecutionStrategy) HealthCheck() error

type NodeDownError

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

func NewNodeDownError

func NewNodeDownError(node *Node, reason string, real error) NodeDownError

func (NodeDownError) Error

func (e NodeDownError) Error() string

type NullExecutionStrategy

type NullExecutionStrategy struct{}

func (*NullExecutionStrategy) ExecuteCommand

func (n *NullExecutionStrategy) ExecuteCommand(_ *Job, _ *RunReportItem) error

func (*NullExecutionStrategy) HealthCheck

func (n *NullExecutionStrategy) HealthCheck() error

type SshExecutionStrategy

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

func NewSshExecutionStrategy

func NewSshExecutionStrategy(node *Node) (*SshExecutionStrategy, error)

func (*SshExecutionStrategy) ExecuteCommand

func (s *SshExecutionStrategy) ExecuteCommand(job *Job, report *RunReportItem) error

func (*SshExecutionStrategy) HealthCheck

func (s *SshExecutionStrategy) HealthCheck() error