Documentation

Index

Constants

View Source
const BogusPreloadedRootFS = "preloaded:bogus-rootfs"
View Source
const DefaultHost = "lrp-route"

Variables

View Source
var DEFAULT_CONSISTENTLY_DURATION = 5 * time.Second
View Source
var DEFAULT_EVENTUALLY_TIMEOUT = 1 * time.Minute
View Source
var SecondaryPreloadedRootFS = "preloaded:" + world.PreloadedStacks[1]

Functions

func ActiveActualLRPs

func ActiveActualLRPs(logger lager.Logger, client bbs.InternalClient, processGuid string) []models.ActualLRP

func Callback

func Callback(listenHost string, handler http.HandlerFunc) (*httptest.Server, string)

func CleanupGarden

func CleanupGarden(gardenClient garden.Client) []error

func ConsulWaitUntilReady

func ConsulWaitUntilReady(addresses world.ComponentAddresses)

func Copy

func Copy(sourcePath, destinationPath string)

func CrashingLRPCreateRequest

func CrashingLRPCreateRequest(addresses world.ComponentAddresses, processGuid string) *models.DesiredLRP

func DefaultDeclaritiveHealthcheckLRPCreateRequest

func DefaultDeclaritiveHealthcheckLRPCreateRequest(addresses world.ComponentAddresses, processGuid, logGuid string, numInstances int) *models.DesiredLRP

func DefaultLRPCreateRequest

func DefaultLRPCreateRequest(addresses world.ComponentAddresses, processGuid, logGuid string, numInstances int) *models.DesiredLRP

func DockerLRPCreateRequest

func DockerLRPCreateRequest(addresses world.ComponentAddresses, processGuid string) *models.DesiredLRP

func GenerateGuid

func GenerateGuid() string

func HelloWorldInstancePoller

func HelloWorldInstancePoller(routerAddr, host string) func() []string

func HexValueForByteArray

func HexValueForByteArray(algorithm string, content []byte) (string, error)

func LRPCreateRequestWithPlacementTag

func LRPCreateRequestWithPlacementTag(addresses world.ComponentAddresses, processGuid string, tags []string) *models.DesiredLRP

func LRPCreateRequestWithRootFS

func LRPCreateRequestWithRootFS(addresses world.ComponentAddresses, processGuid, rootfs string) *models.DesiredLRP

func LRPInstanceStatePoller

func LRPInstanceStatePoller(logger lager.Logger, client bbs.InternalClient, processGuid string, index int, lrp *models.ActualLRP) func() string

func LRPStatePoller

func LRPStatePoller(logger lager.Logger, client bbs.InternalClient, processGuid string, lrp *models.ActualLRP) func() string

func LightweightLRPCreateRequest

func LightweightLRPCreateRequest(addresses world.ComponentAddresses, processGuid string) *models.DesiredLRP

func MatchActualLRPCrashedEvent

func MatchActualLRPCrashedEvent(processGuid, instanceGuid, cellId string, index int) gomega.OmegaMatcher

func RegisterDefaultTimeouts

func RegisterDefaultTimeouts()

func ResponseBodyAndStatusCodeFromHost

func ResponseBodyAndStatusCodeFromHost(routerAddr string, host string, pathElements ...string) ([]byte, int, error)

func ResponseCodeFromHostPoller

func ResponseCodeFromHostPoller(routerAddr string, host string, pathElements ...string) func() (int, error)

func RunningActualLRPs

func RunningActualLRPs(logger lager.Logger, client bbs.InternalClient, processGuid string) []models.ActualLRP

func StopProcesses

func StopProcesses(processes ...ifrit.Process)

func TaskCreateRequest

func TaskCreateRequest(taskGuid string, action models.ActionInterface) *models.Task

func TaskCreateRequestWithCertificateProperties

func TaskCreateRequestWithCertificateProperties(taskGuid string, action models.ActionInterface, certificateProperties *models.CertificateProperties) *models.Task

func TaskCreateRequestWithMemory

func TaskCreateRequestWithMemory(taskGuid string, action models.ActionInterface, memoryMB int) *models.Task

func TaskCreateRequestWithMemoryAndDisk

func TaskCreateRequestWithMemoryAndDisk(taskGuid string, action models.ActionInterface, memoryMB, diskMB int) *models.Task

func TaskCreateRequestWithRootFS

func TaskCreateRequestWithRootFS(taskGuid, rootfs string, action models.ActionInterface) *models.Task

func TaskCreateRequestWithTags

func TaskCreateRequestWithTags(taskGuid string, action models.ActionInterface, tags []string) *models.Task

func TaskFailedPoller

func TaskFailedPoller(logger lager.Logger, client bbs.InternalClient, taskGuid string, task *models.Task) func() bool

func TaskStatePoller

func TaskStatePoller(logger lager.Logger, client bbs.InternalClient, taskGuid string, task *models.Task) func() models.Task_State

func UpsertInigoDomain

func UpsertInigoDomain(logger lager.Logger, bbsClient bbs.InternalClient)

Types

type ActualLRPCrashedEventMatcher

type ActualLRPCrashedEventMatcher struct {
	ProcessGuid  string
	InstanceGuid string
	CellId       string
	Index        int
}

func (*ActualLRPCrashedEventMatcher) FailureMessage

func (matcher *ActualLRPCrashedEventMatcher) FailureMessage(actual interface{}) (message string)

func (*ActualLRPCrashedEventMatcher) Match

func (matcher *ActualLRPCrashedEventMatcher) Match(actual interface{}) (success bool, err error)

func (*ActualLRPCrashedEventMatcher) NegatedFailureMessage

func (matcher *ActualLRPCrashedEventMatcher) NegatedFailureMessage(actual interface{}) (message string)

Directories

Path Synopsis