queries

Documentation

Index

• Constants
• Variables
• type Database
  • func New(client client.Client, namespace, secretName, user, host string, port 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) PresentInHostgroups(host string) (bool, error)
  • func (p *Database) PrimaryHost() (string, error)
  • func (p *Database) ProxySQLInstanceStatus(host string) ([]string, error)
  • func (p *Database) ReadVariable(variable string) (string, error)
  • func (p *Database) ReplicationChannelSources(channelName string) ([]ReplicationChannelSource, error)
  • func (p *Database) ReplicationStatus(ctx context.Context, channel string) (ReplicationStatus, error)
  • func (p *Database) ShowReplicaStatus(ctx context.Context, channel string) (map[string]string, error)
  • func (p *Database) StartReplication(replicaPass string, config ReplicationConfig, shouldGetMasterKey bool) 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
• type ReplicationConfig
• type ReplicationStatus

Constants

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

Variables

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

Types

type Database

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

func New

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

func (*Database) AddReplicationSource

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

func (*Database) ChangeChannelPassword

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

func (*Database) Close

func (p *Database) Close() error

func (*Database) CurrentReplicationChannels

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

func (*Database) DeleteReplicationSource

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

func (*Database) DisableReadonly

func (p *Database) DisableReadonly() error

func (*Database) EnableReadonly

func (p *Database) EnableReadonly() error

func (*Database) Hostname

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

func (*Database) IsReadonly

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

func (*Database) PresentInHostgroups

func (p *Database) PresentInHostgroups(host string) (bool, error)

func (*Database) PrimaryHost

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

func (*Database) ProxySQLInstanceStatus

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

func (*Database) ReadVariable

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

func (*Database) ReplicationChannelSources

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

func (*Database) ReplicationStatus

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

func (*Database) ShowReplicaStatus

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

func (*Database) StartReplication

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

func (*Database) StopAllReplication

func (p *Database) StopAllReplication() error

func (*Database) StopReplication

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

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

type ReplicationConfig

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

type ReplicationStatus

type ReplicationStatus int8

const (
	ReplicationStatusActive ReplicationStatus = iota
	ReplicationStatusError
	ReplicationStatusNotInitiated
)