groupprovider

Documentation

Index

• type QueueGroupProvider
  • func NewQueueGroupProvider(cfg QueueGroupProviderConfig) *QueueGroupProvider
  • func (p *QueueGroupProvider) Begin(job groups.GroupQueueJob) error
  • func (p *QueueGroupProvider) Cancel(job groups.GroupQueueJob) error
  • func (p *QueueGroupProvider) Clear(job groups.GroupQueueJob) error
  • func (p *QueueGroupProvider) IsComplete(job groups.GroupQueueJob) (cancelled bool, err error)
• type QueueGroupProviderConfig

Types

type QueueGroupProvider

type QueueGroupProvider struct {
	// contains filtered or unexported fields
}

func NewQueueGroupProvider

func NewQueueGroupProvider(cfg QueueGroupProviderConfig) *QueueGroupProvider

func (*QueueGroupProvider) Begin

func (p *QueueGroupProvider) Begin(job groups.GroupQueueJob) error

func (*QueueGroupProvider) Cancel

func (p *QueueGroupProvider) Cancel(job groups.GroupQueueJob) error

func (*QueueGroupProvider) Clear

func (p *QueueGroupProvider) Clear(job groups.GroupQueueJob) error

func (*QueueGroupProvider) IsComplete

func (p *QueueGroupProvider) IsComplete(job groups.GroupQueueJob) (cancelled bool, err error)

type QueueGroupProviderConfig

type QueueGroupProviderConfig struct {
	Store dbqueuetypes.QueueGroupStore
}