flags

var (
	AWSRegion     = FlagSet.String("aws-region", "", "AWS region")
	AWSLoadConfig = FlagSet.Bool("aws-load-config", false, "load AWS config from ~/.aws/config")
	AWSRoleARN    = FlagSet.String("aws-role-arn", "", "AWS role ARN")
	SQSQueueURL   = FlagSet.String("aws-sqs-queue-url", "", "AWS SQS queue URL")

	AWSDynamoTable         = FlagSet.String("aws-dynamo-table", "", "AWS DynamoDB table name")
	AWSDynamoQueryKeyPath  = FlagSet.String("aws-dynamo-key-path", "", "AWS DynamoDB query key JSON path")
	AWSDynamoDataPath      = FlagSet.String("aws-dynamo-data-path", "", "AWS DynamoDB data JSON path")
	AWSDynamoRetrieveQuery = FlagSet.String("aws-dynamo-retrieve-query", "", "AWS DynamoDB retrieve query")
	AWSDynamoClearQuery    = FlagSet.String("aws-dynamo-clear-query", "", "AWS DynamoDB clear query")
	AWSDynamoFailQuery     = FlagSet.String("aws-dynamo-fail-query", "", "AWS DynamoDB fail query")
)

var (
	CassandraHosts          = FlagSet.String("cassandra-hosts", "", "Cassandra hosts")
	CassandraUser           = FlagSet.String("cassandra-user", "", "Cassandra user")
	CassandraPassword       = FlagSet.String("cassandra-password", "", "Cassandra password")
	CassandraKeyspace       = FlagSet.String("cassandra-keyspace", "", "Cassandra keyspace")
	CassandraConsistency    = FlagSet.String("cassandra-consistency", "QUORUM", "Cassandra consistency")
	CassandraRetrieveQuery  = FlagSet.String("cassandra-retrieve-query", "", "Cassandra retrieve query")
	CassandraRetrieveParams = FlagSet.String("cassandra-retrieve-params", "", "Cassandra retrieve params")
	CassandraClearQuery     = FlagSet.String("cassandra-clear-query", "", "Cassandra clear query")
	CassandraClearParams    = FlagSet.String("cassandra-clear-params", "", "Cassandra clear params")
	CassandraFailQuery      = FlagSet.String("cassandra-fail-query", "", "Cassandra fail query")
	CassandraFailParams     = FlagSet.String("cassandra-fail-params", "", "Cassandra fail params")
	CassandraQueryKey       = FlagSet.Bool("cassandra-query-key", false, "Cassandra query returns key as first column and value as second column")
)

var (
	CentauriPeerURL = FlagSet.String("centauri-peer-url", "", "Centauri peer URL")
	CentauriChannel = FlagSet.String("centauri-channel", "default", "Centauri channel")
	CentauriKey     = FlagSet.String("centauri-key", "", "Centauri key")
)

var (
	FlagSet       = flag.NewFlagSet("procx", flag.ContinueOnError)
	Driver        = FlagSet.String("driver", "", "driver to use. (aws-dynamo, aws-sqs, cassandra, centauri, gcp-pubsub, local, mongodb, mysql, postgres, rabbitmq, redis-list, redis-pubsub)")
	HostEnv       = FlagSet.Bool("hostenv", false, "use host environment")
	PassWorkAsArg = FlagSet.Bool("pass-work-as-arg", false, "pass work as an argument")
	Daemon        = FlagSet.Bool("daemon", false, "run as daemon")
)

var (
	GCPProjectID    = FlagSet.String("gcp-project-id", "", "GCP project ID")
	GCPSubscription = FlagSet.String("gcp-pubsub-subscription", "", "GCP Pub/Sub subscription name")
)

var (
	MongoHost          = FlagSet.String("mongo-host", "", "MongoDB host")
	MongoPort          = FlagSet.String("mongo-port", "27017", "MongoDB port")
	MongoUser          = FlagSet.String("mongo-user", "", "MongoDB user")
	MongoPassword      = FlagSet.String("mongo-password", "", "MongoDB password")
	MongoDatabase      = FlagSet.String("mongo-database", "", "MongoDB database")
	MongoCollection    = FlagSet.String("mongo-collection", "", "MongoDB collection")
	MongoRetrieveQuery = FlagSet.String("mongo-retrieve-query", "", "MongoDB retrieve query")
	MongoClearQuery    = FlagSet.String("mongo-clear-query", "", "MongoDB clear query")
	MongoFailQuery     = FlagSet.String("mongo-fail-query", "", "MongoDB fail query")
)

var (
	MysqlHost           = FlagSet.String("mysql-host", "", "MySQL host")
	MysqlPort           = FlagSet.String("mysql-port", "3306", "MySQL port")
	MysqlUser           = FlagSet.String("mysql-user", "", "MySQL user")
	MysqlPassword       = FlagSet.String("mysql-password", "", "MySQL password")
	MysqlDatabase       = FlagSet.String("mysql-database", "", "MySQL database")
	MysqlQueryKey       = FlagSet.Bool("mysql-query-key", false, "MySQL query returns key as first column and value as second column")
	MysqlRetrieveQuery  = FlagSet.String("mysql-retrieve-query", "", "MySQL retrieve query")
	MysqlRetrieveParams = FlagSet.String("mysql-retrieve-params", "", "MySQL retrieve params")
	MysqlClearQuery     = FlagSet.String("mysql-clear-query", "", "MySQL clear query")
	MysqlClearParams    = FlagSet.String("mysql-clear-params", "", "MySQL clear params")
	MysqlFailQuery      = FlagSet.String("mysql-fail-query", "", "MySQL fail query")
	MysqlFailParams     = FlagSet.String("mysql-fail-params", "", "MySQL fail params")
)

var (
	PsqlHost           = FlagSet.String("psql-host", "", "PostgreSQL host")
	PsqlPort           = FlagSet.String("psql-port", "5432", "PostgreSQL port")
	PsqlUser           = FlagSet.String("psql-user", "", "PostgreSQL user")
	PsqlPassword       = FlagSet.String("psql-password", "", "PostgreSQL password")
	PsqlDatabase       = FlagSet.String("psql-database", "", "PostgreSQL database")
	PsqlSSLMode        = FlagSet.String("psql-ssl-mode", "disable", "PostgreSQL SSL mode")
	PsqlQueryKey       = FlagSet.Bool("psql-query-key", false, "PostgreSQL query returns key as first column and value as second column")
	PsqlRetrieveQuery  = FlagSet.String("psql-retrieve-query", "", "PostgreSQL retrieve query")
	PsqlRetrieveParams = FlagSet.String("psql-retrieve-params", "", "PostgreSQL retrieve params")
	PsqlClearQuery     = FlagSet.String("psql-clear-query", "", "PostgreSQL clear query")
	PsqlClearParams    = FlagSet.String("psql-clear-params", "", "PostgreSQL clear params")
	PsqlFailQuery      = FlagSet.String("psql-fail-query", "", "PostgreSQL fail query")
	PsqlFailParams     = FlagSet.String("psql-fail-params", "", "PostgreSQL fail params")
)

var (
	RabbitMQURL   = FlagSet.String("rabbitmq-url", "", "RabbitMQ URL")
	RabbitMQQueue = FlagSet.String("rabbitmq-queue", "", "RabbitMQ queue")
)

var (
	RedisHost     = FlagSet.String("redis-host", "", "Redis host")
	RedisPort     = FlagSet.String("redis-port", "6379", "Redis port")
	RedisPassword = FlagSet.String("redis-password", "", "Redis password")
	RedisKey      = FlagSet.String("redis-key", "", "Redis key")
)