deployment

package

v1.3.0 Latest Latest Go to latest Published: Mar 19, 2024 License: Apache-2.0 Imports: 12 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/aerospike/aerospike-management-lib

Links

Open Source Insights

Documentation ¶

Index ¶

func GetAndSetRoster(log logr.Logger, hostConns []*HostConn, policy *as.ClientPolicy, ...) error
func GetClusterNamespaces(log logr.Logger, policy *aero.ClientPolicy, allHosts []*HostConn) (map[string][]string, error)
func GetInfoOnHosts(log logr.Logger, policy *aero.ClientPolicy, allHosts []*HostConn, cmd string) (map[string]InfoResult, error)
func GetQuiescedNodes(log logr.Logger, policy *aero.ClientPolicy, allHosts []*HostConn) ([]string, error)
func InfoQuiesce(log logr.Logger, policy *aero.ClientPolicy, ...) error
func InfoQuiesceUndo(log logr.Logger, policy *aero.ClientPolicy, allHosts []*HostConn) error
func IsClusterAndStable(log logr.Logger, policy *aero.ClientPolicy, allHosts []*HostConn) (bool, error)
func IsUpgrade(fromVersion, toVersion string) (bool, error)
func IsValidUpgrade(fromVersion, toVersion string) error
func ParseInfoIntoMap(str, del, sep string) (map[string]string, error)
func SetMigrateFillDelay(log logr.Logger, policy *aero.ClientPolicy, allHosts []*HostConn, ...) error
func ValidateSCClusterState(log logr.Logger, hostConns []*HostConn, policy *as.ClientPolicy, ...) error
type ASConn
type HostConn
- func NewHostConn(log logr.Logger, id string, asConn *ASConn) *HostConn
- func (n *HostConn) String() string
type InfoResult

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetAndSetRoster ¶

func GetAndSetRoster(log logr.Logger, hostConns []*HostConn, policy *as.ClientPolicy, rosterNodeBlockList []string,
	ignorableNamespaces sets.Set[string]) error

func GetClusterNamespaces ¶

func GetClusterNamespaces(log logr.Logger, policy *aero.ClientPolicy,
	allHosts []*HostConn) (map[string][]string, error)

GetClusterNamespaces gets the cluster namespaces

func GetInfoOnHosts ¶ added in v1.2.0

func GetInfoOnHosts(log logr.Logger, policy *aero.ClientPolicy,
	allHosts []*HostConn, cmd string) (map[string]InfoResult, error)

func GetQuiescedNodes ¶

func GetQuiescedNodes(log logr.Logger, policy *aero.ClientPolicy, allHosts []*HostConn) ([]string, error)

GetQuiescedNodes returns a list of node hostIDs of all nodes that are pending_quiesce=true.

func InfoQuiesce ¶

func InfoQuiesce(log logr.Logger, policy *aero.ClientPolicy, allHosts, selectedHosts []*HostConn,
	removedNamespaces []string) error

InfoQuiesce quiesce hosts.

func InfoQuiesceUndo ¶

func InfoQuiesceUndo(log logr.Logger, policy *aero.ClientPolicy, allHosts []*HostConn) error

InfoQuiesceUndo revert the effects of quiesce on the next recluster event

func IsClusterAndStable ¶

func IsClusterAndStable(log logr.Logger, policy *aero.ClientPolicy, allHosts []*HostConn) (bool, error)

IsClusterAndStable returns true if the cluster formed by the set of hosts is stable.

func IsUpgrade ¶

func IsUpgrade(fromVersion, toVersion string) (bool, error)

IsUpgrade returns true if it is upgrade else false

func IsValidUpgrade ¶

func IsValidUpgrade(fromVersion, toVersion string) error

IsValidUpgrade validates fromVersion and toVersion for all upgrade/downgrade restrictions

func ParseInfoIntoMap ¶

func ParseInfoIntoMap(str, del, sep string) (map[string]string, error)

ParseInfoIntoMap parses info string into a map.

func SetMigrateFillDelay ¶

func SetMigrateFillDelay(log logr.Logger, policy *aero.ClientPolicy, allHosts []*HostConn, migrateFillDelay int) error

SetMigrateFillDelay sets the given migrate-fill-delay on all the given cluster nodes

func ValidateSCClusterState ¶

func ValidateSCClusterState(log logr.Logger, hostConns []*HostConn, policy *as.ClientPolicy,
	ignorableNamespaces sets.Set[string]) error

Types ¶

type ASConn ¶

type ASConn struct {
	Log               logr.Logger
	AerospikeHostName string // host name of the machine to connect through aerospike
	AerospikeTLSName  string // tls name of the aerospike connection
	AerospikePort     int    // aerospike port to connect to
}

func (*ASConn) AlumniReset ¶

func (asc *ASConn) AlumniReset(aerospikePolicy *aero.ClientPolicy) error

AlumniReset runs services alumni reset

func (*ASConn) RunInfo ¶

func (asc *ASConn) RunInfo(
	aerospikePolicy *aero.ClientPolicy, command ...string,
) (map[string]string, error)

RunInfo runs info command on given host

func (*ASConn) TipClearHostname ¶

func (asc *ASConn) TipClearHostname(
	aerospikePolicy *aero.ClientPolicy, address string, heartbeatPort int,
) error

TipClearHostname runs tip clear

func (*ASConn) TipHostname ¶

func (asc *ASConn) TipHostname(
	aerospikePolicy *aero.ClientPolicy, address string, heartbeatPort int,
) error

TipHostname runs tip clear

type HostConn ¶

type HostConn struct {
	Log    logr.Logger
	ASConn *ASConn
	ID     string // host UUID string
}

HostConn has all parameters to connect to an aerospike host and the machine.

func NewHostConn ¶

func NewHostConn(log logr.Logger, id string, asConn *ASConn) *HostConn

NewHostConn returns a new HostConn

func (*HostConn) String ¶

func (n *HostConn) String() string

Implements stringer interface

type InfoResult ¶ added in v1.2.0

type InfoResult map[string]string

Source Files ¶

View all Source files

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