mem_mq

Documentation

Index

• type TaskManager
  • func New(limit int) *TaskManager
  • func (tm *TaskManager) Clear(_ string) error
  • func (tm *TaskManager) Pop(ch string) (mq.Task, error)
  • func (tm *TaskManager) Push(ch string, t mq.Task) error
  • func (tm *TaskManager) Remove(ch string, id string) error

Types

type TaskManager

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

func New

func New(limit int) *TaskManager

func (*TaskManager) Clear

func (tm *TaskManager) Clear(_ string) error

func (*TaskManager) Pop

func (tm *TaskManager) Pop(ch string) (mq.Task, error)

func (*TaskManager) Push

func (tm *TaskManager) Push(ch string, t mq.Task) error

func (*TaskManager) Remove

func (tm *TaskManager) Remove(ch string, id string) error