domain

Documentation

Index

• Constants
• type ArmadaApiConnectionDetails
• type JobInfo
• type JobStatus
• type JobSubmissionDescription
• type LoadTestSpecification
• type OpenIdConnectClientDetails
• type SubmissionDescription
• type WatchContext
  • func NewWatchContext() *WatchContext
  • func (context *WatchContext) GetCurrentState() map[string]*JobInfo
  • func (context *WatchContext) GetCurrentStateSummary() string
  • func (context *WatchContext) GetJobInfo(jobId string) JobInfo
  • func (context *WatchContext) GetNumberOfJobsInStates(states []JobStatus) int
  • func (context *WatchContext) ProcessEvent(event api.Event)

Constants

const (
	Submitted = "Submitted"
	Queued    = "Queued"
	Leased    = "Leased"
	Pending   = "Pending"
	Running   = "Running"
	Succeeded = "Succeeded"
	Failed    = "Failed"
	Cancelled = "Cancelled"
)

Types

type ArmadaApiConnectionDetails

type ArmadaApiConnectionDetails struct {
	ArmadaUrl     string
	Credentials   common.LoginCredentials
	OpenIdConnect OpenIdConnectClientDetails
}

type JobInfo

type JobInfo struct {
	Status JobStatus
	Job    *api.Job
}

type JobStatus

type JobStatus string

type JobSubmissionDescription

type JobSubmissionDescription struct {
	Name  string
	Count int
	Spec  *v1.PodSpec
}

type LoadTestSpecification

type LoadTestSpecification struct {
	Submissions []*SubmissionDescription
}

type OpenIdConnectClientDetails

type OpenIdConnectClientDetails struct {
	ProviderUrl string
	ClientId    string
	LocalPort   uint16
	Scopes      []string

	Username string
	Password string
}

type SubmissionDescription

type SubmissionDescription struct {
	Queue               string
	QueuePrefix         string
	JobSetPrefix        string
	Count               int
	QueuePriorityFactor float64
	Jobs                []*JobSubmissionDescription
}

type WatchContext

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

WatchContext keeps track of the current state when processing a stream of events It is not threadsafe and is expected to only ever be used in a single thread

func NewWatchContext

func NewWatchContext() *WatchContext

func (*WatchContext) GetCurrentState

func (context *WatchContext) GetCurrentState() map[string]*JobInfo

func (*WatchContext) GetCurrentStateSummary

func (context *WatchContext) GetCurrentStateSummary() string

func (*WatchContext) GetJobInfo

func (context *WatchContext) GetJobInfo(jobId string) JobInfo

func (*WatchContext) GetNumberOfJobsInStates

func (context *WatchContext) GetNumberOfJobsInStates(states []JobStatus) int

func (*WatchContext) ProcessEvent

func (context *WatchContext) ProcessEvent(event api.Event)