Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

queue

package

Go to main page

Versions in this module

v1

v1.4.1

May 5, 2017

Changes in this version

type SQSAdaptor

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

v1.4.0

May 2, 2017

Changes in this version

type AggData

+ Finished bool

+ FinishedLambdas int

v1.3.0

Mar 3, 2017

v1.2.0

Oct 6, 2016

Changes in this version

+ func Aggregate(awsConfig *aws.Config, queueURL string, totalExpectedRequests uint) chan RegionsAggData

+ type AggData struct

+ AveKBytesPerSec float32

+ AveReqPerSec float32

+ AveTimeForReq int64

+ AveTimeToFirst int64

+ Fastest int64

+ FatalError string

+ Region string

+ Slowest int64

+ Statuses map[string]int

+ TotBytesRead int

+ TotalConnectionError int

+ TotalReqs int

+ TotalTimedOut int

+ func SumRegionResults(regionData *RegionsAggData) *AggData

+ type DummyAdaptor struct

+ QueueURL string

+ func NewDummyAdaptor(queueURL string) *DummyAdaptor

+ func (adaptor DummyAdaptor) SendResult(result AggData)

+ type RegionsAggData struct

+ Regions map[string]AggData

+ TotalExpectedRequests uint

+ type Result struct

+ Bytes int

+ Elapsed int64

+ ElapsedFirstByte int64

+ ElapsedLastByte int64

+ Host string

+ Instance string

+ State string

+ Status int

+ Time string

+ Type string

+ type SQSAdaptor struct

+ Client *sqs.SQS

+ QueueURL string

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

+ func (adaptor SQSAdaptor) Receive() *AggData

+ func (adaptor SQSAdaptor) SendResult(result AggData)