framework

type Application struct {
	sync.RWMutex
	Type                string            `yaml:"type,omitempty"`
	ID                  string            `yaml:"id,omitempty"`
	Version             string            `yaml:"version,omitempty"`
	Cpu                 float64           `yaml:"cpu,omitempty"`
	Mem                 float64           `yaml:"mem,omitempty"`
	Ports               []int             `yaml:"ports,omitempty"`
	Instances           string            `yaml:"instances,omitempty"`
	Constraints         [][]string        `yaml:"constraints,omitempty"`
	User                string            `yaml:"user,omitempty"`
	Healthcheck         string            `yaml:"healthcheck,omitempty"`
	LaunchCommand       string            `yaml:"launch_command,omitempty"`
	Args                []string          `yaml:"args,omitempty"`
	Env                 map[string]string `yaml:"env,omitempty"`
	ArtifactURLs        []string          `yaml:"artifact_urls,omitempty"`
	AdditionalArtifacts []string          `yaml:"additional_artifacts,omitempty"`
	Scheduler           map[string]string `yaml:"scheduler,omitempty"`
	Tasks               yaml.MapSlice     `yaml:"tasks,omitempty"`
	Dependencies        []string          `yaml:"dependencies,omitempty"`
	Docker              *Docker           `yaml:"docker,omitempty"`
	StartTime           string            `yaml:"start_time,omitempty"`
	TimeSchedule        string            `yaml:"time_schedule,omitempty"`

	BeforeScheduler []string `yaml:"before_scheduler,omitempty"`
	AfterScheduler  []string `yaml:"after_scheduler,omitempty"`
	BeforeTask      []string `yaml:"before_task,omitempty"`
	AfterTask       []string `yaml:"after_task,omitempty"`
	AfterTasks      []string `yaml:"after_tasks,omitempty"`
}

type ApplicationRunStatus struct {
	Application *Application
	Error       error
}

type ApplicationStatus int

type CassandraStateStorage struct {
	// contains filtered or unexported fields
}

type CassandraStorage struct {
	// contains filtered or unexported fields
}

type CassandraUserStorage struct {
	// contains filtered or unexported fields
}

type Client struct {
	// contains filtered or unexported fields
}

type CreateLayerRequest struct {
	Stackfile string `json:"stackfile"`
	Layer     string `json:"layer"`
	Parent    string `json:"parent"`
}

type CreateStackRequest struct {
	Stackfile string `json:"stackfile"`
}

type CreateUserRequest struct {
	Name string `json:"name"`
	Role string `json:"role"`
}

type CronScheduler interface {
	AddFunc(string, func()) (int64, error)
	DeleteJob(int64)
	Entries() []*cron.Entry
}

type Docker struct {
	ForcePullImage bool                 `yaml:"force_pull_image,omitempty"`
	Image          string               `yaml:"image,omitempty"`
	Network        string               `yaml:"network,omitempty"`
	Parameters     map[string]string    `yaml:"parameters,omitempty"`
	PortMappings   []*DockerPortMapping `yaml:"port_mappings,omitempty"`
	Privileged     bool                 `yaml:"privileged,omitempty"`
	Volumes        []*DockerVolume      `yaml:"volumes,omitempty"`
}

type DockerPortMapping struct {
	ContainerPort int    `yaml:"container_port,omitempty"`
	HostPort      int    `yaml:"host_port"`
	ServicePort   int    `yaml:"service_port,omitempty"`
	Protocol      string `yaml:"protocol"`
}

type DockerVolume struct {
	ContainerPath string `yaml:"container_path,omitempty"`
	HostPath      string `yaml:"host_path,omitempty"`
	Mode          string `yaml:"mode,omitempty"`
}

type FrameworkStorage struct {
	FrameworkID      string
	BootstrapContext *Variables
	// contains filtered or unexported fields
}

type GetStackRequest struct {
	Name string `json:"name"`
}

type InMemoryStateStorage struct {
	// contains filtered or unexported fields
}

type InMemoryStorage struct {
	// contains filtered or unexported fields
}

type Layer struct {
	Level int
	Stack *Stack
}

type Merger interface {
	Merge(*Stack)
	GetRunner() Runner
}

type MesosClusterState struct {
	ActivatedSlaves float64 `json:"activated_slaves"`
	Slaves          []Slave `json:"slaves"`
	// contains filtered or unexported fields
}

