helpers

Documentation

Index

• Constants
• Variables
• func ActiveActualLRPs(logger lager.Logger, client bbs.InternalClient, processGuid string) []models.ActualLRP
• func Callback(listenHost string, handler http.HandlerFunc) (*httptest.Server, string)
• func CleanupGarden(gardenClient garden.Client) []error
• func Copy(sourcePath, destinationPath string)
• func CrashingLRPCreateRequest(addresses world.ComponentAddresses, processGuid string) *models.DesiredLRP
• func DefaultDeclaritiveHealthcheckLRPCreateRequest(addresses world.ComponentAddresses, processGuid, logGuid string, ...) *models.DesiredLRP
• func DefaultLRPCreateRequest(addresses world.ComponentAddresses, processGuid, logGuid string, ...) *models.DesiredLRP
• func DockerLRPCreateRequest(addresses world.ComponentAddresses, processGuid string) *models.DesiredLRP
• func GenerateGuid() string
• func HelloWorldInstancePoller(routerAddr, host string) func() []string
• func HexValueForByteArray(algorithm string, content []byte) (string, error)
• func LRPCreateRequestWithPlacementTag(addresses world.ComponentAddresses, processGuid string, tags []string) *models.DesiredLRP
• func LRPCreateRequestWithRootFS(addresses world.ComponentAddresses, processGuid, rootfs string) *models.DesiredLRP
• func LRPInstanceStatePoller(logger lager.Logger, client bbs.InternalClient, processGuid string, index int, ...) func() string
• func LRPStatePoller(logger lager.Logger, client bbs.InternalClient, processGuid string, ...) func() string
• func LightweightLRPCreateRequest(addresses world.ComponentAddresses, processGuid string) *models.DesiredLRP
• func MatchActualLRPCrashedEvent(processGuid, instanceGuid, cellId string, index int) gomega.OmegaMatcher
• func RegisterDefaultTimeouts()
• func ResponseBodyAndStatusCodeFromHost(routerAddr string, host string, pathElements ...string) ([]byte, int, error)
• func ResponseCodeFromHostPoller(routerAddr string, host string, pathElements ...string) func() (int, error)
• func RunningActualLRPs(logger lager.Logger, client bbs.InternalClient, processGuid string) []models.ActualLRP
• func StopProcesses(processes ...ifrit.Process)
• func TaskCreateRequest(taskGuid string, action models.ActionInterface) *models.Task
• func TaskCreateRequestWithCertificateProperties(taskGuid string, action models.ActionInterface, ...) *models.Task
• func TaskCreateRequestWithMemory(taskGuid string, action models.ActionInterface, memoryMB int) *models.Task
• func TaskCreateRequestWithMemoryAndDisk(taskGuid string, action models.ActionInterface, memoryMB, diskMB int) *models.Task
• func TaskCreateRequestWithRootFS(taskGuid, rootfs string, action models.ActionInterface) *models.Task
• func TaskCreateRequestWithTags(taskGuid string, action models.ActionInterface, tags []string) *models.Task
• func TaskFailedPoller(logger lager.Logger, client bbs.InternalClient, taskGuid string, ...) func() bool
• func TaskStatePoller(logger lager.Logger, client bbs.InternalClient, taskGuid string, ...) func() models.Task_State
• func UpsertInigoDomain(logger lager.Logger, bbsClient bbs.InternalClient)
• type ActualLRPCrashedEventMatcher
  • func (matcher *ActualLRPCrashedEventMatcher) FailureMessage(actual interface{}) (message string)
  • func (matcher *ActualLRPCrashedEventMatcher) Match(actual interface{}) (success bool, err error)
  • func (matcher *ActualLRPCrashedEventMatcher) NegatedFailureMessage(actual interface{}) (message string)

Constants

const BogusPreloadedRootFS = "preloaded:bogus-rootfs"

const DefaultHost = "lrp-route"

Variables

var DEFAULT_CONSISTENTLY_DURATION = 5 * time.Second

var DEFAULT_EVENTUALLY_TIMEOUT = 1 * time.Minute

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 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)