server

Documentation

Index

• type QueueServer
  • func NewQueueServer[T any]() *QueueServer[T]
  • func (q *QueueServer[T]) AddJob(job *common.Job[T])
  • func (q *QueueServer[T]) CheckJob(id string) common.Status
  • func (q *QueueServer[T]) GetJob(id string) (*common.Job[T], bool)
  • func (q *QueueServer[T]) NewJob(content T) (*common.Job[T], error)
  • func (q *QueueServer[T]) NewJobs() []*common.Job[T]
  • func (q *QueueServer[T]) RemoveJob(job *common.Job[T])
  • func (q *QueueServer[T]) UpdateJob(job *common.Job[T])

Types

type QueueServer

type QueueServer[T any] struct {
	// contains filtered or unexported fields
}

func NewQueueServer

func NewQueueServer[T any]() *QueueServer[T]

func (*QueueServer[T]) AddJob

func (q *QueueServer[T]) AddJob(job *common.Job[T])

func (*QueueServer[T]) CheckJob

func (q *QueueServer[T]) CheckJob(id string) common.Status

func (*QueueServer[T]) GetJob

func (q *QueueServer[T]) GetJob(id string) (*common.Job[T], bool)

func (*QueueServer[T]) NewJob

func (q *QueueServer[T]) NewJob(content T) (*common.Job[T], error)

func (*QueueServer[T]) NewJobs

func (q *QueueServer[T]) NewJobs() []*common.Job[T]

func (*QueueServer[T]) RemoveJob

func (q *QueueServer[T]) RemoveJob(job *common.Job[T])

func (*QueueServer[T]) UpdateJob

func (q *QueueServer[T]) UpdateJob(job *common.Job[T])