queue

Documentation

Index

• func NewQueue(name string, healthyLimit int) (rmq.Queue, error)
• type HealthCheck
  • func (h *HealthCheck) HealthCheck(ctx context.Context) servicehealthcheck.HealthCheckResult

Functions

func NewQueue

func NewQueue(name string, healthyLimit int) (rmq.Queue, error)

NewQueue creates a new rmq.Queue and initializes health checks for this queue Whenever the number of items in the queue exceeds the healthyLimit The queue will be reported as unhealthy If the queue has already been opened, it will just be returned. Limits will not be updated

Types

type HealthCheck

type HealthCheck struct {

	// IgnoreInterval is a switch used for testing, just to allow multiple
	// functional queries of HealthCheck in rapid bursts
	IgnoreInterval bool
	// contains filtered or unexported fields
}

func (*HealthCheck) HealthCheck

func (h *HealthCheck) HealthCheck(ctx context.Context) servicehealthcheck.HealthCheckResult

HealthCheck checks if the queues are healthy, i.e. whether the number of items accumulated is below the healthyLimit defined when opening the queue