sqs_api_worker

Documentation

Index

• Variables
• func GetLocalCounter() int32
• func IncrLocalCounter()
• func LogStats()
• func WaitSignal() os.Signal

Variables

var (
	QueueFactory = azsqs.NewFactory(sqs.New(session.New()), os.Getenv("AWS_ACCOUNT_ID"))
	MainQueue    = QueueFactory.RegisterQueue(&taskq.QueueOptions{
		Name:  "api-worker",
		Redis: Redis,
	})
	CountTask = taskq.RegisterTask(&taskq.TaskOptions{
		Name: "counter",
		Handler: func() error {
			IncrLocalCounter()
			return nil
		},
	})
)

var Redis = redis.NewClient(&redis.Options{
	Addr: ":6379",
})

Functions

func GetLocalCounter

func GetLocalCounter() int32

func IncrLocalCounter

func IncrLocalCounter()

func LogStats

func LogStats()

func WaitSignal

func WaitSignal() os.Signal