controllers

type AutofollowStats struct {
	SuccessStart        int         `json:"num_success_start_replication"`
	FailedStart         int         `json:"num_failed_start_replication"`
	AutofollowRuleStats []RuleStats `json:"autofollow_stats"`
}

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

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

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

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

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

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

type FlushResult struct {
	Shards struct {
		Total      int `json:"total"`
		Successful int `json:"successful"`
		Failed     int `json:"failed"`
	} `json:"_shards"`
}

type IndexDetails struct {
	LeaderCheckpoint   int `json:"leader_checkpoint"`
	FollowerCheckpoint int `json:"follower_checkpoint"`
	Seq                int `json:"seq_no"`
}

type InnerTask struct {
	Action string `json:"action"`
}

type LeaderStats struct {
	NumReplicatedIndices        int                    `json:"num_replicated_indices"`
	OperationsRead              int                    `json:"operations_read"`
	TranslogSizeBytes           int                    `json:"translog_size_bytes"`
	OperationsReadLucene        int                    `json:"operations_read_lucene"`
	OperationsReadTranslog      int                    `json:"operations_read_translog"`
	TotalReadTimeLuceneMillis   int                    `json:"total_read_time_lucene_millis"`
	TotalReadTimeTranslogMillis int                    `json:"total_read_time_translog_millis"`
	BytesRead                   int                    `json:"bytes_read"`
	IndexStats                  map[string]interface{} `json:"index_stats"`
}

type MappingAllAccess struct {
	AllAccess OpenSearchRoleMapping `json:"all_access"`
}

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

type NodesInfo struct {
	Nodes map[string]TasksInfo `json:"nodes"`
}

type NotReadyError struct {
	StatusCode int
	Err        error
}

type OpenSearchAuditConfig struct {
	Config struct {
		Enabled    bool                   `json:"enabled"`
		Audit      map[string]interface{} `json:"audit"`
		Compliance map[string]interface{} `json:"compliance"`
	} `json:"config"`
}

type OpenSearchHealth struct {
	Status string `json:"status"`
}

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

type OpenSearchRoleMapping struct {
	RoleName        string   `json:"role_name,omitempty"`
	Description     string   `json:"description"`
	BackendRoles    []string `json:"backend_roles"`
	AndBackendRoles []string `json:"and_backend_roles"`
	Hosts           []string `json:"hosts"`
	Users           []string `json:"users"`
	Reserved        bool     `json:"reserved,omitempty"`
	Hidden          bool     `json:"hidden,omitempty"`
}

type OpenSearchServiceReconciler struct {
	client.Client
	Scheme                *runtime.Scheme
	ResourceHashes        map[string]string
	ReplicationWatcher    ReplicationWatcher
	SlowLogIndicesWatcher SlowLogIndicesWatcher
	StatusUpdater         util.StatusUpdater
}

type OpenSearchSettings struct {
	Persistent struct {
		Cluster struct {
			Routing struct {
				Allocation struct {
					Enable *string `json:"enable"`
				} `json:"allocation"`
			} `json:"routing"`
		} `json:"cluster"`
	} `json:"persistent"`
}

type PluginReplicationError struct {
	Err struct {
		Reason   string `json:"reason,omitempty"`
		Type     string `json:"type,omitempty"`
		CausedBy struct {
			Type   string `json:"type,omitempty"`
			Reason string `json:"reason,omitempty"`
		} `json:"caused_by,omitempty"`
	} `json:"error"`
	Status int `json:"status"`
}

type ReconcileService interface {
	Reconcile() error
	Status() error
	Configure() error
}

type ReplicationIndexStats struct {
	Status  string       `json:"status"`
	Reason  string       `json:"reason,omitempty"`
	Details IndexDetails `json:"syncing_details,omitempty"`
}

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

type ReplicationStats struct {
	SyncingIndicesCount       int                 `json:"num_syncing_indices"`
	BootstrappingIndicesCount int                 `json:"num_bootstrapping_indices"`
	PausedIndicesCount        int                 `json:"num_paused_indices"`
	FailedIndicesCount        int                 `json:"num_failed_indices"`
	IndexStats                map[string]struct{} `json:"index_stats"`
}

type ReplicationWatcher struct {
	Lock *sync.Mutex
	// contains filtered or unexported fields
}

type RuleStats struct {
	Name          string   `json:"name"`
	Pattern       string   `json:"pattern"`
	SuccessStart  int      `json:"num_success_start_replication"`
	FailedStart   int      `json:"num_failed_start_replication"`
	FailedIndices []string `json:"failed_indices"`
}

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

type SlowLogIndicesWatcher struct {
	State *string
	// contains filtered or unexported fields
}

type TasksInfo struct {
	Tasks map[string]InnerTask `json:"tasks"`
}