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
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 CleanupGarden ¶
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 HexValueForByteArray ¶
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 LRPStatePoller ¶
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 RunningActualLRPs ¶
func RunningActualLRPs(logger lager.Logger, client bbs.InternalClient, processGuid string) []models.ActualLRP
func StopProcesses ¶
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 TaskCreateRequestWithRootFS ¶
func TaskCreateRequestWithRootFS(taskGuid, rootfs string, action models.ActionInterface) *models.Task
func TaskFailedPoller ¶
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)
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.