dbloadtester

Documentation

Index

• type Config
• type LoadTester
  • func Setup(lookoutIngesterConfig configuration.LookoutIngesterV2Configuration, ...) *LoadTester
  • func (l *LoadTester) GenerateEvents(eventsCh chan<- *utils.EventsWithIds[*armadaevents.EventSequence])
  • func (l *LoadTester) Run(ctx *armadacontext.Context) (*Results, error)
• type QueueEventGenerator
  • func NewQueueEventGenerator(queueName, jobSetName string, totalJobs, maxActiveJobs, creationBatchSize int, ...) *QueueEventGenerator
  • func (q *QueueEventGenerator) Generate(eventsCh chan<- *utils.EventsWithIds[*armadaevents.EventSequence])
• type Results

Types

type Config

type Config struct {
	TotalJobs            int
	QueueNames           []string
	TotalConcurrentJobs  int
	JobTemplateFile      string
	QueueSubmitBatchSize int
}

type LoadTester

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

func Setup

func Setup(lookoutIngesterConfig configuration.LookoutIngesterV2Configuration, testConfig Config) *LoadTester

func (*LoadTester) GenerateEvents

func (l *LoadTester) GenerateEvents(eventsCh chan<- *utils.EventsWithIds[*armadaevents.EventSequence])

GenerateEvents generates EventSequencesWithIds consisting of job and job run events onto the given channel.

func (*LoadTester) Run

func (l *LoadTester) Run(ctx *armadacontext.Context) (*Results, error)

Run performs the load test with the configuration and database provided by the loadtester

type QueueEventGenerator

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

func NewQueueEventGenerator

func NewQueueEventGenerator(queueName, jobSetName string, totalJobs, maxActiveJobs, creationBatchSize int, timeStep int64, jobTemplate *v1.PodSpec) *QueueEventGenerator

func (*QueueEventGenerator) Generate

func (q *QueueEventGenerator) Generate(eventsCh chan<- *utils.EventsWithIds[*armadaevents.EventSequence])

type Results

type Results struct {
	TotalTestDuration        time.Duration
	TotalDBInsertionDuration time.Duration
	TotalEventsProcessed     int
}