manager

package

v1.2.0 Latest Latest Go to latest Published: Jul 3, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation ¶

This section is empty.

View Source

var AlreadyPrimaryClusterError = errors.New("already the primary cluster")

func IsUnreachableError(err error) bool

func New(ctx context.Context, pcs *apiv1.PerconaServerMySQLClusterSet, opts *ManagerOptions) (*mysqlshellClusterSetManager, error)

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

func AsManagerError(err error) *ClusterSetManagerError

func NewAccessDeniedError() *ClusterSetManagerError

NewAccessDeniedError returns an error indicating that the clusterset credentials were rejected by the primary cluster.

func NewGenericError(message string) *ClusterSetManagerError

NewGenericError returns an error for any other cluster set manager failure.

func NewUnreachableError() *ClusterSetManagerError

NewUnreachableError returns an error indicating that no endpoint of the primary cluster could be reached.

func (e *ClusterSetManagerError) Error() string

func (e *ClusterSetManagerError) Message() string

func (e *ClusterSetManagerError) Reason() string

type ManagerOptions struct {
	Client    client.Client
	ClientCmd clientcmd.Client
	Stdout    io.Writer
	Stderr    io.Writer
}