executor

package module

Go to main page

Versions in this module

v0

v0.1442.0

Feb 27, 2024

Changes in this version

+ const ContainerOwnerProperty

+ const ContainerStateProperty

+ const HealthcheckTag

+ const HealthcheckTagValue

+ var ErrNoProcessToStop = registerError("ErrNoProcessToStop", "failed to find a process to stop")

type AllocationRequest

+ GenerateLogMetrics bool

+ type BindMountMode uint8

+ const BindMountModeRO

+ const BindMountModeRW

+ type CachedDependency struct

+ CacheKey string

+ ChecksumAlgorithm string

+ ChecksumValue string

+ From string

+ LogSource string

+ Name string

+ To string

+ type CertificateProperties struct

+ OrganizationalUnit []string

type Client

+ GetBulkMetrics func(lager.Logger) (map[string]Metrics, error)

+ Healthy func(lager.Logger) bool

+ SetHealthy func(lager.Logger, bool)

+ UpdateContainer func(lager.Logger, *UpdateRequest) error

+ VolumeDrivers func(logger lager.Logger) ([]string, error)

type Container

+ AdvertisePreferenceForInstanceAddress bool

+ DiskLimit uint64

+ InternalIP string

+ MemoryLimit uint64

+ Routable bool

+ func (c *Container) IsCreated() bool

+ func (c *Container) TransitionToComplete(failed bool, failureReason string, retryable bool)

+ func (c *Container) TransitionToCreate() error

+ func (c *Container) TransitionToInitialize(req *RunRequest) error

+ func (c *Container) ValidateTransitionTo(newState State) bool

type ContainerCompleteEvent

+ func (e ContainerCompleteEvent) TraceID() string

type ContainerMetrics

+ AbsoluteCPUEntitlementInNanoseconds uint64

+ ContainerAgeInNanoseconds uint64

+ DiskLimitInBytes uint64

+ MemoryLimitInBytes uint64

+ RxInBytes *uint64

+ TxInBytes *uint64

type ContainerReservedEvent

+ func (e ContainerReservedEvent) TraceID() string

type ContainerRunResult

+ Retryable bool

type ContainerRunningEvent

+ func (e ContainerRunningEvent) TraceID() string

type ExecutorResources

+ func (e ExecutorResources) Copy() ExecutorResources

+ func (r *ExecutorResources) Add(res *Resource)

type LifecycleEvent

+ TraceID func() string

type LogConfig

+ Tags map[string]string

+ func (l LogConfig) GetSourceNameAndTagsForLogging() (string, map[string]string)

type MetricsConfig

+ Tags map[string]string

+ type Network struct

+ Properties map[string]string

type PortMapping

+ ContainerTLSProxyPort uint16

+ HostTLSProxyPort uint16

+ type ProxyPortMapping struct

+ AppPort uint16

+ ProxyPort uint16

type Resource

+ MaxPids int

type RunInfo

+ CachedDependencies []CachedDependency

+ CertificateProperties CertificateProperties

+ CheckDefinition *models.CheckDefinition

+ EnableContainerProxy bool

+ ImagePassword string

+ ImageUsername string

+ InternalRoutes internalroutes.InternalRoutes

+ LogRateLimitBytesPerSecond int64

+ Network *Network

+ RootFSPath string

+ Sidecars []Sidecar

+ StartTimeoutMs uint

+ TrustedSystemCertificatesPath string

+ VolumeMounts []VolumeMount

+ type Sidecar struct

+ Action *models.Action

+ DiskMB int32

+ MemoryMB int32

+ type UpdateRequest struct

+ Guid string

+ InternalRoutes internalroutes.InternalRoutes

+ MetricTags map[string]string

+ func NewUpdateRequest(guid string, internalRoutes internalroutes.InternalRoutes, ...) UpdateRequest

+ type VolumeMount struct

+ Config map[string]interface{}

+ ContainerPath string

+ Driver string

+ Mode BindMountMode

+ VolumeId string

v0.1441.2

Jan 13, 2016

Changes in this version

+ var ErrContainerGuidNotAvailable = registerError("ContainerGuidNotAvailable", "container guid not available", ...)

+ var ErrContainerNotCompleted = registerError("ContainerNotCompleted", "container must be stopped before it can be deleted", ...)

+ var ErrContainerNotFound = registerError("ContainerNotFound", "container not found", http.StatusNotFound)

+ var ErrFailureToCheckSpace = registerError("ErrFailureToCheckSpace", "failed to check available space", ...)

+ var ErrGuidNotSpecified = registerError("GuidNotSpecified", "container guid not specified", http.StatusBadRequest)

+ var ErrInsufficientResourcesAvailable = registerError("InsufficientResourcesAvailable", "insufficient resources available", ...)

+ var ErrInvalidSecurityGroup = registerError("ErrInvalidSecurityGroup", "security group has invalid values", ...)

+ var ErrInvalidTransition = registerError("InvalidStateTransition", "container cannot transition to given state", ...)

+ var ErrLimitsInvalid = registerError("LimitsInvalid", "container limits invalid", http.StatusBadRequest)

+ var ErrStepsInvalid = registerError("StepsInvalid", "steps invalid", http.StatusBadRequest)

+ var ErrUnknownEventType = errors.New("unknown event type")

+ var Errors = map[string]Error

