ami

type AMI interface {
	// node
	CollectNodeInfo() (map[string]interface{}, error)
	CollectNodeStats() (map[string]interface{}, error)
	GetModeInfo() (interface{}, error)

	// app
	ApplyApp(string, specv1.Application, map[string]specv1.Configuration, map[string]specv1.Secret) error
	DeleteApp(string, string) error
	StatsApps(string) ([]specv1.AppStats, error)

	// TODO: update
	FetchLog(namespace, service string, tailLines, sinceSeconds int64) (io.ReadCloser, error)

	// RemoteCommand remote debug
	RemoteCommand(option *DebugOptions, pipe Pipe) error

	// RemoteWebsocket remote link
	RemoteWebsocket(ctx context.Context, option *DebugOptions, pipe Pipe) error

	// RemoteLogs remote logs
	RemoteLogs(option *LogsOptions, pipe Pipe) error

	UpdateNodeLabels(string, map[string]string) error

	// RPCApp call baetyl app from baetyl-core
	RPCApp(url string, req *specv1.RPCRequest) (*specv1.RPCResponse, error)
}

type CollectStatsExtFunc func(mode string) (map[string]interface{}, error)

type DebugOptions struct {
	KubeDebugOptions
	NativeDebugOptions
	WebsocketOptions
}

type KubeDebugOptions struct {
	Namespace string
	Name      string
	Container string
	Command   []string
}

type LogsOptions struct {
	Namespace    string
	Name         string
	Container    string
	SinceSeconds *int64
	TailLines    *int64
	LimitBytes   *int64
	Follow       bool
	Previous     bool
	Timestamps   bool
}

type NativeDebugOptions struct {
	IP       string
	Port     string
	Username string
	Password string
}

type New func(cfg config.AmiConfig) (AMI, error)

type Pipe struct {
	InReader  *io.PipeReader
	InWriter  *io.PipeWriter
	OutReader *io.PipeReader
	OutWriter *io.PipeWriter
}

type WebsocketOptions struct {
	Host string
	Path string
}