queue

Documentation

Index

• Constants
• type QueueEvent
• type QueueManager
  • func NewQueue(queue string) *QueueManager
  • func (q *QueueManager) Close() error
  • func (q *QueueManager) Publish(evt QueueEvent) error
  • func (q *QueueManager) Subscribe()

Constants

const (
	EVENT_ISSUE  = "issue"
	EVENT_RENEW  = "renew"
	EVENT_REVOKE = "revoke"
)

const SEQUENTIAL_WAIT_TIME = 60 // in seconds

Types

type QueueEvent

type QueueEvent struct {
	RequestId     int       `json:"RequestId"`
	Domain        string    `json:"Domain"`
	ChallengeType string    `json:"ChallengeType"`
	Type          string    `json:"Type"`
	Attempt       int       `json:"Attempt"`
	CreatedAt     time.Time `json:"CreatedAt"`
}

type QueueManager

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

var QueueMgr *QueueManager

func NewQueue

func NewQueue(queue string) *QueueManager

func (*QueueManager) Close

func (q *QueueManager) Close() error

func (*QueueManager) Publish

func (q *QueueManager) Publish(evt QueueEvent) error

func (*QueueManager) Subscribe

func (q *QueueManager) Subscribe()