queue

package
v0.0.0-...-2798f75 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 8, 2023 License: MIT Imports: 9 Imported by: 0

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

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()
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL