ctr

type AuthCredentials struct {
	UserID   string
	Password string
}

type ContainerAPIClient interface {
	// DestroyContainer kill container and delete it
	DestroyContainer(ctx context.Context, container *types.Container, stopOpts *types.StopOpts, clearIOs bool) (int64, time.Time, error)

	// CreateContainer creates all resources needed in the underlying container management so that a container can be successfully started
	CreateContainer(ctx context.Context, container *types.Container, checkpointDir string) error

	// StartContainer starts the underlying container
	StartContainer(ctx context.Context, container *types.Container, checkpointDir string) (int64, error)

	// GetContainerStats retrieves container stats - CPU, memory, IO and PIDs number, and the time they have been measured
	GetContainerStats(ctx context.Context, container *types.Container) (*types.CPUStats, *types.MemoryStats, *types.IOStats, uint64, time.Time, error)

	// AttachContainer attaches to the container's IO
	AttachContainer(ctx context.Context, container *types.Container, attachConfig *streams.AttachConfig) error

	// PauseContainer pauses a container
	PauseContainer(ctx context.Context, container *types.Container) error

	// UnpauseContainer unpauses a container
	UnpauseContainer(ctx context.Context, container *types.Container) error

	// RestoreContainer restores the container information from the underlying container management client along with initialization of all needed resources - streams, etc.
	RestoreContainer(ctx context.Context, container *types.Container) error

	// Dispose manages stop and dispose the containers client
	Dispose(ctx context.Context) error

	// ListContainers lists all created containers
	ListContainers(ctx context.Context) ([]*types.Container, error)

	// GetContainerInfo provides detailed information about a container
	GetContainerInfo(ctx context.Context, id string) (*types.Container, error)

	// ReleaseContainerResources releases all locally allocated resources for the container by the client implementation - e.g. streams, etc.
	ReleaseContainerResources(ctx context.Context, container *types.Container) error

	// SetContainerExitHooks provides access for hooking a clearing logic to the containers resources management on exit
	SetContainerExitHooks(hooks ...ContainerExitHook)

	//UpdateContainer updates container resource limits
	UpdateContainer(ctx context.Context, container *types.Container, resources *types.Resources) error
}

type ContainerExitHook func(*types.Container, int64, error, bool, func() error) error

type ContainerOpts func(ctrOptions *ctrOpts) error

type IO interface {
	// InitContainerIO will start logger and coping data from fifo
	InitContainerIO(dio *cio.DirectIO) (cio.IO, error)
	// SetLogDriver sets log driver to the IO
	SetLogDriver(logDriver logger.LogDriver)
	// SetMaxBufferSize set the max size of buffer.
	SetMaxBufferSize(maxBufferSize int64)
	// SetNonBlock whether to cache the container's logs with buffer
	SetNonBlock(nonBlock bool)
	// Stream is used to export the stream field
	Stream() streams.Stream
	// UseStdin returns whether the STDIN stream should also be attached
	UseStdin() bool
	// Wait wait for coping-data job
	Wait()
	// Close closes the stream and the logger
	Close() error
	// Reset resets the allocated streams
	Reset()
}

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

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

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

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

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

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

type RegistryConfig struct {
	IsInsecure  bool
	Credentials *AuthCredentials
	Transport   *TLSConfig
}

type TLSConfig struct {
	RootCA     string
	ClientCert string
	ClientKey  string
}