engine

Documentation

Index

• Constants
• func Bytes2K8sEntities(jsonArray [][]byte) *queue.Queue
• type KubeEngine
  • func NewKubeEngine(jobs *queue.Queue, client *kubeclient.Clients) *KubeEngine
  • func (k *KubeEngine) DoCreateTasks()
  • func (k *KubeEngine) DoDeleteTasks()

Constants

const (
	ApiVersion        = "v1"
	DeploymentVersion = "apps/v1"

	KindDeployment            = "Deployment"
	KindNamespace             = "Namespace"
	KindService               = "Service"
	KindPersistentVolume      = "PersistentVolume"
	KindPersistentVolumeClaim = "PersistentVolumeClaim"
	KindStatefulSet           = "StatefulSet"
)

Functions

func Bytes2K8sEntities

func Bytes2K8sEntities(jsonArray [][]byte) *queue.Queue

Types

type KubeEngine

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

func NewKubeEngine

func NewKubeEngine(jobs *queue.Queue, client *kubeclient.Clients) *KubeEngine

func (*KubeEngine) DoCreateTasks

func (k *KubeEngine) DoCreateTasks()

func (*KubeEngine) DoDeleteTasks

func (k *KubeEngine) DoDeleteTasks()