executor

type AllocationFailure struct {
	AllocationRequest
	ErrorMsg string
}

type AllocationRequest struct {
	Guid               string
	GenerateLogMetrics bool
	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, traceID string, requests []AllocationRequest) []AllocationFailure
	GetContainer(logger lager.Logger, guid string) (Container, error)
	RunContainer(lager.Logger, string, *RunRequest) error
	UpdateContainer(lager.Logger, *UpdateRequest) error
	StopContainer(logger lager.Logger, traceID string, guid string) error
	DeleteContainer(logger lager.Logger, traceID string, 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"`
	Routable                              bool               `json:"routable"`
	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"`
	AdvertisePreferenceForInstanceAddress bool               `json:"advertise_preference_for_instance_address"`
}

type ContainerCompleteEvent struct {
	RawContainer Container `json:"container"`
	// contains filtered or unexported fields
}

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"`
	AbsoluteCPUEntitlementInNanoseconds uint64        `json:"absolute_cpu_entitlement_in_ns"`
	ContainerAgeInNanoseconds           uint64        `json:"container_age_in_ns"`
	RxInBytes                           *uint64       `json:"rx_in_bytes"`
	TxInBytes                           *uint64       `json:"tx_in_bytes"`
}

type ContainerReservedEvent struct {
	RawContainer Container `json:"container"`
	// contains filtered or unexported fields
}

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

	Stopped bool `json:"stopped"`
}

type ContainerRunningEvent struct {
	RawContainer Container `json:"container"`
	// contains filtered or unexported fields
}

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

type Error interface {
	error

	Name() string
}

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 {
	TraceID() string
	Container() Container
	// contains filtered or unexported methods
}

type LogConfig struct {
	Guid       string            `json:"guid"`
	Index      int               `json:"index"`
	SourceName string            `json:"source_name"`
	Tags       map[string]string `json:"tags"`
}

type Metrics struct {
	MetricsConfig
	ContainerMetrics
}

type MetricsConfig struct {
	Guid  string            `json:"guid"`
	Index int               `json:"index"`
	Tags  map[string]string `json:"tags"`
}

type Network struct {
	Properties map[string]string `json:"properties,omitempty"`
}

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

type ProxyPortMapping struct {
	AppPort   uint16 `json:"app_port"`
	ProxyPort uint16 `json:"proxy_port"`
}

type Resource struct {
	MemoryMB int `json:"memory_mb"`
	DiskMB   int `json:"disk_mb"`
	MaxPids  int `json:"max_pids"`
}

type RunInfo struct {
	RootFSPath                    string                        `json:"rootfs"`
	CPUWeight                     uint                          `json:"cpu_weight"`
	Ports                         []PortMapping                 `json:"ports"`
	InternalRoutes                internalroutes.InternalRoutes `json:"internal_routes"`
	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"`
	EnableContainerProxy          bool                          `json:"enable_container_proxy"`
	Sidecars                      []Sidecar                     `json:"sidecars"`
	LogRateLimitBytesPerSecond    int64                         `json:"log_rate_limit_bytes_per_second"`
}

type RunRequest struct {
	Guid string
	RunInfo
	Tags
}

type Sidecar struct {
	Action   *models.Action `json:"run"`
	DiskMB   int32          `json:"disk_mb"`
	MemoryMB int32          `json:"memory_mb"`
}

type State string

type Tags map[string]string

type UpdateRequest struct {
	Guid           string
	InternalRoutes internalroutes.InternalRoutes
	MetricTags     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"`
}