Skip to content

Commit

Permalink
Kafka trigger (argoproj#530)
Browse files Browse the repository at this point in the history
* feat(kafka-trigger): added kafka trigger

* feat(kafka-trigger): added kafka producers to sensor context

* feat(kafka-trigger): added kafka trigger tests
  • Loading branch information
VaibhavPage authored Mar 9, 2020
1 parent a21db25 commit adb1f0d
Show file tree
Hide file tree
Showing 24 changed files with 1,359 additions and 194 deletions.
24 changes: 14 additions & 10 deletions Gopkg.lock

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

6 changes: 5 additions & 1 deletion Gopkg.toml
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ required = [

[[constraint]]
name = "github.com/Shopify/sarama"
version = "v1.23.0"
version = "v1.26.1"

[[constraint]]
name = "github.com/stretchr/testify"
Expand Down Expand Up @@ -160,6 +160,10 @@ required = [
name = "k8s.io/gengo"
unused-packages = false

[[prune.project]]
name = "github.com/Shopify/sarama"
unused-packages = false

[[constraint]]
name = "github.com/google/go-github"
revision = "50be09d24ee31a2b0868265e76c24b9545a6eb7a"
Expand Down
2 changes: 1 addition & 1 deletion Makefile
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ override LDFLAGS += \
# docker image publishing options
DOCKER_PUSH?=true
IMAGE_NAMESPACE?=argoproj
IMAGE_TAG?=v0.13.0-rc
IMAGE_TAG?=v0.13.0
BUILD_BINARY?=true

ifeq (${DOCKER_PUSH},true)
Expand Down
28 changes: 26 additions & 2 deletions api/event-source.html
Original file line number Diff line number Diff line change
Expand Up @@ -722,7 +722,7 @@ <h3 id="argoproj.io/v1alpha1.EventSourceSpec">EventSourceSpec
<td>
<code>type</code></br>
<em>
github.com/argoproj/argo-events/pkg/apis/common.EventSourceType
Argo Events common.EventSourceType
</em>
</td>
<td>
Expand Down Expand Up @@ -1932,6 +1932,18 @@ <h3 id="argoproj.io/v1alpha1.SNSEventSource">SNSEventSource
<p>Region is AWS region</p>
</td>
</tr>
<tr>
<td>
<code>roleARN</code></br>
<em>
string
</em>
</td>
<td>
<em>(Optional)</em>
<p>RoleARN is the Amazon Resource Name (ARN) of the role to assume.</p>
</td>
</tr>
</tbody>
</table>
<h3 id="argoproj.io/v1alpha1.SQSEventSource">SQSEventSource
Expand Down Expand Up @@ -2023,6 +2035,18 @@ <h3 id="argoproj.io/v1alpha1.SQSEventSource">SQSEventSource
<p>Namespace refers to Kubernetes namespace to read access related secret from.</p>
</td>
</tr>
<tr>
<td>
<code>roleARN</code></br>
<em>
string
</em>
</td>
<td>
<em>(Optional)</em>
<p>RoleARN is the Amazon Resource Name (ARN) of the role to assume.</p>
</td>
</tr>
</tbody>
</table>
<h3 id="argoproj.io/v1alpha1.SlackEventSource">SlackEventSource
Expand Down Expand Up @@ -2272,5 +2296,5 @@ <h3 id="argoproj.io/v1alpha1.StripeEventSource">StripeEventSource
<hr/>
<p><em>
Generated with <code>gen-crd-api-reference-docs</code>
on git commit <code>95e393b</code>.
on git commit <code>d0d11e4</code>.
</em></p>
49 changes: 46 additions & 3 deletions api/event-source.md
Original file line number Diff line number Diff line change
Expand Up @@ -1397,8 +1397,7 @@ Generic event source

<td>

<code>type</code></br> <em>
github.com/argoproj/argo-events/pkg/apis/common.EventSourceType </em>
<code>type</code></br> <em> Argo Events common.EventSourceType </em>

</td>

Expand Down Expand Up @@ -3833,6 +3832,28 @@ Region is AWS region

</tr>

<tr>

<td>

<code>roleARN</code></br> <em> string </em>

</td>

<td>

<em>(Optional)</em>

<p>

RoleARN is the Amazon Resource Name (ARN) of the role to assume.

</p>

</td>

</tr>

</tbody>

</table>
Expand Down Expand Up @@ -4012,6 +4033,28 @@ from.

</tr>

<tr>

<td>

<code>roleARN</code></br> <em> string </em>

</td>

<td>

<em>(Optional)</em>

<p>

RoleARN is the Amazon Resource Name (ARN) of the role to assume.

</p>

</td>

</tr>

</tbody>

</table>
Expand Down Expand Up @@ -4527,6 +4570,6 @@ all types of events will be processed. More info at
<p>

<em> Generated with <code>gen-crd-api-reference-docs</code> on git
commit <code>95e393b</code>. </em>
commit <code>d0d11e4</code>. </em>

</p>
10 changes: 5 additions & 5 deletions api/gateway.html
Original file line number Diff line number Diff line change
Expand Up @@ -136,7 +136,7 @@ <h3 id="argoproj.io/v1alpha1.Gateway">Gateway
<td>
<code>type</code></br>
<em>
github.com/argoproj/argo-events/pkg/apis/common.EventSourceType
Argo Events common.EventSourceType
</em>
</td>
<td>
Expand Down Expand Up @@ -186,7 +186,7 @@ <h3 id="argoproj.io/v1alpha1.Gateway">Gateway
<td>
<code>eventProtocol</code></br>
<em>
github.com/argoproj/argo-events/pkg/apis/common.EventProtocol
Argo Events common.EventProtocol
</em>
</td>
<td>
Expand Down Expand Up @@ -304,7 +304,7 @@ <h3 id="argoproj.io/v1alpha1.GatewaySpec">GatewaySpec
<td>
<code>type</code></br>
<em>
github.com/argoproj/argo-events/pkg/apis/common.EventSourceType
Argo Events common.EventSourceType
</em>
</td>
<td>
Expand Down Expand Up @@ -354,7 +354,7 @@ <h3 id="argoproj.io/v1alpha1.GatewaySpec">GatewaySpec
<td>
<code>eventProtocol</code></br>
<em>
github.com/argoproj/argo-events/pkg/apis/common.EventProtocol
Argo Events common.EventProtocol
</em>
</td>
<td>
Expand Down Expand Up @@ -671,5 +671,5 @@ <h3 id="argoproj.io/v1alpha1.Subscribers">Subscribers
<hr/>
<p><em>
Generated with <code>gen-crd-api-reference-docs</code>
on git commit <code>95e393b</code>.
on git commit <code>d0d11e4</code>.
</em></p>
16 changes: 7 additions & 9 deletions api/gateway.md
Original file line number Diff line number Diff line change
Expand Up @@ -270,8 +270,7 @@ configurations for the gateway

<td>

<code>type</code></br> <em>
github.com/argoproj/argo-events/pkg/apis/common.EventSourceType </em>
<code>type</code></br> <em> Argo Events common.EventSourceType </em>

</td>

Expand Down Expand Up @@ -358,8 +357,8 @@ Port on which the gateway event source processor is running on.

<td>

<code>eventProtocol</code></br> <em>
github.com/argoproj/argo-events/pkg/apis/common.EventProtocol </em>
<code>eventProtocol</code></br> <em> Argo Events common.EventProtocol
</em>

</td>

Expand Down Expand Up @@ -601,8 +600,7 @@ configurations for the gateway

<td>

<code>type</code></br> <em>
github.com/argoproj/argo-events/pkg/apis/common.EventSourceType </em>
<code>type</code></br> <em> Argo Events common.EventSourceType </em>

</td>

Expand Down Expand Up @@ -689,8 +687,8 @@ Port on which the gateway event source processor is running on.

<td>

<code>eventProtocol</code></br> <em>
github.com/argoproj/argo-events/pkg/apis/common.EventProtocol </em>
<code>eventProtocol</code></br> <em> Argo Events common.EventProtocol
</em>

</td>

Expand Down Expand Up @@ -1323,6 +1321,6 @@ NATS refers to the subscribers over NATS protocol.
<p>

<em> Generated with <code>gen-crd-api-reference-docs</code> on git
commit <code>95e393b</code>. </em>
commit <code>d0d11e4</code>. </em>

</p>
Loading

0 comments on commit adb1f0d

Please sign in to comment.