queue

Documentation

Index

• type PusherQueue
  • func NewPusherQueue() *PusherQueue
  • func (q *PusherQueue) List(queue QueueEnum) ([]string, error)
  • func (q *PusherQueue) Lock(queue QueueEnum, item string) (bool, error)
  • func (q *PusherQueue) Pop(queue QueueEnum) (string, error)
  • func (q *PusherQueue) Push(queue QueueEnum, item string) error
  • func (q *PusherQueue) Unlock(queue QueueEnum, item string) (bool, error)
• type QueueEnum

Types

type PusherQueue

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

func NewPusherQueue

func NewPusherQueue() *PusherQueue

func (*PusherQueue) List

func (q *PusherQueue) List(queue QueueEnum) ([]string, error)

func (*PusherQueue) Lock

func (q *PusherQueue) Lock(queue QueueEnum, item string) (bool, error)

func (*PusherQueue) Pop

func (q *PusherQueue) Pop(queue QueueEnum) (string, error)

func (*PusherQueue) Push

func (q *PusherQueue) Push(queue QueueEnum, item string) error

func (*PusherQueue) Unlock

func (q *PusherQueue) Unlock(queue QueueEnum, item string) (bool, error)

type QueueEnum

type QueueEnum string

const (
	DEPLOY_CONTINUING QueueEnum = "DEPLOY_CONTINUING"
	RUNTIME_DELETING  QueueEnum = "RUNTIME_DELETING"
)