v1

type AllocatedNetwork interface {
	ID() string
	Type() NetworkType
	Gateway() net.IP
	Network() net.IPNet

	Deallocate() error

	WithSandboxUID(sandboxUID *types.UID) AllocatedNetwork
	SandboxUID() *types.UID
}

type ApiServer interface {
	Ready

	Context() context.Context
	Client() Client
	Done() <-chan struct{}
	CACerts() []*x509.Certificate

	Handler() http.Handler
	Server() *server.GenericAPIServer
	Destroy() error
}

type Backend interface {
	Ready

	cadvisor.Interface

	Nanokube() Nanokube
	Name() BackendName

	Driver() Driver
	Network() Network
	Manager() Manager
	Services() []*restful.WebService

	WithBaseURL(baseURL *url.URL) Backend

	Reconcile(obj interface{}, deleted bool)
}

type BackendFunc func(nano Nanokube) Backend

type BackendName string

type Client interface {
	Ready
	client.Interface
	Clientset() *client.Clientset
	InformerFactory() informers.SharedInformerFactory
	WithHeartbeat(interval time.Duration) Client
	WithQps(qps float32) Client
	WithTimeout(timeout time.Duration) Client
	WithTunnel(tunnel tunnel.Tunnel, local bool) Client

	Kubeconfig(name string) *clientcmdapi.Config
	WriteKubeconfig(path string) error
}

type DataDir string

type Driver interface {
	internalapi.ImageManagerService
	internalapi.RuntimeService
	NetworkService
	VolumeService

	Context() context.Context
	Name() string

	ExecOnHost(ctx context.Context, image string, cmd []string, mounts []Path) (string, error)
	ExecOnNetwork(ctx context.Context, network AllocatedNetwork, image string, cmd []string, portMap []PortMap) (string, error)

	CgroupRoot() string
	LogStream(containerID string, status *criv1.ContainerStatus) LogStream
	Service() *restful.WebService

	WithBaseURL(baseURL *url.URL) Driver
	BaseURL() *url.URL

	WithNetwork(network Network) Driver
	Network() Network
}

type Error interface {
	error
	exec.ExitError
	WithCommand(cmd []string) Error
	WithCode(code int) Error
	WithError(err error) Error
	WithErrors(errs ...error) Error
}

type FileName string

type Host interface {
	hostutil.HostUtils
	container.OSInterface
	volume.VolumePlugin
	subpath.Interface
	mount.Interface

	VolumePlugins() []volume.VolumePlugin
}

type LogStream interface {
	Start()
	Stop()
	Destroy()
	Stdout() io.ReadCloser
	Stderr() io.ReadCloser
}

type Manager interface {
	Ready

	cm.ContainerManager
	lifecycle.PodAdmitHandler
	cm.InternalContainerLifecycle
	cm.PodContainerManager
}

type Nanokube interface {
	context.Context
	record.EventRecorder
	record.EventRecorderLogger

	Options() Options

	WithCancel() (context.Context, context.CancelFunc)

	Cancel(reason Error)
	CancelErr(reason error)
	Errors() []error

	Backend(name BackendName) Backend
	DefaultBackend() Backend

	Host() Host
	Client() Client
	Tunnel() tunnel.Tunnel
	StaticPods() []*corev1.Pod

	Services(baseURL *url.URL) []*restful.WebService

	Environ() []string
	CertFilePath() string
	KeyFilePath() string
	RootCaFilePath() string
	WithLoopback(loopback *rest.Config) Nanokube
	KubeconfigPath() string
	NodeReady() <-chan struct{}
	NodeRef() *corev1.ObjectReference

	Storage() Storage
	SetSharedInformerFactory(factory informers.SharedInformerFactory) informers.SharedInformerFactory
	SharedInformerFactory() informers.SharedInformerFactory
}

type Network interface {
	Networks() []AllocatedNetwork
	FromID(ctx context.Context, id string) (AllocatedNetwork, error)
	FromIP(ctx context.Context, ip net.IP) (AllocatedNetwork, error)
	FromUID(ctx context.Context, sandboxUID types.UID) (AllocatedNetwork, error)
	FromStatus(ctx context.Context, status *criv1.PodSandboxStatus) (AllocatedNetwork, error)
	FromConfig(ctx context.Context, config *criv1.PodSandboxConfig) (AllocatedNetwork, error)
	Default(ctx context.Context) AllocatedNetwork
}

type NetworkService interface {
	Context() context.Context
	GetNetwork(ctx context.Context, id string) (*NetworkType, *net.IP, *net.IPNet, error)
	CreateNetwork(ctx context.Context, networkType NetworkType, net *net.IPNet, gateway *net.IP) (string, error)
	RemoveNetwork(ctx context.Context, id string) error
}

type NetworkType string

type Options interface {
	Name() string
	Verbosity() int
	DataDir() DataDir

	DataDirAt(name DataDir) string
	FilePathAt(file FileName) string
	InDataDir(path string) bool

	Args() []string
}

type Path string

type PortMap interface {
	Local() int32
	Remote() int32
	Protocol() Protocol
}

type Protocol corev1.Protocol

type Ready interface {
	Ready() <-chan struct{}
}

type ServiceName string

type Storage interface {
	generic.RESTOptionsGetter

	SetConfig(config *server.Config) *server.Config
	WithResource(inner kubestorage.Interface, resource schema.GroupResource) StorageClient

	Servers() []string
	Shutdown()
}

type StorageClient interface {
	kubestorage.Interface
}

type TunnelName string

type VolumeService interface {
	ClaimVolume(backend Backend, client Client, pvc *corev1.PersistentVolumeClaim) *corev1ac.PersistentVolumeClaimApplyConfiguration
	CreateVolume(pv *corev1.LocalVolumeSource) error
	DeleteVolume(pv *corev1.LocalVolumeSource) error
	ReleaseVolume(backend Backend, client Client, pvc *corev1.PersistentVolumeClaim) error
}