executor

type AllocationFailure struct {
	AllocationRequest
	ErrorMsg string
}

type AllocationRequest struct {
	Guid string
	Resource
	Tags
}

type BindMountMode uint8

type CachedDependency struct {
	Name              string `json:"name"`
	From              string `json:"from"`
	To                string `json:"to"`
	CacheKey          string `json:"cache_key"`
	LogSource         string `json:"log_source"`
	ChecksumValue     string `json:"checksum_value"`
	ChecksumAlgorithm string `json:"checksum_algorithm"`
}

type CertificateProperties struct {
	OrganizationalUnit []string `json:"organizational_unit"`
}

type Client interface {
	Ping(logger lager.Logger) error
	AllocateContainers(logger lager.Logger, requests []AllocationRequest) ([]AllocationFailure, error)
	GetContainer(logger lager.Logger, guid string) (Container, error)
	RunContainer(lager.Logger, *RunRequest) error
	StopContainer(logger lager.Logger, guid string) error
	DeleteContainer(logger lager.Logger, guid string) error
	ListContainers(lager.Logger) ([]Container, error)
	GetBulkMetrics(lager.Logger) (map[string]Metrics, error)
	RemainingResources(lager.Logger) (ExecutorResources, error)
	TotalResources(lager.Logger) (ExecutorResources, error)
	GetFiles(logger lager.Logger, guid string, path string) (io.ReadCloser, error)
	VolumeDrivers(logger lager.Logger) ([]string, error)
	SubscribeToEvents(lager.Logger) (EventSource, error)
	Healthy(lager.Logger) bool
	SetHealthy(lager.Logger, bool)
	Cleanup(lager.Logger)
}

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"`
	InternalIP  string             `json:"internal_ip"`
	RunResult   ContainerRunResult `json:"run_result"`
	MemoryLimit uint64             `json:"memory_limit"`
	DiskLimit   uint64             `json:"disk_limit"`
}

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

type ContainerMetrics struct {
	MemoryUsageInBytes uint64        `json:"memory_usage_in_bytes"`
	DiskUsageInBytes   uint64        `json:"disk_usage_in_bytes"`
	MemoryLimitInBytes uint64        `json:"memory_limit_in_bytes"`
	DiskLimitInBytes   uint64        `json:"disk_limit_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 Network struct {
	Properties map[string]string `json:"properties,omitempty"`
}

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"`
	MaxPids    int    `json:"max_pids"`
	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"`
	StartTimeoutMs                uint                        `json:"start_timeout_ms"`
	Privileged                    bool                        `json:"privileged"`
	CachedDependencies            []CachedDependency          `json:"cached_dependencies"`
	Setup                         *models.Action              `json:"setup"`
	Action                        *models.Action              `json:"run"`
	Monitor                       *models.Action              `json:"monitor"`
	CheckDefinition               *models.CheckDefinition     `json:"check_definition"`
	EgressRules                   []*models.SecurityGroupRule `json:"egress_rules,omitempty"`
	Env                           []EnvironmentVariable       `json:"env,omitempty"`
	TrustedSystemCertificatesPath string                      `json:"trusted_system_certificates_path,omitempty"`
	VolumeMounts                  []VolumeMount               `json:"volume_mounts"`
	Network                       *Network                    `json:"network,omitempty"`
	CertificateProperties         CertificateProperties       `json:"certificate_properties"`
	ImageUsername                 string                      `json:"image_username"`
	ImagePassword                 string                      `json:"image_password"`
}

type RunRequest struct {
	Guid string
	RunInfo
	Tags
}

type State string

type Tags map[string]string

type VolumeMount struct {
	Driver        string                 `json:"driver"`
	VolumeId      string                 `json:"volume_id"`
	Config        map[string]interface{} `json:"config"`
	ContainerPath string                 `json:"container_path"`
	Mode          BindMountMode          `json:"mode"`
}

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