deletequeue

Documentation

Index

• type ChannelQueue
• type Queue
  • func NewQueue() *Queue
  • func (q *Queue) DeleteMessages(channel int64, ids ...int64)

Types

type ChannelQueue

type ChannelQueue struct {
	sync.RWMutex

	Parent *Queue

	Channel int64
	Exiting bool

	Queued     []int64
	Processing []int64
}

type Queue

type Queue struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue() *Queue

func (*Queue) DeleteMessages

func (q *Queue) DeleteMessages(channel int64, ids ...int64)