queuemanage

Documentation

Index

• type Option
  • func WithDBClient(dbClient *dbclient.Client) Option
• type QueueManage
  • func New(ops ...Option) *QueueManage
  • func (qm *QueueManage) CreatePipelineQueue(req apistructs.PipelineQueueCreateRequest) (*apistructs.PipelineQueue, error)
  • func (qm *QueueManage) DeletePipelineQueue(queueID uint64) error
  • func (qm *QueueManage) GetPipelineQueue(queueID uint64) (*apistructs.PipelineQueue, error)
  • func (qm *QueueManage) PagingPipelineQueues(req apistructs.PipelineQueuePagingRequest) (*apistructs.PipelineQueuePagingData, error)
  • func (qm *QueueManage) UpdatePipelineQueue(req apistructs.PipelineQueueUpdateRequest) (*apistructs.PipelineQueue, error)

Types

type Option

type Option func(*QueueManage)

func WithDBClient

func WithDBClient(dbClient *dbclient.Client) Option

type QueueManage

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

func New

func New(ops ...Option) *QueueManage

func (*QueueManage) CreatePipelineQueue

func (qm *QueueManage) CreatePipelineQueue(req apistructs.PipelineQueueCreateRequest) (*apistructs.PipelineQueue, error)

CreatePipelineQueue create a pipeline queue.

func (*QueueManage) DeletePipelineQueue

func (qm *QueueManage) DeletePipelineQueue(queueID uint64) error

DeletePipelineQueue delete a pipeline queue by id.

func (*QueueManage) GetPipelineQueue

func (qm *QueueManage) GetPipelineQueue(queueID uint64) (*apistructs.PipelineQueue, error)

GetPipelineQueue get a pipeline queue by id.

func (*QueueManage) PagingPipelineQueues

func (qm *QueueManage) PagingPipelineQueues(req apistructs.PipelineQueuePagingRequest) (*apistructs.PipelineQueuePagingData, error)

PagingPipelineQueues

func (*QueueManage) UpdatePipelineQueue

func (qm *QueueManage) UpdatePipelineQueue(req apistructs.PipelineQueueUpdateRequest) (*apistructs.PipelineQueue, error)

UpdatePipelineQueue update queue all fields by id.