Documentation ¶
Index ¶
Constants ¶
View Source
const ( Q_RECV string = "receiving" Q_SEND string = "sending" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PriorityQueue ¶
type PriorityQueue struct {
// contains filtered or unexported fields
}
func NewPriorityQueue ¶
func NewPriorityQueue() *PriorityQueue
func (*PriorityQueue) Len ¶
func (p *PriorityQueue) Len() int
func (*PriorityQueue) Less ¶
func (p *PriorityQueue) Less(i, j int) bool
func (*PriorityQueue) Pop ¶
func (p *PriorityQueue) Pop() interface{}
func (*PriorityQueue) Push ¶
func (p *PriorityQueue) Push(qstore interface{})
func (*PriorityQueue) Swap ¶
func (p *PriorityQueue) Swap(i, j int)
type QueueBox ¶
type QueueBox struct {
// contains filtered or unexported fields
}
func NewQueuBox ¶
func NewQueuBox(serviceConfig config.ServiceConfig) *QueueBox
func (*QueueBox) ReceiveMessage ¶
func (q *QueueBox) ReceiveMessage(key string) ([]*email.MessageInfo, error)
type QueueFactory ¶
type QueueFactory struct {
// contains filtered or unexported fields
}
func NewFactory ¶
func NewFactory() *QueueFactory
func (*QueueFactory) GetOrCreate ¶
func (q *QueueFactory) GetOrCreate(key string) QueueProcess
type QueueProcess ¶
type QueueStore ¶
type QueueSubject ¶
type QueueSubject string
Click to show internal directories.
Click to hide internal directories.