elasticsearch

Documentation

Index

• func IsElasticsearchCRDifferent(current *elasticsearch.Elasticsearch, desired *elasticsearch.Elasticsearch) (*elasticsearch.Elasticsearch, bool)
• func NewElasticsearchCR(logStore *logging.LogStoreSpec, namespace, name, logstoreSecretName string, ...) *elasticsearch.Elasticsearch
• func NewEmptyElasticsearchCR(namespace, name, logstoreSecretName string) *elasticsearch.Elasticsearch
• func Reconcile(reader client.Reader, k8sClient client.Client, logStore *logging.LogStoreSpec, ...) error
• func ReconcileCustomResource(k8sClient client.Client, logStore *logging.LogStoreSpec, ...) (err error)
• func Remove(k8sClient client.Client, namespace, logstoreSecretName string) (err error)
• func RemoveCustomResource(k8sClient client.Client, namespace, name, logstoreSecretName string) (err error)
• func StatusAreSame(lhs, rhs []logging.ElasticsearchStatus) bool
• func UpdateStatus(reader client.Reader, k8sClient client.Client, namespace string, ...) error

Functions

func IsElasticsearchCRDifferent

func IsElasticsearchCRDifferent(current *elasticsearch.Elasticsearch, desired *elasticsearch.Elasticsearch) (*elasticsearch.Elasticsearch, bool)

func NewElasticsearchCR

func NewElasticsearchCR(logStore *logging.LogStoreSpec, namespace, name, logstoreSecretName string, existing *elasticsearch.Elasticsearch, ownerRef metav1.OwnerReference) *elasticsearch.Elasticsearch

func NewEmptyElasticsearchCR

func NewEmptyElasticsearchCR(namespace, name, logstoreSecretName string) *elasticsearch.Elasticsearch

func Reconcile

func Reconcile(reader client.Reader, k8sClient client.Client, logStore *logging.LogStoreSpec, namespace, logstoreSecretName string, ownerRef v1.OwnerReference, fetchClusterLogging func() (*logging.ClusterLogging, error)) error

func ReconcileCustomResource

func ReconcileCustomResource(k8sClient client.Client, logStore *logging.LogStoreSpec, namespace, logstoreSecretName string, ownerRef v1.OwnerReference) (err error)

func Remove

func Remove(k8sClient client.Client, namespace, logstoreSecretName string) (err error)

func RemoveCustomResource

func RemoveCustomResource(k8sClient client.Client, namespace, name, logstoreSecretName string) (err error)

func StatusAreSame

func StatusAreSame(lhs, rhs []logging.ElasticsearchStatus) bool

func UpdateStatus

func UpdateStatus(reader client.Reader, k8sClient client.Client, namespace string, fetchClusterLogging func() (*logging.ClusterLogging, error)) error