worker

Documentation

Index

• Variables
• type Handler
• type HandlerFunc
  • func (f HandlerFunc) HandleMessage(msg *sqs.Message) error
• type InvalidMessageError
  • func NewInvalidMessageError(SQSMessage, logMessage string) InvalidMessageError
  • func (e InvalidMessageError) Error() string
• type Service
  • func NewService(n string) (*Service, error)
  • func (s *Service) Backup(n string) *Service
  • func (s *Service) Start(h Handler)

Variables

var (
	// MaxNumberOfMessage at one poll
	MaxNumberOfMessage int64 = 10
	// WaitTimeSecond for each poll
	WaitTimeSecond int64 = 20
)

Exported variables

Types

type Handler

type Handler interface {
	HandleMessage(msg *sqs.Message) error
}

Handler interface

type HandlerFunc

type HandlerFunc func(msg *sqs.Message) error

HandlerFunc is used to define the Handler that is run on for each message

func (HandlerFunc) HandleMessage

func (f HandlerFunc) HandleMessage(msg *sqs.Message) error

HandleMessage is used for the actual execution of each message

type InvalidMessageError

type InvalidMessageError struct {
	SQSMessage string
	LogMessage string
}

InvalidMessageError for message that can't be processed and should be deleted

func NewInvalidMessageError

func NewInvalidMessageError(SQSMessage, logMessage string) InvalidMessageError

NewInvalidMessageError to create new error for messages that should be deleted

func (InvalidMessageError) Error

func (e InvalidMessageError) Error() string

type Service

type Service struct {
	AWSSession         *session.Session
	BackupFirehose     *firehose.Firehose
	BackupFirehoseName string
	JobSQS             *sqs.SQS
	JobSQSURL          string
}

Service works through the job SQS queue

func NewService

func NewService(n string) (*Service, error)

NewService creates new worker service

func (*Service) Backup

func (s *Service) Backup(n string) *Service

Backup to set up Firehose backup option

func (*Service) Start

func (s *Service) Start(h Handler)

Start starts the polling and will continue polling till the application is forcibly stopped