models

package
v0.0.0-...-5c6e8b3 Latest Latest
Warning

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

Go to latest
Published: Jul 28, 2014 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ExecutorServiceName   = "Executor"
	FileServerServiceName = "FileServer"
)

Variables

View Source
var InvalidActionConversion = errors.New("Invalid Action Conversion")

Functions

This section is empty.

Types

type ActualLRP

type ActualLRP struct {
	ProcessGuid  string `json:"process_guid"`
	InstanceGuid string `json:"instance_guid"`
	ExecutorID   string `json:"executor_id"`

	Index int `json:"index"`

	Host  string        `json:"host"`
	Ports []PortMapping `json:"ports"`

	State ActualLRPState `json:"state"`
	Since int64          `json:"since"`
}

func NewActualLRPFromJSON

func NewActualLRPFromJSON(payload []byte) (ActualLRP, error)

func (ActualLRP) ToJSON

func (actual ActualLRP) ToJSON() []byte

type ActualLRPChange

type ActualLRPChange struct {
	Before *ActualLRP
	After  *ActualLRP
}

type ActualLRPState

type ActualLRPState int
const (
	ActualLRPStateInvalid ActualLRPState = iota
	ActualLRPStateStarting
	ActualLRPStateRunning
)

type Buildpack

type Buildpack struct {
	Name string `json:"name"`
	Key  string `json:"key"`
	Url  string `json:"url"`
}

type CCBulkToken

type CCBulkToken struct {
	Id int `json:"id"`
}

type CCDesiredStateServerResponse

type CCDesiredStateServerResponse struct {
	Apps        []DesireAppRequestFromCC `json:"apps"`
	CCBulkToken *json.RawMessage         `json:"token"`
}

type CircusTailorConfig

type CircusTailorConfig struct {
	*flag.FlagSet

	ExecutablePath string
	// contains filtered or unexported fields
}

func NewCircusTailorConfig

func NewCircusTailorConfig(buildpacks []string) CircusTailorConfig

func (CircusTailorConfig) AppDir

func (s CircusTailorConfig) AppDir() string

func (CircusTailorConfig) Args

func (s CircusTailorConfig) Args() []string

func (CircusTailorConfig) BuildArtifactsCacheDir

func (s CircusTailorConfig) BuildArtifactsCacheDir() string

func (CircusTailorConfig) BuildpackOrder

func (s CircusTailorConfig) BuildpackOrder() []string

func (CircusTailorConfig) BuildpackPath

func (s CircusTailorConfig) BuildpackPath(buildpackName string) string

func (CircusTailorConfig) BuildpacksDir

func (s CircusTailorConfig) BuildpacksDir() string

func (CircusTailorConfig) OutputDropletDir

func (s CircusTailorConfig) OutputDropletDir() string

func (CircusTailorConfig) OutputMetadataDir

func (s CircusTailorConfig) OutputMetadataDir() string

func (CircusTailorConfig) OutputMetadataPath

func (s CircusTailorConfig) OutputMetadataPath() string

func (CircusTailorConfig) Path

func (s CircusTailorConfig) Path() string

func (CircusTailorConfig) Validate

func (s CircusTailorConfig) Validate() error

type DesireAppRequestFromCC

type DesireAppRequestFromCC struct {
	ProcessGuid     string                `json:"process_guid"`
	DropletUri      string                `json:"droplet_uri"`
	Stack           string                `json:"stack"`
	StartCommand    string                `json:"start_command"`
	Environment     []EnvironmentVariable `json:"environment"`
	MemoryMB        int                   `json:"memory_mb"`
	DiskMB          int                   `json:"disk_mb"`
	FileDescriptors uint64                `json:"file_descriptors"`
	NumInstances    int                   `json:"num_instances"`
	Routes          []string              `json:"routes"`
	LogGuid         string                `json:"log_guid"`
}

func (DesireAppRequestFromCC) ToJSON

func (d DesireAppRequestFromCC) ToJSON() []byte

type DesiredLRP

type DesiredLRP struct {
	// required
	ProcessGuid string `json:"process_guid"`
	Source      string `json:"source"`
	Stack       string `json:"stack"`

	// optional
	Instances       int                   `json:"instances"`
	MemoryMB        int                   `json:"memory_mb"`
	DiskMB          int                   `json:"disk_mb"`
	FileDescriptors uint64                `json:"file_descriptors"`
	StartCommand    string                `json:"start_command"`
	Environment     []EnvironmentVariable `json:"environment"`
	Routes          []string              `json:"routes"`
	LogGuid         string                `json:"log_guid"`
}

func NewDesiredLRPFromJSON

func NewDesiredLRPFromJSON(payload []byte) (DesiredLRP, error)

func (DesiredLRP) ToJSON

func (desired DesiredLRP) ToJSON() []byte

type DesiredLRPChange

type DesiredLRPChange struct {
	Before *DesiredLRP
	After  *DesiredLRP
}

