queue

Documentation

Overview

Package queue provides the ability for Vela to integrate with different supported Queue backends.

Usage:

import "github.com/go-vela/worker/queue"

Index

• func ToContext(c Setter, q Service)
• type Service
  • func FromContext(c context.Context) Service
• type Setter

Functions

func ToContext

func ToContext(c Setter, q Service)

ToContext adds the queue Service to this context if it supports the Setter interface.

Types

type Service

type Service interface {
	// Pop defines a function that grabs an item off the queue.
	Pop() (*types.Item, error)
}

Service represents the interface for Vela integrating with the different supported Queue backends.

func FromContext

func FromContext(c context.Context) Service

FromContext returns the queue Service associated with this context.

type Setter

type Setter interface {
	Set(string, interface{})
}

Setter defines a context that enables setting values.