opensearchdata

package
v0.9.1-rc1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 27, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ClusterStatusGreen = iota
	ClusterStatusYellow
	ClusterStatusRed
	ClusterStatusError
)

Variables

This section is empty.

Functions

This section is empty.

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) CreateInitialAdmin added in v0.6.2

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

func (*Manager) DeleteInitialAdminState added in v0.8.2

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) ShouldCreateInitialAdmin added in v0.8.2

func (m *Manager) ShouldCreateInitialAdmin() bool

type OpensearchManagerOption added in v0.8.2

type OpensearchManagerOption func(*OpensearchManagerOptions)

func WithNatsConnection added in v0.8.2

func WithNatsConnection(nc *nats.Conn) OpensearchManagerOption

type OpensearchManagerOptions added in v0.8.2

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

type ReadyFunc added in v0.8.0

type ReadyFunc func() bool

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL