KubeMQ Targets

Targets

Standalone Services

Category	Target	Kind	Configuration
Cache
	Redis	cache.redis	Usage
	Memcached	cache.memcached	Usage
	Hazelcast	cache.hazelcast	Usage
Stores/db
	Postgres	stores.postgres	Usage
	Mysql	stores.mysql	Usage
	MSSql	stores.mssql	Usage
	MongoDB	stores.mongodb	Usage
	Elastic Search	stores.elastic-search	Usage
	Cassandra	stores.cassandra	Usage
	Couchbase	stores.couchbase	Usage
	CockroachDB	stores.cockroach	Usage
	Percona	stores.stores.percona	Usage
	Aerospike	stores.aerospike	Usage
	RethinkDB	stores.rethinkdb	Usage
Messaging
	Kafka	messaging.kafka	Usage
	Nats	messaging.nats	Usage
	RabbitMQ	messaging.rabbitmq	Usage
	MQTT	messaging.mqtt	Usage
	ActiveMQ	messaging.activemq	Usage
	IBM-MQ	messaging.ibmmq	Usage
Storage
	Minio/S3	storage.minio	Usage
Serverless
	OpenFaas	serverless.openfaas	Usage
Http
	Http	http	Usage

Google Cloud Platform (GCP)

Category	Target	Kind	Configuration
Cache
	Redis	gcp.cache.redis	Usage
	Memcached	gcp.cache.memcached	Usage
Stores/db
	Postgres	gcp.stores.postgres	Usage
	Mysql	gcp.stores.mysql	Usage
	BigQuery	gcp.bigquery	Usage
	BigTable	gcp.bigtable	Usage
	Firestore	gcp.firestore	Usage
	Spanner	gcp.spanner	Usage
	Firebase	gcp.firebase	Usage
Messaging
	Pub/Sub	gcp.pubsub	Usage
Storage
	Storage	gcp.storage	Usage
Serverless
	Functions	gcp.cloudfunctions	Usage

Amazon Web Service (AWS)

Category	Target	Kind	Configuration
Stores/db
	Athena	aws.athena	Usage
	DynamoDB	aws.dynamodb	Usage
	Elasticsearch	aws.elasticsearch	Usage
	KeySpaces	aws.keyspaces	Usage
	MariaDB	aws.rds.mariadb	Usage
	MSSql	aws.rds.mssql	Usage
	MySQL	aws.rds.mysql	Usage
	Postgres	aws.rds.postgres	Usage
	RedShift	aws.rds.redshift	Usage
	RedShiftSVC	aws.rds.redshift.service	Usage
Messaging
	AmazonMQ	aws.amazonmq	Usage
	MSK	aws.msk	Usage
	Kinesis	aws.kinesis	Usage
	SQS	aws.sqs	Usage
	SNS	aws.sns	Usage
Storage
	S3	aws.s3	Usage
Serverless
	Lambda	aws.lambda	Usage
Other
	CloudWatch Logs	aws.cloudwatch.logs	Usage
	CloudWatch Events	aws.cloudwatch.events	Usage
	CloudWatch Metrics	aws.cloudwatch.metrics	Usage

Microsoft Azure

Category	Target	Kind	Configuration
Stores/db
	Azuresql	azure.stores.azuresql	Usage
	Mysql	azure.stores.mysql	Usage
	Postgres	azure.stores.postgres	Usage
Storage
	Blob	azure.storage.blob	Usage
	Files	azure.storage.files	Usage
	Queue	azure.storage.queue	Usage
EventHubs
	EventHubs	azure.eventhubs	Usage
ServiceBus
	ServiceBus	azure.servicebus	Usage

Sources

Type	Kind	Configuration
Queue	kubemq.queue	Usage
Events	kubemq.events	Usage
Events Store	kubemq.events-store	Usage
Command	kubemq.command	Usage
Query	kubemq.query	Usage

Middlewares

In bindings configuration, KubeMQ Bridges supports middleware setting for each pair of source and target bindings.

These properties contain middleware information settings as follows:

Logs Middleware

KubeMQ Bridges supports level based logging to console according to as follows:

Property	Description	Possible Values
log_level	log level setting	"debug","info","error"
		"" - indicate no logging on this bindings

An example for only error level log to console:

bindings:
  - name: sample-binding 
    properties: 
      log_level: error
    sources:
    ......

Retry Middleware

KubeMQ Bridges supports Retries' target execution before reporting of error back to the source on failed execution.

Retry middleware settings values:

Property	Description	Possible Values
retry_attempts	how many retries before giving up on target execution	default - 1, or any int number
retry_delay_milliseconds	how long to wait between retries in milliseconds	default - 100ms or any int number
retry_max_jitter_milliseconds	max delay jitter between retries	default - 100ms or any int number
retry_delay_type	type of retry delay	"back-off" - delay increase on each attempt
		"fixed" - fixed time delay
		"random" - random time delay

An example for 3 retries with back-off strategy:

bindings:
  - name: sample-binding 
    properties: 
      retry_attempts: 3
      retry_delay_milliseconds: 1000
      retry_max_jitter_milliseconds: 100
      retry_delay_type: "back-off"
    sources:
    ......