autoid_service,owner: change autoid service's etcd lease to 10s (#46455)

close pingcap/tidb#46454
This commit is contained in:
tiancaiamao
2023-09-05 01:11:11 +08:00
committed by GitHub
parent 8b9a90d3a1
commit 18ecfba603
3 changed files with 10 additions and 5 deletions

View File

@ -306,7 +306,8 @@ func newWithCli(selfAddr string, cli *clientv3.Client, store kv.Storage) *Servic
zap.String("addr", selfAddr),
zap.String("category", "autoid service"))
})
err := l.CampaignOwner()
// 10 means that autoid service's etcd lease is 10s.
err := l.CampaignOwner(10)
if err != nil {
panic(err)
}

View File

@ -53,7 +53,7 @@ type Manager interface {
// SetOwnerOpValue updates the owner op value.
SetOwnerOpValue(ctx context.Context, op OpType) error
// CampaignOwner campaigns the owner.
CampaignOwner() error
CampaignOwner(...int) error
// ResignOwner lets the owner start a new election.
ResignOwner(ctx context.Context) error
// Cancel cancels this etcd ownerManager.
@ -173,10 +173,14 @@ func setManagerSessionTTL() error {
}
// CampaignOwner implements Manager.CampaignOwner interface.
func (m *ownerManager) CampaignOwner() error {
func (m *ownerManager) CampaignOwner(withTTL ...int) error {
ttl := ManagerSessionTTL
if len(withTTL) == 1 {
ttl = withTTL[0]
}
logPrefix := fmt.Sprintf("[%s] %s", m.prompt, m.key)
logutil.BgLogger().Info("start campaign owner", zap.String("ownerInfo", logPrefix))
session, err := util2.NewSession(m.ctx, logPrefix, m.etcdCli, util2.NewSessionDefaultRetryCnt, ManagerSessionTTL)
session, err := util2.NewSession(m.ctx, logPrefix, m.etcdCli, util2.NewSessionDefaultRetryCnt, ttl)
if err != nil {
return errors.Trace(err)
}

View File

@ -131,7 +131,7 @@ func sleepContext(ctx context.Context, delay time.Duration) {
}
// CampaignOwner implements Manager.CampaignOwner interface.
func (m *mockManager) CampaignOwner() error {
func (m *mockManager) CampaignOwner(_ ...int) error {
m.wg.Add(1)
go func() {
logutil.BgLogger().Debug("owner manager campaign owner", zap.String("category", "ddl"),