1

collector/README.md

@@ -26,3 +26,19 @@ Collector is a part of the Pegasus ecosystem that serves as:
 1. the service availability detector
 2. the hotkey detector
 3. the capacity units recorder
+
+## Requirement
+
+- Go1.18+
+
+## Development
+
+Build the collector:
+```bash
+make build
+```
+
+Format the code:
+```bash
+make fmt
+```

collector/go.mod

@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-module github.com/pegasus-kv/collector
+module github.com/apache/incubator-pegasus/collector
 
 go 1.18
 

collector/main.go

@@ -26,9 +26,9 @@ import (
 	"strings"
 	"syscall"
 
-	"github.com/pegasus-kv/collector/avail"
-	"github.com/pegasus-kv/collector/metrics"
-	"github.com/pegasus-kv/collector/webui"
+	"github.com/apache/incubator-pegasus/collector/avail"
+	"github.com/apache/incubator-pegasus/collector/metrics"
+	"github.com/apache/incubator-pegasus/collector/webui"
 	log "github.com/sirupsen/logrus"
 	"github.com/spf13/viper"
 	"gopkg.in/natefinch/lumberjack.v2"

collector/sink/falcon_sink.go

@@ -25,7 +25,7 @@ import (
 	"net/http"
 	"time"
 
-	"github.com/pegasus-kv/collector/aggregate"
+	"github.com/apache/incubator-pegasus/collector/aggregate"
 	log "github.com/sirupsen/logrus"
 	"github.com/spf13/viper"
 )

collector/sink/prometheus_sink.go

@@ -20,7 +20,7 @@ package sink
 import (
 	"sync"
 
-	"github.com/pegasus-kv/collector/aggregate"
+	"github.com/apache/incubator-pegasus/collector/aggregate"
 	"github.com/prometheus/client_golang/prometheus"
 )
 

collector/sink/sink.go

@@ -18,7 +18,7 @@
 package sink
 
 import (
-	"github.com/pegasus-kv/collector/aggregate"
+	"github.com/apache/incubator-pegasus/collector/aggregate"
 	log "github.com/sirupsen/logrus"
 	"github.com/spf13/viper"
 )

collector/usage/usage_recorder.go

@@ -22,8 +22,8 @@ import (
 	"fmt"
 	"time"
 
+	"github.com/apache/incubator-pegasus/collector/aggregate"
 	"github.com/apache/incubator-pegasus/go-client/pegasus"
-	"github.com/pegasus-kv/collector/aggregate"
 	log "github.com/sirupsen/logrus"
 	"github.com/spf13/viper"
 	"gopkg.in/tomb.v2"

collector/webui/index.go

@@ -18,8 +18,8 @@
 package webui
 
 import (
+	"github.com/apache/incubator-pegasus/collector/aggregate"
 	"github.com/kataras/iris/v12"
-	"github.com/pegasus-kv/collector/aggregate"
 )
 
 var indexPageClusterStats = []string{