replicationdata

package
Version: v0.11.1 Latest Latest
Warning

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

Go to latest
Published: Sep 9, 2021 License: Apache-2.0 Imports: 7 Imported by: 10

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 (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source
var File_replicationdata_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type MasterStatus

type MasterStatus 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
}

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

func (*MasterStatus) Descriptor deprecated

This method has been deprecated.
func (*MasterStatus) Descriptor() ([]byte, []int)

Deprecated: Use MasterStatus.ProtoReflect.Descriptor instead.

func (*MasterStatus) GetFilePosition

func (x *MasterStatus) GetFilePosition() string

func (*MasterStatus) GetPosition

func (x *MasterStatus) GetPosition() string

func (*MasterStatus) MarshalToSizedBufferVT added in v0.11.0

func (m *MasterStatus) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MasterStatus) MarshalToVT added in v0.11.0

func (m *MasterStatus) MarshalToVT(dAtA []byte) (int, error)

func (*MasterStatus) MarshalVT added in v0.11.0

func (m *MasterStatus) MarshalVT() (dAtA []byte, err error)

func (*MasterStatus) ProtoMessage

func (*MasterStatus) ProtoMessage()

func (*MasterStatus) ProtoReflect added in v0.11.0

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

func (*MasterStatus) Reset

func (x *MasterStatus) Reset()

func (*MasterStatus) SizeVT added in v0.11.0

func (m *MasterStatus) SizeVT() (n int)

func (*MasterStatus) String

func (x *MasterStatus) String() string

func (*MasterStatus) UnmarshalVT added in v0.11.0

func (m *MasterStatus) UnmarshalVT(dAtA []byte) error

type Status

type Status struct {
	Position            string `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	IoThreadRunning     bool   `protobuf:"varint,2,opt,name=io_thread_running,json=ioThreadRunning,proto3" json:"io_thread_running,omitempty"`
	SqlThreadRunning    bool   `protobuf:"varint,3,opt,name=sql_thread_running,json=sqlThreadRunning,proto3" json:"sql_thread_running,omitempty"`
	SecondsBehindMaster uint32 `protobuf:"varint,4,opt,name=seconds_behind_master,json=secondsBehindMaster,proto3" json:"seconds_behind_master,omitempty"`
	MasterHost          string `protobuf:"bytes,5,opt,name=master_host,json=masterHost,proto3" json:"master_host,omitempty"`
	MasterPort          int32  `protobuf:"varint,6,opt,name=master_port,json=masterPort,proto3" json:"master_port,omitempty"`
	MasterConnectRetry  int32  `protobuf:"varint,7,opt,name=master_connect_retry,json=masterConnectRetry,proto3" json:"master_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"`
	FileRelayLogPosition string `` /* 126-byte string literal not displayed */
	MasterServerId       uint32 `protobuf:"varint,11,opt,name=master_server_id,json=masterServerId,proto3" json:"master_server_id,omitempty"`
	MasterUuid           string `protobuf:"bytes,12,opt,name=master_uuid,json=masterUuid,proto3" json:"master_uuid,omitempty"`
	// 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) Descriptor deprecated

This method has been deprecated.
func (*Status) Descriptor() ([]byte, []int)

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetFilePosition

func (x *Status) GetFilePosition() string

func (*Status) GetFileRelayLogPosition

func (x *Status) GetFileRelayLogPosition() string

func (*Status) GetIoThreadRunning

func (x *Status) GetIoThreadRunning() bool

func (*Status) GetMasterConnectRetry

func (x *Status) GetMasterConnectRetry() int32

func (*Status) GetMasterHost

func (x *Status) GetMasterHost() string

func (*Status) GetMasterPort

func (x *Status) GetMasterPort() int32

func (*Status) GetMasterServerId

func (x *Status) GetMasterServerId() uint32

func (*Status) GetMasterUuid

func (x *Status) GetMasterUuid() string

func (*Status) GetPosition

func (x *Status) GetPosition() string

func (*Status) GetRelayLogPosition

func (x *Status) GetRelayLogPosition() string

func (*Status) GetSecondsBehindMaster

func (x *Status) GetSecondsBehindMaster() uint32

func (*Status) GetSqlThreadRunning

func (x *Status) GetSqlThreadRunning() bool

func (*Status) MarshalToSizedBufferVT added in v0.11.0

func (m *Status) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Status) MarshalToVT added in v0.11.0

func (m *Status) MarshalToVT(dAtA []byte) (int, error)

func (*Status) MarshalVT added in v0.11.0

func (m *Status) MarshalVT() (dAtA []byte, err error)

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) ProtoReflect added in v0.11.0

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

func (*Status) Reset

func (x *Status) Reset()

func (*Status) SizeVT added in v0.11.0

func (m *Status) SizeVT() (n int)

func (*Status) String

func (x *Status) String() string

func (*Status) UnmarshalVT added in v0.11.0

func (m *Status) UnmarshalVT(dAtA []byte) error

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 added in v0.11.0

func (StopReplicationMode) Enum added in v0.11.0

func (StopReplicationMode) EnumDescriptor deprecated

This method has been deprecated.
func (StopReplicationMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use StopReplicationMode.Descriptor instead.

func (StopReplicationMode) Number added in v0.11.0

func (StopReplicationMode) String

func (x StopReplicationMode) String() string

func (StopReplicationMode) Type added in v0.11.0

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) Descriptor deprecated

This method has been deprecated.
func (*StopReplicationStatus) Descriptor() ([]byte, []int)

Deprecated: Use StopReplicationStatus.ProtoReflect.Descriptor instead.

func (*StopReplicationStatus) GetAfter

func (x *StopReplicationStatus) GetAfter() *Status

func (*StopReplicationStatus) GetBefore

func (x *StopReplicationStatus) GetBefore() *Status

func (*StopReplicationStatus) MarshalToSizedBufferVT added in v0.11.0

func (m *StopReplicationStatus) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StopReplicationStatus) MarshalToVT added in v0.11.0

func (m *StopReplicationStatus) MarshalToVT(dAtA []byte) (int, error)

func (*StopReplicationStatus) MarshalVT added in v0.11.0

func (m *StopReplicationStatus) MarshalVT() (dAtA []byte, err error)

func (*StopReplicationStatus) ProtoMessage

func (*StopReplicationStatus) ProtoMessage()

func (*StopReplicationStatus) ProtoReflect added in v0.11.0

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

func (*StopReplicationStatus) Reset

func (x *StopReplicationStatus) Reset()

func (*StopReplicationStatus) SizeVT added in v0.11.0

func (m *StopReplicationStatus) SizeVT() (n int)

func (*StopReplicationStatus) String

func (x *StopReplicationStatus) String() string

func (*StopReplicationStatus) UnmarshalVT added in v0.11.0

func (m *StopReplicationStatus) UnmarshalVT(dAtA []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL