runners

package
v0.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 5, 2017 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AnsibleRun added in v0.2.0 

func AnsibleRun()

AnsibleRun starts consuming jobs into a channel of size prefetchLimit

Types

type Consumer added in v0.2.0 

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

Consumer is implementation of rmq.Consumer interface

func NewConsumer added in v0.2.0 

func NewConsumer(tag int) *Consumer

NewConsumer is the entrypoint for runners.Consumer

func (*Consumer) Consume added in v0.2.0 

func (consumer *Consumer) Consume(delivery rmq.Delivery)

Consume will deligate jobs to appropriate runners

type QueueJob added in v0.2.0 

type QueueJob struct {
	Job            models.Job
	Template       models.JobTemplate
	MachineCred    models.Credential
	NetworkCred    models.Credential
	SCMCred        models.Credential
	CloudCred      models.Credential
	Inventory      models.Inventory
	Project        models.Project
	User           models.User
	PreviousJob    *QueueJob
	Token          string
	CredentialPath string // for system jobs
}

QueueJob contains all the information required to start a job

func UpdateProject added in v0.0.3 

func UpdateProject(p models.Project) (*QueueJob, error)

UpdateProject will create and start a update system job using ansible playbook project_update.yml

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.