queue

package
v0.0.0-...-7bee2ce Latest Latest
Warning

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

 Go to latest Published: Oct 23, 2023 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()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.