type DownloadAction

type DownloadAction struct {
	From     string `json:"from"`
	To       string `json:"to"`
	Extract  bool   `json:"extract"`
	CacheKey string `json:"cache_key"`
}

type EmitProgressAction

type EmitProgressAction struct {
	Action         ExecutorAction `json:"action"`
	StartMessage   string         `json:"start_message"`
	SuccessMessage string         `json:"success_message"`
	FailureMessage string         `json:"failure_message"`
}

type EnvironmentVariable

type EnvironmentVariable struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type ErrInvalidJSONMessage

type ErrInvalidJSONMessage struct {
	MissingField string
}

func (ErrInvalidJSONMessage) Error

func (err ErrInvalidJSONMessage) Error() string

type ExecutorAction

type ExecutorAction struct {
	Action interface{} `json:"-"`
}

func EmitProgressFor

func EmitProgressFor(action ExecutorAction, startMessage string, successMessage string, failureMessage string) ExecutorAction

func Parallel

func Parallel(actions ...ExecutorAction) ExecutorAction

func Try

func Try(action ExecutorAction) ExecutorAction

func (ExecutorAction) MarshalJSON

func (a ExecutorAction) MarshalJSON() ([]byte, error)

func (*ExecutorAction) UnmarshalJSON

func (a *ExecutorAction) UnmarshalJSON(bytes []byte) error

type ExecutorPresence

type ExecutorPresence struct {
	ExecutorID string `json:"executor_id"`
	Stack      string `json:"stack"`
}

func NewExecutorPresenceFromJSON

func NewExecutorPresenceFromJSON(payload []byte) (ExecutorPresence, error)

func (ExecutorPresence) ToJSON

func (presence ExecutorPresence) ToJSON() []byte

type FetchResultAction

type FetchResultAction struct {
	File string `json:"file"`
}

type HealthRequest

type HealthRequest struct {
	Method string `json:"method"`
	URL    string `json:"url"`
}

type LRPIdentifier

type LRPIdentifier struct {
	ProcessGuid  string
	Index        int
	InstanceGuid string
}

func LRPIdentifierFromOpaqueID

func LRPIdentifierFromOpaqueID(opaqueID string) (LRPIdentifier, error)

func (LRPIdentifier) OpaqueID

func (ids LRPIdentifier) OpaqueID() string

type LRPStartAuction

type LRPStartAuction struct {
	ProcessGuid  string           `json:"process_guid"`
	InstanceGuid string           `json:"instance_guid"`
	Stack        string           `json:"stack"`
	Actions      []ExecutorAction `json:"actions"`

	DiskMB   int `json:"disk_mb"`
	MemoryMB int `json:"memory_mb"`

	Log   LogConfig     `json:"log"`
	Ports []PortMapping `json:"ports"`

	Index int `json:"index"`

	State     LRPStartAuctionState `json:"state"`
	UpdatedAt int64                `json:"updated_at"`
}

func NewLRPStartAuctionFromJSON

func NewLRPStartAuctionFromJSON(payload []byte) (LRPStartAuction, error)

func (LRPStartAuction) LRPIdentifier

func (auction LRPStartAuction) LRPIdentifier() LRPIdentifier

func (LRPStartAuction) ToJSON

func (auction LRPStartAuction) ToJSON() []byte

type LRPStartAuctionState

type LRPStartAuctionState int
const (
	LRPStartAuctionStateInvalid LRPStartAuctionState = iota
	LRPStartAuctionStatePending
	LRPStartAuctionStateClaimed
)

type LRPStopAuction

type LRPStopAuction struct {
	ProcessGuid string `json:"process_guid"`
	Index       int    `json:"index"`

	State     LRPStopAuctionState `json:"state"`
	UpdatedAt int64               `json:"updated_at"`
}

func NewLRPStopAuctionFromJSON

func NewLRPStopAuctionFromJSON(payload []byte) (LRPStopAuction, error)

func (LRPStopAuction) ToJSON

func (auction LRPStopAuction) ToJSON() []byte

type LRPStopAuctionState

type LRPStopAuctionState int
const (
	LRPStopAuctionStateInvalid LRPStopAuctionState = iota
	LRPStopAuctionStatePending
	LRPStopAuctionStateClaimed
)

type LogConfig

type LogConfig struct {
	Guid       string `json:"guid"`
	SourceName string `json:"source_name"`
	Index      *int   `json:"index"`
}

type MonitorAction

type MonitorAction struct {
	Action             ExecutorAction `json:"action"`
	HealthyHook        HealthRequest  `json:"healthy_hook"`
	UnhealthyHook      HealthRequest  `json:"unhealthy_hook"`
	HealthyThreshold   uint           `json:"healthy_threshold"`
	UnhealthyThreshold uint           `json:"unhealthy_threshold"`
}

type ParallelAction

type ParallelAction struct {
	Actions []ExecutorAction `json:"actions"`
}

type PortMapping

