Golang中如何续约etcd租约？

package main

import (
    "context"
    "time"

    clientv3 "go.etcd.io/etcd/clientv3"
)

func main() {
    cli, err := clientv3.New(clientv3.Config{
        Endpoints:   []string{"localhost:2379"},
        DialTimeout: 5 * time.Second,
    })
    if err != nil {
        // 处理错误
    }
    defer cli.Close()

    leaseID := "my-lease-id" // 从命令行或其他途径获取
    ttl := 60 // 租约时长(秒)

    resp, err := cli.KeepAlive(context.Background(), clientv3.LeaseID(leaseID))
    if err != nil {
        // 处理错误
    }

    // 监控租约状态，处理租约过期或撤销
    for {
        select {
        case <-resp:
            // 租约续约成功
        case <-time.After(time.Duration(ttl/4) * time.Second):
            // 定期检查租约状态
            _, err := cli.GetLease(context.Background(), clientv3.LeaseID(leaseID))
            if err != nil {
                // 租约可能过期或被撤销，需采取相应措施
                break
            }
        }
    }
}

package main

import (
    "context"
    "time"

    "github.com/micro/go-micro"
    clientv3 "go.etcd.io/etcd/clientv3"
)

type leaseRenewer interface {
    Lease() (*clientv3.LeaseGrantResponse, error)
    RenewLease(id clientv3.LeaseID) (*clientv3.LeaseKeepAliveResponse, error)
}

type MyService struct {
    client *clientv3.Client
}

func (s *MyService) Lease() (*clientv3.LeaseGrantResponse, error) {
    return s.client.LeaseGrant(context.Background(), 60)
}

func (s *MyService) RenewLease(id clientv3.LeaseID) (*clientv3.LeaseKeepAliveResponse, error) {
    return s.client.KeepAlive(context.Background(), id)
}

func main() {
    service := micro.NewService(
        micro.Name("my-service"),
        micro.RegisterTTL(60*time.Second),
        micro.RegisterInterval(30*time.Second),
    )

    cli, err := clientv3.New(clientv3.Config{
        Endpoints:   []string{"localhost:2379"},
        DialTimeout: 5 * time.Second,
    })
    if err != nil {
        // 处理错误
    }

    s := &MyService{client: cli}
    service.Init(
        micro.WrapHandler(func(ctx context.Context, req interface{}) (interface{}, error) {
            resp, err := s.RenewLease(clientv3.LeaseID(123)) // 替换为实际的LeaseID
            if err != nil {
                return nil, err
            }
            // 处理resp
            return nil, nil
        }),
    )
    service.Run()
}