engine

type BaseRuntime struct {
	Healthst  HealthState
	State     RunState
	OOMkilled bool
	LastError string
	UpdatedAt time.Time
}

type CloudVolumeSpec struct {
	Type string
	Dirs []string
}

type ConstraintSpec struct {
	Type  string
	Equal bool
	Value string
	Soft  bool
}

type Container struct {
	// FIXME(mijia): multiple ports supporing, will have multiple entries of <NodePort, ContainerPort, Protocol>
	Id            string
	Runtime       adoc.ContainerDetail
	NodeName      string
	NodeIp        string
	ContainerIp   string
	NodePort      int
	ContainerPort int
	Protocol      string
}

type ContainerLabel struct {
	Name           string
	Namespace      string
	InstanceNo     int
	Version        int
	DriftCount     int
	ContainerIndex int
	Annotation     string
}

type ContainerSpec struct {
	ImSpec
	Image         string
	Env           []string
	User          string
	WorkingDir    string
	DnsSearch     []string
	Volumes       []string // a stateful flag
	SystemVolumes []string // not a stateful flag, every node has system volumes
	CloudVolumes  []CloudVolumeSpec
	Command       []string
	Entrypoint    []string
	CpuLimit      int
	MemoryLimit   int64
	Expose        int
	LogConfig     adoc.LogConfig
}

type Dependency struct {
	PodName string
	Policy  DependencyPolicy
}

type DependencyEvent struct {
	Type      string // add, remove, verify
	Name      string
	NodeName  string
	Namespace string
}

type DependencyPolicy int

type Guard struct {
	Working bool `json:"Working"`
}

type HealthCnfOptions struct {
	Interval int `json:"interval"`
	Timeout  int `json:"timeout"`
	Retries  int `json:"retries"`
}

type HealthConfig struct {
	Cmd     string           `json:"cmd"`
	Options HealthCnfOptions `json:"options"`
}

type HealthState int

type ImRuntime struct {
	BaseRuntime
	DriftCount   int
	RestartCount int
	RestartAt    time.Time
}

type ImSpec struct {
	Name      string
	Namespace string
	Version   int
	CreatedAt time.Time
	UpdatedAt time.Time
}

type Listener interface {
	ListenerId() string
	HandleEvent(payload interface{})
}

type NamespacePodsWithSpec struct {
	Spec PodSpec
	Pods map[string][]Pod
}

type NotifySpec struct {
	Level      string
	Namespace  string
	PodName    string
	InstanceNo int
	Timestamp  time.Time
	Message    string
}

type OrcEngine struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Pod struct {
	InstanceNo int
	Containers []Container
	ImRuntime
}

type PodGroup struct {
	Pods []Pod
	BaseRuntime
}

type PodGroupPrevState struct {
	Nodes []string
	// we think a instance only have one ip, as now a instance only have one container.
	IPs []string
}

type PodGroupSpec struct {
	ImSpec
	Pod           PodSpec
	NumInstances  int
	RestartPolicy RestartPolicy
}

type PodGroupWithSpec struct {
	Spec      PodGroupSpec
	PrevState []PodPrevState
	PodGroup
}

type PodPrevState struct {
	NodeName string
	IPs      []string
}

type PodSpec struct {
	ImSpec
	Network      string
	Containers   []ContainerSpec
	Filters      []string // for cluster scheduling
	Labels       map[string]string
	Dependencies []Dependency
	Annotation   string
	Stateful     bool
	SetupTime    int
	KillTimeout  int
	PrevState    PodPrevState
	HealthConfig HealthConfig
}

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

type Publisher interface {
	EmitEvent(payload interface{})
	AddListener(subscriber Listener)
	RemoveListener(subscriber Listener)
}

type Resource struct {
	Cpu    int    `json:"cpu"`
	Memory string `json:"memory"`
}

type RestartPolicy int

type RunState int

type RuntimeEaglePod struct {
	ContainerLabel
	Container   adoc.Container
	ParseSource string
}

type RuntimeEagleView struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type SharedPodWithSpec struct {
	RefCount   int
	VerifyTime time.Time
	Spec       PodSpec
	Pod        Pod
}

type StreamPort struct {
	SrcPort int    `json:"srcport"`
	DstPort int    `json:"dstport"`
	Proto   string `json:"proto"`
}

type StreamPorts struct {
	Ports []StreamPort `json:"ports"`
}

type StreamProc struct {
	StreamPort
	NameSpace string
	ProcName  string
}