Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
AgentEndpoint string
ContainerName string
ExecutorID string
FrameworkID string
}
Config represents an executor config, containing arguments passed by the agent and used to initialize a new executor
type Executor ¶
type Executor struct {
AgentInfo mesos.AgentInfo // AgentInfo contains agent info returned by the agent
Cli *httpcli.Client // Cli is the mesos HTTP cli
ContainerID string // Running container ID
Containerizer container.Containerizer // Containerize to use to manage containers
ContainerName string // Container named generated by mesos
ExecutorID string // Executor ID returned by the agent when running the executor
ExecutorInfo mesos.ExecutorInfo // Executor info returned by the agent after registration
FrameworkID string // Framework ID returned by the agent when running the executor
FrameworkInfo mesos.FrameworkInfo // Framework info returned by the agent after registration
Handler events.Handler // Handler to use to handle events
HealthChecker *healthcheck.Checker // Health checker for Mesos native health checks
HookManager *hook.Manager // Hooks manager
Shutdown bool // Shutdown the executor (used to stop loop event and gently kill the executor)
StopSignals chan os.Signal // Channel receiving stopping signals (SIGINT, SIGTERM, ...)
TaskInfo mesos.TaskInfo // Task info sent by the agent on launch event
UnackedMutex *sync.RWMutex // Mutex used to protect unacked tasks and updates maps
UnackedUpdates map[string]executor.Call_Update // Unacked updates (waiting for an acknowledgment from the agent)
}
Executor represents an executor
func NewExecutor ¶
func NewExecutor(config Config, containerizer container.Containerizer, hookManager *hook.Manager) *Executor
NewExecutor initializes a new executor with the given executor and framework ID
Click to show internal directories.
Click to hide internal directories.