k8sutil

Feb 8, 2019

Changes in this version

type K8sutil

+ BusyboxImage string

+ EnableInitDaemonset bool

+ InitDaemonsetNamespace string

+ func (k *K8sutil) GetMasterNodes(namespace string, name string) (*v1.PodList, error)

Jul 11, 2018

Changes in this version

type K8sutil

+ func (k *K8sutil) CreateMgmtService(service string, clusterName, namespace string) error

Apr 27, 2018

Changes in this version

+ func GetESURL(esHost string, useSSL *bool) string

type K8sutil

+ func (k *K8sutil) CreateMgmtServices(clusterName, namespace string) error

Mar 2, 2018

Changes in this version

type K8sutil

+ func (k *K8sutil) CreateNodeInitDaemonset(namespace string) error

Dec 21, 2017

Changes in this version

type K8sutil

+ K8sVersion []int

+ KubeExt apiextensionsclient.Interface

Oct 25, 2017

Changes in this version

type K8sutil

+ func (k *K8sutil) ConfigmapExists(namespace, name string) bool

+ func (k *K8sutil) CreateCerebroConfiguration(clusterName string) map[string]string

+ func (k *K8sutil) CreateCerebroDeployment(baseImage, clusterName, namespace, cert string, ...) error

+ func (k *K8sutil) CreateConfigMap(namespace string, name string, data map[string]string) error

+ func (k *K8sutil) UpdateConfigMap(namespace string, name string, data map[string]string) error

Oct 3, 2017

Changes in this version

type K8sutil

+ CrdClient apiextensionsclient.Interface

+ ElasticClient *rest.RESTClient

+ func (k *K8sutil) CreateKubernetesCustomResourceDefinition() error

Sep 27, 2017

Changes in this version

type K8sutil

+ func (k *K8sutil) CreateClientDeployment(baseImage string, replicas *int32, javaOptions string, ...) error

+ func (k *K8sutil) CreateKibanaDeployment(baseImage, clusterName, namespace string, ...) error

+ func (k *K8sutil) DeleteDeployment(clusterName, namespace, deploymentType string) error

Jul 14, 2017

Changes in this version

type K8sutil

+ func (k *K8sutil) CertsSecretExists(namespace, clusterName string) bool

+ func (k *K8sutil) CreateCertsSecret(namespace, clusterName, certsDir string) error

+ func (k *K8sutil) DeleteCertsSecret(namespace, clusterName string)

+ func (k *K8sutil) GenerateCerts(configDir, certsDir, namespace, clusterName string) error

+ func (k *K8sutil) GetClientServiceName(clusterName string) string

+ func (k *K8sutil) GetClientServiceNameFullDNS(clusterName, namespace string) string

+ func (k *K8sutil) MonitorDataPods(stopchan chan struct{}) (<-chan *v1.Pod, <-chan error)

+ func (k *K8sutil) UpdateVolumeReclaimPolicy(policy, namespace string)

Jun 29, 2017

Changes in this version

+ func TemplateImagePullSecrets(ips []myspec.ImagePullSecrets) []v1.LocalObjectReference

+ type K8sutil struct

+ Config *rest.Config

+ Kclient KubeInterface

+ MasterHost string

+ TprClient *rest.RESTClient

+ func New(kubeCfgFile, masterHost string) (*K8sutil, error)

+ func (k *K8sutil) CreateClientMasterDeployment(deploymentType, baseImage string, replicas *int32, javaOptions string, ...) error

+ func (k *K8sutil) CreateClientService(clusterName string, nodePort int32) error

+ func (k *K8sutil) CreateDataNodeDeployment(replicas *int32, baseImage, storageClass string, dataDiskSize string, ...) error

+ func (k *K8sutil) CreateDataService(clusterName string) error

+ func (k *K8sutil) CreateDiscoveryService(clusterName string) error

+ func (k *K8sutil) CreateKubernetesThirdPartyResource() error

+ func (k *K8sutil) CreateStorageClass(zone, storageClassProvisioner, storageType string, clusterName string) error

+ func (k *K8sutil) DeleteClientMasterDeployment(deploymentType string, clusterName string) error

+ func (k *K8sutil) DeleteServices(clusterName string)

+ func (k *K8sutil) DeleteStatefulSet(clusterName string) error

+ func (k *K8sutil) DeleteStorageClasses(clusterName string) error

+ func (k *K8sutil) GetElasticSearchClusters() ([]myspec.ElasticsearchCluster, error)

+ func (k *K8sutil) MonitorElasticSearchEvents(stopchan chan struct{}) (<-chan *myspec.ElasticsearchCluster, <-chan error)

+ type KubeInterface interface

+ Deployments func(namespace string) extensionsType.DeploymentInterface

+ ReplicaSets func(namespace string) extensionsType.ReplicaSetInterface

+ Services func(namespace string) coreType.ServiceInterface

+ StatefulSets func(namespace string) appsType.StatefulSetInterface

+ StorageClasses func() storageType.StorageClassInterface

+ ThirdPartyResources func() extensionsType.ThirdPartyResourceInterface