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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateUserClusterKubeconfig ¶
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 ¶
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
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
Source Files
Click to show internal directories.
Click to hide internal directories.