migratorv4

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

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

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

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

type ESSettings struct {
	TotalShardSettings       int32  `json:"totalShardSettings" toml:"totalShardSettings"`
	IndicesBreakerTotalLimit string `json:"indicesBreakerTotalLimit" toml:"indicesBreakerTotalLimit"`
	RuntimeMaxOpenFile       string `json:"runtimeMaxOpenFile" toml:"runtimeMaxOpenFile"`
	RuntimeMaxLockedMem      string `json:"runtimeMaxLockedMem" toml:"runtimeMaxLockedMem"`
	HeapMemory               string `json:"heapMemory" toml:"heapMemory"`
}

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

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

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

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

type MigratorV4Utils interface {
	GetEsTotalShardSettings(path string) (int32, error)
	PatchOpensearchConfig(es *ESSettings) (string, string, error)
	IsExternalElasticSearch(timeout int64) bool
	StopAutomate() error
	StartAutomate() error
	ReadV4Checklist(id, path string) (bool, error)
	UpdatePostChecklistFile(id, path string) error
	ExecuteCommand(command string, args []string, workingDir string) error
	GetServicesStatus() (bool, error)
	GetAutomateFQDN(timeout int64) string
	GetMaintenanceStatus(timeout int64) (bool, error)
	SetMaintenanceMode(timeout int64, status bool) (stdOut, stdErr string, err error)
}

type MigratorV4UtilsImpl struct {
}

type MockMigratorV4UtilsImpl struct {
	GetEsTotalShardSettingsFunc func(path string) (int32, error)
	PatchOpensearchConfigFunc   func(es *ESSettings) (string, string, error)
	IsExternalElasticSearchFunc func(timeout int64) bool
	StopAutomateFunc            func() error
	StartAutomateFunc           func() error
	ReadV4ChecklistFunc         func(id, path string) (bool, error)
	UpdatePostChecklistFileFunc func(id, path string) error
	ExecuteCommandFunc          func(command string, args []string, workingDir string) error
	GetServicesStatusFunc       func() (bool, error)
	CreateMigrateJsonFunc       func() error
	GetAutomateFQDNFunc         func(timeout int64) string
	GetMaintenanceStatusFunc    func(timeout int64) (bool, error)
	SetMaintenanceModeFunc      func(timeout int64, status bool) (stdOut, stdErr string, err error)
}

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

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