queuestatus

Documentation

Index

• Variables
• type Manager

Variables

var (
	// Mgr default user group manager
	Mgr = newManager()
)

Types

type Manager

type Manager interface {
	// List list queue status
	List(ctx context.Context) ([]*model.JobQueueStatus, error)
	// AllJobTypeStatus get all job type status
	AllJobTypeStatus(ctx context.Context) (map[string]bool, error)
	// Get get queue status by JobType
	Get(ctx context.Context, jobType string) (*model.JobQueueStatus, error)
	// UpdateStatus update queue status
	UpdateStatus(ctx context.Context, jobType string, paused bool) error
	// CreateOrUpdate create a queue status or update it if it already exists
	CreateOrUpdate(ctx context.Context, status *model.JobQueueStatus) (int64, error)
}

Manager the manager for queue status