stipulate engine interface: ResourceRemap

Author: jschwinger233

engine/docker/container.go

@@ -220,6 +220,10 @@ func (e *Engine) VirtualizationCreate(ctx context.Context, opts *enginetypes.Vir
 	return r, err
 }
 
+func (e *Engine) VirtualizationResourceRemap(ctx context.Context, opts *enginetypes.VirtualizationRemapOptions) (<-chan enginetypes.VirtualizationRemapMessage, error) {
+	return nil, nil
+}
+
 // VirtualizationCopyTo copy things to virtualization
 func (e *Engine) VirtualizationCopyTo(ctx context.Context, ID, target string, content io.Reader, AllowOverwriteDirWithFile, CopyUIDGID bool) error {
 	return withTarfileDump(target, content, func(target, tarfile string) error {

engine/engine.go

@@ -36,6 +36,7 @@ type API interface {
 	BuildContent(ctx context.Context, scm coresource.Source, opts *enginetypes.BuildContentOptions) (string, io.Reader, error)
 
 	VirtualizationCreate(ctx context.Context, opts *enginetypes.VirtualizationCreateOptions) (*enginetypes.VirtualizationCreated, error)
+	VirtualizationResourceRemap(context.Context, *enginetypes.VirtualizationRemapOptions) (<-chan enginetypes.VirtualizationRemapMessage, error)
 	VirtualizationCopyTo(ctx context.Context, ID, target string, content io.Reader, AllowOverwriteDirWithFile, CopyUIDGID bool) error
 	VirtualizationStart(ctx context.Context, ID string) error
 	VirtualizationStop(ctx context.Context, ID string, gracefulTimeout time.Duration) error

engine/mocks/API.go

@@ -53,6 +53,10 @@ func (s *SSHClient) VirtualizationCreate(ctx context.Context, opts *enginetypes.
 	}, errors.Wrap(err, stderr.String())
 }
 
+func (s *SSHClient) VirtualizationResourceRemap(ctx context.Context, opts *enginetypes.VirtualizationRemapOptions) (<-chan enginetypes.VirtualizationRemapMessage, error) {
+	return nil, nil
+}
+
 // VirtualizationCopyTo send bytes to file system
 func (s *SSHClient) VirtualizationCopyTo(ctx context.Context, ID, target string, content io.Reader, AllowOverwriteDirWithFile, _ bool) (err error) {
 	// mkdir -p $(dirname $PATH)

engine/systemd/virtualization.go

@@ -68,3 +68,15 @@ type VirtualizationWaitResult struct {
 	Message string
 	Code    int64
 }
+
+type VirtualizationRemapOptions struct {
+	CPUAvailable      map[string]int64
+	CPUInit           map[string]int64 // engine can be aware of oversell
+	CPUShareBase      int64
+	WorkloadResources map[string]VirtualizationResource
+}
+
+type VirtualizationRemapMessage struct {
+	ID string
+	VirtualizationResource
+}

engine/types/virtualization.go

@@ -173,6 +173,10 @@ func (v *Virt) VirtualizationCreate(ctx context.Context, opts *enginetypes.Virtu
 	return &enginetypes.VirtualizationCreated{ID: resp.ID, Name: opts.Name}, nil
 }
 
+func (v *Virt) VirtualizationResourceRemap(ctx context.Context, opts *enginetypes.VirtualizationRemapOptions) (<-chan enginetypes.VirtualizationRemapMessage, error) {
+	return nil, nil
+}
+
 // VirtualizationCopyTo copies one.
 func (v *Virt) VirtualizationCopyTo(ctx context.Context, ID, target string, content io.Reader, AllowOverwriteDirWithFile, CopyUIDGID bool) (err error) {
 	log.Warnf("VirtualizationCopyTo does not implement")