replicationdatav19

package
v1.36.10-2025040823455... Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: unknown License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	StopReplicationMode_name = map[int32]string{
		0: "IOANDSQLTHREAD",
		1: "IOTHREADONLY",
	}
	StopReplicationMode_value = map[string]int32{
		"IOANDSQLTHREAD": 0,
		"IOTHREADONLY":   1,
	}
)

Enum value maps for StopReplicationMode.

View Source 
var File_vitess_replicationdata_v19_replicationdata_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type FullStatus 

type FullStatus struct {
	ServerId                    uint32         `protobuf:"varint,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	ServerUuid                  string         `protobuf:"bytes,2,opt,name=server_uuid,json=serverUuid,proto3" json:"server_uuid,omitempty"`
	ReplicationStatus           *Status        `protobuf:"bytes,3,opt,name=replication_status,json=replicationStatus,proto3" json:"replication_status,omitempty"`
	PrimaryStatus               *PrimaryStatus `protobuf:"bytes,4,opt,name=primary_status,json=primaryStatus,proto3" json:"primary_status,omitempty"`
	GtidPurged                  string         `protobuf:"bytes,5,opt,name=gtid_purged,json=gtidPurged,proto3" json:"gtid_purged,omitempty"`
	Version                     string         `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"`
	VersionComment              string         `protobuf:"bytes,7,opt,name=version_comment,json=versionComment,proto3" json:"version_comment,omitempty"`
	ReadOnly                    bool           `protobuf:"varint,8,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	GtidMode                    string         `protobuf:"bytes,9,opt,name=gtid_mode,json=gtidMode,proto3" json:"gtid_mode,omitempty"`
	BinlogFormat                string         `protobuf:"bytes,10,opt,name=binlog_format,json=binlogFormat,proto3" json:"binlog_format,omitempty"`
	BinlogRowImage              string         `protobuf:"bytes,11,opt,name=binlog_row_image,json=binlogRowImage,proto3" json:"binlog_row_image,omitempty"`
	LogBinEnabled               bool           `protobuf:"varint,12,opt,name=log_bin_enabled,json=logBinEnabled,proto3" json:"log_bin_enabled,omitempty"`
	LogReplicaUpdates           bool           `protobuf:"varint,13,opt,name=log_replica_updates,json=logReplicaUpdates,proto3" json:"log_replica_updates,omitempty"`
	SemiSyncPrimaryEnabled      bool           `` /* 133-byte string literal not displayed */
	SemiSyncReplicaEnabled      bool           `` /* 133-byte string literal not displayed */
	SemiSyncPrimaryStatus       bool           `` /* 130-byte string literal not displayed */
	SemiSyncReplicaStatus       bool           `` /* 130-byte string literal not displayed */
	SemiSyncPrimaryClients      uint32         `` /* 133-byte string literal not displayed */
	SemiSyncPrimaryTimeout      uint64         `` /* 133-byte string literal not displayed */
	SemiSyncWaitForReplicaCount uint32         `` /* 152-byte string literal not displayed */
	SuperReadOnly               bool           `protobuf:"varint,21,opt,name=super_read_only,json=superReadOnly,proto3" json:"super_read_only,omitempty"`
	// contains filtered or unexported fields
}

FullStatus contains the full status of MySQL including the replication information, semi-sync information, GTID information among others

func (*FullStatus) ClearPrimaryStatus 

func (x *FullStatus) ClearPrimaryStatus()

func (*FullStatus) ClearReplicationStatus 

func (x *FullStatus) ClearReplicationStatus()

func (*FullStatus) GetBinlogFormat 

func (x *FullStatus) GetBinlogFormat() string

func (*FullStatus) GetBinlogRowImage 

func (x *FullStatus) GetBinlogRowImage() string

func (*FullStatus) GetGtidMode 

func (x *FullStatus) GetGtidMode() string

func (*FullStatus) GetGtidPurged 

func (x *FullStatus) GetGtidPurged() string

func (*FullStatus) GetLogBinEnabled 

func (x *FullStatus) GetLogBinEnabled() bool

func (*FullStatus) GetLogReplicaUpdates 

func (x *FullStatus) GetLogReplicaUpdates() bool

func (*FullStatus) GetPrimaryStatus 

func (x *FullStatus) GetPrimaryStatus() *PrimaryStatus

func (*FullStatus) GetReadOnly 

func (x *FullStatus) GetReadOnly() bool

func (*FullStatus) GetReplicationStatus 

func (x *FullStatus) GetReplicationStatus() *Status

func (*FullStatus) GetSemiSyncPrimaryClients 

func (x *FullStatus) GetSemiSyncPrimaryClients() uint32

func (*FullStatus) GetSemiSyncPrimaryEnabled 

func (x *FullStatus) GetSemiSyncPrimaryEnabled() bool

func (*FullStatus) GetSemiSyncPrimaryStatus 

func (x *FullStatus) GetSemiSyncPrimaryStatus() bool

func (*FullStatus) GetSemiSyncPrimaryTimeout 

func (x *FullStatus) GetSemiSyncPrimaryTimeout() uint64

func (*FullStatus) GetSemiSyncReplicaEnabled 

func (x *FullStatus) GetSemiSyncReplicaEnabled() bool

func (*FullStatus) GetSemiSyncReplicaStatus 

func (x *FullStatus) GetSemiSyncReplicaStatus() bool

func (*FullStatus) GetSemiSyncWaitForReplicaCount 

func (x *FullStatus) GetSemiSyncWaitForReplicaCount() uint32

func (*FullStatus) GetServerId 

func (x *FullStatus) GetServerId() uint32

func (*FullStatus) GetServerUuid 

func (x *FullStatus) GetServerUuid() string

func (*FullStatus) GetSuperReadOnly 

func (x *FullStatus) GetSuperReadOnly() bool

func (*FullStatus) GetVersion 

func (x *FullStatus) GetVersion() string

func (*FullStatus) GetVersionComment 

func (x *FullStatus) GetVersionComment() string

func (*FullStatus) HasPrimaryStatus 

func (x *FullStatus) HasPrimaryStatus() bool

func (*FullStatus) HasReplicationStatus 

func (x *FullStatus) HasReplicationStatus() bool

func (*FullStatus) ProtoMessage 

func (*FullStatus) ProtoMessage()

func (*FullStatus) ProtoReflect 

func (x *FullStatus) ProtoReflect() protoreflect.Message

func (*FullStatus) Reset 

func (x *FullStatus) Reset()

func (*FullStatus) SetBinlogFormat 

func (x *FullStatus) SetBinlogFormat(v string)

func (*FullStatus) SetBinlogRowImage 

func (x *FullStatus) SetBinlogRowImage(v string)

func (*FullStatus) SetGtidMode 

func (x *FullStatus) SetGtidMode(v string)

func (*FullStatus) SetGtidPurged 

func (x *FullStatus) SetGtidPurged(v string)

func (*FullStatus) SetLogBinEnabled 

func (x *FullStatus) SetLogBinEnabled(v bool)

func (*FullStatus) SetLogReplicaUpdates 

func (x *FullStatus) SetLogReplicaUpdates(v bool)

func (*FullStatus) SetPrimaryStatus 

func (x *FullStatus) SetPrimaryStatus(v *PrimaryStatus)

func (*FullStatus) SetReadOnly 

func (x *FullStatus) SetReadOnly(v bool)

func (*FullStatus) SetReplicationStatus 

func (x *FullStatus) SetReplicationStatus(v *Status)

func (*FullStatus) SetSemiSyncPrimaryClients 

func (x *FullStatus) SetSemiSyncPrimaryClients(v uint32)

func (*FullStatus) SetSemiSyncPrimaryEnabled 

func (x *FullStatus) SetSemiSyncPrimaryEnabled(v bool)

func (*FullStatus) SetSemiSyncPrimaryStatus 

func (x *FullStatus) SetSemiSyncPrimaryStatus(v bool)

func (*FullStatus) SetSemiSyncPrimaryTimeout 

func (x *FullStatus) SetSemiSyncPrimaryTimeout(v uint64)

func (*FullStatus) SetSemiSyncReplicaEnabled 

func (x *FullStatus) SetSemiSyncReplicaEnabled(v bool)

func (*FullStatus) SetSemiSyncReplicaStatus 

func (x *FullStatus) SetSemiSyncReplicaStatus(v bool)

func (*FullStatus) SetSemiSyncWaitForReplicaCount 

func (x *FullStatus) SetSemiSyncWaitForReplicaCount(v uint32)

func (*FullStatus) SetServerId 

func (x *FullStatus) SetServerId(v uint32)

func (*FullStatus) SetServerUuid 

func (x *FullStatus) SetServerUuid(v string)

func (*FullStatus) SetSuperReadOnly 

func (x *FullStatus) SetSuperReadOnly(v bool)

func (*FullStatus) SetVersion 

func (x *FullStatus) SetVersion(v string)

func (*FullStatus) SetVersionComment 

func (x *FullStatus) SetVersionComment(v string)

func (*FullStatus) String 

func (x *FullStatus) String() string

type FullStatus_builder 

type FullStatus_builder struct {
	ServerId                    uint32
	ServerUuid                  string
	ReplicationStatus           *Status
	PrimaryStatus               *PrimaryStatus
	GtidPurged                  string
	Version                     string
	VersionComment              string
	ReadOnly                    bool
	GtidMode                    string
	BinlogFormat                string
	BinlogRowImage              string
	LogBinEnabled               bool
	LogReplicaUpdates           bool
	SemiSyncPrimaryEnabled      bool
	SemiSyncReplicaEnabled      bool
	SemiSyncPrimaryStatus       bool
	SemiSyncReplicaStatus       bool
	SemiSyncPrimaryClients      uint32
	SemiSyncPrimaryTimeout      uint64
	SemiSyncWaitForReplicaCount uint32
	SuperReadOnly               bool
	// contains filtered or unexported fields
}

func (FullStatus_builder) Build 

func (b0 FullStatus_builder) Build() *FullStatus

type PrimaryStatus 

type PrimaryStatus struct {
	Position     string `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	FilePosition string `protobuf:"bytes,2,opt,name=file_position,json=filePosition,proto3" json:"file_position,omitempty"`
	// contains filtered or unexported fields
}

