Documentation
¶
Index ¶
Constants ¶
View Source
const DefaultChannelName = ""
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ReplicationStatus ¶
type ReplicationStatus int8
const ( ReplicationStatusActive ReplicationStatus = iota ReplicationStatusError ReplicationStatusNotInitiated )
type Replicator ¶
type Replicator interface {
ChangeReplicationSource(host, replicaPass string, port int32) error
StartReplication(host, replicaPass string, port int32) error
ReplicationStatus() (ReplicationStatus, string, error)
EnableReadonly() error
IsReadonly() (bool, error)
ReportHost() (string, error)
Close() error
CloneInProgress() (bool, error)
NeedsClone(donor string, port int32) (bool, error)
Clone(donor, user, pass string, port int32) error
IsReplica() (bool, error)
DumbQuery() error
SetSemiSyncSource(enabled bool) error
SetSemiSyncSize(size int) error
}
func NewReplicator ¶
func NewReplicator(user apiv1alpha1.SystemUser, pass, host string, port int32) (Replicator, error)
Click to show internal directories.
Click to hide internal directories.