queue

Documentation

Index

• type Process
  • func NewProcess(git *repo.Git) (*Process, error)
  • func (p *Process) Git() *repo.Git
  • func (p *Process) Log(message, level string)
  • func (p *Process) ResetWait()
  • func (p *Process) Standby()
• type Queue
  • func NewQueue() *Queue
  • func (q *Queue) ResetWaits()
  • func (q *Queue) StandbyAll()
  • func (q *Queue) WaitForAll()
  • func (q *Queue) Walk(c *configs.Configs) (*Queue, error)

Types

type Process

type Process struct {
	// contains filtered or unexported fields
}

func NewProcess

func NewProcess(git *repo.Git) (*Process, error)

NewQueue returns a new instance of Queue

func (*Process) Git

func (p *Process) Git() *repo.Git

Git returns the Process' Git

func (*Process) Log

func (p *Process) Log(message, level string)

func (*Process) ResetWait

func (p *Process) ResetWait()

func (*Process) Standby

func (p *Process) Standby()

type Queue

type Queue []*Process

func NewQueue

func NewQueue() *Queue

NewQueue returns a new *Queue

func (*Queue) ResetWaits

func (q *Queue) ResetWaits()

func (*Queue) StandbyAll

func (q *Queue) StandbyAll()

StandbyAll sets all repos to watch for changes

func (*Queue) WaitForAll

func (q *Queue) WaitForAll()

func (*Queue) Walk

func (q *Queue) Walk(c *configs.Configs) (*Queue, error)

Walk goes through the config's directories and adds each as Git instance to the Queue