common

package

v0.15.4 Latest Latest Go to latest Published: Apr 10, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

RestRequestRoutes is the routes for Rest Request

func (r *RestRequestRoutes) AddToRoutes(routes []Route)

AddToRoutes adds more routes

func (r *RestRequestRoutes) Routes() []Route

Routes gets routes

type Route struct {
	Name        string
	Method      string
	Pattern     string
	HandlerFunc http.HandlerFunc
}

Route defines a rest api

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

TaskQueue is rate limiting queue for task

func NewTaskQueue(taskName string, maxRetries int) *TaskQueue

NewTaskQueue creates a queue maxRetries limit retry number, no limit if maxRetries=0 1s, 2s, 4s, 8s, 16s, 32s, 60s, 60s, 60s, ...

func (q *TaskQueue) Add(task string)

Add a task into the queue

func (q *TaskQueue) AddRateLimited(task string)

AddRateLimited a task

func (q *TaskQueue) Done(task string)

Done completes the task and remove from the queue

func (q *TaskQueue) Forget(task string)

Forget cleanup the rate limit on the task

func (q *TaskQueue) Get() (string, bool)

Get a task from queue. It's a blocking call

func (q *TaskQueue) NumRequeues(task string) int

NumRequeues get number of task retried

func (q *TaskQueue) Shutdown()

Shutdown the queue