queue

Documentation

Index

• type QueueManager
  • func NewQueueManager(adminToken string, allowAnonymousRead bool, db *sql.DB) *QueueManager
  • func (m *QueueManager) InitTable(ctx context.Context)
  • func (m *QueueManager) Register(container *restful.Container)
  • func (m *QueueManager) Schedule(ctx context.Context, logger *slog.Logger)

Types

type QueueManager

type QueueManager struct {
	MessageDAO *dao.Message

	MessageService *service.MessageService

	MessageController *controller.MessageController
	// contains filtered or unexported fields
}

func NewQueueManager

func NewQueueManager(adminToken string, allowAnonymousRead bool, db *sql.DB) *QueueManager

func (*QueueManager) InitTable

func (m *QueueManager) InitTable(ctx context.Context)

func (*QueueManager) Register

func (m *QueueManager) Register(container *restful.Container)

func (*QueueManager) Schedule

func (m *QueueManager) Schedule(ctx context.Context, logger *slog.Logger)