queue

Documentation

Overview

Package queue implement a producer consumer queue for lossless models.

Index

• func GetQueueFill() int
• func Looper()
• type ErrorFull
  • func (e ErrorFull) Error() string
• type QueuedJob
  • func EnqueueJob(request *types.ServiceRequest) (*QueuedJob, error)
• type Timings

Functions

func GetQueueFill

func GetQueueFill() int

func Looper

func Looper()

Types

type ErrorFull

type ErrorFull struct{}

func (ErrorFull) Error

func (e ErrorFull) Error() string

type QueuedJob

type QueuedJob struct {
	Request   *types.ServiceRequest
	Semaphore *utils.Semaphore
	Response  *faas.APIResponse
	Timings   *Timings
}

func EnqueueJob

func EnqueueJob(request *types.ServiceRequest) (*QueuedJob, error)

EnqueueJob enqueues the passed job in the queue and it blocks the caller until the job has been executed

type Timings

type Timings struct {
	ExecutionTime     float64 `json:"execution_time"`      // the time of executing the job comprising the GET to openfaas
	FaasExecutionTime float64 `json:"faas_execution_time"` // the execution time as it is told by openfaas
	QueueTime         float64 `json:"queue_time"`          // the time in which the job remains in the local queue (comprises the execution time)

}