vadmin

type Admintools struct {
	PRunner  cmds.PodRunner
	Log      logr.Logger
	EVWriter events.EVWriter
	VDB      *vapi.VerticaDB
	DevMode  bool // true to include verbose logging for some operations
}

type DBCreator struct {
	Admintools *Admintools
	Parms      createdb.Parms
}

type DBInitializer interface {
	GenCmd() []string
	GetInitiator() types.NamespacedName
	GetConfigParms() map[string]string
	LogFailure(string, error) (ctrl.Result, error)
}

type DBReviver struct {
	Admintools *Admintools
	Parms      revivedb.Parms
}

type Dispatcher interface {
	// CreateDB will create a brand new database. It assumes the communal
	// storage location is empty.
	CreateDB(ctx context.Context, opts ...createdb.Option) (ctrl.Result, error)

	// ReviveDB will initialize a database using a pre-populated communal path.
	ReviveDB(ctx context.Context, opts ...revivedb.Option) (ctrl.Result, error)

	// DescribeDB will read state information about the database in communal
	// storage and return it back to the caller.
	DescribeDB(ctx context.Context, opts ...describedb.Option) (string, ctrl.Result, error)

	// FetchNodeState will determine if the given set of nodes are considered UP
	// or DOWN in our consensous state. It returns a map of vnode to its node state.
	FetchNodeState(ctx context.Context, opts ...fetchnodestate.Option) (map[string]string, ctrl.Result, error)

	// ReIP will update the catalog on disk with new IPs for all of the nodes given.
	ReIP(ctx context.Context, opts ...reip.Option) (ctrl.Result, error)

	// StopDB will stop all the vertica hosts of a running cluster.
	StopDB(ctx context.Context, opts ...stopdb.Option) error

	// AddNode will add a new vertica node to the cluster. If add node fails due to
	// a license limit, the error will be of type addnode.LicenseLimitError.
	AddNode(ctx context.Context, opts ...addnode.Option) error

	// AddSubcluster will create a subcluster in the vertica cluster.
	AddSubcluster(ctx context.Context, opts ...addsc.Option) error

	// RemoveNode will remove an existng vertica node from the cluster.
	RemoveNode(ctx context.Context, opts ...removenode.Option) error

	// RemoveSubcluster will remove the given subcluster from the vertica cluster.
	RemoveSubcluster(ctx context.Context, opts ...removesc.Option) error

	// RestartNode will restart a subset of nodes. Use this when vertica has not
	// lost cluster quorum. The IP given for each vnode may not match the current IP
	// in the vertica catalogs.
	RestartNode(ctx context.Context, opts ...restartnode.Option) (ctrl.Result, error)

	// StartDB will start a subset of nodes. Use this when vertica has lost
	// cluster quorum. The IP given for each vnode *must* match the current IP
	// in the vertica catalog. If they aren't a call to ReIP is necessary.
	StartDB(ctx context.Context, opts ...startdb.Option) (ctrl.Result, error)
}

type HTTPSCerts struct {
	Key    string
	Cert   string
	CaCert string
}

type VClusterOps struct {
	Log    logr.Logger
	VDB    *vapi.VerticaDB
	Client client.Client
	VClusterProvider
	Password string
	EVWriter events.EVWriter
}

type VClusterProvider interface {
	VCreateDatabase(options *vops.VCreateDatabaseOptions) (vops.VCoordinationDatabase, error)
	VStopDatabase(options *vops.VStopDatabaseOptions) error
	VStartDatabase(options *vops.VStartDatabaseOptions) error
	VFetchNodeState(options *vops.VFetchNodeStateOptions) ([]vops.NodeInfo, error)
	VAddSubcluster(options *vops.VAddSubclusterOptions) error
	VAddNode(options *vops.VAddNodeOptions) (vops.VCoordinationDatabase, error)
	VReIP(options *vops.VReIPOptions) error
}