queue

Documentation

Index

• Constants
• func GetLogger(ctx context.Context) *zap.Logger
• type Config
• type Handler
• type HandlerFunc
  • func (f HandlerFunc) HandleMessage(ctx context.Context, msg *M) error
• type M
• type Q
  • 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
  • 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()

Constants

const (
	CommandScheduleDeployment string = "api-schedule-deployment"
	CommandUpdateDeployment   string = "api-update-deployment"
	CommandCallbackMessage    string = "api-callback-message"
)

API Queue Commands

const (
	CommandDeployNamespace string = "sch-deploy-namespace"
	// CommandRestartNamespace is the command used for scheduling a service restart in a namespace
	CommandRestartNamespace string = "sch-restart-namespace"
)

Scheduler Queue Commands

const (
	MessageAttributeReqID   string = "x_req_id"
	MessageAttributeCommand string = "eve_cmd"
	MessageAttributeID      string = "eve_id"
)

Functions

func GetLogger

func GetLogger(ctx context.Context) *zap.Logger

Types

type Config

type Config struct {
	MaxNumberOfMessage int64  `split_words:"true" default:"10"`
	QueueURL           string `split_words:"true" required:"true"`
	WaitTimeSecond     int64  `split_words:"true" default:"20"`
	VisibilityTimeout  int64  `split_words:"true" default:"3600"`
}

Config struct

type Handler

type Handler interface {
	HandleMessage(ctx context.Context, msg *M) error
}

type HandlerFunc

type HandlerFunc func(ctx context.Context, msg *M) error

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

func (HandlerFunc) HandleMessage

func (f HandlerFunc) HandleMessage(ctx context.Context, msg *M) error

HandleMessage wraps a function for handling sqs messages

type M

type M struct {
	ID            uuid.UUID
	GroupID       string
	Body          json.Object
	ReceiptHandle string
	MessageID     string
	Command       string
	DedupeID      string
}

type Q

type Q struct {
	// contains filtered or unexported fields
}

func NewQ

func NewQ(sess *session.Session, config Config) *Q

func (*Q) Delete

func (q *Q) Delete(ctx context.Context, m *M) error

func (*Q) Message

func (q *Q) Message(ctx context.Context, m *M) error

func (*Q) Receive

func (q *Q) Receive(ctx context.Context) ([]*mContext, error)

type Worker

type Worker struct {
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(name string, q *Q, timeout time.Duration) *Worker

func (*Worker) DeleteMessage

func (worker *Worker) DeleteMessage(ctx context.Context, m *M) error

func (*Worker) Message

func (worker *Worker) Message(ctx context.Context, qUrl string, m *M) error

func (*Worker) Start

func (worker *Worker) Start(h Handler)

func (*Worker) Stop

func (worker *Worker) Stop()