Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var RootCmd = &cobra.Command{ Use: "olake", Short: "root command", RunE: func(cmd *cobra.Command, args []string) error { viper.SetDefault(constants.ConfigFolder, os.TempDir()) viper.SetDefault(constants.StatePath, filepath.Join(os.TempDir(), "state.json")) viper.SetDefault(constants.StreamsPath, filepath.Join(os.TempDir(), "streams.json")) viper.SetDefault(constants.DifferencePath, filepath.Join(os.TempDir(), "difference_streams.json")) if !noSave { configFolder := utils.Ternary(configPath == "not-set", filepath.Dir(destinationConfigPath), filepath.Dir(configPath)).(string) streamsPathEnv := utils.Ternary(streamsPath == "", filepath.Join(configFolder, "streams.json"), streamsPath).(string) differencePathEnv := utils.Ternary(streamsPath != "", filepath.Join(filepath.Dir(streamsPath), "difference_streams.json"), filepath.Join(configFolder, "difference_streams.json")).(string) statePathEnv := utils.Ternary(statePath == "", filepath.Join(configFolder, "state.json"), statePath).(string) viper.Set(constants.ConfigFolder, configFolder) viper.Set(constants.StatePath, statePathEnv) viper.Set(constants.StreamsPath, streamsPathEnv) viper.Set(constants.DifferencePath, differencePathEnv) } if encryptionKey != "" { viper.Set(constants.EncryptionKey, encryptionKey) } logger.Init() telemetry.Init() if len(args) == 0 { return cmd.Help() } if ok := utils.IsValidSubcommand(commands, args[0]); !ok { return fmt.Errorf("'%s' is an invalid command. Use 'olake --help' to display usage guide", args[0]) } return nil }, }
RootCmd represents the base command when called without any subcommands
Functions ¶
Types ¶
type StreamClassification ¶ added in v0.2.9
type StreamClassification struct {
SelectedStreams []string
CDCStreams []types.StreamInterface
IncrementalStreams []types.StreamInterface
FullLoadStreams []types.StreamInterface
NewStreamsState []*types.StreamState
}
various stream formats
Click to show internal directories.
Click to hide internal directories.