queue

type CloseNotifier interface {
	// CloseNotify returns a channel that receives a single value
	// when the client connection has gone away.
	CloseNotify() <-chan bool
}

type Queue interface {
	// Publish inserts work at the tail of this queue, waiting for
	// space to become available if the queue is full.
	Publish(*Work) error

	// Remove removes the specified work item from this queue,
	// if it is present.
	Remove(*Work) error

	// PullClose retrieves and removes the head of this queue,
	// waiting if necessary until work becomes available.
	Pull() *Work

	// PullClose retrieves and removes the head of this queue,
	// waiting if necessary until work becomes available. The
	// CloseNotifier should be provided to clone the channel
	// if the subscribing client terminates its connection.
	PullClose(CloseNotifier) *Work
}

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

type Work struct {
	Signed    bool            `json:"signed"`
	Verified  bool            `json:"verified"`
	Yaml      string          `json:"config"`
	YamlEnc   string          `json:"secret"`
	Repo      *model.Repo     `json:"repo"`
	Build     *model.Build    `json:"build"`
	BuildLast *model.Build    `json:"build_last"`
	Job       *model.Job      `json:"job"`
	Netrc     *model.Netrc    `json:"netrc"`
	Keys      *model.Key      `json:"keys"`
	System    *model.System   `json:"system"`
	Secrets   []*model.Secret `json:"secrets"`
	User      *model.User     `json:"user"`
}