opensearchdata

Documentation

Index

• Constants
• type ClusterStatus
• type DeleteStatus
• type Manager
  • func NewManager(logger *zap.SugaredLogger, opts ...OpensearchManagerOption) *Manager
  • func (m *Manager) AddClusterMetadata(ctx context.Context, cluster *opnicorev1.Cluster) error
  • func (m *Manager) CreateInitialAdmin(password []byte, readyFunc ...ReadyFunc)
  • func (m *Manager) DeleteInitialAdminState() error
  • func (m *Manager) DeleteTaskStatus(ctx context.Context, id string, readyFunc ...ReadyFunc) (DeleteStatus, error)
  • func (m *Manager) DoClusterDataDelete(ctx context.Context, id string, readyFunc ...ReadyFunc) error
  • func (m *Manager) GetClusterStatus() ClusterStatus
  • func (m *Manager) ReconcileClusterMetadata(ctx context.Context, clusters []*opnicorev1.Cluster) error
  • func (m *Manager) ShouldCreateInitialAdmin() bool
  • func (m *Manager) UpdateClusterMetadata(ctx context.Context, ref *opnicorev1.Reference, ...) error
• type OpensearchManagerOption
  • func WithNatsConnection(nc *nats.Conn) OpensearchManagerOption
• type OpensearchManagerOptions
• type ReadyFunc

Constants

const (
	ClusterStatusGreen = iota
	ClusterStatusYellow
	ClusterStatusRed
	ClusterStatusError
)

Types

type ClusterStatus

type ClusterStatus int

type DeleteStatus

type DeleteStatus int

const (
	DeletePending DeleteStatus = iota
	DeleteRunning
	DeleteFinished
	DeleteFinishedWithErrors
	DeleteError
)

type Manager

type Manager struct {
	OpensearchManagerOptions
	*loggingutil.AsyncOpensearchClient
	// contains filtered or unexported fields
}

func NewManager

func NewManager(logger *zap.SugaredLogger, opts ...OpensearchManagerOption) *Manager

func (*Manager) AddClusterMetadata

func (m *Manager) AddClusterMetadata(ctx context.Context, cluster *opnicorev1.Cluster) error

func (*Manager) CreateInitialAdmin

func (m *Manager) CreateInitialAdmin(password []byte, readyFunc ...ReadyFunc)

func (*Manager) DeleteInitialAdminState

func (m *Manager) DeleteInitialAdminState() error

func (*Manager) DeleteTaskStatus

func (m *Manager) DeleteTaskStatus(ctx context.Context, id string, readyFunc ...ReadyFunc) (DeleteStatus, error)

func (*Manager) DoClusterDataDelete

func (m *Manager) DoClusterDataDelete(ctx context.Context, id string, readyFunc ...ReadyFunc) error

func (*Manager) GetClusterStatus

func (m *Manager) GetClusterStatus() ClusterStatus

func (*Manager) ReconcileClusterMetadata

func (m *Manager) ReconcileClusterMetadata(ctx context.Context, clusters []*opnicorev1.Cluster) error

func (*Manager) ShouldCreateInitialAdmin

func (m *Manager) ShouldCreateInitialAdmin() bool

func (*Manager) UpdateClusterMetadata

func (m *Manager) UpdateClusterMetadata(ctx context.Context, ref *opnicorev1.Reference, update types.ClusterMetadataDocUpdate) error

type OpensearchManagerOption

type OpensearchManagerOption func(*OpensearchManagerOptions)

func WithNatsConnection

func WithNatsConnection(nc *nats.Conn) OpensearchManagerOption

type OpensearchManagerOptions

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

type ReadyFunc

type ReadyFunc func() bool

Ready func should return true if there is a critical error That would stop the opensearch query from running.