queue

Documentation

Index

• func Aggregate(awsConfig *aws.Config, queueURL string, totalExpectedRequests int, ...) chan RegionsAggData
• type AggData
  • func SumRegionResults(regionData *RegionsAggData) *AggData
• type DummyAdaptor
  • func NewDummyAdaptor(queueURL string) *DummyAdaptor
  • func (adaptor DummyAdaptor) SendResult(result AggData)
• type RegionsAggData
• type Result
• type SQSAdaptor
  • func NewSQSAdapter(awsConfig *aws.Config, queueURL string) *SQSAdaptor
  • func (adaptor SQSAdaptor) Receive() *AggData
  • func (adaptor SQSAdaptor) SendResult(result AggData)

Functions

func Aggregate

func Aggregate(awsConfig *aws.Config, queueURL string, totalExpectedRequests int, lambdasByRegion int) chan RegionsAggData

Aggregate listens for results and sends totals, closing the channel when done

Types

type AggData

type AggData struct {
	TotalReqs            int            `json:"total-reqs"`
	TotalTimedOut        int            `json:"total-timed-out"`
	TotalConnectionError int            `json:"total-conn-error"`
	AveTimeToFirst       int64          `json:"ave-time-to-first"`
	TotBytesRead         int            `json:"tot-bytes-read"`
	Statuses             map[string]int `json:"statuses"`
	AveTimeForReq        int64          `json:"ave-time-for-req"`
	AveReqPerSec         float32        `json:"ave-req-per-sec"`
	AveKBytesPerSec      float32        `json:"ave-kbytes-per-sec"`
	Slowest              int64          `json:"slowest"`
	Fastest              int64          `json:"fastest"`
	Region               string         `json:"region"`
	FatalError           string         `json:"fatal-error"`
	Finished             bool           `json:"finished"`
	FinishedLambdas      int            `json:"finished-lambdas"`
}

AggData type

func SumRegionResults

func SumRegionResults(regionData *RegionsAggData) *AggData

SumRegionResults adds all the results together

type DummyAdaptor

type DummyAdaptor struct {
	QueueURL string
}

DummyAdaptor is used to send messages to the screen for testing

func NewDummyAdaptor

func NewDummyAdaptor(queueURL string) *DummyAdaptor

NewDummyAdaptor returns a new sqs adator object

func (DummyAdaptor) SendResult

func (adaptor DummyAdaptor) SendResult(result AggData)

SendResult prints the result

type RegionsAggData

type RegionsAggData struct {
	Regions               map[string]AggData
	TotalExpectedRequests int
	// contains filtered or unexported fields
}

RegionsAggData type

type Result

type Result struct {
	Time             string `json:"time"`
	Host             string `json:"host"`
	Type             string `json:"type"`
	Status           int    `json:"status"`
	ElapsedFirstByte int64  `json:"elapsed-first-byte"`
	ElapsedLastByte  int64  `json:"elapsed-last-byte"`
	Elapsed          int64  `json:"elapsed"`
	Bytes            int    `json:"bytes"`
	State            string `json:"state"`
	Instance         string `json:"instance"`
}

Result test result

type SQSAdaptor

type SQSAdaptor struct {
	Client   *sqs.SQS
	QueueURL string
}

SQSAdaptor is used to send messages to the queue

func NewSQSAdapter

func NewSQSAdapter(awsConfig *aws.Config, queueURL string) *SQSAdaptor

NewSQSAdapter returns a new sqs adator object

func (SQSAdaptor) Receive

func (adaptor SQSAdaptor) Receive() *AggData

Receive a result, or timeout in 1 second

func (SQSAdaptor) SendResult

func (adaptor SQSAdaptor) SendResult(result AggData)

SendResult adds a result to the queue