Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ActiveMQAddress = FlagSet.String("activemq-address", "", "ActiveMQ STOMP address") ActiveMQType = FlagSet.String("activemq-type", "", "ActiveMQ type. Valid values are: topic, queue") ActiveMQName = FlagSet.String("activemq-name", "", "ActiveMQ name") ActiveMQEnableTLS = FlagSet.Bool("activemq-enable-tls", false, "Enable TLS") ActiveMQTLSInsecure = FlagSet.Bool("activemq-tls-insecure", false, "Enable TLS insecure") ActiveMQTLSCA = FlagSet.String("activemq-tls-ca-file", "", "TLS CA") ActiveMQTLSCert = FlagSet.String("activemq-tls-cert-file", "", "TLS cert") ActiveMQTLSKey = FlagSet.String("activemq-tls-key-file", "", "TLS key") )
View Source
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") AWSDynamoRetrieveField = FlagSet.String("aws-dynamo-retrieve-field", "", "AWS DynamoDB retrieve field") 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") AWSDynamoUnmarshalJSON = FlagSet.Bool("aws-dynamo-unmarshal-json", true, "AWS DynamoDB unmarshal JSON") AWSDynamoLimit = FlagSet.Int("aws-dynamo-limit", 0, "AWS DynamoDB limit") AWSDynamoNextToken = FlagSet.String("aws-dynamo-next-token", "", "AWS DynamoDB next token") AWSDynamoIncludeNextToken = FlagSet.Bool("aws-dynamo-include-next-token", false, "AWS DynamoDB include next token as _nextToken in response") 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.") )
View Source
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") CassandraRetrieveField = FlagSet.String("cassandra-retrieve-field", "", "Cassandra retrieve field. If not set, all fields will be returned as a JSON object") )
View Source
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") )
View Source
var ( CockroachDBRoutingID = FlagSet.String("cockroach-routing-id", "", "CockroachDB routing id") CockroachDBHost = FlagSet.String("cockroach-host", "", "CockroachDB host") CockroachDBPort = FlagSet.String("cockroach-port", "26257", "CockroachDB port") CockroachDBUser = FlagSet.String("cockroach-user", "", "CockroachDB user") CockroachDBPassword = FlagSet.String("cockroach-password", "", "CockroachDB password") CockroachDBDatabase = FlagSet.String("cockroach-database", "", "CockroachDB database") CockroachDBSSLMode = FlagSet.String("cockroach-ssl-mode", "disable", "CockroachDB SSL mode") CockroachDBTLSRootCert = FlagSet.String("cockroach-tls-root-cert", "", "CockroachDB SSL root cert") CockroachDBTLSCert = FlagSet.String("cockroach-tls-cert", "", "CockroachDB TLS cert") CockroachDBTLSKey = FlagSet.String("cockroach-tls-key", "", "CockroachDB TLS key") CockroachDBQueryKey = FlagSet.Bool("cockroach-query-key", false, "CockroachDB query returns key as first column and value as second column") CockroachDBRetrieveField = FlagSet.String("cockroach-retrieve-field", "", "CockroachDB retrieve field. If not set, all fields will be returned as a JSON object") CockroachDBRetrieveQuery = FlagSet.String("cockroach-retrieve-query", "", "CockroachDB retrieve query") CockroachDBRetrieveParams = FlagSet.String("cockroach-retrieve-params", "", "CockroachDB retrieve params") CockroachDBClearQuery = FlagSet.String("cockroach-clear-query", "", "CockroachDB clear query") CockroachDBClearParams = FlagSet.String("cockroach-clear-params", "", "CockroachDB clear params") CockroachDBFailQuery = FlagSet.String("cockroach-fail-query", "", "CockroachDB fail query") CockroachDBFailParams = FlagSet.String("cockroach-fail-params", "", "CockroachDB fail params") )
View Source
var ( CouchbaseAddress = FlagSet.String("couchbase-address", "", "Couchbase address") CouchbaseUser = FlagSet.String("couchbase-user", "", "Couchbase user") CouchbasePassword = FlagSet.String("couchbase-password", "", "Couchbase password") CouchbaseBucketName = FlagSet.String("couchbase-bucket", "", "Couchbase bucket name") CouchbaseScope = FlagSet.String("couchbase-scope", "_default", "Couchbase scope") CouchbaseCollection = FlagSet.String("couchbase-collection", "_default", "Couchbase collection") CouchbaseRetrieveQuery = FlagSet.String("couchbase-retrieve-query", "", "Couchbase retrieve query") CouchbaseRetrieveParams = FlagSet.String("couchbase-retrieve-params", "", "Couchbase retrieve params") CouchbaseID = FlagSet.String("couchbase-id", "", "Couchbase id") CouchbaseClearOp = FlagSet.String("couchbase-clear-op", "", "Couchbase clear op. one of: mv, rm, set, merge") CouchbaseClearDoc = FlagSet.String("couchbase-clear-doc", "", "Couchbase clear doc, if op is set or merge") CouchbaseClearBucket = FlagSet.String("couchbase-clear-bucket", "", "Couchbase clear bucket, if op is set or merge. Default to the current bucket.") CouchbaseClearScope = FlagSet.String("couchbase-clear-scope", "_default", "Couchbase clear scope, default to the current scope.") CouchbaseClearCollection = FlagSet.String("couchbase-clear-collection", "_default", "Couchbase clear collection, default to the current collection.") CouchbaseClearID = FlagSet.String("couchbase-clear-id", "", "Couchbase clear id, default to the current id.") CouchbaseFailOp = FlagSet.String("couchbase-fail-op", "", "Couchbase fail op. one of: mv, rm, set, merge") CouchbaseFailDoc = FlagSet.String("couchbase-fail-doc", "", "Couchbase fail doc, if op is set or merge") CouchbaseFailBucket = FlagSet.String("couchbase-fail-bucket", "", "Couchbase fail bucket, if op is set or merge. Default to the current bucket.") CouchbaseFailScope = FlagSet.String("couchbase-fail-scope", "_default", "Couchbase fail scope, default to the current scope.") CouchbaseFailCollection = FlagSet.String("couchbase-fail-collection", "_default", "Couchbase fail collection, default to the current collection.") CouchbaseFailID = FlagSet.String("couchbase-fail-id", "", "Couchbase fail id, default to the current id.") // TLS CouchbaseEnableTLS = FlagSet.Bool("couchbase-enable-tls", false, "Enable TLS") CouchbaseTLSInsecure = FlagSet.Bool("couchbase-tls-insecure", false, "Enable TLS insecure") CouchbaseCAFile = FlagSet.String("couchbase-tls-ca-file", "", "Couchbase TLS CA file") CouchbaseCertFile = FlagSet.String("couchbase-tls-cert-file", "", "Couchbase TLS cert file") CouchbaseKeyFile = FlagSet.String("couchbase-tls-key-file", "", "Couchbase TLS key file") )
View Source
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") ElasticsearchClearDoc = FlagSet.String("elasticsearch-clear-doc", "", "Elasticsearch clear doc") 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") ElasticsearchFailDoc = FlagSet.String("elasticsearch-fail-doc", "", "Elasticsearch fail doc") 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") )
View Source
var ( FlagSet = flag.NewFlagSet("procx", flag.ContinueOnError) Driver = FlagSet.String("driver", "", "driver to use. (activemq, aws-dynamo, aws-s3, aws-sqs, cassandra, centauri, cockroach, couchbase, elasticsearch, fs, gcp-bq, gcp-firestore, gcp-gcs, gcp-pubsub, github, http, kafka, local, mongodb, mssql, mysql, nats, nfs, nsq, postgres, pulsar, rabbitmq, redis-list, redis-pubsub, redis-stream, smb)") 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") DaemonInterval = FlagSet.Int("daemon-interval", 0, "daemon interval in milliseconds") )
View Source
var ( FSKey = FlagSet.String("fs-key", "", "FS key") FSFolder = FlagSet.String("fs-folder", "", "FS folder") FSKeyRegex = FlagSet.String("fs-key-regex", "", "FS key regex") FSKeyPrefix = FlagSet.String("fs-key-prefix", "", "FS key prefix") FSClearOp = FlagSet.String("fs-clear-op", "", "FS clear operation. Valid values: mv, rm") FSFailOp = FlagSet.String("fs-fail-op", "", "FS fail operation. Valid values: mv, rm") FSClearFolder = FlagSet.String("fs-clear-folder", "", "FS clear folder, if clear op is mv") FSClearKey = FlagSet.String("fs-clear-key", "", "FS clear key, if clear op is mv. default is origional key name.") FSClearKeyTemplate = FlagSet.String("fs-clear-key-template", "", "FS clear key template, if clear op is mv.") FSFailFolder = FlagSet.String("fs-fail-folder", "", "FS fail folder, if fail op is mv") FSFailKey = FlagSet.String("fs-fail-key", "", "FS fail key, if fail op is mv. default is original key name.") FSFailKeyTemplate = FlagSet.String("fs-fail-key-template", "", "FS fail key template, if fail op is mv.") )
View Source
var ( GCPProjectID = FlagSet.String("gcp-project-id", "", "GCP project ID") GCPSubscription = FlagSet.String("gcp-pubsub-subscription", "", "GCP Pub/Sub subscription name") GCPFirestoreRetrieveCollection = FlagSet.String("gcp-firestore-retrieve-collection", "", "GCP Firestore retrieve collection") GCPFirestoreRetrieveDocument = FlagSet.String("gcp-firestore-retrieve-document", "", "GCP Firestore retrieve document") GCPFirestoreRetrieveQueryPath = FlagSet.String("gcp-firestore-retrieve-query-path", "", "GCP Firestore retrieve query path") GCPFirestoreRetrieveQueryOp = FlagSet.String("gcp-firestore-retrieve-query-op", "", "GCP Firestore retrieve query op") GCPFirestoreRetrieveQueryValue = FlagSet.String("gcp-firestore-retrieve-query-value", "", "GCP Firestore retrieve query value") GCPFirestoreRetrieveDocumentJSONKey = FlagSet.String("gcp-firestore-retrieve-document-json-key", "", "GCP Firestore retrieve document JSON key") GCPFirestoreRetrieveQueryOrderBy = FlagSet.String("gcp-firestore-retrieve-query-order-by", "", "GCP Firestore retrieve query order by key") GCPFirestoreRetrieveQueryOrder = FlagSet.String("gcp-firestore-retrieve-query-order", "", "GCP Firestore retrieve query order. Valid values: asc, desc") GCPFirestoreClearOp = FlagSet.String("gcp-firestore-clear-op", "", "GCP Firestore clear op. Possible values: 'mv', 'rm', 'update'") GCPFirestoreClearUpdate = FlagSet.String("gcp-firestore-clear-update", "", "GCP Firestore clear update object. Will be merged with document before update or move.") GCPFirestoreClearCollection = FlagSet.String("gcp-firestore-clear-collection", "", "GCP Firestore clear collection") GCPFirestoreFailOp = FlagSet.String("gcp-firestore-fail-op", "", "GCP Firestore fail op. Possible values: 'mv', 'rm', 'update'") GCPFirestoreFailUpdate = FlagSet.String("gcp-firestore-fail-update", "", "GCP Firestore fail update object. Will be merged with document before update or move.") GCPFirestoreFailCollection = FlagSet.String("gcp-firestore-fail-collection", "", "GCP Firestore fail collection") 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.") GCPBQRetrieveField = FlagSet.String("gcp-bq-retrieve-field", "", "GCP BigQuery retrieve field") 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") )
View Source
var ( GitHubRepo = FlagSet.String("github-repo", "", "GitHub repo") GitHubOwner = FlagSet.String("github-owner", "", "GitHub owner") GitHubToken = FlagSet.String("github-token", "", "GitHub token") GitHubFile = FlagSet.String("github-file", "", "GitHub file") GitHubFilePrefix = FlagSet.String("github-file-prefix", "", "GitHub file prefix") GitHubFileRegex = FlagSet.String("github-file-regex", "", "GitHub file regex") GitHubRef = FlagSet.String("github-ref", "", "GitHub ref") GitHubOpenPR = FlagSet.Bool("github-open-pr", false, "open PR on changes. Default: false") GitHubBaseBranch = FlagSet.String("github-base-branch", "", "base branch for PR") GitHubBranch = FlagSet.String("github-branch", "", "branch for PR.") GitHubCommitName = FlagSet.String("github-commit-name", "", "commit name") GitHubCommitEmail = FlagSet.String("github-commit-email", "", "commit email") GitHubCommitMessage = FlagSet.String("github-commit-message", "", "commit message") GitHubPRTitle = FlagSet.String("github-pr-title", "", "PR title") GitHubPRBody = FlagSet.String("github-pr-body", "", "PR body") GitHubClearOp = FlagSet.String("github-clear-op", "", "clear operation. One of: [mv, rm]") GitHubClearOpLocation = FlagSet.String("github-clear-location", "", "clear operation location, if op is mv") GitHubFailOp = FlagSet.String("github-fail-op", "", "fail operation. One of: [mv, rm]") GitHubFailOpLocation = FlagSet.String("github-fail-location", "", "fail operation location, if op is mv") )
View Source
var ( HTTPRetreieveMethod = FlagSet.String("http-retrieve-method", "GET", "HTTP retrieve method") HTTPRetrieveURL = FlagSet.String("http-retrieve-url", "", "HTTP retrieve url") HTTPRetrieveContentType = FlagSet.String("http-retrieve-content-type", "", "HTTP retrieve content type") HTTPRetrieveSuccessfulStatusCodes = FlagSet.String("http-retrieve-successful-status-codes", "", "HTTP retrieve successful status codes") HTTPRetrieveHeaders = FlagSet.String("http-retrieve-headers", "", "HTTP retrieve headers") HTTPRetrieveKeyJSONSelector = FlagSet.String("http-retrieve-key-json-selector", "", "HTTP retrieve key json selector") HTTPRetrieveWorkJSONSelector = FlagSet.String("http-retrieve-work-json-selector", "", "HTTP retrieve work json selector") HTTPRetrieveBodyFile = FlagSet.String("http-retrieve-body-file", "", "HTTP retrieve body file") HTTPRetrieveBody = FlagSet.String("http-retrieve-body", "", "HTTP retrieve body") HTTPClearMethod = FlagSet.String("http-clear-method", "GET", "HTTP clear method") HTTPClearURL = FlagSet.String("http-clear-url", "", "HTTP clear url") HTTPClearContentType = FlagSet.String("http-clear-content-type", "", "HTTP clear content type") HTTPClearSuccessfulStatusCodes = FlagSet.String("http-clear-successful-status-codes", "", "HTTP clear successful status codes") HTTPClearHeaders = FlagSet.String("http-clear-headers", "", "HTTP clear headers") HTTPClearBodyFile = FlagSet.String("http-clear-body-file", "", "HTTP clear body file") HTTPClearBody = FlagSet.String("http-clear-body", "", "HTTP clear body") HTTPFailMethod = FlagSet.String("http-fail-method", "GET", "HTTP fail method") HTTPFailURL = FlagSet.String("http-fail-url", "", "HTTP fail url") HTTPFailContentType = FlagSet.String("http-fail-content-type", "", "HTTP fail content type") HTTPFailSuccessfulStatusCodes = FlagSet.String("http-fail-successful-status-codes", "", "HTTP fail successful status codes") HTTPFailHeaders = FlagSet.String("http-fail-headers", "", "HTTP fail headers") HTTPFailBodyFile = FlagSet.String("http-fail-body-file", "", "HTTP fail body file") HTTPFailBody = FlagSet.String("http-fail-body", "", "HTTP fail body") HTTPEnableTLS = FlagSet.Bool("http-enable-tls", false, "HTTP enable tls") HTTPTLSInsecure = FlagSet.Bool("http-tls-insecure", false, "HTTP tls insecure") HTTPTLSCertFile = FlagSet.String("http-tls-cert-file", "", "HTTP tls cert file") HTTPTLSKeyFile = FlagSet.String("http-tls-key-file", "", "HTTP tls key file") HTTPTLSCAFile = FlagSet.String("http-tls-ca-file", "", "HTTP tls ca file") )
View Source
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") )
View Source
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") MongoLimit = FlagSet.Int("mongo-limit", 0, "MongoDB limit") 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") MongoAuthSource = FlagSet.String("mongo-auth-source", "", "MongoDB auth source") )
View Source
var ( MSSqlHost = FlagSet.String("mssql-host", "", "MSSQL host") MSSqlPort = FlagSet.String("mssql-port", "1433", "MSSQL port") MSSqlUser = FlagSet.String("mssql-user", "", "MSSQL user") MSSqlPassword = FlagSet.String("mssql-password", "", "MSSQL password") MSSqlDatabase = FlagSet.String("mssql-database", "", "MSSQL database") MSSqlRetrieveField = FlagSet.String("mssql-retrieve-field", "", "MSSQL retrieve field. If not set, all fields will be returned as a JSON object") MSSqlRetrieveQuery = FlagSet.String("mssql-retrieve-query", "", "MSSQL retrieve query") MSSqlRetrieveParams = FlagSet.String("mssql-retrieve-params", "", "MSSQL retrieve params") MSSqlClearQuery = FlagSet.String("mssql-clear-query", "", "MSSQL clear query") MSSqlClearParams = FlagSet.String("mssql-clear-params", "", "MSSQL clear params") MSSqlFailQuery = FlagSet.String("mssql-fail-query", "", "MSSQL fail query") MSSqlFailParams = FlagSet.String("mssql-fail-params", "", "MSSQL fail params") )
View Source
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") MysqlRetrieveField = FlagSet.String("mysql-retrieve-field", "", "MySQL retrieve field. If not set, all fields will be returned as a JSON object") 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") )
View Source
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") )
View Source
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") 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.") )
View Source
var ( NSQNSQLookupdAddress = FlagSet.String("nsq-nsqlookupd-address", "", "NSQ nsqlookupd address") NSQNSQDAddress = FlagSet.String("nsq-nsqd-address", "", "NSQ nsqd address") NSQTopic = FlagSet.String("nsq-topic", "", "NSQ topic") NSQChannel = FlagSet.String("nsq-channel", "", "NSQ channel") NSQEnableTLS = FlagSet.Bool("nsq-enable-tls", false, "Enable TLS") NSQTLSSkipVerify = FlagSet.Bool("nsq-tls-skip-verify", false, "NSQ TLS skip verify") NSQCAFile = FlagSet.String("nsq-tls-ca-file", "", "NSQ TLS CA file") NSQCertFile = FlagSet.String("nsq-tls-cert-file", "", "NSQ TLS cert file") NSQKeyFile = FlagSet.String("nsq-tls-key-file", "", "NSQ TLS key file") )
View Source
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") PsqlTLSRootCert = FlagSet.String("psql-tls-root-cert", "", "PostgreSQL SSL root cert") PsqlTLSCert = FlagSet.String("psql-tls-cert", "", "PostgreSQL TLS cert") PsqlTLSKey = FlagSet.String("psql-tls-key", "", "PostgreSQL TLS key") PsqlQueryKey = FlagSet.Bool("psql-query-key", false, "PostgreSQL query returns key as first column and value as second column") PsqlRetrieveField = FlagSet.String("psql-retrieve-field", "", "PostgreSQL retrieve field. If not set, all fields will be returned as a JSON object") 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") )
View Source
var ( PulsarAddress = FlagSet.String("pulsar-address", "", "Pulsar address") PulsarSubscription = FlagSet.String("pulsar-subscription", "", "Pulsar subscription name") PulsarTopic = FlagSet.String("pulsar-topic", "", "Pulsar topic") PulsarTopicsPattern = FlagSet.String("pulsar-topics-pattern", "", "Pulsar topics pattern") PulsarTopics = FlagSet.String("pulsar-topics", "", "Pulsar topics, comma separated") PulsarTLSTrustCertsFilePath = FlagSet.String("pulsar-tls-trust-certs-file", "", "Pulsar TLS trust certs file path") PulsarTLSAllowInsecureConnection = FlagSet.Bool("pulsar-tls-allow-insecure-connection", false, "Pulsar TLS allow insecure connection") PulsarTLSValidateHostname = FlagSet.Bool("pulsar-tls-validate-hostname", false, "Pulsar TLS validate hostname") PulsarAuthToken = FlagSet.String("pulsar-auth-token", "", "Pulsar auth token") PulsarAuthTokenFile = FlagSet.String("pulsar-auth-token-file", "", "Pulsar auth token file") PulsarAuthCertFile = FlagSet.String("pulsar-auth-cert-file", "", "Pulsar auth cert file") PulsarAuthKeyFile = FlagSet.String("pulsar-auth-key-file", "", "Pulsar auth key file") PulsarAuthOAuthParams = FlagSet.String("pulsar-auth-oauth-params", "", "Pulsar auth oauth params") )
View Source
var ( RabbitMQURL = FlagSet.String("rabbitmq-url", "", "RabbitMQ URL") RabbitMQQueue = FlagSet.String("rabbitmq-queue", "", "RabbitMQ queue") )
View Source
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'.") )
View Source
var ( ScyllaHosts = FlagSet.String("scylla-hosts", "", "Scylla hosts") ScyllaUser = FlagSet.String("scylla-user", "", "Scylla user") ScyllaPassword = FlagSet.String("scylla-password", "", "Scylla password") ScyllaKeyspace = FlagSet.String("scylla-keyspace", "", "Scylla keyspace") ScyllaConsistency = FlagSet.String("scylla-consistency", "QUORUM", "Scylla consistency") ScyllaRetrieveQuery = FlagSet.String("scylla-retrieve-query", "", "Scylla retrieve query") ScyllaRetrieveParams = FlagSet.String("scylla-retrieve-params", "", "Scylla retrieve params") ScyllaLocalDC = FlagSet.String("scylla-local-dc", "", "Scylla local dc") ScyllaClearQuery = FlagSet.String("scylla-clear-query", "", "Scylla clear query") ScyllaClearParams = FlagSet.String("scylla-clear-params", "", "Scylla clear params") ScyllaFailQuery = FlagSet.String("scylla-fail-query", "", "Scylla fail query") ScyllaFailParams = FlagSet.String("scylla-fail-params", "", "Scylla fail params") ScyllaRetrieveField = FlagSet.String("scylla-retrieve-field", "", "Scylla retrieve field. If not set, all fields will be returned as a JSON object") )
View Source
var ( SMBHost = FlagSet.String("smb-host", "", "SMB host") SMBPort = FlagSet.Int("smb-port", 445, "SMB port") SMBUser = FlagSet.String("smb-user", "", "SMB user") SMBPass = FlagSet.String("smb-pass", "", "SMB pass") SMBKey = FlagSet.String("smb-key", "", "SMB key") SMBKeyGlob = FlagSet.String("smb-key-glob", "", "SMB key glob") SMBClearOp = FlagSet.String("smb-clear-op", "", "SMB clear operation. Valid values: mv, rm") SMBFailOp = FlagSet.String("smb-fail-op", "", "SMB fail operation. Valid values: mv, rm") SMBClearKey = FlagSet.String("smb-clear-key", "", "SMB clear key, if clear op is mv. default is origional key name.") SMBClearKeyTemplate = FlagSet.String("smb-clear-key-template", "", "SMB clear key template, if clear op is mv.") SMBFailKey = FlagSet.String("smb-fail-key", "", "SMB fail key, if fail op is mv. default is original key name.") SMBFailKeyTemplate = FlagSet.String("smb-fail-key-template", "", "SMB fail key template, if fail op is mv.") )
Functions ¶
This section is empty.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.