1
package aof
2
 
3
import (
4
	"context"
5
	"time"
6
)
7
 
8
func (d *DiskKV) Acquire(ctx context.Context, lease []byte, ttl time.Duration) (token uint64, err error) {
9
	return d.memKv.Acquire(ctx, lease, ttl)
10
}
11
 
12
func (d *DiskKV) Renew(ctx context.Context, lease []byte, ttl time.Duration, prevToken uint64) (newToken uint64, err error) {
13
	return d.memKv.Renew(ctx, lease, ttl, prevToken)
14
}
15
 
16
func (d *DiskKV) Release(ctx context.Context, lease []byte, token uint64) error {
17
	return d.memKv.Release(ctx, lease, token)
18
}