queries

package

v1.20.0 Latest Latest Go to latest Published: Jun 4, 2026 License: Apache-2.0 Imports: 9 Imported by: 1

Documentation ¶

Index ¶

Constants
Variables
type Database
- func New(ctx context.Context, client client.Client, ...) (Database, error)
type ReplicationChannelSource
type ReplicationConfig
type ReplicationStatus

Constants ¶

const (
	WriterHostgroup = "writer_hostgroup"
	ReaderHostgroup = "reader_hostgroup"
)

View Source

const (
	WriterHostgroupID = 11
	ReaderHostgroupID = 10
)

Hostgroup IDs are hardcoded in ProxySQL config inside docker image https://github.com/percona/percona-docker/blob/pxc-operator-1.3.0/proxysql/dockerdir/etc/proxysql-admin.cnf#L23

Variables ¶

View Source

var ErrNotFound = errors.New("not found")

Functions ¶

This section is empty.

Types ¶

type Database ¶

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

func New ¶

func New(ctx context.Context, client client.Client, namespace, secretName, user, host string, port int32, timeout int32) (Database, error)

func (*Database) AddReplicationSource ¶ added in v1.9.0

func (p *Database) AddReplicationSource(name, host string, port, weight int) error

func (*Database) ChangeChannelPassword ¶ added in v1.10.0

func (p *Database) ChangeChannelPassword(channel, password string) error

func (*Database) Close ¶

func (p *Database) Close() error

func (*Database) CurrentReplicationChannels ¶ added in v1.9.0

func (p *Database) CurrentReplicationChannels() ([]string, error)

func (*Database) DeleteReplicationSource ¶ added in v1.9.0

func (p *Database) DeleteReplicationSource(name, host string, port int) error

func (*Database) DisableReadonly ¶ added in v1.9.0

func (p *Database) DisableReadonly() error

func (*Database) EnableReadonly ¶ added in v1.9.0

func (p *Database) EnableReadonly() error

func (*Database) Hostname ¶

func (p *Database) Hostname() (string, error)

func (*Database) IsReadonly ¶ added in v1.9.0

func (p *Database) IsReadonly() (bool, error)

func (*Database) NonPrimaryHostsProxySQL ¶ added in v1.19.0

func (p *Database) NonPrimaryHostsProxySQL() ([]string, error)

func (*Database) PresentInHostgroup ¶ added in v1.19.0

func (p *Database) PresentInHostgroup(host string, hostgroup int) (bool, error)

func (*Database) PrimaryHost ¶

func (p *Database) PrimaryHost() (string, error)

func (*Database) ProxySQLInstanceStatus ¶ added in v1.11.0

func (p *Database) ProxySQLInstanceStatus(host string) ([]string, error)

func (*Database) ReadVariable ¶ added in v1.14.0

func (p *Database) ReadVariable(variable string) (string, error)

func (*Database) ReaderHost ¶ added in v1.19.1

func (p *Database) ReaderHost() (string, error)

ReaderHost returns any online host from the reader hostgroup (10). This is useful for replica clusters where no writer hostgroup exists.

func (*Database) ReplicationChannelSources ¶ added in v1.9.0

func (p *Database) ReplicationChannelSources(channelName string) ([]ReplicationChannelSource, error)

func (*Database) ReplicationStatus ¶ added in v1.9.0

func (p *Database) ReplicationStatus(ctx context.Context, channel string) (ReplicationStatus, error)

func (*Database) ShowReplicaStatus ¶ added in v1.14.0

func (p *Database) ShowReplicaStatus(ctx context.Context, channel string) (map[string]string, error)

func (*Database) StartReplication ¶ added in v1.9.0

func (p *Database) StartReplication(replicaPass string, config ReplicationConfig, shouldGetMasterKey bool) error

func (*Database) StopAllReplication ¶ added in v1.9.0

func (p *Database) StopAllReplication() error

func (*Database) StopReplication ¶ added in v1.9.0

func (p *Database) StopReplication(name string) error

func (*Database) Version ¶

func (p *Database) Version() (string, error)

func (*Database) WsrepLocalStateComment ¶

func (p *Database) WsrepLocalStateComment() (string, error)

type ReplicationChannelSource ¶ added in v1.9.0

type ReplicationChannelSource struct {
	Name   string
	Host   string
	Port   int
	Weight int
}

type ReplicationConfig ¶ added in v1.10.0

type ReplicationConfig struct {
	Source             ReplicationChannelSource
	SourceRetryCount   uint
	SourceConnectRetry uint
	SSL                bool
	SSLSkipVerify      bool
	CA                 string
}

type ReplicationStatus ¶ added in v1.9.0

type ReplicationStatus int8

const (
	ReplicationStatusActive ReplicationStatus = iota
	ReplicationStatusError
	ReplicationStatusNotInitiated
)

Source Files ¶

View all Source files

queries.go

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