plugin

type ComposePlugin interface {
	// Name gets the name of the plugin
	Name() string

	// execute some tasks before the Image is pulled
	LaunchTaskPreImagePull(ctx context.Context, composeFiles *[]string, executorId string, taskInfo *mesos.TaskInfo) error

	// execute some tasks after the Image is pulled
	LaunchTaskPostImagePull(ctx context.Context, composeFiles *[]string, executorId string, taskInfo *mesos.TaskInfo) error

	// execute the tasks after the pod is launched
	PostLaunchTask(ctx context.Context, composeFiles []string, taskInfo *mesos.TaskInfo) (string, error)

	// execute the task before we send a Kill to Mesos
	PreKillTask(ctx context.Context, taskInfo *mesos.TaskInfo) error

	// execute the task after we send a Kill to Mesos
	PostKillTask(ctx context.Context, taskInfo *mesos.TaskInfo) error

	// execute the task to shutdown the pod
	Shutdown(taskInfo *mesos.TaskInfo, ed executor.ExecutorDriver) error
}

type Monitor interface {
	Start(ctx context.Context) (types.PodStatus, error)
}

type PodStatusHook interface {
	//  TaskInfoInitializer is invoked to initialize the hook with TaskInfo
	TaskInfoInitializer(ctx context.Context, data interface{}) error
	// Execute is invoked when the pod.taskStatusCh channel has a new status. It returns an error on failure,
	// and also a flag "failExec" indicating if the error needs to fail the execution when a series of hooks are executed
	// This is to support cases where a few hooks can be executed in a best effort manner and need not fail the executor
	Execute(ctx context.Context, podStatus string, data interface{}) (failExec bool, err error)

	// This will be called from the pod.stopDriver. This will be used to end anything which needs clean-up at the end
	// of the executor
	Shutdown(ctx context.Context, podStatus string, data interface{})
}