mapper

Documentation

Index

• func CreateK8sResources(resourceList v1.ResourceList) models.K8sResources
• func ResolveK8sServiceForK8sCronJob(services *v1.ServiceList, cronJob batchv1.CronJob) string
• func ResolveK8sServiceForK8sDaemonSet(services *v1.ServiceList, daemonSet appsv1.DaemonSet) string
• func ResolveK8sServiceForK8sDeployment(services *v1.ServiceList, deployment appsv1.Deployment) string
• func ResolveK8sServiceForK8sStatefulSet(services *v1.ServiceList, statefulSet appsv1.StatefulSet) string
• type WorkloadMapper
  • func NewMapper(kubernetesApi *kubernetes.API, clusterName string, workspaceId string, ...) WorkloadMapper

Functions

func CreateK8sResources

func CreateK8sResources(resourceList v1.ResourceList) models.K8sResources

func ResolveK8sServiceForK8sCronJob

func ResolveK8sServiceForK8sCronJob(services *v1.ServiceList, cronJob batchv1.CronJob) string

func ResolveK8sServiceForK8sDaemonSet

func ResolveK8sServiceForK8sDaemonSet(services *v1.ServiceList, daemonSet appsv1.DaemonSet) string

func ResolveK8sServiceForK8sDeployment

func ResolveK8sServiceForK8sDeployment(services *v1.ServiceList, deployment appsv1.Deployment) string

func ResolveK8sServiceForK8sStatefulSet

func ResolveK8sServiceForK8sStatefulSet(services *v1.ServiceList, statefulSet appsv1.StatefulSet) string

Types

type WorkloadMapper

type WorkloadMapper interface {
	MapCluster(clusterName string, nodes *v1.NodeList) (workload.Cluster, error)
	MapWorkloads(cluster workload.Cluster) ([]workload.Data, error)
}

func NewMapper

func NewMapper(
	kubernetesApi *kubernetes.API,
	clusterName string,
	workspaceId string,
	runId string) WorkloadMapper