flags

Documentation

Index

• Variables

Variables

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")

	AWSS3Bucket           = FlagSet.String("aws-s3-bucket", "", "AWS S3 bucket")
	AWSS3Key              = FlagSet.String("aws-s3-key", "", "AWS S3 key")
	AWSS3KeyRegex         = FlagSet.String("aws-s3-key-regex", "", "AWS S3 key regex")
	AWSS3KeyPrefix        = FlagSet.String("aws-s3-key-prefix", "", "AWS S3 key prefix")
	AWSS3ClearOp          = FlagSet.String("aws-s3-clear-op", "", "AWS S3 clear operation. Valid values: mv, rm")
	AWSS3FailOp           = FlagSet.String("aws-s3-fail-op", "", "AWS S3 fail operation. Valid values: mv, rm")
	AWSS3ClearBucket      = FlagSet.String("aws-s3-clear-bucket", "", "AWS S3 clear bucket, if clear op is mv")
	AWSS3ClearKey         = FlagSet.String("aws-s3-clear-key", "", "AWS S3 clear key, if clear op is mv. default is origional key name.")
	AWSS3ClearKeyTemplate = FlagSet.String("aws-s3-clear-key-template", "", "AWS S3 clear key template, if clear op is mv.")
	AWSS3FailBucket       = FlagSet.String("aws-s3-fail-bucket", "", "AWS S3 fail bucket, if fail op is mv")
	AWSS3FailKey          = FlagSet.String("aws-s3-fail-key", "", "AWS S3 fail key, if fail op is mv. default is original key name.")
	AWSS3FailKeyTemplate  = FlagSet.String("aws-s3-fail-key-template", "", "AWS S3 fail key template, if fail op is mv.")
)

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")
	CentauriKeyBase64 = FlagSet.String("centauri-key-base64", "", "Centauri key base64")
)

var (
	FlagSet         = flag.NewFlagSet("procx", flag.ContinueOnError)
	Driver          = FlagSet.String("driver", "", "driver to use. (aws-dynamo, aws-s3, aws-sqs, cassandra, centauri, gcp-bq, gcp-gcs, 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")
	PassWorkAsStdin = FlagSet.Bool("pass-work-as-stdin", false, "pass work as stdin")
	PayloadFile     = FlagSet.String("payload-file", "", "file to write payload to")
	KeepPayloadFile = FlagSet.Bool("keep-payload-file", false, "keep payload file after processing")
	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")

	GCPGCSBucket           = FlagSet.String("gcp-gcs-bucket", "", "GCP GCS bucket")
	GCPGCSKey              = FlagSet.String("gcp-gcs-key", "", "GCP GCS key")
	GCPGCSKeyRegex         = FlagSet.String("gcp-gcs-key-regex", "", "GCP GCS key regex")
	GCPGCSKeyPrefix        = FlagSet.String("gcp-gcs-key-prefix", "", "GCP GCS key prefix")
	GCPGCSClearOp          = FlagSet.String("gcp-gcs-clear-op", "", "GCP GCS clear operation. Valid values: mv, rm")
	GCPGCSFailOp           = FlagSet.String("gcp-gcs-fail-op", "", "GCP GCS fail operation. Valid values: mv, rm")
	GCPGCSClearBucket      = FlagSet.String("gcp-gcs-clear-bucket", "", "GCP GCS clear bucket, if clear op is mv")
	GCPGCSClearKey         = FlagSet.String("gcp-gcs-clear-key", "", "GCP GCS clear key, if clear op is mv. default is origional key name.")
	GCPGCSClearKeyTemplate = FlagSet.String("gcp-gcs-clear-key-template", "", "GCP GCS clear key template, if clear op is mv.")
	GCPGCSFailBucket       = FlagSet.String("gcp-gcs-fail-bucket", "", "GCP GCS fail bucket, if fail op is mv")
	GCPGCSFailKey          = FlagSet.String("gcp-gcs-fail-key", "", "GCP GCS fail key, if fail op is mv. default is original key name.")
	GCPGCSFailKeyTemplate  = FlagSet.String("gcp-gcs-fail-key-template", "", "GCP GCS fail key template, if fail op is mv.")

	GCPBQQueryKey      = FlagSet.Bool("gcp-bq-query-key", false, "GCP BQ query returns key as first column and value as second column")
	GCPBQRetrieveQuery = FlagSet.String("gcp-bq-retrieve-query", "", "GCP BQ retrieve query")
	GCPBQClearQuery    = FlagSet.String("gcp-bq-clear-query", "", "GCP BQ clear query")
	GCPBQFailQuery     = FlagSet.String("gcp-bq-fail-query", "", "GCP BQ fail query")
)

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 (
	NFSHost             = FlagSet.String("nfs-host", "", "NFS host")
	NFSKey              = FlagSet.String("nfs-key", "", "NFS key")
	NFSFolder           = FlagSet.String("nfs-folder", "", "NFS folder")
	NFSTarget           = FlagSet.String("nfs-target", "", "NFS target")
	NFSMountPath        = FlagSet.String("nfs-mount-path", "", "NFS mount path")
	NFSKeyRegex         = FlagSet.String("nfs-key-regex", "", "NFS key regex")
	NFSKeyPrefix        = FlagSet.String("nfs-key-prefix", "", "NFS key prefix")
	NFSClearOp          = FlagSet.String("nfs-clear-op", "", "NFS clear operation. Valid values: mv, rm")
	NFSFailOp           = FlagSet.String("nfs-fail-op", "", "NFS fail operation. Valid values: mv, rm")
	NFSClearFolder      = FlagSet.String("nfs-clear-folder", "", "NFS clear folder, if clear op is mv")
	NFSClearKey         = FlagSet.String("nfs-clear-key", "", "NFS clear key, if clear op is mv. default is origional key name.")
	NFSClearKeyTemplate = FlagSet.String("nfs-clear-key-template", "", "NFS clear key template, if clear op is mv.")
	NFSFailFolder       = FlagSet.String("nfs-fail-folder", "", "NFS fail folder, if fail op is mv")
	NFSFailKey          = FlagSet.String("nfs-fail-key", "", "NFS fail key, if fail op is mv. default is original key name.")
	NFSFailKeyTemplate  = FlagSet.String("nfs-fail-key-template", "", "NFS fail key template, if fail op is mv.")
)

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")
)