<http><debug><chat>

Author: iceopen

demo/bigcache/main.go

@@ -0,0 +1,15 @@
+package main
+
+import (
+	"log"
+	"time"
+
+	"github.com/google/gops/agent"
+)
+
+func main() {
+	if err := agent.Listen(nil); err != nil {
+		log.Fatal(err)
+	}
+	time.Sleep(time.Hour)
+}

demo/debugcharts/main.go

@@ -0,0 +1,48 @@
+package main
+
+import (
+	"fmt"
+	"log"
+	"net/http"
+	"runtime"
+	"time"
+
+	_ "net/http/pprof"
+
+	"github.com/gorilla/handlers"
+	_ "github.com/mkevac/debugcharts"
+)
+
+func dummyCPUUsage() {
+	var a uint64
+	var t = time.Now()
+	for {
+		t = time.Now()
+		a += uint64(t.Unix())
+	}
+}
+
+func dummyAllocations() {
+	var d []uint64
+
+	for {
+		for i := 0; i < 2*1024*1024; i++ {
+			d = append(d, 42)
+		}
+		time.Sleep(time.Second * 10)
+		fmt.Println(len(d))
+		d = make([]uint64, 0)
+		runtime.GC()
+		time.Sleep(time.Second * 10)
+	}
+}
+
+func main() {
+	go dummyAllocations()
+	go dummyCPUUsage()
+	go func() {
+		log.Fatal(http.ListenAndServe(":8080", handlers.CompressHandler(http.DefaultServeMux)))
+	}()
+	log.Printf("you can now open http://localhost:8080/debug/charts/ in your browser")
+	select {}
+}

demo/riot/log/main.go

@@ -0,0 +1,38 @@
+package main
+
+import (
+	"log"
+
+	"github.com/go-ego/riot"
+	"github.com/go-ego/riot/types"
+)
+
+var (
+	// searcher 是协程安全的
+	searcher = riot.Engine{}
+)
+
+func main() {
+	// 初始化
+	searcher.Init(types.EngineOpts{
+		Using:         3,
+		SegmenterDict: "zh",
+		// SegmenterDict: "your gopath"+"/src/github.com/go-ego/riot/data/dict/dictionary.txt",
+	})
+	defer searcher.Close()
+
+	text := "此次百度收购将成中国互联网最大并购"
+	text1 := "百度宣布拟全资收购91无线业务"
+	text2 := "百度是中国最大的搜索引擎"
+
+	// 将文档加入索引，docId 从1开始
+	searcher.IndexDoc(1, types.DocIndexData{Content: text})
+	searcher.IndexDoc(2, types.DocIndexData{Content: text1}, false)
+	searcher.IndexDoc(3, types.DocIndexData{Content: text2}, true)
+
+	// 等待索引刷新完毕
+	searcher.FlushIndex()
+
+	// 搜索输出格式见 types.SearchResp 结构体
+	log.Print(searcher.Search(types.SearchReq{Text: "百度中国"}))
+}