+ func EnvironmentVariablesToModel(envVars []EnvironmentVariable) []models.EnvironmentVariable

+ type AllocationFailure struct

+ ErrorMsg string

+ func NewAllocationFailure(req *AllocationRequest, msg string) AllocationFailure

+ func (fail *AllocationFailure) Error() string

+ type AllocationRequest struct

+ Guid string

+ func NewAllocationRequest(guid string, resource *Resource, tags Tags) AllocationRequest

+ func (a *AllocationRequest) Validate() error

+ type Client interface

+ AllocateContainers func(requests []AllocationRequest) ([]AllocationFailure, error)

+ Cleanup func()

+ DeleteContainer func(guid string) error

+ GetAllMetrics func(Tags) (map[string]Metrics, error)

+ GetContainer func(guid string) (Container, error)

+ GetFiles func(guid string, path string) (io.ReadCloser, error)

+ GetMetrics func(guid string) (ContainerMetrics, error)

+ ListContainers func(Tags) ([]Container, error)

+ Ping func() error

+ RemainingResources func() (ExecutorResources, error)

+ RemainingResourcesFrom func([]Container) (ExecutorResources, error)

+ RunContainer func(*RunRequest) error

+ StopContainer func(guid string) error

+ SubscribeToEvents func() (EventSource, error)

+ TotalResources func() (ExecutorResources, error)

+ type ClientProvider interface

+ WithLogger func(logger lager.Logger) Client

+ type Container struct

+ AllocatedAt int64

+ ExternalIP string

+ Guid string

+ RunResult ContainerRunResult

+ State State

+ Tags Tags

+ func NewContainerFromResource(guid string, resource *Resource, tags Tags) Container

+ func NewReservedContainerFromAllocationRequest(req *AllocationRequest, allocatedAt int64) Container

+ func (c *Container) HasTags(tags Tags) bool

+ func (newContainer Container) Copy() Container

+ type ContainerCompleteEvent struct

+ RawContainer Container

+ func NewContainerCompleteEvent(container Container) ContainerCompleteEvent

+ func (ContainerCompleteEvent) EventType() EventType

+ func (e ContainerCompleteEvent) Container() Container

+ type ContainerMetrics struct

+ DiskUsageInBytes uint64

+ MemoryUsageInBytes uint64

+ TimeSpentInCPU time.Duration

+ type ContainerReservedEvent struct

+ RawContainer Container

+ func NewContainerReservedEvent(container Container) ContainerReservedEvent

+ func (ContainerReservedEvent) EventType() EventType

+ func (e ContainerReservedEvent) Container() Container

+ type ContainerRunResult struct

+ Failed bool

+ FailureReason string

+ Stopped bool

+ type ContainerRunningEvent struct

+ RawContainer Container

+ func NewContainerRunningEvent(container Container) ContainerRunningEvent

+ func (ContainerRunningEvent) EventType() EventType

+ func (e ContainerRunningEvent) Container() Container

+ type DiskLimitScope uint8

+ const ExclusiveDiskLimit

+ const TotalDiskLimit

+ type EnvironmentVariable struct

+ Name string

+ Value string

+ func EnvironmentVariablesFromModel(envVars []*models.EnvironmentVariable) []EnvironmentVariable

+ type Error interface

+ HttpCode func() int

+ Name func() string

+ type Event interface

+ EventType func() EventType

+ type EventSource interface

+ Close func() error

+ Next func() (Event, error)

+ type EventType string

+ const EventTypeContainerComplete

+ const EventTypeContainerReserved

+ const EventTypeContainerRunning

+ const EventTypeInvalid

+ type ExecutorResources struct

+ Containers int

+ DiskMB int

+ MemoryMB int

+ func NewExecutorResources(memoryMB, diskMB, containers int) ExecutorResources

+ func (r *ExecutorResources) Subtract(res *Resource) bool

+ type InnerContainer Container

+ type LifecycleEvent interface

+ Container func() Container

+ type LogConfig struct

+ Guid string

+ Index int

+ SourceName string

+ type Metrics struct

+ type MetricsConfig struct

+ Guid string

+ Index int

+ type PortMapping struct

+ ContainerPort uint16

+ HostPort uint16

+ type Resource struct

+ DiskMB int

+ MemoryMB int

+ RootFSPath string

+ func NewResource(memoryMB, diskMB int, rootFSPath string) Resource

+ type RunInfo struct

+ Action *models.Action

+ CPUWeight uint

+ DiskScope DiskLimitScope

+ EgressRules []*models.SecurityGroupRule

+ Env []EnvironmentVariable

+ LogConfig LogConfig

+ MetricsConfig MetricsConfig

+ Monitor *models.Action

+ Ports []PortMapping

+ Privileged bool

+ Setup *models.Action

+ StartTimeout uint

+ type RunRequest struct

+ Guid string

+ func NewRunRequest(guid string, runInfo *RunInfo, tags Tags) RunRequest

+ type State string

+ const StateCompleted

+ const StateCreated

+ const StateInitializing

+ const StateInvalid

+ const StateReserved

+ const StateRunning

+ type Tags map[string]string

+ func (t Tags) Add(other Tags)

+ func (t Tags) Copy() Tags

+ type WorkPoolSettings struct

+ CreateWorkPoolSize int

+ DeleteWorkPoolSize int

+ MetricsWorkPoolSize int

+ ReadWorkPoolSize int

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