kubengine

Documentation

Index

• func ToV1Env(envs []internaltypes.Env) *[]v1.EnvVar
• type Client
  • func NewClient() (*Client, error)
  • func (c *Client) CreatePod(ctx context.Context, name string, image string, s internaltypes.Stage, ...) (error, v1.Pod)
  • func (c *Client) CreateVolume(ctx context.Context) (string, *v1.PersistentVolumeClaim)
  • func (c *Client) DeletePod(ctx context.Context, name string) error
  • func (c *Client) GetPodExitCode(ctx context.Context, name string) (int32, error)
  • func (c *Client) GetPodStdOut(ctx context.Context, name string) (string, error)
  • func (cli *Client) KubeEngine(wg *sync.WaitGroup, sID string, ctx context.Context, w internaltypes.Workflow, ...)
  • func (c *Client) RemoveVolume(ctx context.Context, vol string, claim *v1.PersistentVolumeClaim)
  • func (cli *Client) RunStageKubernetes(s internaltypes.Stage, ctx context.Context, envs []internaltypes.Env, ...)
• type RequestBody
• type ResponseBody

Functions

func ToV1Env

func ToV1Env(envs []internaltypes.Env) *[]v1.EnvVar

Types

type Client

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

func NewClient

func NewClient() (*Client, error)

func (*Client) CreatePod

func (c *Client) CreatePod(ctx context.Context, name string, image string, s internaltypes.Stage, envs []internaltypes.Env, runid string, w internaltypes.Workflow, LwWhite *logger.MyLogWriter) (error, v1.Pod)

func (c *Client) CreatePod(ctx context.Context, name string, image string, command []string, envs []internaltypes.Env, volume string, claim *v1.PersistentVolumeClaim) (error, v1.Pod) {

func (*Client) CreateVolume

func (c *Client) CreateVolume(ctx context.Context) (string, *v1.PersistentVolumeClaim)

func (*Client) DeletePod

func (c *Client) DeletePod(ctx context.Context, name string) error

func (*Client) GetPodExitCode

func (c *Client) GetPodExitCode(ctx context.Context, name string) (int32, error)

func (*Client) GetPodStdOut

func (c *Client) GetPodStdOut(ctx context.Context, name string) (string, error)

func (*Client) KubeEngine

func (cli *Client) KubeEngine(wg *sync.WaitGroup, sID string, ctx context.Context, w internaltypes.Workflow, allOutputs map[string][]internaltypes.Env, skippedStages *[]string, results chan internaltypes.Result, runid string)

func (cli *Client) KubeEngine(wg *sync.WaitGroup, sID string, ctx context.Context, w internaltypes.Workflow, vol string, claim *v1.PersistentVolumeClaim, allOutputs map[string][]internaltypes.Env, skippedStages *[]string, results chan internaltypes.Result) {

func (*Client) RemoveVolume

func (c *Client) RemoveVolume(ctx context.Context, vol string, claim *v1.PersistentVolumeClaim)

func (*Client) RunStageKubernetes

func (cli *Client) RunStageKubernetes(s internaltypes.Stage, ctx context.Context, envs []internaltypes.Env, globalImage string, LwWhite *logger.MyLogWriter, result *internaltypes.Result, allOutputs map[string][]internaltypes.Env, LwRed *logger.MyLogWriter, w internaltypes.Workflow, runid string)

func (cli *Client) RunStageKubernetes(s internaltypes.Stage, ctx context.Context, envs []internaltypes.Env, globalImage string, volume string, claim *v1.PersistentVolumeClaim, LwWhite *logger.MyLogWriter, result *internaltypes.Result, allOutputs map[string][]internaltypes.Env, LwRed *logger.MyLogWriter) bool {

type RequestBody

type RequestBody struct {
	Image   string   `json:"image"`
	Command string   `json:"command"`
	Args    []string `json:"args"`
}

type ResponseBody

type ResponseBody struct {
	ExitCode int32  `json:"exit_code"`
	Output   string `json:"output"`
}