sqserv

Apr 29, 2021

Changes in this version

+ type MetricCallback func(m MetricType, val float64, inflight int)

+ type MetricType int

+ const MetricAck

+ const MetricHeartBeat

+ const MetricNack

+ const MetricPollFailure

+ const MetricReceive

+ const MetricShutdown

+ type QueueConf struct

+ Metrics MetricCallback

+ Name string

+ ReadBatch uint

+ Region string

+ type SQSServer struct

+ ErrorLog *log.Logger

+ Handler http.Handler

+ func New(conf *aws.Config, h http.Handler) (*SQSServer, error)

+ func (s *SQSServer) ListenAndServe(queues ...string) error

+ func (s *SQSServer) ListenAndServeQueues(queues ...QueueConf) error

+ func (s *SQSServer) Shutdown(maxWait time.Duration)