handlers

Documentation

Index

• Variables
• func AddLimiter(c *gin.Context)
• func CheckPoolExists(c *gin.Context)
• func CollectMetrics(apiName string) func(*gin.Context)
• func Consume(c *gin.Context)
• func CreatePushGroup(c *gin.Context)
• func Delete(c *gin.Context)
• func DeleteDeadLetter(c *gin.Context)
• func DeleteLimiter(c *gin.Context)
• func DeletePushGroup(c *gin.Context)
• func DeleteToken(c *gin.Context)
• func DestroyQueue(c *gin.Context)
• func EngineMetaInfo(c *gin.Context)
• func GetAccessLogStatus(c *gin.Context)
• func GetDeadLetterSize(c *gin.Context)
• func GetHTTPLogger(c *gin.Context) *logrus.Entry
• func GetLimiter(c *gin.Context)
• func GetPushGroup(c *gin.Context)
• func ListLimiters(c *gin.Context)
• func ListNamespacePushGroups(c *gin.Context)
• func ListPools(c *gin.Context)
• func ListPushGroups(c *gin.Context)
• func ListTokens(c *gin.Context)
• func NewToken(c *gin.Context)
• func PProf(c *gin.Context)
• func PeekDeadLetter(c *gin.Context)
• func PeekJob(c *gin.Context)
• func PeekQueue(c *gin.Context)
• func PrometheusMetrics(c *gin.Context)
• func Publish(c *gin.Context)
• func PublishBulk(c *gin.Context)
• func RespawnDeadLetter(c *gin.Context)
• func SetLimiter(c *gin.Context)
• func Setup(l *logrus.Logger)
• func SetupParamDefaults(conf *config.Config)
• func SetupQueueEngine(c *gin.Context)
• func Size(c *gin.Context)
• func Throttle(throttler *throttler.Throttler, action string) gin.HandlerFunc
• func UpdateAccessLogStatus(c *gin.Context)
• func UpdatePushGroup(c *gin.Context)
• func ValidateMultiConsume(c *gin.Context)
• func ValidateParams(c *gin.Context)
• func ValidateToken(c *gin.Context)
• func Version(c *gin.Context)
• type PerformanceMetrics

Variables

var (
	DefaultTTL     string
	DefaultDelay   string
	DefaultTries   string
	DefaultTTR     string
	DefaultTimeout string
)

Functions

func AddLimiter

func AddLimiter(c *gin.Context)

POST /token/:namespace/:token/limit

func CheckPoolExists

func CheckPoolExists(c *gin.Context)

func CollectMetrics

func CollectMetrics(apiName string) func(*gin.Context)

func Consume

func Consume(c *gin.Context)

GET /:namespace/:queue[,:queue]* @query:

• ttr: uint32
• timeout: uint32
• count: uint32

NOTE: according to RFC3986, the URL path part can contain comma(",") , so I decide to use "," as the separator of queue names

func CreatePushGroup

func CreatePushGroup(c *gin.Context)

POST /pusher/:namespace/:group

func Delete

func Delete(c *gin.Context)

DELETE /:namespace/:queue/job/:job_id

func DeleteDeadLetter

func DeleteDeadLetter(c *gin.Context)

DELETE /:namespace/:queue/deadletter Delete job(s) in the deadletter

func DeleteLimiter

func DeleteLimiter(c *gin.Context)

DELETE /token/:namespace/:token/limit

func DeletePushGroup

func DeletePushGroup(c *gin.Context)

DELETE /pusher/:namespace/:group

func DeleteToken

func DeleteToken(c *gin.Context)

DELETE /token/:namespace/:token

func DestroyQueue

func DestroyQueue(c *gin.Context)

func EngineMetaInfo

func EngineMetaInfo(c *gin.Context)

GET /info?pool= List all namespaces and queues

func GetAccessLogStatus

func GetAccessLogStatus(c *gin.Context)

GetAccessLogStatus return whether the accesslog was enabled or not GET /accesslog

func GetDeadLetterSize

func GetDeadLetterSize(c *gin.Context)

GetDeadLetterSize return the size of dead letter GET /:namespace/:queue/deadletter/size

func GetHTTPLogger

func GetHTTPLogger(c *gin.Context) *logrus.Entry

func GetLimiter

func GetLimiter(c *gin.Context)

GET /token/:namespace/:token/limit

func GetPushGroup

func GetPushGroup(c *gin.Context)

GET /pusher/:namespace/:group

func ListLimiters

func ListLimiters(c *gin.Context)

GET /limiters

func ListNamespacePushGroups

func ListNamespacePushGroups(c *gin.Context)

GET /pusher/:namespace?pool=xxx

func ListPools

func ListPools(c *gin.Context)

GET /pools/

func ListPushGroups

func ListPushGroups(c *gin.Context)

GET /pushers

func ListTokens

func ListTokens(c *gin.Context)

GET /token/:namespace

func NewToken

func NewToken(c *gin.Context)

POST /token/:namespace

func PProf

func PProf(c *gin.Context)

func PeekDeadLetter

func PeekDeadLetter(c *gin.Context)

GET /:namespace/:queue/deadletter Get the first job in the deadletter

func PeekJob

func PeekJob(c *gin.Context)

GET /:namespace/:queue/job/:job_id

func PeekQueue

func PeekQueue(c *gin.Context)

GET /:namespace/:queue/peek

func PrometheusMetrics

func PrometheusMetrics(c *gin.Context)

GET /metrics

func Publish

func Publish(c *gin.Context)

PUT /:namespace/:queue @query:

• delay: uint32
• ttl: uint32
• tries: uint16

func PublishBulk

func PublishBulk(c *gin.Context)

PUT /:namespace/:queue/bulk @query:

• delay: uint32
• ttl: uint32
• tries: uint16

func RespawnDeadLetter

func RespawnDeadLetter(c *gin.Context)

PUT /:namespace/:queue/deadletter Respawn job(s) in the deadletter

func SetLimiter

func SetLimiter(c *gin.Context)

PUT /token/:namespace/:token/limit

func Setup

func Setup(l *logrus.Logger)

func SetupParamDefaults

func SetupParamDefaults(conf *config.Config)

func SetupQueueEngine

func SetupQueueEngine(c *gin.Context)

func Size

func Size(c *gin.Context)

GET /:namespace/:queue/size

func Throttle

func Throttle(throttler *throttler.Throttler, action string) gin.HandlerFunc

func UpdateAccessLogStatus

func UpdateAccessLogStatus(c *gin.Context)

UpdateAccessLogStatus update the accesslog status POST /accesslog

func UpdatePushGroup

func UpdatePushGroup(c *gin.Context)

PUT /pusher/:namespace/:group

func ValidateMultiConsume

func ValidateMultiConsume(c *gin.Context)

func ValidateParams

func ValidateParams(c *gin.Context)

Validate namespace and queue names don't contain any illegal characters

func ValidateToken

func ValidateToken(c *gin.Context)

func Version

func Version(c *gin.Context)

GET /version

Types

type PerformanceMetrics

type PerformanceMetrics struct {
	Latencies  *prometheus.HistogramVec
	HTTPCodes  *prometheus.CounterVec
	RateLimits *prometheus.CounterVec
}