FilesExpand file tree

main

/

inspect.go

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

68 lines (61 loc) · 1.91 KB

main

/

inspect.go

Copy path

Top

File metadata and controls

• Code
• Blame

68 lines (61 loc) · 1.91 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

package cmd

import (

"os"

"os/signal"

"github.com/spf13/afero"

"github.com/spf13/cobra"

"github.com/supabase/cli/internal/inspect/cache"

"github.com/supabase/cli/internal/inspect/index_usage"

"github.com/supabase/cli/internal/inspect/replication_slots"

)

var (

inspectCmd = &cobra.Command{

GroupID: groupLocalDev,

Use: "inspect",

Short: "Tools to inspect your Supabase Database",

}

inspectCacheHitCmd = &cobra.Command{

Use: "db:cache-hit",

Short: "Shows cache hit rates for tables and indices",

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

fsys := afero.NewOsFs()

if err := parseDatabaseConfig(fsys); err != nil {

return err

}

ctx, _ := signal.NotifyContext(cmd.Context(), os.Interrupt)

return cache.Run(ctx, dbConfig, fsys)

},

}

inspectReplicationSlotsCmd = &cobra.Command{

Use: "db:replication-slots",

Short: "Shows information about replication slots on the database",

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

fsys := afero.NewOsFs()

if err := parseDatabaseConfig(fsys); err != nil {

return err

}

ctx, _ := signal.NotifyContext(cmd.Context(), os.Interrupt)

return replication_slots.Run(ctx, dbConfig, fsys)

},

}

inspectIndexUsageCmd = &cobra.Command{

Use: "db:index-usage",

Short: "Shows information about the efficiency of indexes",

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

fsys := afero.NewOsFs()

if err := parseDatabaseConfig(fsys); err != nil {

return err

}

ctx, _ := signal.NotifyContext(cmd.Context(), os.Interrupt)

return index_usage.Run(ctx, dbConfig, fsys)

},

}

)

func init() {

inspectFlags := inspectCmd.PersistentFlags()

inspectFlags.StringVar(&dbUrl, "db-url", "", "connect using the specified database url")

inspectCmd.AddCommand(inspectCacheHitCmd)

inspectCmd.AddCommand(inspectReplicationSlotsCmd)

inspectCmd.AddCommand(inspectIndexUsageCmd)

rootCmd.AddCommand(inspectCmd)

}