cmd

func Before ¶

func Before(ctx context.Context, command *cli.Command) (context.Context, error)

Before loads the configuration file and returns

func CloseSetupComponents ¶

func CloseSetupComponents(iSource source.ISource, iStore store.IStore, iOutput output.IOutput)

CloseSetupComponents resources uniformly

func Flags ¶

func Flags() []cli.Flag

func Listen ¶

func Listen(ctx context.Context, config *config.Config) error

Listen starts the entire CDC listening process, including data source, storage, and output handling

func ListenCommand ¶

func ListenCommand() *cli.Command

func SetupComponents ¶

func SetupComponents(cfg *config.Config) (source.ISource, store.IStore, output.IOutput, error)

SetupComponents components: Store, Source, Output