execution

Documentation

Index

• type ExecutionHandler
  • func NewExecutionHandler(auditor audit.Auditor, store storage.Store, executioner Executioner) ExecutionHandler
• type Executioner
  • func NewExecutioner(kubeClient kubernetes.Client, metadataStore metadata.Store, ...) Executioner
• type Job
• type MockExecutioner
  • func (m *MockExecutioner) Execute(jobExecutionAuditLog *postgres.JobsExecutionAuditLog, jobName string, ...) (string, error)

Types

type ExecutionHandler

type ExecutionHandler interface {
	Handle() http.HandlerFunc
	Status() http.HandlerFunc
	// contains filtered or unexported methods
}

func NewExecutionHandler

func NewExecutionHandler(auditor audit.Auditor, store storage.Store, executioner Executioner) ExecutionHandler

type Executioner

type Executioner interface {
	Execute(*postgres.JobsExecutionAuditLog, string, map[string]string) (string, error)
}

func NewExecutioner

func NewExecutioner(kubeClient kubernetes.Client, metadataStore metadata.Store, secretsStore secrets.Store) Executioner

type Job

type Job struct {
	Name        string            `json:"name"`
	Args        map[string]string `json:"args"`
	CallbackURL string            `json:"callback_url"`
}

type MockExecutioner

type MockExecutioner struct {
	mock.Mock
}

func (*MockExecutioner) Execute

func (m *MockExecutioner) Execute(jobExecutionAuditLog *postgres.JobsExecutionAuditLog, jobName string, jobArgs map[string]string) (string, error)