queries

package

v1.10.0 Latest Latest Go to latest Published: Nov 19, 2021 License: Apache-2.0 Imports: 9 Imported by: 1

Documentation ¶

This section is empty.

View Source

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

This section is empty.

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

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

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

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

func (p *Database) Close() error

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

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

func (p *Database) DisableReadonly() error

func (p *Database) EnableReadonly() error

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

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

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

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

func (p *Database) ReplicationStatus(channel string) (ReplicationStatus, error)

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

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

func (p *Database) StopAllReplication() error

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

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

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

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

type ReplicationConfig struct {
	Source             ReplicationChannelSource
	SourceRetryCount   uint
	SourceConnectRetry uint
}

type ReplicationStatus int8

const (
	ReplicationStatusActive ReplicationStatus = iota
	ReplicationStatusError
	ReplicationStatusNotInitiated
)