Skip to content

Commit 2c00792

Browse files
authored
Remove SetSemiSyncSize and SetSemiSyncSource functions since (#420)
semi sync replication support is removed completely
1 parent e44f7e6 commit 2c00792

File tree

1 file changed

+0
-14
lines changed

1 file changed

+0
-14
lines changed

pkg/replicator/replicatorexec.go

Lines changed: 0 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -259,20 +259,6 @@ func (d *dbImplExec) DumbQuery(ctx context.Context) error {
259259
return errors.Wrap(err, "SELECT 1")
260260
}
261261

262-
func (d *dbImplExec) SetSemiSyncSource(ctx context.Context, enabled bool) error {
263-
var errb, outb bytes.Buffer
264-
q := fmt.Sprintf("SET GLOBAL rpl_semi_sync_master_enabled=%t", enabled)
265-
err := d.exec(ctx, q, &outb, &errb)
266-
return errors.Wrap(err, "set rpl_semi_sync_master_enabled")
267-
}
268-
269-
func (d *dbImplExec) SetSemiSyncSize(ctx context.Context, size int) error {
270-
var errb, outb bytes.Buffer
271-
q := fmt.Sprintf("SET GLOBAL rpl_semi_sync_master_wait_for_slave_count=%d", size)
272-
err := d.exec(ctx, q, &outb, &errb)
273-
return errors.Wrap(err, "set rpl_semi_sync_master_wait_for_slave_count")
274-
}
275-
276262
func (d *dbImplExec) GetGlobal(ctx context.Context, variable string) (interface{}, error) {
277263
rows := []*struct {
278264
Val interface{} `csv:"val"`

0 commit comments

Comments
 (0)