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 (
	ElasticsearchAddress       = FlagSet.String("elasticsearch-address", "", "Elasticsearch address")
	ElasticsearchUsername      = FlagSet.String("elasticsearch-username", "", "Elasticsearch username")
	ElasticsearchPassword      = FlagSet.String("elasticsearch-password", "", "Elasticsearch password")
	ElasticsearchTLSSkipVerify = FlagSet.Bool("elasticsearch-tls-skip-verify", false, "Elasticsearch TLS skip verify")
	ElasticsearchEnableTLS     = FlagSet.Bool("elasticsearch-enable-tls", false, "Elasticsearch enable TLS")
	ElasticsearchCAFile        = FlagSet.String("elasticsearch-tls-ca-file", "", "Elasticsearch TLS CA file")
	ElasticsearchCertFile      = FlagSet.String("elasticsearch-tls-cert-file", "", "Elasticsearch TLS cert file")
	ElasticsearchKeyFile       = FlagSet.String("elasticsearch-tls-key-file", "", "Elasticsearch TLS key file")
	ElasticsearchRetrieveQuery = FlagSet.String("elasticsearch-retrieve-query", "", "Elasticsearch retrieve query")
	ElasticsearchRetrieveIndex = FlagSet.String("elasticsearch-retrieve-index", "", "Elasticsearch retrieve index")
	ElasticsearchClearQuery    = FlagSet.String("elasticsearch-clear-query", "", "Elasticsearch clear query")
	ElasticsearchClearIndex    = FlagSet.String("elasticsearch-clear-index", "", "Elasticsearch clear index")
	ElasticsearchClearOp       = FlagSet.String("elasticsearch-clear-op", "", "Elasticsearch clear op. Valid values are: delete, put, merge-put, move")
	ElasticsearchFailQuery     = FlagSet.String("elasticsearch-fail-query", "", "Elasticsearch fail query")
	ElasticsearchFailIndex     = FlagSet.String("elasticsearch-fail-index", "", "Elasticsearch fail index")
	ElasticsearchFailOp        = FlagSet.String("elasticsearch-fail-op", "", "Elasticsearch fail op. Valid values are: delete, put, merge-put, move")
)

var (
	FlagSet         = flag.NewFlagSet("procx", flag.ContinueOnError)
	Driver          = FlagSet.String("driver", "", "driver to use. (aws-dynamo, aws-s3, aws-sqs, cassandra, centauri, elasticsearch, gcp-bq, gcp-gcs, gcp-pubsub, kafka, local, mongodb, mysql, nats, nfs, postgres, rabbitmq, redis-list, redis-pubsub, redis-stream)")
	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 (
	KafkaBrokers      = FlagSet.String("kafka-brokers", "", "Kafka brokers, comma separated")
	KafkaGroup        = FlagSet.String("kafka-group", "", "Kafka group")
	KafkaTopic        = FlagSet.String("kafka-topic", "", "Kafka topic")
	KafkaEnableTLS    = FlagSet.Bool("kafka-enable-tls", false, "Enable TLS")
	KafkaTLSInsecure  = FlagSet.Bool("kafka-tls-insecure", false, "Enable TLS insecure")
	KafkaCAFile       = FlagSet.String("kafka-tls-ca-file", "", "Kafka TLS CA file")
	KafkaCertFile     = FlagSet.String("kafka-tls-cert-file", "", "Kafka TLS cert file")
	KafkaKeyFile      = FlagSet.String("kafka-tls-key-file", "", "Kafka TLS key file")
	KafkaEnableSasl   = FlagSet.Bool("kafka-enable-sasl", false, "Enable SASL")
	KafkaSaslType     = FlagSet.String("kafka-sasl-type", "", "Kafka SASL type. Can be either 'scram' or 'plain'")
	KafkaSaslUsername = FlagSet.String("kafka-sasl-username", "", "Kafka SASL user")
	KafkaSaslPassword = FlagSet.String("kafka-sasl-password", "", "Kafka SASL password")
)

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")
	MongoEnableTLS     = FlagSet.Bool("mongo-enable-tls", false, "Enable TLS")
	MongoTLSInsecure   = FlagSet.Bool("mongo-tls-insecure", false, "Enable TLS insecure")
	MongoCAFile        = FlagSet.String("mongo-tls-ca-file", "", "Mongo TLS CA file")
	MongoCertFile      = FlagSet.String("mongo-tls-cert-file", "", "Mongo TLS cert file")
	MongoKeyFile       = FlagSet.String("mongo-tls-key-file", "", "Mongo TLS key file")
)

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 (
	NATSURL           = FlagSet.String("nats-url", "", "NATS URL")
	NATSSubject       = FlagSet.String("nats-subject", "", "NATS subject")
	NATSCredsFile     = FlagSet.String("nats-creds-file", "", "NATS creds file")
	NATSJWTFile       = FlagSet.String("nats-jwt-file", "", "NATS JWT file")
	NATSNKeyFile      = FlagSet.String("nats-nkey-file", "", "NATS NKey file")
	NATSUsername      = FlagSet.String("nats-username", "", "NATS username")
	NATSPassword      = FlagSet.String("nats-password", "", "NATS password")
	NATSToken         = FlagSet.String("nats-token", "", "NATS token")
	NATSQueueGroup    = FlagSet.String("nats-queue-group", "", "NATS queue group")
	NATSEnableTLS     = FlagSet.Bool("nats-enable-tls", false, "NATS enable TLS")
	NATSTLSInsecure   = FlagSet.Bool("nats-tls-insecure", false, "NATS TLS insecure")
	NATSTLSCAFile     = FlagSet.String("nats-tls-ca-file", "", "NATS TLS CA file")
	NATSTLSCertFile   = FlagSet.String("nats-tls-cert-file", "", "NATS TLS cert file")
	NATSTLSKeyFile    = FlagSet.String("nats-tls-key-file", "", "NATS TLS key file")
	NATSClearResponse = FlagSet.String("nats-clear-response", "", "NATS clear response")
	NATSFailResponse  = FlagSet.String("nats-fail-response", "", "NATS fail response")
)

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

	RedisEnableTLS     = FlagSet.Bool("redis-enable-tls", false, "Enable TLS")
	RedisTLSSkipVerify = FlagSet.Bool("redis-tls-skip-verify", false, "Redis TLS skip verify")
	RedisCAFile        = FlagSet.String("redis-tls-ca-file", "", "Redis TLS CA file")
	RedisCertFile      = FlagSet.String("redis-tls-cert-file", "", "Redis TLS cert file")
	RedisKeyFile       = FlagSet.String("redis-tls-key-file", "", "Redis TLS key file")

	RedisConsumerGroup = FlagSet.String("redis-stream-consumer-group", "", "Redis consumer group")
	RedisConsumerName  = FlagSet.String("redis-steam-consumer-name", "", "Redis consumer name. Default is a random UUID")
	RedisValueKeys     = FlagSet.String("redis-stream-value-keys", "", "Redis stream value keys to select. Comma separated, default all.")
	RedisClearOp       = FlagSet.String("redis-stream-clear-op", "", "Redis clear operation. Valid values are 'ack' and 'del'.")
	RedisFailOp        = FlagSet.String("redis-stream-fail-op", "", "Redis fail operation. Valid values are 'ack' and 'del'.")
)