runtime

type AllocatedSocket interface {
	// isAllocatedSocket()
	proxy.ContextDialer
	io.Closer
	Conn() net.Conn
	Ready() error
}

type AllocatedSocketReference interface {
	ReferableByReferenceId
}

type AllocatedSocketWithUnixConn interface {
	AllocatedSocket
	UnixConn() *net.UnixConn
}

type BindableConsoleSocket interface {
	ConsoleSocket
	BindToAllocatedSocket(ctx context.Context, sock AllocatedSocket) error
}

type CgroupAdapter interface {
	Stat(ctx context.Context) (*stats.Metrics, error)
	ToggleControllers(ctx context.Context) error
	OpenEventChan(ctx context.Context) (<-chan *runmv1.CgroupEvent, <-chan error, error)
}

type CgroupEvent struct {
	Low         uint64
	High        uint64
	Max         uint64
	OOM         uint64
	OOMKill     uint64
	ContainerID string
}

type ConsoleSocket interface {
	ReceiveMaster() (console.Console, error)
	Path() string
	// UnixConn() *net.UnixConn
	Close() error
}

type EventHandler interface {
	Publish(ctx context.Context, event *PublishEvent) error

	Receive(ctx context.Context) (<-chan *PublishEvent, error)
}

type FileConn interface {
	syscall.Conn
	net.Conn
	Read(p []byte) (n int, err error)
	Write(p []byte) (n int, err error)
	Close() error
}

type GuestManagement interface {
	TimeSync(ctx context.Context, unixTimeNs uint64, timezone string) error
	Readiness(ctx context.Context) error
	RunCommand(ctx context.Context, cmd *exec.Cmd) error
}

type HostAllocatedStdio struct {
	StdinSocket  AllocatedSocket
	StdoutSocket AllocatedSocket
	StderrSocket AllocatedSocket

	ReferenceId string
	// contains filtered or unexported fields
}

type HostNullIo struct {
	IO
}

type IO interface {
	Stdin() io.WriteCloser
	Stdout() io.ReadCloser
	Stderr() io.ReadCloser
	Close() error
	// unused
	Set(cmd *exec.Cmd)
}

type Platform interface {
	CopyConsole(ctx context.Context, console io.ReadWriteCloser, id, stdin, stdout, stderr string, wg *sync.WaitGroup) (cons RuntimeConsole, retErr error)
	ShutdownConsole(ctx context.Context, console RuntimeConsole) error
	Close() error
}

type PublishEvent struct {
	Topic string
	Data  []byte
}

type ReferableByReferenceId interface {
	GetReferenceId() string
}

type Runtime interface {
	// SharedDir() string
	// io: yes
	// ✅
	NewPipeIO(ctx context.Context, cioUID, ioGID int, opts ...gorunc.IOOpt) (IO, error)
	// io: yes
	NewTempConsoleSocket(ctx context.Context) (ConsoleSocket, error)
	// io: yes
	// ✅
	NewNullIO() (IO, error)
	// io: yes
	// console: yes
	// channel: yes
	// fd: yes
	Create(ctx context.Context, id, bundle string, opts *gorunc.CreateOpts) error
	// io: yes
	// console: yes
	// channel: yes
	Exec(ctx context.Context, id string, spec specs.Process, opts *gorunc.ExecOpts) error
	// fd: yes
	Checkpoint(ctx context.Context, id string, opts *gorunc.CheckpointOpts, actions ...gorunc.CheckpointAction) error
	// io: yes
	Restore(ctx context.Context, id, bundle string, opts *gorunc.RestoreOpts) (int, error)
	// ✅
	Kill(ctx context.Context, id string, signal int, opts *gorunc.KillOpts) error
	Start(ctx context.Context, id string) error
	// ✅
	Delete(ctx context.Context, id string, opts *gorunc.DeleteOpts) error
	// ✅
	Update(ctx context.Context, id string, resources *specs.LinuxResources) error
	Pause(ctx context.Context, id string) error
	Resume(ctx context.Context, id string) error
	Ps(ctx context.Context, id string) ([]int, error)
	ReadPidFile(ctx context.Context, path string) (int, error)
	SubscribeToReaperExits(ctx context.Context) (<-chan gorunc.Exit, error)
	State(context.Context, string) (*gorunc.Container, error)
	RuncRun(context.Context, string, string, *gorunc.CreateOpts) (int, error)

	Close(ctx context.Context) error
}

type RuntimeConsole interface {
	console.File

	// Resize resizes the console to the provided window size
	Resize(console.WinSize) error
	// ResizeFrom resizes the calling console to the size of the
	// provided console
	ResizeFrom(RuntimeConsole) error
	// SetRaw sets the console in raw mode
	SetRaw() error
	// DisableEcho disables echo on the console
	DisableEcho() error
	// Reset restores the console to its original state
	Reset() error
	// Size returns the window size of the console
	Size() (console.WinSize, error)
}

type RuntimeCreator interface {
	Create(ctx context.Context, opts *RuntimeOptions) (Runtime, error)
	Features(ctx context.Context) (*features.Features, error)
}

type RuntimeExtras interface {

	// Stats returns runtime specific metrics for a container.
	Stats(context.Context, string) (*gorunc.Stats, error)

	// Events returns events for the container.
	Events(context.Context, string, time.Duration) (chan *gorunc.Event, error)

	// List lists all containers.
	List(context.Context) ([]*gorunc.Container, error)

	// Version returns the version of runc.
	Version(context.Context) (gorunc.Version, error)

	Top(context.Context, string, string) (*gorunc.TopResults, error)
}

type RuntimeOptions struct {
	ProcessCreateConfig *process.CreateConfig
	Mounts              []process.Mount
	Rootfs              string
	Namespace           string
	Publisher           events.Publisher
	OciSpec             *oci.Spec
	Bundle              string
	PdeathSignal        syscall.Signal
}

type ServerStateGetter interface {
	GetOpenIO(referenceId string) (IO, bool)
	GetOpenVsockConnection(port uint32) (VsockAllocatedSocket, bool)
	GetOpenUnixConnection(path string) (UnixAllocatedSocket, bool)
	GetOpenConsole(referenceId string) (ConsoleSocket, bool)
}

type ServerStateSetter interface {
	StoreOpenIO(referenceId string, io IO)
	StoreOpenSocket(referenceId string, socket AllocatedSocket)
	StoreOpenConsole(referenceId string, console ConsoleSocket)
}

type SocketAllocator interface {
	AllocateSocket(ctx context.Context) (AllocatedSocket, error)
}

type UnixAllocatedSocket interface {
	AllocatedSocket
	Path() string
}

type VsockAllocatedSocket interface {
	AllocatedSocket
	Port() uint32
}

type VsockFdProxier interface {
	ProxyFd(ctx context.Context, port uint32) (*net.Conn, uintptr, error)
}

type VsockProxier interface {
	ProxyVsock(ctx context.Context, port uint32) (net.Conn, error)
	ListenAndAcceptSingleVsockConnection(ctx context.Context, port uint32, dialCallback func(ctx context.Context) error) (net.Conn, error)
}