update
This commit is contained in:
@@ -8,6 +8,7 @@ import (
|
|||||||
"net/http"
|
"net/http"
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
|
"regexp"
|
||||||
"sort"
|
"sort"
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
@@ -27,6 +28,8 @@ func NewFileServer(dataDir string) *FileServer {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
var cartFileRe = regexp.MustCompile(`^(\d+)\.events\.log$`)
|
||||||
|
|
||||||
func listCartFiles(dir string) ([]CartFileInfo, error) {
|
func listCartFiles(dir string) ([]CartFileInfo, error) {
|
||||||
entries, err := os.ReadDir(dir)
|
entries, err := os.ReadDir(dir)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
@@ -6,7 +6,6 @@ import (
|
|||||||
"log"
|
"log"
|
||||||
"net/http"
|
"net/http"
|
||||||
"os"
|
"os"
|
||||||
"regexp"
|
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
actor "git.tornberg.me/go-cart-actor/pkg/actor"
|
actor "git.tornberg.me/go-cart-actor/pkg/actor"
|
||||||
@@ -30,8 +29,6 @@ func envOrDefault(key, def string) string {
|
|||||||
return def
|
return def
|
||||||
}
|
}
|
||||||
|
|
||||||
var cartFileRe = regexp.MustCompile(`^(\d+)\.events\.log$`)
|
|
||||||
|
|
||||||
var globalDisk *actor.DiskStorage[cart.CartGrain]
|
var globalDisk *actor.DiskStorage[cart.CartGrain]
|
||||||
|
|
||||||
func buildRegistry() actor.MutationRegistry {
|
func buildRegistry() actor.MutationRegistry {
|
||||||
|
|||||||
Reference in New Issue
Block a user