esindex

Documentation

Index

• Constants
• func Add(mgr manager.Manager) error
• func ContainsFinalizer(instance *ibmcloudv1alpha1.EsIndex) bool
• func ContainsOwnerReference(instance *ibmcloudv1alpha1.EsIndex) bool
• func DeleteFinalizer(instance *ibmcloudv1alpha1.EsIndex) []string
• type EsConnection
• type EsHTTPS
• type IndexCreate
• type ReconcileEsIndex
  • func (r *ReconcileEsIndex) Reconcile(request reconcile.Request) (reconcile.Result, error)
• type RestResult

Constants

const (
	// ResourceStateCreated indicates a resource is in a created state
	ResourceStateCreated string = "Created"
	// ResourceStatePending indicates a resource is in a pending state
	ResourceStatePending string = "Pending"
	// ResourceStateFailed indicates a resource is in a failed state
	ResourceStateFailed string = "Failed"
	// ResourceStateUnknown indicates a resource is in a unknown state
	ResourceStateUnknown string = "Unknown"
	// ResourceStateDeleting indicates a resource is being deleted
	ResourceStateDeleting string = "Deleting"
	// ResourceStateOnline indicates a resource has been fully synchronized and online
	ResourceStateOnline string = "Online"
)

const ErrorTypeEsURINotFound string = "EsUriNotFound"

ErrorTypeEsURINotFound - elastic search uri is not found in binding secret

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new EsIndex Controller and adds it to the Manager with default RBAC. The Manager will set fields on the Controller and Start it when the Manager is Started.

func ContainsFinalizer

func ContainsFinalizer(instance *ibmcloudv1alpha1.EsIndex) bool

ContainsFinalizer checks if the instance contains streams finalizer

func ContainsOwnerReference

func ContainsOwnerReference(instance *ibmcloudv1alpha1.EsIndex) bool

ContainsOwnerReference checks if the instance contains streams finalizer

func DeleteFinalizer

func DeleteFinalizer(instance *ibmcloudv1alpha1.EsIndex) []string

DeleteFinalizer delete esindex finalizer

Types

type EsConnection

type EsConnection struct {
	HTTPS EsHTTPS `json:"https"`
}

EsConnection is a struct for elastic search connection

type EsHTTPS

type EsHTTPS struct {
	Composed []string `json:"composed"`
}

EsHTTPS is a struct for elastic search https connection

type IndexCreate

type IndexCreate struct {
	Settings struct {
		NumberOfShards   int64 `json:"number_of_shards,omitempty"`
		NumberOfReplicas int64 `json:"number_of_replicas,omitempty"`
	} `json:"settings,omitempty"`
	Mappings map[string]interface{} `json:"mappings,omitempty"`
}

IndexCreate for rest call body to elasticsearch

type ReconcileEsIndex

type ReconcileEsIndex struct {
	client.Client
	// contains filtered or unexported fields
}

ReconcileEsIndex reconciles a EsIndex object

func (*ReconcileEsIndex) Reconcile

func (r *ReconcileEsIndex) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a EsIndex object and makes changes based on the state read and what is in the EsIndex.Spec TODO(user): Modify this Reconcile function to implement your Controller logic. The scaffolding writes a Deployment as an example Automatically generate RBAC rules to allow the Controller to read and write Deployments +kubebuilder:rbac:groups=ibmcloud.ibm.com,resources=esindices,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=ibmcloud.ibm.com,resources=esindices/status,verbs=get;update;patch +kubebuilder:rbac:groups=ibmcloud.ibm.com,resources=/status,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=ibmcloud.ibm.com,resources=esindices/finalizers,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=ibmcloud.ibm.com,resources=bindings,verbs=get;list;watch +kubebuilder:rbac:groups=core,resources=secrets,verbs=get;list;watch +kubebuilder:rbac:groups=core,resources=configmaps,verbs=get;list;watch

type RestResult

type RestResult struct {
	StatusCode int
	Body       string
	ErrorType  string
}

RestResult is a struct for REST call result