Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

replicator

package

Go to main page

Versions in this module

v0

v0.6.0

Sep 4, 2023

Changes in this version

type Replicator

+ func NewReplicatorExec(pod *corev1.Pod, cliCmd clientcmd.Client, user apiv1alpha1.SystemUser, ...) (Replicator, error)

+ CheckIfInPrimaryPartition func(ctx context.Context) (bool, error)

+ CheckIfPrimaryUnreachable func(ctx context.Context) (bool, error)

+ DisableSuperReadonly func(ctx context.Context) error

v0.5.0

Mar 30, 2023

v0.4.0

Jan 26, 2023

Changes in this version

type Replicator

+ CheckIfDatabaseExists func(name string) (bool, error)

+ GetGlobal func(variable string) (interface{}, error)

+ GetGroupReplicationMembers func() ([]string, error)

+ ResetReplication func() error

v0.3.0

Sep 28, 2022

v0.2.0

Jun 29, 2022

Changes in this version

+ var ErrGroupReplicationNotReady = errors.New(...)

+ var ErrRestartAfterClone error = errors.New(...)

+ type MemberState string

+ const MemberStateError

+ const MemberStateOffline

+ const MemberStateOnline

+ const MemberStateRecovering

+ const MemberStateUnreachable

type Replicator

+ ChangeGroupReplicationPassword func(replicaPass string) error

+ EnableSuperReadonly func() error

+ GetGroupReplicationPrimary func() (string, error)

+ GetGroupReplicationReplicas func() ([]string, error)

+ GetMemberState func(host string) (MemberState, error)

+ SetGlobal func(variable, value string) error

+ StartGroupReplication func(password string) error

+ StopGroupReplication func() error

+ StopReplication func() error

v0.1.0

Jan 25, 2022

Changes in this version

+ const DefaultChannelName

+ type ReplicationStatus int8

+ const ReplicationStatusActive

+ const ReplicationStatusError

+ const ReplicationStatusNotInitiated

+ type Replicator interface

+ ChangeReplicationSource func(host, replicaPass string, port int32) error

+ Clone func(donor, user, pass string, port int32) error

+ CloneInProgress func() (bool, error)

+ Close func() error

+ DumbQuery func() error

+ EnableReadonly func() error

+ IsReadonly func() (bool, error)

+ IsReplica func() (bool, error)

+ NeedsClone func(donor string, port int32) (bool, error)

+ ReplicationStatus func() (ReplicationStatus, string, error)

+ ReportHost func() (string, error)

+ SetSemiSyncSize func(size int) error

+ SetSemiSyncSource func(enabled bool) error

+ StartReplication func(host, replicaPass string, port int32) error

+ func NewReplicator(user apiv1alpha1.SystemUser, pass, host string, port int32) (Replicator, error)