PrimaryStatus is the replication status for a MySQL primary (returned by 'show master status').

func (*PrimaryStatus) GetFilePosition 

func (x *PrimaryStatus) GetFilePosition() string

func (*PrimaryStatus) GetPosition 

func (x *PrimaryStatus) GetPosition() string

func (*PrimaryStatus) ProtoMessage 

func (*PrimaryStatus) ProtoMessage()

func (*PrimaryStatus) ProtoReflect 

func (x *PrimaryStatus) ProtoReflect() protoreflect.Message

func (*PrimaryStatus) Reset 

func (x *PrimaryStatus) Reset()

func (*PrimaryStatus) SetFilePosition 

func (x *PrimaryStatus) SetFilePosition(v string)

func (*PrimaryStatus) SetPosition 

func (x *PrimaryStatus) SetPosition(v string)

func (*PrimaryStatus) String 

func (x *PrimaryStatus) String() string

type PrimaryStatus_builder 

type PrimaryStatus_builder struct {
	Position     string
	FilePosition string
	// contains filtered or unexported fields
}

func (PrimaryStatus_builder) Build 

func (b0 PrimaryStatus_builder) Build() *PrimaryStatus

type Status 

type Status struct {
	Position              string `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	ReplicationLagSeconds uint32 `` /* 127-byte string literal not displayed */
	SourceHost            string `protobuf:"bytes,5,opt,name=source_host,json=sourceHost,proto3" json:"source_host,omitempty"`
	SourcePort            int32  `protobuf:"varint,6,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
	ConnectRetry          int32  `protobuf:"varint,7,opt,name=connect_retry,json=connectRetry,proto3" json:"connect_retry,omitempty"`
	// RelayLogPosition will be empty for flavors that do not support returning the full GTIDSet from the relay log, such as MariaDB.
	RelayLogPosition                       string `protobuf:"bytes,8,opt,name=relay_log_position,json=relayLogPosition,proto3" json:"relay_log_position,omitempty"`
	FilePosition                           string `protobuf:"bytes,9,opt,name=file_position,json=filePosition,proto3" json:"file_position,omitempty"`
	RelayLogSourceBinlogEquivalentPosition string `` /* 184-byte string literal not displayed */
	SourceServerId                         uint32 `protobuf:"varint,11,opt,name=source_server_id,json=sourceServerId,proto3" json:"source_server_id,omitempty"`
	SourceUuid                             string `protobuf:"bytes,12,opt,name=source_uuid,json=sourceUuid,proto3" json:"source_uuid,omitempty"`
	IoState                                int32  `protobuf:"varint,13,opt,name=io_state,json=ioState,proto3" json:"io_state,omitempty"`
	LastIoError                            string `protobuf:"bytes,14,opt,name=last_io_error,json=lastIoError,proto3" json:"last_io_error,omitempty"`
	SqlState                               int32  `protobuf:"varint,15,opt,name=sql_state,json=sqlState,proto3" json:"sql_state,omitempty"`
	LastSqlError                           string `protobuf:"bytes,16,opt,name=last_sql_error,json=lastSqlError,proto3" json:"last_sql_error,omitempty"`
	RelayLogFilePosition                   string `` /* 126-byte string literal not displayed */
	SourceUser                             string `protobuf:"bytes,18,opt,name=source_user,json=sourceUser,proto3" json:"source_user,omitempty"`
	SqlDelay                               uint32 `protobuf:"varint,19,opt,name=sql_delay,json=sqlDelay,proto3" json:"sql_delay,omitempty"`
	AutoPosition                           bool   `protobuf:"varint,20,opt,name=auto_position,json=autoPosition,proto3" json:"auto_position,omitempty"`
	UsingGtid                              bool   `protobuf:"varint,21,opt,name=using_gtid,json=usingGtid,proto3" json:"using_gtid,omitempty"`
	HasReplicationFilters                  bool   `` /* 128-byte string literal not displayed */
	SslAllowed                             bool   `protobuf:"varint,23,opt,name=ssl_allowed,json=sslAllowed,proto3" json:"ssl_allowed,omitempty"`
	ReplicationLagUnknown                  bool   `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

Status is the replication status for MySQL/MariaDB/File-based. Returned by a flavor-specific command and parsed into a Position and fields.

func (*Status) GetAutoPosition 

func (x *Status) GetAutoPosition() bool

func (*Status) GetConnectRetry 

func (x *Status) GetConnectRetry() int32

func (*Status) GetFilePosition 

func (x *Status) GetFilePosition() string

func (*Status) GetHasReplicationFilters 

func (x *Status) GetHasReplicationFilters() bool

func (*Status) GetIoState 

func (x *Status) GetIoState() int32

func (*Status) GetLastIoError 

func (x *Status) GetLastIoError() string

func (*Status) GetLastSqlError 

func (x *Status) GetLastSqlError() string

func (*Status) GetPosition 

func (x *Status) GetPosition() string

func (*Status) GetRelayLogFilePosition 

func (x *Status) GetRelayLogFilePosition() string

func (*Status) GetRelayLogPosition 

func (x *Status) GetRelayLogPosition() string

func (*Status) GetRelayLogSourceBinlogEquivalentPosition 

func (x *Status) GetRelayLogSourceBinlogEquivalentPosition() string

func (*Status) GetReplicationLagSeconds 

func (x *Status) GetReplicationLagSeconds() uint32

func (*Status) GetReplicationLagUnknown 

func (x *Status) GetReplicationLagUnknown() bool

func (*Status) GetSourceHost 

func (x *Status) GetSourceHost() string

func (*Status) GetSourcePort 

func (x *Status) GetSourcePort() int32

func (*Status) GetSourceServerId 

func (x *Status) GetSourceServerId() uint32

func (*Status) GetSourceUser 

func (x *Status) GetSourceUser() string

func (*Status) GetSourceUuid 

func (x *Status) GetSourceUuid() string

func (*Status) GetSqlDelay 

func (x *Status) GetSqlDelay() uint32

func (*Status) GetSqlState 

func (x *Status) GetSqlState() int32

func (*Status) GetSslAllowed 

func (x *Status) GetSslAllowed() bool

func (*Status) GetUsingGtid 

func (x *Status) GetUsingGtid() bool

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

func (x *Status) ProtoReflect() protoreflect.Message

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) SetAutoPosition 

func (x *Status) SetAutoPosition(v bool)

func (*Status) SetConnectRetry 

func (x *Status) SetConnectRetry(v int32)

func (*Status) SetFilePosition 

func (x *Status) SetFilePosition(v string)

func (*Status) SetHasReplicationFilters 

func (x *Status) SetHasReplicationFilters(v bool)

func (*Status) SetIoState 

func (x *Status) SetIoState(v int32)

func (*Status) SetLastIoError 

func (x *Status) SetLastIoError(v string)

func (*Status) SetLastSqlError 

func (x *Status) SetLastSqlError(v string)

func (*Status) SetPosition 

func (x *Status) SetPosition(v string)

func (*Status) SetRelayLogFilePosition 

func (x *Status) SetRelayLogFilePosition(v string)

func (*Status) SetRelayLogPosition 

func (x *Status) SetRelayLogPosition(v string)

func (*Status) SetRelayLogSourceBinlogEquivalentPosition 

func (x *Status) SetRelayLogSourceBinlogEquivalentPosition(v string)

func (*Status) SetReplicationLagSeconds 

func (x *Status) SetReplicationLagSeconds(v uint32)

func (*Status) SetReplicationLagUnknown 

func (x *Status) SetReplicationLagUnknown(v bool)

func (*Status) SetSourceHost 

func (x *Status) SetSourceHost(v string)

func (*Status) SetSourcePort 

func (x *Status) SetSourcePort(v int32)

func (*Status) SetSourceServerId 

func (x *Status) SetSourceServerId(v uint32)

func (*Status) SetSourceUser 

func (x *Status) SetSourceUser(v string)

func (*Status) SetSourceUuid 

func (x *Status) SetSourceUuid(v string)

func (*Status) SetSqlDelay 

func (x *Status) SetSqlDelay(v uint32)

func (*Status) SetSqlState 

func (x *Status) SetSqlState(v int32)

func (*Status) SetSslAllowed 

func (x *Status) SetSslAllowed(v bool)

func (*Status) SetUsingGtid 

func (x *Status) SetUsingGtid(v bool)

func (*Status) String 

func (x *Status) String() string

type Status_builder 

type Status_builder struct {
	Position              string
	ReplicationLagSeconds uint32
	SourceHost            string
	SourcePort            int32
	ConnectRetry          int32
	// RelayLogPosition will be empty for flavors that do not support returning the full GTIDSet from the relay log, such as MariaDB.
	RelayLogPosition                       string
	FilePosition                           string
	RelayLogSourceBinlogEquivalentPosition string
	SourceServerId                         uint32
	SourceUuid                             string
	IoState                                int32
	LastIoError                            string
	SqlState                               int32
	LastSqlError                           string
	RelayLogFilePosition                   string
	SourceUser                             string
	SqlDelay                               uint32
	AutoPosition                           bool
	UsingGtid                              bool
	HasReplicationFilters                  bool
	SslAllowed                             bool
	ReplicationLagUnknown                  bool
	// contains filtered or unexported fields
}

func (Status_builder) Build 

func (b0 Status_builder) Build() *Status

type StopReplicationMode 

type StopReplicationMode int32

StopReplicationMode is used to provide controls over how replication is stopped. 

const (
	StopReplicationMode_IOANDSQLTHREAD StopReplicationMode = 0
	StopReplicationMode_IOTHREADONLY   StopReplicationMode = 1
)

func (StopReplicationMode) Descriptor 

func (StopReplicationMode) Descriptor() protoreflect.EnumDescriptor

func (StopReplicationMode) Enum 

func (x StopReplicationMode) Enum() *StopReplicationMode

func (StopReplicationMode) Number 

func (x StopReplicationMode) Number() protoreflect.EnumNumber

func (StopReplicationMode) String 

func (x StopReplicationMode) String() string

func (StopReplicationMode) Type 

func (StopReplicationMode) Type() protoreflect.EnumType

type StopReplicationStatus 

type StopReplicationStatus struct {
	Before *Status `protobuf:"bytes,1,opt,name=before,proto3" json:"before,omitempty"`
	After  *Status `protobuf:"bytes,2,opt,name=after,proto3" json:"after,omitempty"`
	// contains filtered or unexported fields
}

StopReplicationStatus represents the replication status before calling StopReplication, and the replication status collected immediately after calling StopReplication.

func (*StopReplicationStatus) ClearAfter 

func (x *StopReplicationStatus) ClearAfter()

func (*StopReplicationStatus) ClearBefore 

func (x *StopReplicationStatus) ClearBefore()

func (*StopReplicationStatus) GetAfter 

func (x *StopReplicationStatus) GetAfter() *Status

func (*StopReplicationStatus) GetBefore 

func (x *StopReplicationStatus) GetBefore() *Status

func (*StopReplicationStatus) HasAfter 

func (x *StopReplicationStatus) HasAfter() bool

func (*StopReplicationStatus) HasBefore 

func (x *StopReplicationStatus) HasBefore() bool

func (*StopReplicationStatus) ProtoMessage 

func (*StopReplicationStatus) ProtoMessage()

func (*StopReplicationStatus) ProtoReflect 

func (x *StopReplicationStatus) ProtoReflect() protoreflect.Message

func (*StopReplicationStatus) Reset 

func (x *StopReplicationStatus) Reset()

func (*StopReplicationStatus) SetAfter 

func (x *StopReplicationStatus) SetAfter(v *Status)

func (*StopReplicationStatus) SetBefore 

func (x *StopReplicationStatus) SetBefore(v *Status)

func (*StopReplicationStatus) String 

func (x *StopReplicationStatus) String() string

type StopReplicationStatus_builder 

type StopReplicationStatus_builder struct {
	Before *Status
	After  *Status
	// contains filtered or unexported fields
}

func (StopReplicationStatus_builder) Build 

func (b0 StopReplicationStatus_builder) Build() *StopReplicationStatus

Source Files

  • replicationdata.pb.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.