server

Documentation

Index

• type QueueServer
  • func NewQueueServer[T any]() *QueueServer[T]
  • func (q *QueueServer[T]) AddJob(job *common.Job[T])
  • func (q *QueueServer[T]) AddWaitJob(content T) *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) string
  • 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])
  • func (q *QueueServer[T]) WaitJob(id string) (*common.Job[T], bool)

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

func (q *QueueServer[T]) AddWaitJob(content T) *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) string

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

func (*QueueServer[T]) WaitJob

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