Versions in this module Expand all Collapse all v0 v0.0.1 Dec 29, 2021 Changes in this version + var MaxNumberOfMessage int64 = 10 + var WaitTimeSecond int64 = 20 + type Handler interface + HandleMessage func(msg *sqs.Message) error + type HandlerFunc func(msg *sqs.Message) error + func (f HandlerFunc) HandleMessage(msg *sqs.Message) error + type InvalidMessageError struct + LogMessage string + SQSMessage string + func NewInvalidMessageError(SQSMessage, logMessage string) InvalidMessageError + func (e InvalidMessageError) Error() string + type Service struct + AWSSession *session.Session + BackupFirehose *firehose.Firehose + BackupFirehoseName string + JobSQS *sqs.SQS + JobSQSURL string + func NewService(n string) (*Service, error) + func (s *Service) Backup(n string) *Service + func (s *Service) Start(h Handler)
Go to main page