server

package
v1.2.1 Latest Latest
Warning

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

Go to latest
Published: May 15, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Index

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

func (q *QueueServer[J, R]) AddWaitJob(content J) common.Job[J, R]

func (*QueueServer[J, R]) CheckJob

func (q *QueueServer[J, R]) CheckJob(id string) common.Status

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

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])

func (*QueueServer[J, R]) WaitJob

func (q *QueueServer[J, R]) WaitJob(id string) (common.Job[J, R], bool)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL