Set _client_role attribute for binlogsyncer

dveeden · dveeden · commit b401eead57e6 · 2023-05-05T15:12:09.000+02:00
diff --git a/replication/binlogsyncer.go b/replication/binlogsyncer.go
@@ -891,6 +891,7 @@ func (b *BinlogSyncer) newConnection(ctx context.Context) (*client.Conn, error)
 	return client.ConnectWithDialer(timeoutCtx, "", addr, b.cfg.User, b.cfg.Password,
 		"", b.cfg.Dialer, func(c *client.Conn) {
 			c.SetTLSConfig(b.cfg.TLSConfig)
+			c.SetAttributes(map[string]string{"_client_role": "binary_log_listener"})
 		})
 }
 

Original file line number	Diff line number	Diff line change
`@@ -891,6 +891,7 @@ func (b BinlogSyncer) newConnection(ctx context.Context) (client.Conn, error)`
`891`	`891`	`return client.ConnectWithDialer(timeoutCtx, "", addr, b.cfg.User, b.cfg.Password,`
`892`	`892`	`"", b.cfg.Dialer, func(c *client.Conn) {`
`893`	`893`	`c.SetTLSConfig(b.cfg.TLSConfig)`
	`894`	`+ c.SetAttributes(map[string]string{"_client_role": "binary_log_listener"})`
`894`	`895`	`})`
`895`	`896`	`}`
`896`	`897`