Versions in this module Expand all Collapse all v0 v0.22.0 Dec 23, 2021 Changes in this version + const CommandCallbackMessage + const CommandDeployNamespace + const CommandRestartNamespace + const CommandScheduleDeployment + const CommandUpdateDeployment + const MessageAttributeCommand + const MessageAttributeID + const MessageAttributeReqID + func GetLogger(ctx context.Context) *zap.Logger + type Config struct + MaxNumberOfMessage int64 + QueueURL string + VisibilityTimeout int64 + WaitTimeSecond int64 + type Handler interface + HandleMessage func(ctx context.Context, msg *M) error + type HandlerFunc func(ctx context.Context, msg *M) error + func (f HandlerFunc) HandleMessage(ctx context.Context, msg *M) error + type M struct + Body json.Object + Command string + DedupeID string + GroupID string + ID uuid.UUID + MessageID string + ReceiptHandle string + type Q struct + func NewQ(sess *session.Session, config Config) *Q + func (q *Q) Delete(ctx context.Context, m *M) error + func (q *Q) Message(ctx context.Context, m *M) error + func (q *Q) Receive(ctx context.Context) ([]*mContext, error) + type Worker struct + func NewWorker(name string, q *Q, timeout time.Duration) *Worker + func (worker *Worker) DeleteMessage(ctx context.Context, m *M) error + func (worker *Worker) Message(ctx context.Context, qUrl string, m *M) error + func (worker *Worker) Start(h Handler) + func (worker *Worker) Stop()
Go to main page