Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AppEventsQueue ¶
type AppEventsQueue struct {
// contains filtered or unexported fields
}
func GetAppQueue ¶
func GetAppQueue() *AppEventsQueue
func (*AppEventsQueue) Dequeue ¶
func (q *AppEventsQueue) Dequeue() *service.ApplicationWrapper
Dequeue removes an Item from the start of the queue
func (*AppEventsQueue) Enqueue ¶
func (q *AppEventsQueue) Enqueue(event *service.ApplicationWrapper)
Enqueue adds an Item to the end of the queue
func (*AppEventsQueue) Purge ¶
func (s *AppEventsQueue) Purge()
func (*AppEventsQueue) Size ¶
func (s *AppEventsQueue) Size() int
Size returns the number of Items in the queue
type EnvQueueProcessor ¶
type EnvQueueProcessor struct {
// contains filtered or unexported fields
}
func (*EnvQueueProcessor) New ¶
func (processor *EnvQueueProcessor) New() QueueProcessor
func (*EnvQueueProcessor) Run ¶
func (processor *EnvQueueProcessor) Run()
type QueueProcessor ¶
type QueueProcessor interface {
Run()
}
Source Files
Click to show internal directories.
Click to hide internal directories.