replicationdata

package
v0.10.3 Latest Latest
Warning

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

 Go to latest Published: Dec 14, 2021 License: Apache-2.0 Imports: 5 Imported by: 20

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthReplicationdata        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowReplicationdata          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupReplicationdata = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var StopReplicationMode_name = map[int32]string{
	0: "IOANDSQLTHREAD",
	1: "IOTHREADONLY",
}
View Source 
var StopReplicationMode_value = map[string]int32{
	"IOANDSQLTHREAD": 0,
	"IOTHREADONLY":   1,
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*MasterStatus) Descriptor 

func (*MasterStatus) Descriptor() ([]byte, []int)

func (*MasterStatus) GetFilePosition 

func (m *MasterStatus) GetFilePosition() string

func (*MasterStatus) GetPosition 

func (m *MasterStatus) GetPosition() string

func (*MasterStatus) Marshal added in v0.10.0 

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

func (*MasterStatus) MarshalTo added in v0.10.0 

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

func (*MasterStatus) MarshalToSizedBuffer added in v0.10.0 

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

func (*MasterStatus) ProtoMessage 

func (*MasterStatus) ProtoMessage()

func (*MasterStatus) Reset 

func (m *MasterStatus) Reset()

func (*MasterStatus) Size added in v0.10.0 

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

func (*MasterStatus) String 

func (m *MasterStatus) String() string

func (*MasterStatus) Unmarshal added in v0.10.0 

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

func (*MasterStatus) XXX_DiscardUnknown 

func (m *MasterStatus) XXX_DiscardUnknown()

func (*MasterStatus) XXX_Marshal 

func (m *MasterStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MasterStatus) XXX_Merge 

func (m *MasterStatus) XXX_Merge(src proto.Message)

func (*MasterStatus) XXX_Size 

func (m *MasterStatus) XXX_Size() int

func (*MasterStatus) XXX_Unmarshal 

func (m *MasterStatus) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

func (*Status) Descriptor() ([]byte, []int)

func (*Status) GetFilePosition 

func (m *Status) GetFilePosition() string

func (*Status) GetFileRelayLogPosition 

func (m *Status) GetFileRelayLogPosition() string

func (*Status) GetIoThreadRunning 

func (m *Status) GetIoThreadRunning() bool

func (*Status) GetMasterConnectRetry 

func (m *Status) GetMasterConnectRetry() int32

func (*Status) GetMasterHost 

func (m *Status) GetMasterHost() string

func (*Status) GetMasterPort 

func (m *Status) GetMasterPort() int32

func (*Status) GetMasterServerId 

func (m *Status) GetMasterServerId() uint32

func (*Status) GetMasterUuid 

func (m *Status) GetMasterUuid() string

func (*Status) GetPosition 

func (m *Status) GetPosition() string

func (*Status) GetRelayLogPosition 

func (m *Status) GetRelayLogPosition() string

func (*Status) GetSecondsBehindMaster 

func (m *Status) GetSecondsBehindMaster() uint32

func (*Status) GetSqlThreadRunning 

func (m *Status) GetSqlThreadRunning() bool

func (*Status) Marshal added in v0.10.0 

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

func (*Status) MarshalTo added in v0.10.0 

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

func (*Status) MarshalToSizedBuffer added in v0.10.0 

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

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) Size added in v0.10.0 

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

func (*Status) String 

func (m *Status) String() string

func (*Status) Unmarshal added in v0.10.0 

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

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Status) XXX_Merge 

func (m *Status) XXX_Merge(src proto.Message)

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

func (m *Status) XXX_Unmarshal(b []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) EnumDescriptor 

func (StopReplicationMode) EnumDescriptor() ([]byte, []int)

func (StopReplicationMode) String 

func (x StopReplicationMode) String() string

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*StopReplicationStatus) Descriptor 

func (*StopReplicationStatus) Descriptor() ([]byte, []int)

func (*StopReplicationStatus) GetAfter 

func (m *StopReplicationStatus) GetAfter() *Status

func (*StopReplicationStatus) GetBefore 

func (m *StopReplicationStatus) GetBefore() *Status

func (*StopReplicationStatus) Marshal added in v0.10.0 

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

func (*StopReplicationStatus) MarshalTo added in v0.10.0 

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

func (*StopReplicationStatus) MarshalToSizedBuffer added in v0.10.0 

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

func (*StopReplicationStatus) ProtoMessage 

func (*StopReplicationStatus) ProtoMessage()

func (*StopReplicationStatus) Reset 

func (m *StopReplicationStatus) Reset()

func (*StopReplicationStatus) Size added in v0.10.0 

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

func (*StopReplicationStatus) String 

func (m *StopReplicationStatus) String() string

func (*StopReplicationStatus) Unmarshal added in v0.10.0 

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

func (*StopReplicationStatus) XXX_DiscardUnknown 

func (m *StopReplicationStatus) XXX_DiscardUnknown()

func (*StopReplicationStatus) XXX_Marshal 

func (m *StopReplicationStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopReplicationStatus) XXX_Merge 

func (m *StopReplicationStatus) XXX_Merge(src proto.Message)

func (*StopReplicationStatus) XXX_Size 

func (m *StopReplicationStatus) XXX_Size() int

func (*StopReplicationStatus) XXX_Unmarshal 

func (m *StopReplicationStatus) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

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.