kubernetes

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 27, 2017 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source 
const TIMEOUT = 300

TIMEOUT is how long we'll wait for the termination of kubernetes resource to be successful used when undeploying resources from kubernetes

Variables

This section is empty.

Functions

func PrintList 

func PrintList(objects []runtime.Object, opt kobject.ConvertOptions) error

PrintList will take the data converted and decide on the commandline attributes given

Types

type Kubernetes 

type Kubernetes struct {
	// the user provided options from the command line
	Opt kobject.ConvertOptions
}

Kubernetes implements Transformer interface and represents Kubernetes transformer

func (*Kubernetes) CheckUnsupportedKey added in v0.2.0 

func (k *Kubernetes) CheckUnsupportedKey(komposeObject *kobject.KomposeObject, unsupportedKey map[string]bool) []string

CheckUnsupportedKey checks if given komposeObject contains keys that are not supported by this tranfomer. list of all unsupported keys are stored in unsupportedKey variable returns list of TODO: ....

func (*Kubernetes) ConfigEmptyVolumeSource added in v0.1.2 

func (k *Kubernetes) ConfigEmptyVolumeSource() *api.VolumeSource

ConfigEmptyVolumeSource is helper function to create an EmptyDir api.VolumeSource

func (*Kubernetes) ConfigEnvs added in v0.1.2 

func (k *Kubernetes) ConfigEnvs(name string, service kobject.ServiceConfig) []api.EnvVar

ConfigEnvs configures the environment variables.

func (*Kubernetes) ConfigPVCVolumeSource added in v0.1.2 

func (k *Kubernetes) ConfigPVCVolumeSource(name string, readonly bool) *api.VolumeSource

ConfigPVCVolumeSource is helper function to create an api.VolumeSource with a PVC

func (*Kubernetes) ConfigPorts added in v0.1.2 

func (k *Kubernetes) ConfigPorts(name string, service kobject.ServiceConfig) []api.ContainerPort

ConfigPorts configures the container ports.

func (*Kubernetes) ConfigServicePorts added in v0.1.2 

func (k *Kubernetes) ConfigServicePorts(name string, service kobject.ServiceConfig) []api.ServicePort

ConfigServicePorts configure the container service ports.

func (*Kubernetes) ConfigVolumes added in v0.1.2 

func (k *Kubernetes) ConfigVolumes(name string, service kobject.ServiceConfig) ([]api.VolumeMount, []api.Volume, []*api.PersistentVolumeClaim)

ConfigVolumes configure the container volumes.

func (*Kubernetes) CreateHeadlessService added in v0.2.0 

func (k *Kubernetes) CreateHeadlessService(name string, service kobject.ServiceConfig, objects []runtime.Object) *api.Service

CreateHeadlessService creates a k8s headless service. Thi is used for docker-compose services without ports. For such services we can't create regular Kubernetes Service. and without Service Pods can't find each other using DNS names. Instead of regular Kubernetes Service we create Headless Service. DNS of such service points directly to Pod IP address. You can find more about Headless Services in Kubernetes documentation https://kubernetes.io/docs/user-guide/services/#headless-services

func (*Kubernetes) CreateKubernetesObjects added in v0.1.2 

func (k *Kubernetes) CreateKubernetesObjects(name string, service kobject.ServiceConfig, opt kobject.ConvertOptions) []runtime.Object

CreateKubernetesObjects generates a Kubernetes artifact for each input type service

func (*Kubernetes) CreatePVC added in v0.1.2 

func (k *Kubernetes) CreatePVC(name string, mode string) *api.PersistentVolumeClaim

CreatePVC initializes PersistentVolumeClaim

func (*Kubernetes) CreateService added in v0.1.2 

func (k *Kubernetes) CreateService(name string, service kobject.ServiceConfig, objects []runtime.Object) *api.Service

CreateService creates a k8s service

func (*Kubernetes) Deploy added in v0.1.1 

func (k *Kubernetes) Deploy(komposeObject kobject.KomposeObject, opt kobject.ConvertOptions) error

Deploy submits deployment and svc to k8s endpoint

func (*Kubernetes) GetKubernetesClient added in v0.2.0 

func (k *Kubernetes) GetKubernetesClient() (*client.Client, string, error)

GetKubernetesClient creates the k8s Client, returns k8s client and namespace

func (*Kubernetes) InitD added in v0.1.2 

func (k *Kubernetes) InitD(name string, service kobject.ServiceConfig, replicas int) *extensions.Deployment

InitD initializes Kubernetes Deployment object

func (*Kubernetes) InitDS added in v0.1.2 

func (k *Kubernetes) InitDS(name string, service kobject.ServiceConfig) *extensions.DaemonSet

InitDS initializes Kubernetes DaemonSet object

func (*Kubernetes) InitPod added in v0.2.0 

func (k *Kubernetes) InitPod(name string, service kobject.ServiceConfig) *api.Pod

InitPod initializes Kubernetes Pod object

func (*Kubernetes) InitRC added in v0.1.2 

func (k *Kubernetes) InitRC(name string, service kobject.ServiceConfig, replicas int) *api.ReplicationController

InitRC initializes Kubernetes ReplicationController object

func (*Kubernetes) InitSvc added in v0.1.2 

func (k *Kubernetes) InitSvc(name string, service kobject.ServiceConfig) *api.Service

InitSvc initializes Kubernets Service object

func (*Kubernetes) PortsExist added in v0.1.2 

func (k *Kubernetes) PortsExist(name string, service kobject.ServiceConfig) bool

PortsExist checks if service has ports defined

func (*Kubernetes) SortServicesFirst added in v0.1.2 

func (k *Kubernetes) SortServicesFirst(objs *[]runtime.Object)

SortServicesFirst - the objects that we get can be in any order this keeps services first according to best practice kubernetes services should be created first http://kubernetes.io/docs/user-guide/config-best-practices/

func (*Kubernetes) Transform 

func (k *Kubernetes) Transform(komposeObject kobject.KomposeObject, opt kobject.ConvertOptions) []runtime.Object

Transform maps komposeObject to k8s objects returns object that are already sorted in the way that Services are first

func (*Kubernetes) Undeploy added in v0.1.1 

func (k *Kubernetes) Undeploy(komposeObject kobject.KomposeObject, opt kobject.ConvertOptions) error

Undeploy deletes deployed objects from Kubernetes cluster

func (*Kubernetes) UpdateController added in v0.1.2 

func (k *Kubernetes) UpdateController(obj runtime.Object, updateTemplate func(*api.PodTemplateSpec), updateMeta func(meta *api.ObjectMeta))

UpdateController updates the given object with the given pod template update function and ObjectMeta update function

func (*Kubernetes) UpdateKubernetesObjects added in v0.1.2 

func (k *Kubernetes) UpdateKubernetesObjects(name string, service kobject.ServiceConfig, objects *[]runtime.Object)

UpdateKubernetesObjects loads configurations to k8s objects

func (*Kubernetes) VolumesFrom added in v0.1.2 

func (k *Kubernetes) VolumesFrom(objects *[]runtime.Object, komposeObject kobject.KomposeObject)

VolumesFrom creates volums and volumeMounts for volumes_from

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.