Implement Realtime Trigger - Githubissues

kestra-io / plugin-gcp

Apache License 2.0

6 stars 9 forks source link

Implement Realtime Trigger #377

Closed iNikitaGricenko closed 2 months ago

iNikitaGricenko commented 2 months ago

What changes are being made and why?

Implemented Consume stream method (async method)
Implemented Realtime Trigger
Added test for Realtime Trigger
Changed Trigger test

How the changes have been QAed?

triggers:
  - id: watch
    type: io.kestra.plugin.gcp.pubsub.RealtimeTrigger
    projectId: "{{globals.project}}"
    topic: test-topic
    subscription: test-subscription