server

package
v0.9.0 Latest Latest
Warning

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

Go to latest
Published: May 8, 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 added in v0.5.0

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

func (*QueueServer[J, R]) WaitJob added in v0.4.0

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