requestq

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 6, 2020 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const QueueNotExist = QueueNotExistError("")

QueueNotExist TODO

Variables

This section is empty.

Functions

func LoadQueues 

func LoadQueues(rq *RQ) (err error)

LoadQueues TODO

func RedisKeyFromQueueID 

func RedisKeyFromQueueID(qid QueueID) string

RedisKeyFromQueueID TODO

Types

type CallByQueueID 

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

CallByQueueID TODO

func NewCallByQueueIDOperation 

func NewCallByQueueIDOperation(rq *RQ, f FuncWithQueueID) *CallByQueueID

NewCallByQueueIDOperation TODO

func (*CallByQueueID) Operate 

func (opt *CallByQueueID) Operate(id QueueID) (result Result, err error)

Operate TODO

type FuncWithQueueID 

type FuncWithQueueID func(QueueID) (Result, error)

FuncWithQueueID TODO

type IdxQueue 

type IdxQueue struct {
	Idx int
	*Queue
}

IdxQueue TODO

func NewIdxQueue 

func NewIdxQueue(rq *RQ, qid QueueID, status QueueStatus, idx int) *IdxQueue

NewIdxQueue TODO

type Queue 

type Queue struct {
	ID QueueID
	// contains filtered or unexported fields
}

Queue TODO

func NewQueue 

func NewQueue(rq *RQ, id QueueID, status QueueStatus) *Queue

NewQueue TODO

func (*Queue) Clear 

func (queue *Queue) Clear() (result Result, err error)

Clear TODO

func (*Queue) Dequeuing 

func (queue *Queue) Dequeuing() int64

Dequeuing TODO

func (*Queue) Get 

func (queue *Queue) Get() (result Result, err error)

Get TODO

func (*Queue) Idle 

func (queue *Queue) Idle() bool

Idle TODO

func (*Queue) Info 

func (queue *Queue) Info() (result Result, err error)

Info TODO

func (*Queue) Put 

func (queue *Queue) Put(request *Request) (Result, error)

Put TODO

func (*Queue) QueueSize 

func (queue *Queue) QueueSize() int64

QueueSize TODO

func (*Queue) Queuing 

func (queue *Queue) Queuing() int64

Queuing TODO

func (*Queue) SetStatus 

func (queue *Queue) SetStatus(status QueueStatus) (result Result, err error)

SetStatus TODO

func (*Queue) Status 

func (queue *Queue) Status() QueueStatus

Status TODO

func (*Queue) Sync 

func (queue *Queue) Sync(lock bool) (result Result, err error)

Sync TODO

func (*Queue) View 

func (queue *Queue) View(start int64, end int64) (result Result, err error)

View TODO

type QueueBox 

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

QueueBox TODO

func NewQueueBox 

func NewQueueBox(rq *RQ) *QueueBox

NewQueueBox TODO

func (*QueueBox) AddQueue 

func (box *QueueBox) AddQueue(qid QueueID) (queue *IdxQueue, err error)

AddQueue TODO

func (*QueueBox) GetQueue 

func (box *QueueBox) GetQueue(qid QueueID) (*IdxQueue, bool)

GetQueue TODO

func (*QueueBox) Info 

func (box *QueueBox) Info() (result Result)

Info TODO

func (*QueueBox) OrderedQueues 

func (box *QueueBox) OrderedQueues(k int64, start int64, status QueueStatus) Result

OrderedQueues TODO

func (*QueueBox) QueueNum 

func (box *QueueBox) QueueNum(status QueueStatus) int

QueueNum TODO

func (*QueueBox) RandomQueues 

func (box *QueueBox) RandomQueues(k int64, status QueueStatus) Result

RandomQueues TODO

func (*QueueBox) RemoveQueue 

func (box *QueueBox) RemoveQueue(qid QueueID) error

RemoveQueue TODO

func (*QueueBox) UpdateQueueStatus 

func (box *QueueBox) UpdateQueueStatus(qid QueueID, status QueueStatus) (result Result, err error)

UpdateQueueStatus TODO

type QueueID 

type QueueID struct {
	Host   string `json:"host"`
	Port   string `json:"port"`
	Scheme string `json:"scheme"`
}

QueueID TODO

func CreateQueueID 

func CreateQueueID(host, port, scheme string) QueueID

CreateQueueID TODO

func QueueIDFromRedisKey 

func QueueIDFromRedisKey(key string) (qid QueueID, err error)

QueueIDFromRedisKey TODO

func QueueIDFromRequest 

func QueueIDFromRequest(req *Request) QueueID

QueueIDFromRequest TODO

func (QueueID) MarshalJSON 

func (qid QueueID) MarshalJSON() ([]byte, error)

MarshalJSON TODO

func (QueueID) String 

func (qid QueueID) String() string

type QueueNotExistError 

type QueueNotExistError string

QueueNotExistError TODO

func (QueueNotExistError) Error 

func (e QueueNotExistError) Error() string

type QueueOperation 

type QueueOperation interface {
	Operate(id QueueID) (Result, error)
}

QueueOperation TODO

type QueueStatus 

type QueueStatus string

QueueStatus type 

const (
	QueueNilStatus QueueStatus = "nil"
	QueueWorking   QueueStatus = "working"
	QueuePaused    QueueStatus = "paused"
)

QueueStatus enum

type RQ 

type RQ struct {
	Conf    *viper.Viper
	Client  *redis.Client
	Process *process.Process
	// contains filtered or unexported fields
}

RQ TODO

func NewRQ 

func NewRQ(conf *viper.Viper, client *redis.Client) (rq *RQ, err error)

NewRQ creates RQ object

func (*RQ) AddRequest 

func (rq *RQ) AddRequest(rawReq *RawRequest) (result Result, err error)

AddRequest TODO

func (*RQ) ClearQueue 

func (rq *RQ) ClearQueue(qid QueueID) (Result, error)

ClearQueue TODO

func (*RQ) DeleteQueue 

func (rq *RQ) DeleteQueue(qid QueueID) (Result, error)

DeleteQueue TODO

func (*RQ) ForceSyncQueue 

func (rq *RQ) ForceSyncQueue(qid QueueID) (result Result, err error)

ForceSyncQueue TODO

func (*RQ) GetRequest 

func (rq *RQ) GetRequest(qid QueueID) (result Result, err error)

GetRequest TODO

func (*RQ) Info 

func (rq *RQ) Info() (result Result, err error)

Info TODO

func (*RQ) OrderedQueues 

func (rq *RQ) OrderedQueues(k int64, start int64, status QueueStatus) Result

OrderedQueues TODO

func (*RQ) Pause 

func (rq *RQ) Pause() (Result, error)

Pause TODO

func (*RQ) PauseQueue 

func (rq *RQ) PauseQueue(qid QueueID) (result Result, err error)

PauseQueue TODO

func (*RQ) QueueInfo 

func (rq *RQ) QueueInfo(qid QueueID) (Result, error)

QueueInfo TODO

func (*RQ) RandomQueues 

func (rq *RQ) RandomQueues(k int64, status QueueStatus) Result

RandomQueues TODO

func (*RQ) Resume 

func (rq *RQ) Resume() (Result, error)

Resume TODO

func (*RQ) ResumeQueue 

func (rq *RQ) ResumeQueue(qid QueueID) (result Result, err error)

ResumeQueue TODO

func (*RQ) SyncQueue 

func (rq *RQ) SyncQueue(qid QueueID) (result Result, err error)

SyncQueue TODO

func (*RQ) ViewQueue 

func (rq *RQ) ViewQueue(qid QueueID, start int64, end int64) (result Result, err error)

ViewQueue TODO

type RQStats 

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

RQStats TODO

func NewRQStats 

func NewRQStats() *RQStats

NewRQStats TODO

func (*RQStats) IncrRequestNum 

func (rqStats *RQStats) IncrRequestNum(d int64) int64

IncrRequestNum TODO

func (*RQStats) RequestNum 

func (rqStats *RQStats) RequestNum() int64

RequestNum TODO

func (*RQStats) Stats 

func (rqStats *RQStats) Stats() Result

Stats TODO

func (*RQStats) UpdateInput 

func (rqStats *RQStats) UpdateInput(d int64)

UpdateInput TODO

func (*RQStats) UpdateOutput 

func (rqStats *RQStats) UpdateOutput(d int64)

UpdateOutput TODO

type RQStatus 

type RQStatus string

RQStatus type 

const (
	RQWorking   RQStatus = "working"
	RQPaused    RQStatus = "paused"
	RQPreparing RQStatus = "preparing"
	RQStopping  RQStatus = "stopping"
)

RQStatus enum

type RawRequest 

type RawRequest struct {
	URL      string                 `json:"url" binding:"required"`
	Method   string                 `json:"method,omitempty"`
	Meta     map[string]interface{} `json:"meta,omitempty"`
	Headers  map[string]string      `json:"headers,omitempty"`
	Cookies  map[string]string      `json:"cookies,omitempty"`
	Body     []byte                 `json:"body,omitempty"`
	Encoding string                 `json:"encoding,omitempty"`
}

RawRequest TODO

type Request 

type Request struct {
	RawReq *RawRequest
	*utils.ParsedURL
}

Request TODO

func NewRequest 

func NewRequest(rawReq *RawRequest) (request *Request, err error)

NewRequest TODO

func (*Request) JSON 

func (req *Request) JSON() ([]byte, error)

JSON TODO

type Result 

type Result map[string]interface{}

Result TODO

type UnavailableError 

type UnavailableError string

UnavailableError TODO

func (UnavailableError) Error 

func (e UnavailableError) Error() string

type ViewQueue 

type ViewQueue struct {
	R     *RQ
	Start int64
	End   int64
}

ViewQueue TODO

func NewViewQueueOperation 

func NewViewQueueOperation(rq *RQ, start, end int64) *ViewQueue

NewViewQueueOperation TODO

func (*ViewQueue) Operate 

func (opt *ViewQueue) Operate(id QueueID) (Result, error)

Operate TODO

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.