Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CmdOptions ¶
type CmdOptions struct {
LogLevel string `` /* 127-byte string literal not displayed */
Postgres string `long:"postgres" description:"PostgreSQL connection string" env:"DBZ2PG_PGURL"`
Kafka []string `long:"kafka" description:"Kafka connection string" env:"DBZ2PG_KAFKA"`
Topic string `long:"topic" description:"Topic name (or prefix of the topic name) to consume" env:"DBZ2PG_TOPIC" required:"True"`
Timeout int `long:"timeout" default:"10" description:"Idle timeout for consuming kafka messages" env:"DBZ2PG_TIMEOUT"`
}
CmdOptions holds command line options passed
func Parse ¶
func Parse() (*CmdOptions, error)
Parse will parse command line arguments and initialize pgengine
Click to show internal directories.
Click to hide internal directories.