cmd/eksterd/fetch.go

@@ -39,6 +39,17 @@ import (
 	"willnorris.com/go/microformats"
 )
 
+type cacheItem struct {
+	item    []byte
+	created time.Time
+}
+
+var cache map[string]cacheItem
+
+func init() {
+	cache = make(map[string]cacheItem)
+}
+
 func (b *memoryBackend) feedHeader(fetchURL, contentType string, body io.Reader) (microsub.Feed, error) {
 	log.Printf("ProcessContent %s\n", fetchURL)
 	log.Println("Found " + contentType)

cmd/eksterd/main.go

@@ -26,7 +26,6 @@ import (
 	"regexp"
 	"time"
 
-	"cloud.google.com/go/profiler"
 	"github.com/garyburd/redigo/redis"
 	"github.com/pstuifzand/ekster/pkg/microsub"
 )
@@ -59,17 +58,6 @@ func newPool(addr string) *redis.Pool {
 }
 
 func main() {
-
-	if os.Getenv("GOOGLE_APPLICATION_CREDENTIALS") != "" {
-		if err := profiler.Start(profiler.Config{
-			Service:        "microsub-server",
-			ServiceVersion: "1.0",
-			ProjectID:      "microsub-server", // optional on GCP
-		}); err != nil {
-			log.Fatalf("Cannot start the profiler: %v", err)
-		}
-	}
-
 	log.Println("eksterd - microsub server")
 	flag.Parse()