k8shandler

Documentation

Index

• func CreateOrUpdateConfigMaps(dpl *v1alpha1.Elasticsearch) (string, error)
• func CreateOrUpdateElasticsearchCluster(dpl *v1alpha1.Elasticsearch, configMapName, serviceAccountName string) error
• func CreateOrUpdateServiceAccount(dpl *v1alpha1.Elasticsearch) (string, error)
• func CreateOrUpdateServices(dpl *v1alpha1.Elasticsearch) error
• type ClusterState
  • func NewClusterState(dpl *v1alpha1.Elasticsearch, configMapName, serviceAccountName string) (ClusterState, error)
  • func (cState *ClusterState) UpdateStatus(dpl *v1alpha1.Elasticsearch) error
• type NodeTypeFactory
• type NodeTypeInterface
  • func NewDeploymentNode(name, namespace string) NodeTypeInterface
  • func NewStatefulSetNode(name, namespace string) NodeTypeInterface

Functions

func CreateOrUpdateConfigMaps

func CreateOrUpdateConfigMaps(dpl *v1alpha1.Elasticsearch) (string, error)

CreateOrUpdateConfigMaps ensures the existens of ConfigMaps with Elasticsearch configuration

func CreateOrUpdateElasticsearchCluster

func CreateOrUpdateElasticsearchCluster(dpl *v1alpha1.Elasticsearch, configMapName, serviceAccountName string) error

CreateOrUpdateElasticsearchCluster creates an Elasticsearch deployment

func CreateOrUpdateServiceAccount

func CreateOrUpdateServiceAccount(dpl *v1alpha1.Elasticsearch) (string, error)

CreateOrUpdateServiceAccount ensures the existence of the serviceaccount for Elasticsearch cluster

func CreateOrUpdateServices

func CreateOrUpdateServices(dpl *v1alpha1.Elasticsearch) error

CreateOrUpdateServices ensures the existence of the services for Elasticsearch cluster

Types

type ClusterState

type ClusterState struct {
	Nodes                []*nodeState
	DanglingStatefulSets *apps.StatefulSetList
	DanglingDeployments  *apps.DeploymentList
	DanglingReplicaSets  *apps.ReplicaSetList
	DanglingPods         *v1.PodList
}

ClusterState struct represents the state of the cluster

func NewClusterState

func NewClusterState(dpl *v1alpha1.Elasticsearch, configMapName, serviceAccountName string) (ClusterState, error)

NewClusterState func generates ClusterState for the current cluster

func (*ClusterState) UpdateStatus

func (cState *ClusterState) UpdateStatus(dpl *v1alpha1.Elasticsearch) error

UpdateStatus updates the status of Elasticsearch CRD

type NodeTypeFactory

type NodeTypeFactory func(name, namespace string) NodeTypeInterface

NodeTypeFactory is a factory to construct either statefulset or deployment

type NodeTypeInterface

type NodeTypeInterface interface {
	// contains filtered or unexported methods
}

NodeTypeInterface interace represents individual Elasticsearch node

func NewDeploymentNode

func NewDeploymentNode(name, namespace string) NodeTypeInterface

NewDeploymentNode constructs deploymentNode struct for data nodes

func NewStatefulSetNode

func NewStatefulSetNode(name, namespace string) NodeTypeInterface

NewStatefulSetNode constructs statefulSetNode struct for non-data nodes