elastic

Documentation

Index

• Constants
• type ClusterHealthResponse
• type ClusterSettings
• type Persistent
• type Reconciler
  • func NewReconciler(ctx context.Context, client client.Client, opniCluster *v1beta2.OpniCluster) *Reconciler
  • func (r *Reconciler) OpensearchResources() (resourceList []resources.Resource, _ error)
  • func (r *Reconciler) UpgradeData() (retry bool, err error)

Constants

const (
	OpniMasterWorkload     = "opni-es-master"
	OpniDataWorkload       = "opni-es-data"
	OpniClientWorkload     = "opni-es-client"
	OpniDashboardsWorkload = "opni-es-kibana"
)

Types

type ClusterHealthResponse

type ClusterHealthResponse struct {
	Status             string  `json:"status,omitempty"`
	ActiveShards       int     `json:"active_shards,omitempty"`
	RelocatingShards   int     `json:"relocating_shards,omitempty"`
	InitializingShards int     `json:"initializing_shards,omitempty"`
	UnassignedShards   int     `json:"unassigned_shards,omitempty"`
	PercentActive      float32 `json:"active_shards_percent_as_number,omitempty"`
}

type ClusterSettings

type ClusterSettings struct {
	Persistent Persistent `json:"persistent,omitempty"`
}

type Persistent

type Persistent struct {
	ClusterRoutingAllocationEnable string `json:"cluster.routing.allocation.enable,omitempty"`
}

type Reconciler

type Reconciler struct {
	// contains filtered or unexported fields
}

func NewReconciler

func NewReconciler(ctx context.Context, client client.Client, opniCluster *v1beta2.OpniCluster) *Reconciler

func (*Reconciler) OpensearchResources

func (r *Reconciler) OpensearchResources() (resourceList []resources.Resource, _ error)

func (*Reconciler) UpgradeData

func (r *Reconciler) UpgradeData() (retry bool, err error)