replica

Documentation

Overview

Copyright 2024-2025 ApeCloud, Ltd.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Variables
• func RegisterReplicaController(provider *catalog.DatabaseProvider, engine *sqle.Engine, ...)
• func RegisterReplicaOptions(options *ReplicaOptions)
• type ReplicaOptions

Variables

var ErrPartialPrimaryKeyUpdate = errors.New("primary key columns are (partially) updated but are not fully specified in the binlog")

Functions

func RegisterReplicaController

func RegisterReplicaController(provider *catalog.DatabaseProvider, engine *sqle.Engine, pool *backend.ConnectionPool, builder *backend.DuckBuilder)

registerReplicaController registers the replica controller into the engine to handle the replication commands, such as START REPLICA, STOP REPLICA, etc.

func RegisterReplicaOptions

func RegisterReplicaOptions(options *ReplicaOptions)

Types

type ReplicaOptions

type ReplicaOptions struct {
	ReportHost     string
	ReportPort     int
	ReportUser     string
	ReportPassword string
}

ReplicaOptions holds the options for a replica server. https://dev.mysql.com/doc/refman/8.4/en/replication-options-replica.html