client

Documentation

Index

• Constants
• func AddArmadaApiConnectionCommandlineArgs(rootCmd *cobra.Command)
• func CreateChunkedSubmitRequests(queue string, jobSetId string, jobs []*api.JobSubmitRequestItem) []*api.JobSubmitRequest
• func CreateQueue(submitClient api.SubmitClient, queue *api.Queue) error
• func ExtractCommandlineArmadaApiConnectionDetails() *client.ApiConnectionDetails
• func LoadCommandlineArgsFromConfigFile(cfgFile string)
• func SubmitJobs(submitClient api.SubmitClient, request *api.JobSubmitRequest) (*api.JobSubmitResponse, error)
• func WatchJobSet(client api.EventClient, jobSetId string, waitForNew bool, ...)
• func WatchJobSetWithJobIdsFilter(client api.EventClient, jobSetId string, waitForNew bool, jobIds []string, ...)
• type ArmadaLoadTester
  • func NewArmadaLoadTester(connectionDetails *client.ApiConnectionDetails) *ArmadaLoadTester
  • func (apiLoadTester ArmadaLoadTester) RunSubmissionTest(spec domain.LoadTestSpecification, watchEvents bool)
• type LoadTester

Constants

const MaxJobsPerRequest = 200

Functions

func AddArmadaApiConnectionCommandlineArgs

func AddArmadaApiConnectionCommandlineArgs(rootCmd *cobra.Command)

func CreateChunkedSubmitRequests

func CreateChunkedSubmitRequests(queue string, jobSetId string, jobs []*api.JobSubmitRequestItem) []*api.JobSubmitRequest

func CreateQueue

func CreateQueue(submitClient api.SubmitClient, queue *api.Queue) error

func ExtractCommandlineArmadaApiConnectionDetails

func ExtractCommandlineArmadaApiConnectionDetails() *client.ApiConnectionDetails

func LoadCommandlineArgsFromConfigFile

func LoadCommandlineArgsFromConfigFile(cfgFile string)

func SubmitJobs

func SubmitJobs(submitClient api.SubmitClient, request *api.JobSubmitRequest) (*api.JobSubmitResponse, error)

func WatchJobSet

func WatchJobSet(client api.EventClient, jobSetId string, waitForNew bool, context context.Context, onUpdate func(*domain.WatchContext, api.Event) bool)

func WatchJobSetWithJobIdsFilter

func WatchJobSetWithJobIdsFilter(client api.EventClient, jobSetId string, waitForNew bool, jobIds []string, context context.Context, onUpdate func(*domain.WatchContext, api.Event) bool)

Types

type ArmadaLoadTester

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

func NewArmadaLoadTester

func NewArmadaLoadTester(connectionDetails *client.ApiConnectionDetails) *ArmadaLoadTester

func (ArmadaLoadTester) RunSubmissionTest

func (apiLoadTester ArmadaLoadTester) RunSubmissionTest(spec domain.LoadTestSpecification, watchEvents bool)

type LoadTester

type LoadTester interface {
	RunSubmissionTest(spec domain.LoadTestSpecification)
}