README
¶
taskq example using SQS backend
The example requires AWS_ACCOUNT_ID, AWS_ACCESS_KEY_ID, and AWS_SECRET_ACCESS_KEY environment
variables.
First, start the consumer:
go run consumer/main.go
Then, start the producer:
go run producer/main.go
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
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 }, }) )
View Source
var Redis = redis.NewClient(&redis.Options{
Addr: ":6379",
})
Functions ¶
func GetLocalCounter ¶
func GetLocalCounter() int32
func IncrLocalCounter ¶
func IncrLocalCounter()
func WaitSignal ¶
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.