for {
// FIXME: We can't use ListObjectsV2, it is not universally supported.
// (Ceph RGW supported ListObjectsV2 since v15.1.0, released 2020 Jan 30th)
// (as of 2020, DigitalOcean Spaces still does not support V2 - https://developers.digitalocean.com/documentation/spaces/#list-bucket-conten…
getGlobalCheckpointFromStorage 函数遍历 v1/global_checkpoint 目录下的所有 .ts 文件,读取其中的时间戳并取最大值:
1 func getGlobalCheckpointFromStorage(ctx context.Context, s storage.ExternalStorage) (uint64, error) {
2 var globalCheckPointTS uint64 = 0
3 opt := storage.WalkOption{SubDir: stream.GetStreamB…