cri

type AlpineStatus uint8

type Container struct {
	// container 可能会依赖底层实现, 因此这里不让它依赖具体的实现类
	Id string

	// 所属的pod
	Pod *Pod `json:"-"`

	// ContainerName example:
	// /k8s_POD_xxx
	// /k8s_xxx
	ContainerName string

	// K8sContainerName k8s container name
	K8sContainerName string

	// 常见状态
	State ContainerState

	// 容器常见配置
	Labels map[string]string
	Env    map[string]string

	// 挂载点 已经转换到hostfs
	Mounts []*MountPoint

	// docker 的 MergedDir 特有字段, 已经转换到hostfs
	MergedDir string

	ContainerRole ContainerRole

	// 该 container 所属的 pod 的 sandbox cid
	SandboxID string

	Tz TzInfo

	// 该容器是否已经被我们hack过
	Hacked int

	// pouch 场景, 只有登录到 container 里 才能获取 daemonset 的 hostname
	Hostname string

	// 运行时
	Runtime string

	// NetworkMode
	NetworkMode string

	// If PidMode is "host", it means that the container uses the pid namespace of the physical machine.
	PidMode string

	// docker json log: https://docs.docker.com/config/containers/logging/json-file/
	LogPath string

	// Attributes can be used to prevent arbitrary extension fields
	Attributes sync.Map

	// The number of zombie processes inside the container
	ZombieCount int

	// pid 1 process name
	Pid1Name string

	// Whether pid 1 has the ability to recycle zombie processes
	Pid1CanRecycleZombieProcesses bool
}

type ContainerEngine interface {
	// Init initializes the engine
	Init() error

	// Type returns engine type, such as "docker" "containerd"
	Type() string

	ListAllContainers(ctx context.Context) ([]*EngineSimpleContainer, error)

	GetContainerDetail(ctx context.Context, cid string) (*EngineDetailContainer, error)

	Exec(ctx context.Context, c *Container, req ExecRequest) (ExecResult, error)

	// ExecAsync runs command in target container
	ExecAsync(ctx context.Context, c *Container, req ExecRequest) (ExecAsyncResult, error)

	// CopyToContainer copies file from src(in agent) to dst(in container)
	CopyToContainer(ctx context.Context, c *Container, src, dst string) error

	// CopyFromContainer copies file from src(in container) to dst(in agent)
	CopyFromContainer(ctx context.Context, c *Container, src, dst string) error

	// Supports checks if engine supports the specified feature
	Supports(feature ContainerEngineFeature) bool
}

type ContainerEngineFeature uint8

type ContainerRole string

type ContainerState struct {
	Pid    int
	Status string
}

type EngineDetailContainer struct {
	ID          string
	Name        string
	Labels      map[string]string
	Env         []string
	Source      interface{}
	IsSandbox   bool
	SandboxId   string
	Hostname    string
	Runtime     string
	NetworkMode string
	PidMode     string
	MergedDir   string
	LogPath     string
	Mounts      []*MountPoint
	State       ContainerState
}

type EngineSimpleContainer struct {
	ID     string
	Labels map[string]string
	Source interface{}
}

type ExecAsyncResult struct {
	Cmd    string
	Result chan ExecAsyncResultCode
	Stdout io.Reader
	Stderr io.Reader
}

type ExecAsyncResultCode struct {
	Code int
	Err  error
}

type ExecRequest struct {
	Cmd        []string `json:"cmd"`
	Env        []string `json:"env"`
	WorkingDir string   `json:"workingDir"`
	Input      io.Reader
	// User is the user passed to docker exec, defaults to 'root'
	User                 string
	FixOut               bool
	NoWrapCmdWithTimeout bool
}

type ExecResult struct {
	Cmd      string
	ExitCode int
	Stdout   *bytes.Buffer
	Stderr   *bytes.Buffer
}

type Interface interface {
	MetaStore

	// CopyToContainer copies file to container
	CopyToContainer(ctx context.Context, c *Container, srcPath, dstPath string) error

	// CopyFromContainer copies file from container
	CopyFromContainer(ctx context.Context, c *Container, srcPath, dstPath string) error

	// Exec runs command in target container
	Exec(ctx context.Context, c *Container, req ExecRequest) (ExecResult, error)

	// ExecAsync runs command in target container
	ExecAsync(ctx context.Context, c *Container, req ExecRequest) (ExecAsyncResult, error)

	Start() error

	Stop()

	// Engine returns the underlying ContainerEngine
	Engine() ContainerEngine
}

type LocalAgentMeta interface {
	Namespace() string
	PodName() string
	PodIP() string
	NodeName() string
	NodeIP() string
	Node() *v1.Node
	IsLocalPod(pod *v1.Pod) bool
}

type MetaListener interface {
	OnAnyPodChanged()
}

type MetaStore interface {
	// GetAllPods returns all local pods
	GetAllPods() []*Pod

	// GetPod queries one local pod by namespace and podName.
	// Returns an error if not found.
	GetPod(namespace, podName string) (*Pod, error)

	// GetPod queries one local pod by its sandbox id.
	// Returns an error if not found.
	GetPodBySandboxId(sandboxId string) (*Pod, error)

	// GetContainerByCid queries one container by cid
	GetContainerByCid(cid string) (*Container, bool)

	LocalAgentMeta() LocalAgentMeta

	Start() error

	Stop()

	AddListener(MetaListener)
	RemoveListener(MetaListener)
}

type MountPoint struct {
	// Source is the path in agent (already starts with core.GetHostFs())
	Source string
	// Destination is the container path
	Destination string
	RW          bool
}

type NsEnterType uint8

type Pod struct {
	// 我们依赖k8s的模型是肯定的
	*v1.Pod
	// All containers
	All []*Container `json:"-"`
	// TODO 考虑大小为1, 改名为main
	Biz     []*Container `json:"biz"`
	Sidecar []*Container `json:"sidecar"`
	// Sandbox container
	Sandbox  *Container `json:"sandbox"`
	Hostname string     `json:"hostname"`
}

type TzInfo struct {
	Name   string
	TzObj  *time.Location `json:"-"`
	Zone   string
	Offset int

	// EtcLocaltime is timezone name read from /etc/localtime
	EtcLocaltime string
	// EnvTz is timezone name read from Env 'TZ'
	EnvTz string
}