queue

package
v0.0.0-...-28ab817 Latest Latest
Warning

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

Go to latest
Published: Sep 13, 2022 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const (
	EVENT_ISSUE  = "issue"
	EVENT_RENEW  = "renew"
	EVENT_REVOKE = "revoke"
)
View Source
const SEQUENTIAL_WAIT_TIME = 60 // in seconds

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

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