The output of look command can be used to the loki

Author: SimFG

README.md

@@ -23,6 +23,14 @@ $ etcdctl+ distribute -h
 Download the [etcdctl+.ts](ts/etcdctl+.ts), and [config it](https://simfg.github.io/fig). You can also use the [etcdctl.ts](https://simfg.github.io/etcdctl.ts) config the `etcdctl` command.
 
 ## Function List
+
+1. **distribute** View data distribution according to data size
+2. **look** Show or export all the etcd data, and be used with terminal or loki
+3. **find** Get key based on certain characters
+4. **leader** Get the leader node info
+5. **clear** Clear all the etcd data
+6. **decode** decode the etcd value that is encoded 
+
 ### distribute
 View data distribution in etcd according to the `key` size , `value` size or `key + value` size by setting the `type` command param.
 ```shell
@@ -81,6 +89,19 @@ Kv List
 | by-dev/meta/channelwatch/-9223372036854775808/by-dev-rootcoord-dml_4_435191634150817793v0 | - | 326013 | 326013 | 1 | 0 |
 ```
 
+### find
+Get key based on certain characters
+```shell
+$ ./etcdctl+ find --key=index
+Kv List
+| Key | Value |
+| by-dev/meta/field-index/438660758500016136/438660903999573339 |  |
+| by-dev/meta/segment-index/438660758500016136/438660758500016137/438660758500216145/438660903999573340 |  |
+| by-dev/meta/segment-index/438660758500016136/438660758500016137/438660758500216146/438660903999573341 |  |
+| by-dev/meta/segment-index/438660758500016136/438660758500016137/438672571137461581/438672571137461597 |  |
+| by-dev/meta/segment-index/438660758500016136/438660758500016137/438672571137461582/438672571137461598 |  |
+```
+
 ### leader
 Get the leader node info
 ```shell

bin/etcdctl+

@@ -59,21 +59,25 @@ Sometimes, you may only want to observe data of a certain range size, you can se
 	cmd.Flags().IntVar(&filterMin, "filter-min", -1, "The filter min value")
 
 	cmd.RegisterFlagCompletionFunc("write-out", func(_ *cobra.Command, _ []string, _ string) ([]string, cobra.ShellCompDirective) {
-		return []string{"stdout", "file"}, cobra.ShellCompDirectiveDefault
+		return []string{"stdout", "file", "log"}, cobra.ShellCompDirectiveDefault
 	})
 	cmd.RegisterFlagCompletionFunc("filter", func(_ *cobra.Command, _ []string, _ string) ([]string, cobra.ShellCompDirective) {
 		return []string{"none", "key", "value", "kv"}, cobra.ShellCompDirectiveDefault
 	})
 	return cmd
 }
 
+func isLog() bool {
+	return writeOut == "log"
+}
+
 func lookFunc(cmd *cobra.Command, args []string) {
 	core.InitClient()
 	resp, datac := core.GetAllData()
 
 	var writer io.Writer
 	switch writeOut {
-	case "file":
+	case "file", "log":
 		f := GetFileWriter()
 		defer f.Close()
 		writer = f
@@ -104,10 +108,12 @@ func appendBuffer(resp *clientv3.GetResponse, datac <-chan []*mvccpb.KeyValue, w
 		f.Seek(0, 0)
 	}
 	var buffer bytes.Buffer
-	buffer.WriteString("Current Stage\n")
-	buffer.WriteString(fmt.Sprintf("  %s", resp.Header.String()))
-	buffer.WriteString("\nKv List\n")
-	buffer.WriteString("| Key | Value | Size | CreateRevision | ModRevision | Version | Lease |\n")
+	if !isLog() {
+		buffer.WriteString("Current Stage\n")
+		buffer.WriteString(fmt.Sprintf("  %s", resp.Header.String()))
+		buffer.WriteString("\nKv List\n")
+		buffer.WriteString("| Key | Value | Size | CreateRevision | ModRevision | Version | Lease |\n")
+	}
 
 	for data := range datac {
 		for _, kv := range data {
@@ -119,7 +125,11 @@ func appendBuffer(resp *clientv3.GetResponse, datac <-chan []*mvccpb.KeyValue, w
 			if showValue {
 				v = base64.StdEncoding.EncodeToString(kv.Value)
 			}
-			buffer.WriteString(fmt.Sprintf("| %s | %s | %s | %d | %d | %d | %d |\n",
+			format := "| %s | %s | %s | %d | %d | %d | %d |\n"
+			if isLog() {
+				format = "key=%s value=%s size=%s create_revision=%d mod_revision=%d version=%d lease=%d\n"
+			}
+			buffer.WriteString(fmt.Sprintf(format,
 				string(kv.Key), v,
 				core.ReadableSize(size),
 				kv.CreateRevision, kv.ModRevision, kv.Version,

cmd/look_cmd.go

@@ -9,7 +9,7 @@ import (
 )
 
 var (
-	byteUnits = []string{"B", "KB", "MB", "GB"}
+	byteUnits = []string{"b", "kb", "mb", "gb", "tb", "pb", "eb"}
 )
 
 func Exit(err error) {
@@ -42,7 +42,7 @@ func ReadableSize(s int) string {
 		i++
 		sf /= 1024
 	}
-	return fmt.Sprintf("%.1f %s", sf, byteUnits[i])
+	return fmt.Sprintf("%.1f%s", sf, byteUnits[i])
 }
 
 func Interrupt(f func()) {