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
|
package cmd
import (
"github.com/pkg/errors"
"github.com/spf13/cobra"
)
var (
syncCmdKongStateFile []string
syncCmdParallelism int
syncCmdDBUpdateDelay int
syncWorkspace string
)
// syncCmd represents the sync command
var syncCmd = &cobra.Command{
Use: "sync",
Short: "Sync performs operations to get Kong's configuration " +
"to match the state file",
Long: `Sync command reads the state file and performs operation on Kong
to get Kong's state in sync with the input state.`,
Args: validateNoArgs,
RunE: func(cmd *cobra.Command, args []string) error {
return syncMain(syncCmdKongStateFile, false, syncCmdParallelism, syncCmdDBUpdateDelay, syncWorkspace)
},
PreRunE: func(cmd *cobra.Command, args []string) error {
if len(syncCmdKongStateFile) == 0 {
return errors.New("A state file with Kong's configuration " +
"must be specified using -s/--state flag.")
}
return nil
},
}
func init() {
rootCmd.AddCommand(syncCmd)
syncCmd.Flags().StringSliceVarP(&syncCmdKongStateFile,
"state", "s", []string{"kong.yaml"}, "file(s) containing Kong's configuration.\n"+
"This flag can be specified multiple times for multiple files.\n"+
"Use '-' to read from stdin.")
syncCmd.Flags().StringVar(&syncWorkspace, "workspace", "",
"Sync configuration to a specific workspace "+
"(Kong Enterprise only).\n"+
"This takes precedence over _workspace fields in state files.")
syncCmd.Flags().BoolVar(&dumpConfig.SkipConsumers, "skip-consumers",
false, "do not diff consumers or "+
"any plugins associated with consumers")
syncCmd.Flags().IntVar(&syncCmdParallelism, "parallelism",
10, "Maximum number of concurrent operations")
syncCmd.Flags().StringSliceVar(&dumpConfig.SelectorTags,
"select-tag", []string{},
"only entities matching tags specified via this flag are synced.\n"+
"Multiple tags are ANDed together.")
syncCmd.Flags().IntVar(&syncCmdDBUpdateDelay, "db-update-propagation-delay",
0, "aritificial delay in seconds that is injected between insert operations \n"+
"for related entities (usually for cassandra deployments).\n"+
"See 'db_update_propagation' in kong.conf.")
}
|
