opensearchdata

Documentation

Index

• Constants
• type ClusterStatus
• type DeleteStatus
• type Manager
  • func NewManager(logger *zap.SugaredLogger, kv future.Future[system.KeyValueStoreClient]) *Manager
  • 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
• type ReadyFunc

Constants

const (
	ClusterStatusGreen = iota
	ClusterStatusYellow
	ClusterStatusRed
	ClusterStatusError
	ClusterStatusNoClient
)

Types

type ClusterStatus

type ClusterStatus int

type DeleteStatus

type DeleteStatus int

const (
	DeletePending DeleteStatus = iota
	DeleteRunning
	DeleteFinished
	DeleteFinishedWithErrors
	DeleteError
)

type Manager

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

func NewManager

func NewManager(logger *zap.SugaredLogger, kv future.Future[system.KeyValueStoreClient]) *Manager

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

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.