queue

type Check struct {
	ID    string
	State CheckState
}

type CheckState struct {
	Status   string              `json:"status,omitempty"`
	Progress float32             `json:"progress,omitempty"`
	Report   vulcanreport.Report `json:"report,omitempty"`
	Error    string              `json:"error,omitempty"`
}

type Message struct {
	ExternalID string    `json:"external_id"`
	Received   time.Time `json:"Received"`
	Payload    string    `json:"payload"`
}

type Queue interface {
	Dequeue() (*Check, error)
	Enqueue(Check) error
}

type SimpleMQ struct {
	Addr  string
	Path  string
	Queue []Message
	Srv   *http.Server

	sync.Mutex
	// contains filtered or unexported fields
}

type SimpleMQClientServer struct {
	Addr string
	// contains filtered or unexported fields
}