Versions in this module Expand all Collapse all v0 v0.4.2 Apr 28, 2016 Changes in this version + var ErrNotFound = errors.New("queue item not found") + func Publish(c context.Context, w *Work) error + func Remove(c context.Context, w *Work) error + func ToContext(c Setter, q Queue) + type CloseNotifier interface + CloseNotify func() <-chan bool + type Queue interface + Publish func(*Work) error + Pull func() *Work + PullClose func(CloseNotifier) *Work + Remove func(*Work) error + func FromContext(c context.Context) Queue + func New() Queue + type Setter interface + Set func(string, interface{}) + type Work struct + Build *model.Build + BuildLast *model.Build + Job *model.Job + Keys *model.Key + Netrc *model.Netrc + Repo *model.Repo + Secrets []*model.Secret + Signed bool + System *model.System + User *model.User + Verified bool + Yaml string + YamlEnc string + func Pull(c context.Context) *Work + func PullClose(c context.Context, cn CloseNotifier) *Work
Go to main page