util

Documentation

Overview

Package util provides functions for creating Kubernetes resources required for running WorkflowDefinitions in a cluster

Index

• func CreateUserClusterKubeconfig(reqBytes []byte, msg *nats.Msg, natsInfo map[string]string)
• func Delete(reqBytes []byte, natsInfo map[string]string)
• func GetUnstructuredScaledObject(name, namespace string) *unstructured.Unstructured
• func Run(reqBytes []byte, natsInfo map[string]string)
• func ScaleUp(reqBytes []byte, natsInfo map[string]string)
• type Request

Functions

func CreateUserClusterKubeconfig

func CreateUserClusterKubeconfig(reqBytes []byte, msg *nats.Msg, natsInfo map[string]string)

CreateUserClusterKubeconfig is a synchronous subscriber used to create new Key and Certificate to allow a user to access a Kubernetes cluster. It will create the new file and respond with it to the API Service to save in Vault

func Delete

func Delete(reqBytes []byte, natsInfo map[string]string)

Delete is used to delete a WorkflowDefinition and all related resources from the user's Kubernetes cluster

func GetUnstructuredScaledObject

func GetUnstructuredScaledObject(name, namespace string) *unstructured.Unstructured

GetUnstructuredScaledObject creates a K8s Unstructured object that is a KEDA ScaledObject

func Run

func Run(reqBytes []byte, natsInfo map[string]string)

Run is used to handle most of Pleo's functionality for running different resources on a user's Kubernetes cluster

func ScaleUp

func ScaleUp(reqBytes []byte, natsInfo map[string]string)

ScaleUp is used when a user attempts to access a Workflow that is no longer running. This will start up some new Pods for the user to use

Types

type Request

type Request struct {
	common.BasicRequest
	TCPPorts           []core.ServicePort                    `json:"tcp_ports,omitempty"`
	HTTPPorts          []core.ServicePort                    `json:"http_ports,omitempty"`
	AuthDisabled       bool                                  `json:"auth_disabled,omitempty"`
	Namespace          string                                `json:"namespace,omitempty"`
	WorkflowDefinition workflowdefinition.WorkflowDefinition `json:"data,omitempty"`
}

Request is a struct containing the necessary fields for all Pleo operations coming from the API