Commit Graph

3297 Commits

Author SHA1 Message Date
Carlos Mendible 0d58c00bcf
Added jsonsecretstore (#328)
Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
2020-05-29 05:55:45 -07:00
Sashi Kumar 42a7af4c0c
[DynamoDB] Update BulkSet and BulkDelete with BatchWriteItem (#331)
* [DynamoDB] Update BulkSet and BulkDelete with BatchWriteItem

* Validate type of value

* Marshal value before setting for Set and BulkSet

Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-05-27 15:12:34 -07:00
Yaron Schneider d779825d38
Update Readme.md (#351) 2020-05-27 15:05:05 -07:00
Yaron Schneider e82164f4e7
Add bi-directional bindings support (#350)
* add bi-directional bindings

* added invoke response

* added explicit types

* change operationtype to operationkind
2020-05-26 23:32:20 -07:00
Trond Hindenes d3e9a7b3a7
Use shared aws auth package (#347)
* Use shared sqs auth package

* Goimports-ed files

* Added support for endpoint param in aws credentials abstraction, since the sqs-sns pubsub module required it

* Added endpoint support for all aws things

* Updated tests
2020-05-26 16:27:16 -07:00
Mayank Kumar 3ed4f0f63c
Add pubsub support for mqtt (#330)
* Add pubsub support for mqtt

- update README.md
- add tests for metadata parsing
- linting

* Add pubsub support for mqtt

- remove topic field from metadata.

* Add pubsub support for mqtt

- use consumerID as clientID for mqtt connection

* Add pubsub support for mqtt

- address review comments
2020-05-22 20:39:09 -07:00
Joni Collinge 1461b0e4a5
Fix issue with ASB pubsub throttling (#329)
* Applied throttling to receiver loop

* added init lock renewal

* added prefect count config option

* renew message locks before processing

* moved lock acquisition per go routine

* fix test

* added max active message throttles

* rename numConcurrentHandlers to maxConcurrentHandlers

* fix typo in abandonMessage func name

* set maxActiveMessages to minimum of prefetchCount

* remove prefetch count constraint

* removed conditional activeMessage tracking

Co-authored-by: Shalabh Mohan Shrivastava <shalabhs@microsoft.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-05-22 20:38:28 -07:00
Trond Hindenes 52e37224e5
aws sqs: Use implicit creds and region by default, explicit if specified (#340)
* Use implicit creds by default, explicit if specified

* Remove log lines

* Support implicit region as well

* gofmt-ed file

* removed a newline

* Use a separate package for aws auth stuff

* Rename + alias imports

* gofmt

* goimportsed file

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-05-22 15:59:22 -07:00
John b54585c4f0
Apache Pulsar - pubsub component (#346)
* created pulsar component

* fixed multi topic issue

* moved metadata struct

* finished writing metadata tests

* fixed linter issues

* modifies consumer type to failover

* uncapitalized errors

* changed subscriptionName to consumerID

* acknowledge message only if there's no error returned from handler

Co-authored-by: john verdonck <John@johns-MacBook-Pro.local>
2020-05-22 10:04:07 -07:00
Kyle Housley 8eff31b191
Add AWS SNS/SQS support (#342)
* working but WIP aws pubsub

* working pubsub impl, problematic resource naming

* working implementation with tags and hashed topic/queue names

* add correct permissions for sqs queue to allow sns publishing

* fix logging messages, make awsToken optional, rename test functions, nits

* lowercase comments

* nits, repetitive use of 'the'

Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-05-21 14:20:16 -07:00
Joni Collinge aa4f9e8753
handle uservalues (#333) 2020-05-20 17:02:47 -07:00
Joni Collinge 1e4363cbe4
Update mDNS resolver to respect service IP address (#341)
* updated mdns resolver to respect ip address

* add conditional case for default

Co-authored-by: Young Bu Park <youngp@microsoft.com>
2020-05-19 10:17:26 -07:00
Brooke Hamilton 909739702e
Fixed SQL Server state store integration tests (#324) (#325) 2020-05-18 09:40:26 -07:00
Mark Chmarny b647397b2c
Fixed termination signal, added read test (#321)
* titter search binding

* refactored signal processing for lint comp

* titter search binding

* refactored signal processing for lint comp

* fixed twitter ref

* fixed termination signal, added read test

* removed unused maxTweet property

* fixed lint issues

* lint fix

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-04-30 14:21:23 -07:00
Yaron Schneider 71eaf77932
Update Readme.md (#320) 2020-04-30 09:06:54 -07:00
Ben Coleman e97529a4a8
Unescape azure blob data (#313)
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-04-30 08:15:18 -07:00
Mark Chmarny 0e731f96aa
Added Twitter search input binding (#318)
* titter search binding

* refactored signal processing for lint comp

* titter search binding

* refactored signal processing for lint comp

* fixed twitter ref

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-04-29 08:02:57 -07:00
Lynn Orrell 8480a29c18
EventGrid Component Updates (#319)
* event grid udpates

* Initial event grid input binding

* Added Write() support to EventGrid component

* Updated eventgrid binding to use fasthttp instead of net/http

* Fixed linting issue in EventGrid binding

* Tidy up go.mod

* Added handshakePort to allow custom port for EG callback

* Now properly throwing an http 500 on handler err

* Updated event grid sdk for cloud event 1.0 support
Added support for all event grid sources via scope
Now validating required metadata on read/write

* Updated tests

* Fixed linting issue

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Young Bu Park <youngp@microsoft.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2020-04-29 08:02:22 -07:00
Lynn Orrell 8827c58e78
Added Azure Event Grid Bindings (#290)
* event grid udpates

* Initial event grid input binding

* Added Write() support to EventGrid component

* Updated eventgrid binding to use fasthttp instead of net/http

* Fixed linting issue in EventGrid binding

* Tidy up go.mod

* Added handshakePort to allow custom port for EG callback

* Now properly throwing an http 500 on handler err

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Young Bu Park <youngp@microsoft.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2020-04-28 12:50:13 -07:00
Kyle Housley 0c4cade71f
Add pubsub support for kafka (#315)
* fixes issue #8: adds kafka as pubsub component

* fixes issue #8: adds kafka as pubsub component

* pubsub kafka: modifies readme

* pubsub kafka: fixes bug

* pubsub kafka: fixes bug

* pubsub kafka: changes are per PR review

* changes as PR review

* removed unused field

* only close channel once

* working kafka pubsub

* add testing for metadata parsing

* linting

* remove unused PublishTopic, remove loglevel

* Use one consumer group for subscriptions

Co-authored-by: Roberto J Rojas <robertojrojas@gmail.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Young Bu Park <youngp@microsoft.com>
Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
2020-04-27 19:53:04 -07:00
Ben Coleman ebf31ef7c5
Added SendGrid output binding for sending emails (#308)
* Added first cut of SendGrid binding

* Removed some junk

* tidy up based on PR review comments
Removed duped line, and logging, normalised error messages

* Silly mistakes on emailTo and subject checks

* Moving to new twilio folder structure

* adds BCC and CC, better error handling

* microscopic comment typo

* linter was complaining

* removing my accidental docs commit

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
2020-04-22 21:54:01 -07:00
Julian-Chu 91616f7b2d
fix broken links in developing-component.md (#312) 2020-04-20 19:16:23 -07:00
Sivamuthu Kumar fd531b006f
Cosmos - Nested PartitionKey Support (#296)
* Nested partition key in cosmosdb bindings

* fix lint

* Lookup values by iterating

* fix lint

Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
2020-04-15 10:29:43 -07:00
Francisco Beltrao 75fcd7accf
Add message time to live in RabbitMQ, Azure Service Bus/Storage Queue bindings (#298)
* Add message ttl for Azure Service Bus/Storage Queue
and RabbitMQ

* Rename metadata key to ttlInSeconds
Move defaultQueueTTL to RabbitMQ metadata

* Move integration tests to own files

* Add +build integration_test tag

* Remove integration test skip

Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
2020-04-15 10:07:16 -07:00
Yaron Schneider 4f9d6d97e3
add partitionKey to kafka binding (#303)
Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
2020-04-09 14:42:01 -07:00
Ricardo Niepel 7dd4d8ff2e
Update PR template to include doc issue ref (#287)
Initiative to ensure docs are in line to current feature set

Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
2020-04-09 13:12:51 -07:00
Julian-Chu caab6d32eb
don't treat non-existent keys as errors (#300) 2020-04-09 12:03:02 -07:00
Pruthvidhar R Dhodda a36e498d02
Add TLS support for bindings.redis (#302)
* Add TLS support for bindings.redis

* Remove unsused dependencies

* Fix failing tests

* Remove unused variables
2020-04-09 12:02:24 -07:00
Ben Coleman 1ab1a86a60
Small misspelling in error messages (#299) 2020-04-07 11:41:58 -07:00
Young Bu Park b3e025deb9
Fix linter check (#295)
Fix linter check
2020-04-01 17:47:22 -07:00
Young Bu Park f87cd99ee7
Turn off linter for windows (#294)
Turn off linter for windows
2020-04-01 17:45:14 -07:00
Young Bu Park d8e1728e06
Increase linter timeout to 20m (#292)
Increase linter timeout to 20m

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-04-01 17:42:31 -07:00
Young Bu Park 0489fb17f3
Fix linter errors (#293) 2020-04-01 17:22:15 -07:00
Yaron Schneider 0d23c2d428
Update components-contrib.yml (#291)
Update to v2 for actions checkout.
2020-04-01 16:28:41 -07:00
pruthvidhodda fe9b90075a
Change redis client library to go-redis for redis component (#283)
* Change redis client library to go-redis for redis component to support TLS
2020-03-30 19:50:48 -07:00
Sivamuthu Kumar 910a8931f7
Empty response when aerospike state key not found (#285) 2020-03-28 09:06:01 -07:00
Piotr Jasina 1ac30f7be5
Add Hazelcast pubsub support (#254) 2020-03-24 17:00:36 -07:00
Sivamuthu Kumar b14500315a
Add Kinesis data stream binding (#273)
* Add Kinesis data stream binding

* fix lint kinesis

* Add license at top of the file

Co-authored-by: Young Bu Park <youngp@microsoft.com>
2020-03-24 11:33:23 -07:00
Ricardo Niepel 934ef7a7ba
Add metadata support to Azure Blob binding (#281)
* add metadata support to AzBlobBinding

* change to tabs

* fix lint error

* improve error message

* uncap error message
2020-03-21 16:33:35 -07:00
madhugilla dc1e938e61
Alicloudoss (#278)
* Object storage implementation for AliCloud

* linting fixes

* fixed comments and ran "go mod tidy" based on the feedback

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-03-20 12:34:38 -07:00
Carlos Landeras 22717373ca
[Azure Storage Queue Binding] Add option to decode base64 payloads #232 (#251)
* [Azure Storage Queue Binding] Add option to decode base64 payloads

* Fix tests

* Fix linting

* Fix wrong assertion

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
2020-03-20 03:47:00 -07:00
Abhishek Gupta a0b981bda5
don't treat non-existent keys as errors (#274)
Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
2020-03-19 14:22:17 -07:00
Sivamuthu Kumar f21a0e93e1
eventhub read and write from same partition (#269) 2020-03-19 12:31:10 -07:00
Abhishek Gupta b6f15ed72c
don't treat non-existent keys as errors (#275) 2020-03-19 12:28:37 -07:00
Sivamuthu Kumar 14b08a11cf
Couchbase state store: don't treat non-existent keys as errors (#276)
* Couchabse state store: don't treat non-existent keys as errors

* Check specific key not found error
2020-03-19 12:27:38 -07:00
Sivamuthu Kumar 16c230aec7
GCP Cloud Pubsub implementation (#266)
* GCP Cloud Pubsub pub sub implementation

* fixing lint

* using consumerID instead of subscription
2020-03-15 11:12:22 -07:00
Abhishek Gupta cf077cca65
Updated Event Hubs bindings implementation to use EPH (#253)
* update implementation to use EPH

* fixed minor lint error

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-03-09 22:07:52 -07:00
Abhishek Gupta 807e8893cb
Azure Event Hubs pubsub component (#242)
* event hubs pubsub

* go mod tidy

* go mod

Co-authored-by: yaron2 <yaronsc@microsoft.com>
Co-authored-by: Young Bu Park <youngp@microsoft.com>
2020-03-09 22:02:04 -07:00
Yaron Schneider 21853a1182
fix key for azure keyvault (#267) 2020-03-09 21:56:11 -07:00
Sivamuthu Kumar da7ce3f738
Twilio Binding - Get To Number from Request (#256)
* Twilio Binding - Get To Number from Request

* fix typo and rephrase error message

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-03-09 15:44:59 -07:00