couchbase / moss / 186

pending completion

Build # 186

Build Type

push

travis-ci

Committed by

abhinavdangeti

Commit Message

mossScope: Emit version in diag stats for cbcollect_info

Change-Id: I0c43c0400
Reviewed-on: http://review.couchbase.org/73791
Reviewed-by: Steve Yen <steve.yen@gmail.com>
Tested-by: abhinav dangeti <abhinav@couchbase.com>

Run Details

8 of 8 new or added lines in 2 files covered. (100.0%)

2805 of 3518 relevant lines covered (79.73%)

8173.37 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

58.73

/cmd/mossScope/cmd/diagStats.go

// Copyright © 2017 Couchbase, Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package cmd

import (
        "encoding/json"
        "fmt"

        "github.com/couchbase/moss"
        "github.com/spf13/cobra"
)

// diagStatsCmd represents the diag command
var diagStatsCmd = &cobra.Command{
        Use:   "diag",
        Short: "Dumps all the diagnostic stats",
        Long: `This command dumps all the diagnostic stats for the store.
        ./mossScope stats diag <path_to_store>`,

        PreRunE: func(cmd *cobra.Command, args []string) error {
                if len(args) < 1 {
                        return fmt.Errorf("At least one path is required!")
                }
                return nil
        },

        RunE: func(cmd *cobra.Command, args []string) error {
                return invokeDiagStats(args)
        },
}

func invokeDiagStats(dirs []string) error {
        if jsonFormat {
                fmt.Printf("[")
        } else {
                emitVersion()
                fmt.Println()
        }

        for index, dir := range dirs {
                store, err := moss.OpenStore(dir, ReadOnlyMode)
                if err != nil || store == nil {
                        return fmt.Errorf("Moss-OpenStore() API failed, err: %v", err)
                }
                defer store.Close()

                snap, err := store.Snapshot()
                if err != nil || snap == nil {
                        continue
                }

                footer := snap.(*moss.Footer)
                stats := make(map[string]uint64)

                fetchFooterStats(footer, stats)

                store_stats, err := store.Stats()
                if err != nil {
                        return fmt.Errorf("Store-Stats() failed!, err: %v", err)
                }

                for k, v := range store_stats {
                        stats[k] = v.(uint64)
                }

                if jsonFormat {
                        jBuf, err := json.Marshal(stats)
                        if err != nil {
                                return fmt.Errorf("Json-Marshal() failed!, err: %v", err)
                        }
                        if index != 0 {
                                fmt.Printf(",")
                        }
                        fmt.Printf("{\"%s\":%s}", dir, string(jBuf))
                } else {
                        fmt.Println(dir)
                        for k, v := range stats {
                                fmt.Printf("%35s : %v\n", k, v)
                        }
                        fmt.Println()
                }
        }

        if jsonFormat {
                fmt.Printf("]\n")
        }

        return nil
}

func init() {
        statsCmd.AddCommand(diagStatsCmd)

        // Local flag that is intended to work over stats diag
        diagStatsCmd.Flags().BoolVar(&jsonFormat, "json", false,
                "Emits output in JSON")
}

1	// Copyright © 2017 Couchbase, Inc.
2	//
3	// Licensed under the Apache License, Version 2.0 (the "License");
4	// you may not use this file except in compliance with the License.
5	// You may obtain a copy of the License at
6	//
7	// http://www.apache.org/licenses/LICENSE-2.0
8	//
9	// Unless required by applicable law or agreed to in writing, software
10	// distributed under the License is distributed on an "AS IS" BASIS,
11	// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12	// See the License for the specific language governing permissions and
13	// limitations under the License.
14
15	package cmd
16
17	import (
18	"encoding/json"
19	"fmt"
20
21	"github.com/couchbase/moss"
22	"github.com/spf13/cobra"
23	)
24
25	// diagStatsCmd represents the diag command
26	var diagStatsCmd = &cobra.Command{
27	Use: "diag",
28	Short: "Dumps all the diagnostic stats",
29	Long: `This command dumps all the diagnostic stats for the store.
30	./mossScope stats diag <path_to_store>`,
31
32	PreRunE: func(cmd *cobra.Command, args []string) error {	×
33	if len(args) < 1 {	×
34	return fmt.Errorf("At least one path is required!")	×
35	}	×
36	return nil	×
37	},
38
39	RunE: func(cmd *cobra.Command, args []string) error {	×
40	return invokeDiagStats(args)	×
41	},	×
42	}
43
44	func invokeDiagStats(dirs []string) error {	1✔
45	if jsonFormat {	2✔
46	fmt.Printf("[")	1✔
47	} else {	1✔
48	emitVersion()	×
49	fmt.Println()	×
50	}	×
51
52	for index, dir := range dirs {	2✔
53	store, err := moss.OpenStore(dir, ReadOnlyMode)	1✔
54	if err != nil \|\| store == nil {	1✔
55	return fmt.Errorf("Moss-OpenStore() API failed, err: %v", err)	×
56	}	×
57	defer store.Close()	1✔
58		1✔
59	snap, err := store.Snapshot()	1✔
60	if err != nil \|\| snap == nil {	1✔
61	continue	×
62	}
63
64	footer := snap.(*moss.Footer)	1✔
65	stats := make(map[string]uint64)	1✔
66		1✔
67	fetchFooterStats(footer, stats)	1✔
68		1✔
69	store_stats, err := store.Stats()	1✔
70	if err != nil {	1✔
71	return fmt.Errorf("Store-Stats() failed!, err: %v", err)	×
72	}	×
73
74	for k, v := range store_stats {	11✔
75	stats[k] = v.(uint64)	10✔
76	}	10✔
77
78	if jsonFormat {	2✔
79	jBuf, err := json.Marshal(stats)	1✔
80	if err != nil {	1✔
81	return fmt.Errorf("Json-Marshal() failed!, err: %v", err)	×
82	}	×
83	if index != 0 {	1✔
84	fmt.Printf(",")	×
85	}	×
86	fmt.Printf("{\"%s\":%s}", dir, string(jBuf))	1✔
87	} else {	×
88	fmt.Println(dir)	×
89	for k, v := range stats {	×
90	fmt.Printf("%35s : %v\n", k, v)	×
91	}	×
92	fmt.Println()	×
93	}
94	}
95
96	if jsonFormat {	2✔
97	fmt.Printf("]\n")	1✔
98	}	1✔
99
100	return nil	1✔
101	}
102
103	func init() {	2✔
104	statsCmd.AddCommand(diagStatsCmd)	2✔
105		2✔
106	// Local flag that is intended to work over stats diag	2✔
107	diagStatsCmd.Flags().BoolVar(&jsonFormat, "json", false,	2✔
108	"Emits output in JSON")	2✔
109	}	2✔

couchbase / moss / 186

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous