loafergo

Oct 4, 2024

Changes in this version

type Message

+ Attributes func() map[string]string

+ BackedOff func() bool

+ Backoff func(delay time.Duration)

type Router

+ VisibilityTimeout func(ctx context.Context) int32

Sep 17, 2024

Changes in this version

type Message

+ SystemAttributeByKey func(key string) string

+ SystemAttributes func() map[string]string

Sep 11, 2024

Changes in this version

type Message

+ DecodeMessage func(out any) error

Sep 10, 2024

Changes in this version

type Message

+ Message func() string

+ TimeStamp func() time.Time

Aug 14, 2024

Changes in this version

+ var ErrEmptyInput = newError("input must be filled")

+ var ErrEmptyParam = newError("required parameter is missing")

+ var ErrEmptyRequiredField = newError("required field is missing")

+ var ErrGetMessage = newError("unable to retrieve message")

+ var ErrInvalidCreds = newError("invalid aws credentials")

+ var ErrMarshal = newError("unable to marshal request")

+ var ErrMessageProcessing = newError("processing time exceeding limit")

+ var ErrNoHandler = newError("handler is nil")

+ var ErrNoRoute = newError("message received without a route")

+ var ErrNoSQSClient = newError("sqs client is nil")

+ type Config struct

+ Logger Logger

+ RetryTimeout time.Duration

+ type Error struct

+ Err string

+ func (e *Error) Context(err error) *Error

+ func (e *Error) Error() string

+ type Handler func(context.Context, Message) error

+ type Logger interface

+ Log func(...interface{})

+ type LoggerFunc func(...interface{})

+ func (f LoggerFunc) Log(args ...interface{})

+ type Manager struct

+ func NewManager(config *Config) *Manager

+ func (m *Manager) GetRoutes() []Router

+ func (m *Manager) RegisterRoute(route Router)

+ func (m *Manager) RegisterRoutes(routes []Router)

+ func (m *Manager) Run(ctx context.Context) error

+ type Message interface

+ Attribute func(key string) string

+ Body func() []byte

+ Decode func(out interface{}) error

+ Dispatch func()

+ Identifier func() string

+ Metadata func() map[string]string

+ type Router interface

+ Commit func(ctx context.Context, m Message) error

+ Configure func(ctx context.Context) error

+ GetMessages func(ctx context.Context) ([]Message, error)

+ HandlerMessage func(ctx context.Context, msg Message) error

+ WorkerPoolSize func(ctx context.Context) int32

+ type SNSClient interface

+ Publish func(ctx context.Context, params *sns.PublishInput, optFns ...func(*sns.Options)) (*sns.PublishOutput, error)

+ PublishBatch func(ctx context.Context, params *sns.PublishBatchInput, ...) (*sns.PublishBatchOutput, error)

+ type SQSClient interface

+ ChangeMessageVisibility func(ctx context.Context, params *sqs.ChangeMessageVisibilityInput, ...) (*sqs.ChangeMessageVisibilityOutput, error)

+ DeleteMessage func(ctx context.Context, params *sqs.DeleteMessageInput, ...) (*sqs.DeleteMessageOutput, error)

+ GetQueueUrl func(ctx context.Context, params *sqs.GetQueueUrlInput, ...) (*sqs.GetQueueUrlOutput, error)

+ ReceiveMessage func(ctx context.Context, params *sqs.ReceiveMessageInput, ...) (*sqs.ReceiveMessageOutput, error)