process.go

package local

import (
	"io"

	pb "github.com/datacol-io/datacol/api/models"
	"github.com/datacol-io/datacol/cloud"
	"github.com/datacol-io/datacol/common"
	sched "github.com/datacol-io/datacol/k8s"
)

func (g *LocalCloud) ProcessRun(name string, stream io.ReadWriter, opts pb.ProcessRunOptions) error {
	ns := g.Name
	cfg, err := getKubeClientConfig(ns)
	if err != nil {
		return err
	}

	app, _ := g.AppGet(name)
	envVars, _ := g.EnvironmentGet(name)

	return sched.ProcessRun(g.kubeClient(), cfg, ns, name, g.latestImage(app), opts, envVars, false, stream, cloud.LocalProvider)
}

func (g *LocalCloud) ProcessList(app string) ([]*pb.Process, error) {
	return sched.ProcessList(g.kubeClient(), g.Name, app)
}

func (g *LocalCloud) ProcessLimits(name, resource string, limits map[string]string) error {
	return sched.ProcessLimits(g.kubeClient(), g.Name, name, resource, limits)
}

func (g *LocalCloud) ProcessSave(name string, structure map[string]int32) error {
	app, err := g.AppGet(name)
	if err != nil {
		return err
	}

	build, err := g.BuildGet(app.Name, app.BuildId)
	if err != nil {
		return err
	}

	envVars, _ := g.EnvironmentGet(name)

	return common.ScaleApp(g.kubeClient(), g.Name, name, g.latestImage(app), envVars,
		false, build.Procfile, structure, cloud.LocalProvider)
}

func (a *LocalCloud) DockerCredsGet() (*pb.DockerCred, error) {
	return nil, nil
}