executor

type AllocationFailure struct {
	AllocationRequest
	ErrorMsg string
}

type AllocationRequest struct {
	Guid string
	Resource
	Tags
}

type Client interface {
	Ping() error
	AllocateContainers(requests []AllocationRequest) ([]AllocationFailure, error)
	GetContainer(guid string) (Container, error)
	RunContainer(*RunRequest) error
	StopContainer(guid string) error
	DeleteContainer(guid string) error
	ListContainers(Tags) ([]Container, error)
	GetAllMetrics(Tags) (map[string]Metrics, error)
	GetMetrics(guid string) (ContainerMetrics, error)
	RemainingResources() (ExecutorResources, error)
	RemainingResourcesFrom([]Container) (ExecutorResources, error)
	TotalResources() (ExecutorResources, error)
	GetFiles(guid string, path string) (io.ReadCloser, error)
	SubscribeToEvents() (EventSource, error)
	Cleanup()
}

type ClientProvider interface {
	WithLogger(logger lager.Logger) Client
}

type Container struct {
	Guid string `json:"guid"`
	Resource
	RunInfo
	Tags        Tags
	State       State              `json:"state"`
	AllocatedAt int64              `json:"allocated_at"`
	ExternalIP  string             `json:"external_ip"`
	RunResult   ContainerRunResult `json:"run_result"`
}

type ContainerCompleteEvent struct {
	RawContainer Container `json:"container"`
}

type ContainerMetrics struct {
	MemoryUsageInBytes uint64        `json:"memory_usage_in_bytes"`
	DiskUsageInBytes   uint64        `json:"disk_usage_in_bytes"`
	TimeSpentInCPU     time.Duration `json:"time_spent_in_cpu"`
}

type ContainerReservedEvent struct {
	RawContainer Container `json:"container"`
}

type ContainerRunResult struct {
	Failed        bool   `json:"failed"`
	FailureReason string `json:"failure_reason"`

	Stopped bool `json:"stopped"`
}

type ContainerRunningEvent struct {
	RawContainer Container `json:"container"`
}

type DiskLimitScope uint8

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

type Error interface {
	error

	Name() string
	HttpCode() int
}

type Event interface {
	EventType() EventType
}

type EventSource interface {
	Next() (Event, error)
	Close() error
}

type EventType string

type ExecutorResources struct {
	MemoryMB   int `json:"memory_mb"`
	DiskMB     int `json:"disk_mb"`
	Containers int `json:"containers"`
}

type InnerContainer Container

type LifecycleEvent interface {
	Container() Container
	// contains filtered or unexported methods
}

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

type Metrics struct {
	MetricsConfig
	ContainerMetrics
}

type MetricsConfig struct {
	Guid  string `json:"guid"`
	Index int    `json:"index"`
}

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

type Resource struct {
	MemoryMB   int    `json:"memory_mb"`
	DiskMB     int    `json:"disk_mb"`
	RootFSPath string `json:"rootfs"`
}

type RunInfo struct {
	CPUWeight     uint                        `json:"cpu_weight"`
	DiskScope     DiskLimitScope              `json:"disk_scope,omitempty"`
	Ports         []PortMapping               `json:"ports"`
	LogConfig     LogConfig                   `json:"log_config"`
	MetricsConfig MetricsConfig               `json:"metrics_config"`
	StartTimeout  uint                        `json:"start_timeout"`
	Privileged    bool                        `json:"privileged"`
	Setup         *models.Action              `json:"setup"`
	Action        *models.Action              `json:"run"`
	Monitor       *models.Action              `json:"monitor"`
	EgressRules   []*models.SecurityGroupRule `json:"egress_rules,omitempty"`
	Env           []EnvironmentVariable       `json:"env,omitempty"`
}

type RunRequest struct {
	Guid string
	RunInfo
	Tags
}

type State string

type Tags map[string]string

type WorkPoolSettings struct {
	CreateWorkPoolSize  int
	DeleteWorkPoolSize  int
	ReadWorkPoolSize    int
	MetricsWorkPoolSize int
}