Documentation
¶
Index ¶
- Constants
- Variables
- func MustNewMinuteWindow() *average.SlidingWindow
- func RedisKeyFromQueueID(qid QueueID) string
- func WindowTotal(window *average.SlidingWindow, second time.Duration) int64
- type CallByQueue
- type ExceedLimitError
- type Limiter
- type Pod
- func (pod *Pod) AddRequest(rawReq *request.RawRequest) (Result, error)
- func (pod *Pod) ClearQueue(qid QueueID) (Result, error)
- func (pod *Pod) DeleteQueue(qid QueueID) (Result, error)
- func (pod *Pod) ForceSyncQueue(qid QueueID) (Result, error)
- func (pod *Pod) GetRequest(qid QueueID) (req *request.Request, err error)
- func (pod *Pod) Info() (result Result, err error)
- func (pod *Pod) OnStart() (err error)
- func (pod *Pod) OnStop() (err error)
- func (pod *Pod) Pause() (Result, error)
- func (pod *Pod) PauseQueue(qid QueueID) (Result, error)
- func (pod *Pod) QueueInfo(qid QueueID) (Result, error)
- func (pod *Pod) Queues(k int) (Result, error)
- func (pod *Pod) Resume() (Result, error)
- func (pod *Pod) ResumeQueue(qid QueueID) (Result, error)
- func (pod *Pod) SyncQueue(qid QueueID) (Result, error)
- func (pod *Pod) ViewQueue(qid QueueID, start int64, end int64) (Result, error)
- func (pod *Pod) ViewQueues(k int, start int, status QueueStatus) (Result, error)
- type Queue
- func (queue *Queue) Clear() (result Result, err error)
- func (queue *Queue) Dequeuing() int64
- func (queue *Queue) Get() (req *request.Request, qsize int64, err error)
- func (queue *Queue) Idle() bool
- func (queue *Queue) Info() Result
- func (queue *Queue) Put(request *request.Request) (result Result, err error)
- func (queue *Queue) QueueSize() int64
- func (queue *Queue) Queuing() int64
- func (queue *Queue) SetStatus(status QueueStatus) (err error)
- func (queue *Queue) SetStatusOn(newStatus QueueStatus, on QueueStatus) (err error)
- func (queue *Queue) Status() QueueStatus
- func (queue *Queue) Sync() (result Result, err error)
- func (queue *Queue) View(start int64, end int64) (result Result, err error)
- type QueueBox
- func (box *QueueBox) AddRequest(qid QueueID, req *request.Request) (result Result, err error)
- func (box *QueueBox) ClearQueue(qid QueueID) (Result, error)
- func (box *QueueBox) DeleteIdleQueue(qid QueueID) error
- func (box *QueueBox) DeleteQueue(qid QueueID) (Result, error)
- func (box *QueueBox) GetRequest(qid QueueID) (req *request.Request, err error)
- func (box *QueueBox) Info() (result Result)
- func (box *QueueBox) LoadPaused() (err error)
- func (box *QueueBox) LoadQueues() (err error)
- func (box *QueueBox) QueueInfo(qid QueueID) (Result, error)
- func (box *QueueBox) Queues(k int) Result
- func (box *QueueBox) QueuesNum(status QueueStatus) int
- func (box *QueueBox) SetStatus(qid QueueID, newStatus QueueStatus) (Result, error)
- func (box *QueueBox) SyncQueue(qid QueueID, force bool) (result Result, err error)
- func (box *QueueBox) ViewQueue(qid QueueID, start int64, end int64) (result Result, err error)
- func (box *QueueBox) ViewQueues(k int, start int, status QueueStatus) Result
- type QueueID
- type QueueNotExistError
- type QueueStatus
- type Result
- type ResultAndErrorFunc
- type Stats
- type Status
- type UnavailableError
Constants ¶
const RedisConfigKey = "rq:pod:conf"
RedisConfigKey TODO
const RedisPausedQueuesKey = "rq:pod:paused"
RedisPausedQueuesKey TODO
const RedisQueueKeyPrefix = "rq:q:"
RedisQueueKeyPrefix TODO
Variables ¶
var QueueStatusList = []QueueStatus{ QueueInit, QueueWorking, QueuePaused, QueueRemoved, }
QueueStatusList TODO
var QueueStatusMap = map[string]QueueStatus{ utils.Text(QueueInit): QueueInit, utils.Text(QueueWorking): QueueWorking, utils.Text(QueuePaused): QueuePaused, utils.Text(QueueRemoved): QueueRemoved, }
QueueStatusMap TODO
var StatusMap = map[string]Status{ utils.Text(Init): Init, utils.Text(Preparing): Preparing, utils.Text(Working): Working, utils.Text(Paused): Paused, utils.Text(Stopping): Stopping, utils.Text(Stopped): Stopped, }
StatusMap TODO
Functions ¶
func MustNewMinuteWindow ¶ added in v0.0.8
func MustNewMinuteWindow() *average.SlidingWindow
MustNewMinuteWindow TODO
func WindowTotal ¶ added in v0.0.8
func WindowTotal(window *average.SlidingWindow, second time.Duration) int64
WindowTotal TODO
Types ¶
type ExceedLimitError ¶ added in v0.0.3
type ExceedLimitError string
ExceedLimitError TODO
func (ExceedLimitError) Error ¶ added in v0.0.3
func (e ExceedLimitError) Error() string
type Pod ¶
type Pod struct { Client *redis.Client Process *process.Process *sync.RWMutex // contains filtered or unexported fields }
Pod TODO
func (*Pod) AddRequest ¶
func (pod *Pod) AddRequest(rawReq *request.RawRequest) (Result, error)
AddRequest TODO
func (*Pod) ForceSyncQueue ¶
ForceSyncQueue TODO
func (*Pod) GetRequest ¶
GetRequest TODO
func (*Pod) ViewQueues ¶ added in v0.0.5
ViewQueues TODO
type Queue ¶
type Queue struct { ID QueueID // contains filtered or unexported fields }
Queue TODO
func (*Queue) SetStatus ¶
func (queue *Queue) SetStatus(status QueueStatus) (err error)
SetStatus TODO
func (*Queue) SetStatusOn ¶ added in v0.0.14
func (queue *Queue) SetStatusOn(newStatus QueueStatus, on QueueStatus) (err error)
SetStatusOn TODO
type QueueBox ¶
QueueBox TODO
func (*QueueBox) AddRequest ¶ added in v0.0.8
AddRequest TODO
func (*QueueBox) ClearQueue ¶ added in v0.0.8
ClearQueue TODO
func (*QueueBox) DeleteIdleQueue ¶ added in v0.0.8
DeleteIdleQueue TODO
func (*QueueBox) DeleteQueue ¶ added in v0.0.8
DeleteQueue TODO
func (*QueueBox) GetRequest ¶ added in v0.0.8
GetRequest TODO
func (*QueueBox) LoadPaused ¶ added in v0.0.12
LoadPaused TODO
func (*QueueBox) LoadQueues ¶ added in v0.0.8
LoadQueues TODO
func (*QueueBox) QueuesNum ¶ added in v0.0.8
func (box *QueueBox) QueuesNum(status QueueStatus) int
QueuesNum TODO
func (*QueueBox) SetStatus ¶ added in v0.0.12
func (box *QueueBox) SetStatus(qid QueueID, newStatus QueueStatus) (Result, error)
SetStatus TODO
func (*QueueBox) ViewQueues ¶ added in v0.0.5
func (box *QueueBox) ViewQueues(k int, start int, status QueueStatus) Result
ViewQueues TODO
type QueueID ¶
type QueueID struct { Host string `json:"host"` Port string `json:"port"` Scheme string `json:"scheme"` }
QueueID TODO
func QueueIDFromRedisKey ¶
QueueIDFromRedisKey TODO
func QueueIDFromRequest ¶
QueueIDFromRequest TODO
func QueueIDFromString ¶ added in v0.0.12
QueueIDFromString TODO
type QueueNotExistError ¶
type QueueNotExistError string
QueueNotExistError TODO
func (QueueNotExistError) Error ¶
func (e QueueNotExistError) Error() string
type QueueStatus ¶
type QueueStatus int
QueueStatus type
const ( QueueInit QueueStatus // init QueueWorking // working QueuePaused // paused QueueRemoved // removed )
QueueStatus enum
func (QueueStatus) MarshalJSON ¶ added in v0.0.16
func (s QueueStatus) MarshalJSON() ([]byte, error)
MarshalJSON TODO
func (*QueueStatus) UnmarshalJSON ¶ added in v0.0.16
func (s *QueueStatus) UnmarshalJSON(b []byte) error
UnmarshalJSON TODO
type ResultAndErrorFunc ¶ added in v0.0.12
ResultAndErrorFunc TODO
type Stats ¶
type Stats struct {
// contains filtered or unexported fields
}
Stats TODO
func (*Stats) IncrRequestNum ¶
IncrRequestNum TODO
type Status ¶
type Status int
Status type
const ( Init Status // init Preparing // preparing Working // working Paused // paused Stopping //stopping Stopped //stopped )
Status enum
func (Status) MarshalJSON ¶ added in v0.0.16
MarshalJSON TODO
func (*Status) UnmarshalJSON ¶ added in v0.0.16
UnmarshalJSON TODO
type UnavailableError ¶
type UnavailableError string
UnavailableError TODO
func (UnavailableError) Error ¶
func (e UnavailableError) Error() string