type PortMapping struct {
	ContainerPort uint32 `json:"container_port"`
	HostPort      uint32 `json:"host_port,omitempty"`
}

type ResourceLimits

type ResourceLimits struct {
	Nofile *uint64 `json:"nofile,omitempty"`
}

type RunAction

type RunAction struct {
	Path           string                `json:"path"`
	Args           []string              `json:"args"`
	Env            []EnvironmentVariable `json:"env"`
	Timeout        time.Duration         `json:"timeout"`
	ResourceLimits ResourceLimits        `json:"resource_limits"`
}

type ServiceRegistration

type ServiceRegistration struct {
	Name string `json:"name"`
	Id   string `json:"id"`
}

type ServiceRegistrations

type ServiceRegistrations []ServiceRegistration

func (ServiceRegistrations) FilterByName

func (s ServiceRegistrations) FilterByName(serviceName string) ServiceRegistrations

type StagingInfo

type StagingInfo struct {
	// yaml keys matter here! they are used by the old DEA for staging_info.yml
	BuildpackKey      string `yaml:"-" json:"buildpack_key,omitempty"`
	DetectedBuildpack string `yaml:"detected_buildpack" json:"detected_buildpack"`

	// do not change to be consistent keys; look up 4 lines
	DetectedStartCommand string `yaml:"start_command" json:"detected_start_command"`
}

type StagingRequestFromCC

type StagingRequestFromCC struct {
	AppId                          string                `json:"app_id"`
	TaskId                         string                `json:"task_id"`
	Stack                          string                `json:"stack"`
	AppBitsDownloadUri             string                `json:"app_bits_download_uri"`
	BuildArtifactsCacheDownloadUri string                `json:"build_artifacts_cache_download_uri,omitempty"`
	FileDescriptors                int                   `json:"file_descriptors"`
	MemoryMB                       int                   `json:"memory_mb"`
	DiskMB                         int                   `json:"disk_mb"`
	Buildpacks                     []Buildpack           `json:"buildpacks"`
	Environment                    []EnvironmentVariable `json:"environment"`
}

type StagingResponseForCC

type StagingResponseForCC struct {
	AppId                string `json:"app_id,omitempty"`
	TaskId               string `json:"task_id,omitempty"`
	BuildpackKey         string `json:"buildpack_key,omitempty"`
	DetectedBuildpack    string `json:"detected_buildpack,omitempty"`
	DetectedStartCommand string `json:"detected_start_command,omitempty"`
	Error                string `json:"error,omitempty"`
}

type StagingTaskAnnotation

type StagingTaskAnnotation struct {
	AppId  string `json:"app_id"`
	TaskId string `json:"task_id"`
}

type StopLRPInstance

type StopLRPInstance struct {
	ProcessGuid  string `json:"process_guid"`
	InstanceGuid string `json:"instance_guid"`
	Index        int    `json:"index"`
}

func NewStopLRPInstanceFromJSON

func NewStopLRPInstanceFromJSON(payload []byte) (StopLRPInstance, error)

func (StopLRPInstance) LRPIdentifier

func (stop StopLRPInstance) LRPIdentifier() LRPIdentifier

func (StopLRPInstance) ToJSON

func (stop StopLRPInstance) ToJSON() []byte

type Task

type Task struct {
	Guid       string           `json:"guid"`
	Actions    []ExecutorAction `json:"actions"`
	Stack      string           `json:"stack"`
	MemoryMB   int              `json:"memory_mb"`
	DiskMB     int              `json:"disk_mb"`
	CpuPercent float64          `json:"cpu_percent"`
	Log        LogConfig        `json:"log"`
	CreatedAt  int64            `json:"created_at"` //  the number of nanoseconds elapsed since January 1, 1970 UTC
	UpdatedAt  int64            `json:"updated_at"`

	Type TaskType `json:"type"`

	State TaskState `json:"state"`

	ExecutorID string `json:"executor_id"`

	ContainerHandle string `json:"container_handle"`

	Result        string `json:"result"`
	Failed        bool   `json:"failed"`
	FailureReason string `json:"failure_reason"`

	Annotation string `json:"annotation,omitempty"`
}

func NewTaskFromJSON

func NewTaskFromJSON(payload []byte) (Task, error)

func (Task) ToJSON

func (task Task) ToJSON() []byte

type TaskState

type TaskState int
const (
	TaskStateInvalid TaskState = iota
	TaskStatePending
	TaskStateClaimed
	TaskStateRunning
	TaskStateCompleted
	TaskStateResolving
)

type TaskType

type TaskType string
const (
	TaskTypeStaging          TaskType = "Staging"
	TaskTypeDropletMigration TaskType = "DropletMigration"
)

type TryAction

type TryAction struct {
	Action ExecutorAction `json:"action"`
}

type UploadAction

type UploadAction struct {
	To       string `json:"to"`
	From     string `json:"from"`
	Compress bool   `json:"compress"`
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL