mysqlsh

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Jul 3, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrEndpointUnreachable = errors.New("endpoint unreachable")
	ErrAccessDenied        = errors.New("access denied")
)
View Source 
var ErrMetadataExistsButGRNotActive = errors.New("MYSQLSH 51314: metadata exists, instance belongs to that metadata, but GR is not active")

Functions

func New 

func New(e k8sexec.Interface, uri string) *mysqlsh

func URI added in v1.2.0 

func URI(user, password, host string) string

Types

type CreateClusterSetOptions added in v1.2.0 

type CreateClusterSetOptions struct {
	SSLMode apiv1.ClusterSetSSLMode
}

func (*CreateClusterSetOptions) Default added in v1.2.0 

func (o *CreateClusterSetOptions) Default()

type ExecOptions added in v1.2.0 

type ExecOptions struct {
	Pod           *corev1.Pod
	ContainerName string
	Client        clientcmd.Client
	Stdout        io.Writer
	Stderr        io.Writer
}

func (*ExecOptions) Defaults added in v1.2.0 

func (o *ExecOptions) Defaults()

func (*ExecOptions) Validate added in v1.2.0 

func (o *ExecOptions) Validate() error

type MysqlshExec added in v1.2.0 

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

func NewWithExec added in v0.6.0 

func NewWithExec(uri string, opts *ExecOptions) (*MysqlshExec, error)

func (*MysqlshExec) ClusterSetStatusWithExec added in v1.2.0 

func (m *MysqlshExec) ClusterSetStatusWithExec(ctx context.Context) (clusterset.Status, error)

func (*MysqlshExec) ClusterStatusWithExec added in v1.2.0 

func (m *MysqlshExec) ClusterStatusWithExec(ctx context.Context) (innodbcluster.Status, error)

func (*MysqlshExec) CreateClusterSetWithExec added in v1.2.0 

func (m *MysqlshExec) CreateClusterSetWithExec(ctx context.Context, name string, opts *CreateClusterSetOptions) error

func (*MysqlshExec) CreateReplicaClusterWithExec added in v1.2.0 

func (m *MysqlshExec) CreateReplicaClusterWithExec(
	ctx context.Context,
	clusterName, recoveryMethod, endpoint string, port int32) error

func (*MysqlshExec) DoesClusterExistWithExec added in v1.2.0 

func (m *MysqlshExec) DoesClusterExistWithExec(ctx context.Context, clusterName string) bool

func (*MysqlshExec) ForcePrimaryClusterWithExec added in v1.2.0 

func (m *MysqlshExec) ForcePrimaryClusterWithExec(ctx context.Context, clusterName string) error

func (*MysqlshExec) Ping added in v1.2.0 

func (m *MysqlshExec) Ping(ctx context.Context) error

func (*MysqlshExec) RebootClusterFromCompleteOutageWithExec added in v1.2.0 

func (m *MysqlshExec) RebootClusterFromCompleteOutageWithExec(ctx context.Context, clusterName string) error

func (*MysqlshExec) RemoveInstanceWithExec added in v1.2.0 

func (m *MysqlshExec) RemoveInstanceWithExec(ctx context.Context, clusterName, instance string) error

func (*MysqlshExec) RemoveReplicaClusterWithExec added in v1.2.0 

func (m *MysqlshExec) RemoveReplicaClusterWithExec(ctx context.Context, clusterName string, force bool) error

func (*MysqlshExec) Rescan80WithExec added in v1.2.0 

func (m *MysqlshExec) Rescan80WithExec(ctx context.Context, clusterName string) error

func (*MysqlshExec) Rescan84WithExec added in v1.2.0 

func (m *MysqlshExec) Rescan84WithExec(ctx context.Context, clusterName string) error

func (*MysqlshExec) SetPrimaryClusterWithExec added in v1.2.0 

func (m *MysqlshExec) SetPrimaryClusterWithExec(ctx context.Context, clusterName string) error

func (*MysqlshExec) SetPrimaryInstanceWithExec added in v1.2.0 

func (m *MysqlshExec) SetPrimaryInstanceWithExec(ctx context.Context, clusterName, instance string) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.