Documentation ¶
Index ¶
- type QueueServer
- func (q *QueueServer[J, R]) AddJob(job *common.Job[J, R])
- func (q *QueueServer[J, R]) AddWaitJob(content J) *common.Job[J, R]
- func (q *QueueServer[J, R]) CheckJob(id string) common.Status
- func (q *QueueServer[J, R]) GetJob(id string) (*common.Job[J, R], bool)
- func (q *QueueServer[J, R]) NewJob(job J) string
- func (q *QueueServer[J, R]) NewJobs() []*common.Job[J, R]
- func (q *QueueServer[J, R]) RemoveJob(job *common.Job[J, R])
- func (q *QueueServer[J, R]) ServeHTTP(w http.ResponseWriter, r *http.Request)
- func (q *QueueServer[J, R]) UpdateJob(job *common.Job[J, R])
- func (q *QueueServer[J, R]) WaitJob(id string) (*common.Job[J, R], bool)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type QueueServer ¶
type QueueServer[J, R any] struct { // contains filtered or unexported fields }
func NewQueueServer ¶
func NewQueueServer[T, R any](authorization string) *QueueServer[T, R]
func (*QueueServer[J, R]) AddJob ¶
func (q *QueueServer[J, R]) AddJob(job *common.Job[J, R])
func (*QueueServer[J, R]) AddWaitJob ¶ added in v0.5.0
func (q *QueueServer[J, R]) AddWaitJob(content J) *common.Job[J, R]
func (*QueueServer[J, R]) GetJob ¶
func (q *QueueServer[J, R]) GetJob(id string) (*common.Job[J, R], bool)
func (*QueueServer[J, R]) NewJob ¶
func (q *QueueServer[J, R]) NewJob(job J) string
func (*QueueServer[J, R]) NewJobs ¶
func (q *QueueServer[J, R]) NewJobs() []*common.Job[J, R]
func (*QueueServer[J, R]) RemoveJob ¶
func (q *QueueServer[J, R]) RemoveJob(job *common.Job[J, R])
func (*QueueServer[J, R]) ServeHTTP ¶ added in v0.7.0
func (q *QueueServer[J, R]) ServeHTTP(w http.ResponseWriter, r *http.Request)
func (*QueueServer[J, R]) UpdateJob ¶
func (q *QueueServer[J, R]) UpdateJob(job *common.Job[J, R])
Click to show internal directories.
Click to hide internal directories.