type MesosState interface {
	Update() error
	GetActivatedSlaves() int
	GetSlaves() []Slave
}

type MesosTaskRunner interface {
	ScheduleApplication(*Application, MesosState, CronScheduler) (int64, <-chan *ApplicationRunStatus)
	DeleteSchedule(int64, CronScheduler)
	StageApplication(application *Application, mesos MesosState) <-chan *ApplicationRunStatus
	ResourceOffer(driver scheduler.SchedulerDriver, offer *mesos.Offer) (string, error)
	StatusUpdate(driver scheduler.SchedulerDriver, status *mesos.TaskStatus) bool
}

type NoopUserStorage struct{}

type RefreshTokenRequest struct {
	Name string `json:"name"`
}

type RemoveScheduledRequest struct {
	ID int64 `json:"id"`
}

type RemoveStackRequest struct {
	Name  string `json:"name"`
	Force bool   `json:"force"`
}

type RunContext struct {
	StackName    string
	Zone         string
	Variables    *Variables
	Marathon     marathon.Marathon
	Scheduler    Scheduler
	StateStorage StateStorage
}

type RunRequest struct {
	Name             string            `json:"name"`
	Zone             string            `json:"zone"`
	MaxWait          int               `json:"maxwait"`
	Variables        map[string]string `json:"variables"`
	SkipApplications []string          `json:"skip"`
}

type Runner interface {
	Run(*RunRequest, *RunContext) error
	GetStack() *Stack
}

type ScheduledTask struct {
	ID           int64  `json:"id"`
	Name         string `json:"name"`
	StartTime    string `json:"start_time"`
	TimeSchedule string `json:"time_schedule"`
}

type Scheduler interface {
	Start() error
	RunApplication(application *Application) <-chan *ApplicationRunStatus
	GetMesosState() MesosState
	GetScheduledTasks() []*ScheduledTask
	RemoveScheduled(int64) bool
}

type SchedulerConfig struct {
	Master          string
	Storage         *FrameworkStorage
	User            string
	FrameworkName   string
	FrameworkRole   string
	FailoverTimeout time.Duration
}

type Slave struct {
	Active     bool                   `json:"active"`
	Attributes map[string]string      `json:"attributes"`
	Hostname   string                 `json:"hostname"`
	ID         string                 `json:"id"`
	PID        string                 `json:"pid"`
	Resources  map[string]interface{} `json:"resources"`
}

type Stack struct {
	Namespace    string
	Name         string                  `yaml:"name,omitempty"`
	From         string                  `yaml:"from,omitempty"`
	Applications map[string]*Application `yaml:"applications,omitempty"`
	Layer        int
}

type StackDeployScheduler struct {
	*SchedulerConfig

	Cron *cron.Cron
	// contains filtered or unexported fields
}

type StackDeployServer struct {
	// contains filtered or unexported fields
}

type StackState struct {
	Name         string
	Zone         string
	Status       StackStatus
	Variables    *Variables
	Applications map[string]ApplicationStatus
}

type StackStatus int

type StateStorage interface {
	SaveStackStatus(name string, zone string, status StackStatus) error
	SaveApplicationStatus(stack string, zone string, applicationName string, status ApplicationStatus) error
	SaveStackVariables(stack string, zone string, variables *Variables) error
	GetStackState(name string, zone string) (*StackState, error)
}

type Storage interface {
	GetAll() ([]*Stack, error)
	GetStack(string) (*Stack, error)
	GetStackRunner(string) (Runner, error)
	StoreStack(*Stack) error
	RemoveStack(string, bool) error
	Init() error
	GetLayersStack(string) (Merger, error)
}

type TaskRunner interface {
	FillContext(context *Variables, application *Application, task marathon.Task) error
	RunTask(context *Variables, application *Application, task map[string]string) error
}

type User struct {
	Name string   `json:"name"`
	Key  string   `json:"key"`
	Role UserRole `json:"role"`
}

type UserRole int

type UserStorage interface {
	SaveUser(User) error
	GetUser(string) (*User, error)
	CheckKey(string, string) (bool, error)
	IsAdmin(string) (bool, error)
	CreateUser(string, UserRole) (string, error)
	RefreshToken(string) (string, error)
}

type Variables struct {
	// contains filtered or unexported fields
}