Граф коммитов

60 Коммитов

Автор SHA1 Сообщение Дата
Joel Hendrix c07509cff9
Update to the GA version of go-amqp (#288)
* Update to the GA version of go-amqp

Updated readme message with GA announcement of azeventhubs.

* update changelog and version info

* update internal pipeline to supported version of Ubuntu

* check for specific error conditions that are now explicitly returned
2023-05-24 15:53:35 -07:00
Joel Hendrix 1761881894
Update to latest azure-amqp-common-go and go-amqp modules (#287)
* Update to latest azure-amqp-common-go and go-amqp modules

* fix test fake and update go-amqp with race fix

* fix bug in lease renal logic
2023-03-31 12:38:42 -07:00
Joel Hendrix 8a67a58a98
Update to latest go-amqp and common module (#281)
* Update to latest go-amqp and common module

* fix detection of closed links

* clean up lint

* cleanup

* make detach errors recoverable

* update to latest common and tagged go-amqp
2022-12-06 11:03:37 -08:00
Richard Park 73b7c0f7b2
Update to handle use *amqp.DetachError instead of ErrLinkDetached (go-amqp change) (#245)
Updating to the latest go-amqp and azure-amqp-common-go

* go-amqp will return *amqp.DetachError now instead of ErrLinkDetached (which is being removed).
* Now that we can set fields to nil they can be properly omitted.

Misc: Fixing a unit test that was broken.
2021-12-07 17:06:42 -08:00
Richard Park fa1b408451 - Adding in a simple stress test that can run through the recovery code in a realistic way.
- Adjusting tests to handle the link ID
- Changing Recover() so I don't break the public facing API by breaking it apart into an internal version and a public facing one. (the internal one let's us pass in the expected link ID to avoid the expensive recovery)
2021-08-03 00:14:02 +00:00
Richard Park aefb43824c Addressing feedback from jhendrix:
- Default to infinite retries to be backwards compatible with our previous change
- Document that < 0 is a valid value and indicates infinite retries.
2021-07-16 20:06:19 +00:00
Richard Park 2235a9da19 Merge remote-tracking branch 'upstream/master' into eh-retry
(Joel had moved the concurrency tests)
2021-07-15 23:18:01 +00:00
Richard Park e2af248b76 Exposing the sender max retry count option up through the Hub. 2021-07-15 23:13:33 +00:00
Joel Hendrix 03123a928b
Enable race detection in integration tests (#224)
* Enable race detection in integration tests

Move tests specific to race detection to their own source file under the
race build tag.
Removed error checking for concurrent test and updated comment.

* add missing target

* add missing test case reporting

* check for error on Recover()
2021-07-15 14:59:46 -07:00
Joel Hendrix 0eb7b61636
Fix sender.Recover() to be goroutine safe (#218)
* Fix sender.Recover() to be goroutine safe

Tidy go.sum

* add tracing to recovery code

* honor context while sleeping

* add comments detailing limitations

* add concurrency test

fix hang when test misbehaves
2021-07-07 19:01:53 -07:00
Catalina Peralta 88c818d3f4 updating env var check 2020-12-10 07:57:04 -08:00
Catalina Peralta 26a34c48b6 checking for azure environment variable when creating a new hub 2020-12-09 15:10:00 -08:00
Catalina Peralta c8ff9f4836 Update yamls 2020-09-21 15:48:39 -07:00
Jeff Principe 9898ba6578
Support sending and receiving custom annotations in System Properties (#174)
* Support sending and receiving custom annotations in System Properties

* fix terraform setup and make tests pass

* remove extra annotation assignment

* don't allow partition key to overwrite annotations

* update version number

Co-authored-by: Joel Hendrix <jhendrix@microsoft.com>
2020-06-08 12:35:13 -07:00
Joel Hendrix 7a1b2e2089
switch pack.ag/amqp to github.com/Azure/go-amqp (#152)
bump common lib to v3
bump mod ver to v3 due to changes in public surface area
2019-12-17 14:59:24 -08:00
Jie Shen 557f9eb3ea Fix testEpochGreaterThenLess failure caused by update amqp version 2019-08-01 14:17:43 +08:00
David Justice f02849d748
move to v2 2019-06-06 08:51:48 -07:00
David Justice 17f75b29eb
move to v2 of common 2019-06-06 08:51:48 -07:00
David Justice e7ca69248d
batch iterator rather than event batch 2019-06-06 08:51:47 -07:00
David Justice bd38add7f7
add system properties to Event 2019-05-06 11:09:38 -07:00
David Justice dd77959ec0
add websocket support 2019-04-25 09:34:04 -07:00
David Justice d71a6c23ac
sender recovery on conn drops and too large batch test 2019-04-18 10:50:21 -07:00
David Justice eb0f70969a
move test requirements into terraform 2018-12-12 11:14:04 -08:00
David Justice 6b8068f8b3
move to mgmt options 2018-09-04 08:41:30 -07:00
David Justice 9d7b04d86b
move from opentracing to opencensus 2018-08-24 16:24:05 -07:00
David Justice 9ca434032a
improve eph robustness 2018-07-23 17:19:49 -07:00
David Justice db370f1394
recover fully from link detach 2018-07-19 10:41:41 -07:00
David Justice bd2438a5dd
do not try to recover sender errors that are client errors 2018-07-19 09:14:53 -07:00
David Justice d09d1b114e
add event hub management functionality 2018-07-18 10:46:58 -07:00
David Justice a0641e565b
fix inconsistencies when provisioning hubs 2018-07-03 14:53:36 -07:00
David Justice edc24dc9e0
add register and unregister methods 2018-06-28 16:01:33 -07:00
David Justice 5f21327d22
update tests to all include timeouts 2018-06-28 13:00:15 -07:00
David Justice 77c22786fa
add partition key to the received event 2018-06-22 08:40:48 -07:00
David Justice 7d33131d7f
simplify environmental construction by prefering SAS 2018-05-18 08:54:41 -07:00
David Justice 7fa8bd2178
improve eph tests 2018-04-23 13:17:45 -07:00
David Justice 10352efea3
enable integration tests 2018-04-23 13:17:07 -07:00
David Justice 303ab97d77
uncomment sas test 2018-04-13 15:59:14 -07:00
David Justice adb9eeb44b
span logger and tracing prototype propogating tracing 2018-04-13 15:59:17 -07:00
David Justice b04f160320
add license header to files 2018-03-21 15:12:54 -07:00
David Justice 1c26ed71dc
move common into common repo 2018-03-21 14:48:15 -07:00
David Justice 74bdcf30cf
remove client and add documentation 2018-03-21 11:18:59 -07:00
David Justice f8b3f8df5f almost through storage eph implementation 2018-03-12 18:20:51 -07:00
David Justice edf34fa970 in memory event hubs first test 2018-03-09 09:02:49 -08:00
David Justice 0fefd66361 added epoch and batch send support 2018-03-07 14:42:39 -08:00
David Justice 427137e916 add handle functionality to the receiver to monitor lifecycle 2018-03-07 14:42:39 -08:00
David Justice 47515688c4 more wip 2018-03-07 14:40:33 -08:00
Kale Blankenship f849d32365 Changes made while reviewing 2018-03-07 08:18:29 -08:00
David Justice b4be1d2439 pass environment down from hub options 2018-02-22 12:52:55 -08:00
David Justice ac58da63db incorporate feedback from SB 2018-02-20 13:32:04 -08:00
David Justice a631efc0ab more SAS tests 2018-02-20 10:32:23 -08:00