Skip to content

Commit

Permalink
Add AMQP trigger support
Browse files Browse the repository at this point in the history
  • Loading branch information
tombojer committed Apr 5, 2024
1 parent 6b44292 commit 864aa73
Show file tree
Hide file tree
Showing 15 changed files with 2,926 additions and 479 deletions.
94 changes: 94 additions & 0 deletions api/jsonschema/schema.json
Original file line number Diff line number Diff line change
Expand Up @@ -3219,6 +3219,96 @@
],
"type": "object"
},
"io.argoproj.sensor.v1alpha1.AMQPExchangeDeclareConfig": {
"description": "AMQPExchangeDeclareConfig holds the configuration for the exchange on the server",
"properties": {
"autoDelete": {
"description": "AutoDelete removes the exchange when no bindings are active",
"type": "boolean"
},
"durable": {
"description": "Durable keeps the exchange also after the server restarts",
"type": "boolean"
},
"internal": {
"description": "Internal when true does not accept publishings",
"type": "boolean"
},
"noWait": {
"description": "NowWait when true does not wait for a confirmation from the server",
"type": "boolean"
}
},
"type": "object"
},
"io.argoproj.sensor.v1alpha1.AMQPTrigger": {
"properties": {
"auth": {
"$ref": "#/definitions/io.argoproj.common.BasicAuth",
"description": "Auth hosts secret selectors for username and password"
},
"connectionBackoff": {
"$ref": "#/definitions/io.argoproj.common.Backoff",
"description": "Backoff holds parameters applied to connection."
},
"exchangeDeclare": {
"$ref": "#/definitions/io.argoproj.sensor.v1alpha1.AMQPExchangeDeclareConfig",
"description": "ExchangeDeclare holds the configuration for the exchange on the server For more information, visit https://pkg.go.dev/github.com/rabbitmq/amqp091-go#Channel.ExchangeDeclare"
},
"exchangeName": {
"description": "ExchangeName is the exchange name For more information, visit https://www.rabbitmq.com/tutorials/amqp-concepts.html",
"type": "string"
},
"exchangeType": {
"description": "ExchangeType is rabbitmq exchange type",
"type": "string"
},
"metadata": {
"additionalProperties": {
"type": "string"
},
"description": "Metadata holds the user defined metadata which will passed along the event payload.",
"type": "object"
},
"parameters": {
"description": "Parameters is the list of parameters that is applied to resolved AMQP trigger object.",
"items": {
"$ref": "#/definitions/io.argoproj.sensor.v1alpha1.TriggerParameter"
},
"type": "array"
},
"payload": {
"description": "Payload is the list of key-value extracted from an event payload to construct the request payload.",
"items": {
"$ref": "#/definitions/io.argoproj.sensor.v1alpha1.TriggerParameter"
},
"type": "array"
},
"routingKey": {
"description": "Routing key for publishing",
"type": "string"
},
"tls": {
"$ref": "#/definitions/io.argoproj.common.TLSConfig",
"description": "TLS configuration for the amqp client."
},
"url": {
"description": "URL for rabbitmq service",
"type": "string"
},
"urlSecret": {
"$ref": "#/definitions/io.k8s.api.core.v1.SecretKeySelector",
"description": "URLSecret is secret reference for rabbitmq service URL"
}
},
"required": [
"exchangeName",
"exchangeType",
"routingKey",
"payload"
],
"type": "object"
},
"io.argoproj.sensor.v1alpha1.AWSLambdaTrigger": {
"description": "AWSLambdaTrigger refers to specification of the trigger to invoke an AWS Lambda function",
"properties": {
Expand Down Expand Up @@ -4611,6 +4701,10 @@
"io.argoproj.sensor.v1alpha1.TriggerTemplate": {
"description": "TriggerTemplate is the template that describes trigger specification.",
"properties": {
"amqp": {
"$ref": "#/definitions/io.argoproj.sensor.v1alpha1.AMQPTrigger",
"description": "AMQP refers to the trigger designed to place message on AMQP subject."
},
"argoWorkflow": {
"$ref": "#/definitions/io.argoproj.sensor.v1alpha1.ArgoWorkflowTrigger",
"description": "ArgoWorkflow refers to the trigger that can perform various operations on an Argo workflow."
Expand Down
94 changes: 94 additions & 0 deletions api/openapi-spec/swagger.json

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

0 comments on commit 864aa73

Please sign in to comment.