scenario

Documentation

Index

• type Job
• type Payload
• type Scenario
• type ScenarioReader
  • func NewScenario(seed int64, scenario *Scenario) *ScenarioReader
  • func (s *ScenarioReader) NextJob() *Job

Types

type Job

type Job struct {
	Payload    *Payload `json:"payload"`
	RunAfter   uint     `json:"run_after"`
	MaxRetries uint     `json:"max_retries"`
	Timeout    uint     `json:"timeout"`
}

type Payload

type Payload struct {
	Id           uint   `json:"id"`
	CycleTime    uint   `json:"cycle_time"`
	RequestCount uint   `json:"request_count"`
	FailCount    uint   `json:"fail_count"`
	Value        string `json:"value"`
}

type Scenario

type Scenario struct {
	QueueName       string `json:"queue_name"`
	TotalJobs       uint   `json:"total_jobs"`
	JobConcurrency  uint   `json:"job_concurrency"`
	MaxWorkers      uint   `json:"max_workers"`
	PollingInterval uint   `json:"polling_interval"`
	ErrorRate       uint   `json:"error_rate"`
	MaxPayloadSize  uint   `json:"max_payload_size"`
	MaxRetries      uint   `json:"max_retries"`
	MaxRunAfter     uint   `json:"max_run_after"`
	MaxCycleTime    uint   `json:"max_cycle_time"`
}

type ScenarioReader

type ScenarioReader struct {
	*Scenario
	// contains filtered or unexported fields
}

func NewScenario

func NewScenario(seed int64, scenario *Scenario) *ScenarioReader

func (*ScenarioReader) NextJob

func (s *ScenarioReader) NextJob() *Job