common

Documentation

Index

• Variables
• func Bosh(argv ...string) *gexec.Session
• func ConcourseClient() concourse.Client
• func ContainersBy(condition, value string) []string
• func DeleteAllContainers()
• func Deploy(manifest string, args ...string)
• func FlyTable(argv ...string) []map[string]string
• func LoadJobInstances() (map[string][]BoshInstance, map[string][]BoshInstance)
• func ParseTable(content string) [][]string
• func PgDump() *gexec.Session
• func SpawnBosh(argv ...string) *gexec.Session
• func SplitTableColumns(row string) []string
• func StartDeploy(manifest string, args ...string) *gexec.Session
• func VolumesByResourceType(name string) []string
• func WaitForDeploymentAndCompileLocks()
• func WaitForLandedWorker() string
• func WaitForRunningWorker() string
• func WaitForStalledWorker() string
• func WaitForWorkerInState(desiredStates ...string) string
• func WaitForWorkersToBeRunning(expected int)
• func WorkerState(name string) string
• func WorkersWithContainers() []string
• type BoshInstance
  • func Instance(name string) *BoshInstance
  • func JobInstance(job string) *BoshInstance
  • func JobInstances(job string) []BoshInstance

Variables

var (
	Fly            = FlyCli{}
	DeploymentName string

	DbConn *sql.DB

	AtcExternalURL string
	AtcUsername    string
	AtcPassword    string

	WorkerGardenClient       gclient.Client
	WorkerBaggageclaimClient bclient.Client

	Logger *lagertest.TestLogger
)

var InstanceRow = regexp.MustCompile(`^([^/]+)/([^\s]+)\s+-\s+(\w+)\s+z1\s+([0-9]+\.[0-9]+\.[0-9]+\.[0-9]+)\s+([^\s]+)\s*`)

var JobRow = regexp.MustCompile(`^([^\s]+)\s+(\w+)\s+(\w+)\s+-\s+-\s+-\s*`)

var Psql = sq.StatementBuilder.PlaceholderFormat(sq.Dollar)

Functions

func Bosh

func Bosh(argv ...string) *gexec.Session

func ConcourseClient

func ConcourseClient() concourse.Client

func ContainersBy

func ContainersBy(condition, value string) []string

func DeleteAllContainers

func DeleteAllContainers()

func Deploy

func Deploy(manifest string, args ...string)

func FlyTable

func FlyTable(argv ...string) []map[string]string

func LoadJobInstances

func LoadJobInstances() (map[string][]BoshInstance, map[string][]BoshInstance)

func ParseTable

func ParseTable(content string) [][]string

func PgDump

func PgDump() *gexec.Session

func SpawnBosh

func SpawnBosh(argv ...string) *gexec.Session

func SplitTableColumns

func SplitTableColumns(row string) []string

func StartDeploy

func StartDeploy(manifest string, args ...string) *gexec.Session

func VolumesByResourceType

func VolumesByResourceType(name string) []string

func WaitForDeploymentAndCompileLocks

func WaitForDeploymentAndCompileLocks()

func WaitForLandedWorker

func WaitForLandedWorker() string

func WaitForRunningWorker

func WaitForRunningWorker() string

func WaitForStalledWorker

func WaitForStalledWorker() string

func WaitForWorkerInState

func WaitForWorkerInState(desiredStates ...string) string

func WaitForWorkersToBeRunning

func WaitForWorkersToBeRunning(expected int)

func WorkerState

func WorkerState(name string) string

func WorkersWithContainers

func WorkersWithContainers() []string

Types

type BoshInstance

type BoshInstance struct {
	Name  string
	Group string
	ID    string
	IP    string
	DNS   string
}

func Instance

func Instance(name string) *BoshInstance

func JobInstance

func JobInstance(job string) *BoshInstance

func JobInstances

func JobInstances(job string) []BoshInstance