* Miscellaneous minor improvements
* Remove timeout from ResourceManager and separate timeout from HttpClientProperties
---------
Co-authored-by: ohad bitton <32278684+ohadbitt@users.noreply.github.com>
* stream source info size
* some good code, unfished
* manaed streaming queuing policy per format
* ser raw size for stream
* remove todo
* format
* fix test
* print exception message on last retry
* used undeclared jackson dep
* format
* add comment
* good comments
* better
* changelog
* format
* comments - E2E
* changelog
* comments
* comment
* fix
* last comments
---------
Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
* Introduces KustoQuery wrapper object
* working on async client
* updating client with KustoQuery object
* updating client with KustoQuery object
* updating client with KustoQuery object
* will simplify later.
* will simplify later.
* will simplify later.
* ran formatter, fixed test, fixed bad merge
* AtomicBooleans in already modified test. Save some lines, might as well.
* hide KustoQuery object
* rename and hide KustoRequest
* adding E2ETests for async queries
* ran formatter
* no complete in sink
* move blocking operations off the io thread
* run formatter
* replace execute utilization
* fixes teardown. async still doesn't work yet.
* fixes msal4j issue
* build.yaml
* Introduces KustoQuery wrapper object
* working on async client
* updating client with KustoQuery object
* updating client with KustoQuery object
* updating client with KustoQuery object
* will simplify later.
* will simplify later.
* will simplify later.
* ran formatter, fixed test, fixed bad merge
* AtomicBooleans in already modified test. Save some lines, might as well.
* hide KustoQuery object
* rename and hide KustoRequest
* adding E2ETests for async queries
* ran formatter
* no complete in sink
* move blocking operations off the io thread
* run formatter
* replace execute utilization
* fixes teardown. async still doesn't work yet.
* fixes msal4j issue
* rebased
* rework azure branch
* remove unused dependencies
* fix some more issues with imports
* add default timeout 10 min
* re-add readme
* modified changelog
* modified changelog
* removes krL
* remove async test file
* remove closeable from query clients
* fixes pom version change and removes unused reactor property
* CI_EXECUTION
* storageaccountset guard clause
* close clients in E2ETest
* remove extra assertions from teardown
* remove reactor step verifiers for now
* readd deflate to cloudinfo
* renoved reactor test library for now
* run formatter
* added fixme
* move URIBuilder to further facilitate removal of Apache
* add more detail to assertion failure
* Made InvalidConnectionString extend DataClientException so users can optionally catch the more specific exception
* commenting everything async until implementation works
* commenting everything async until implementation works
* ran formatter
* remove unused Apache classes
* removed commented code
* move message to appropriate assertion
* removed last of the commented code and ran formatter
* readd the auto-delete policy
* make request object usage private
* put back more Apache things.
* renove trailing space
* Update BaseClient.java
---------
Co-authored-by: cole <cole.snyder@gmork.tech>
Co-authored-by: asafmahlev <asafmahlev@microsoft.com>
Co-authored-by: ohad bitton <32278684+ohadbitt@users.noreply.github.com>
* Added kcsb's app for tracing and user for tracing to queued ingest client and ingestion properties
* Changed setter\getters permissions in ingestionProperties
* Removed tracing from ingestionProperties
* Pr comments and created a clientdetails to handle deafults
* initial commit removing apache http libraries
* updated MSAL wrapper class to include headers in response
* Added TestHttpResponse class to replace BasicHttpResponse in Tests
* Added KustoParseException to replace ParseException from old Apache Client.
* removed todo regarding ParseException
* removed EofSensorInputStream
* added fixme to replace EofSensorInputStream
* Return of the Apache
* Fixed UtilitiesTest
Removed cast to Closeable in CloudInfo
* return UriBuilder to UriUtils
* add proxy options back to HttpClientFactory
* ran formatter
* closeable and fix build
* fix test
* format
* removed extra throws
* Per Ohad review comments:
-Adds custom HTTP status codes
-Integrates status codes
-Uses Context.NONE static factory
* removed caught exceptions that were rethrown with no changes/side effects in QueuedIngestClientImpl per review comments
* removes block on body by using BinaryData
removes Entity references
* ran formatter
* added Tracing object and builder to shorten method signatures
added HttpRequestBuilder to separate request building logic from execute methods in the client, providing better testability
Created BaseClient class to host the inner httpClient
Put post methods on BaseClient so no need for utils class
removed HttpPostUtils.java
updated impacted tests
left notes on Keep-Alive header in ClientFactory
ran formatter
* puts old URIBuilder back in place
* update readme with ProxyOptions
* aligns with PR 342
* fix issue with Closeable
* ran formatter
* Fix sync HttpWrapper implementation
* fix build
* format
* build
* Few bug fixes
Build works also with OKHttp providers
* readd the exclusion of commons-codec for security posture
* adds response timeout and client provider to the client properties wrapper
* removes references to Netty
* removes extra comment
* adds Keep-Alive back to prevent breaking change for users of Keep-Alive. updates CHANGELOG.md
ran formatter.
* removes deflate algorithm from encoding header
* revert removing Apache core (URIBuilder depends on utilities in core)
* remove netty from client factory
* fix
* removes CloseParentResourcesStream.java
* reusable Gzip logic
* factory now uses azure-core default http client options
* I always forget the formatter
* fix test
---------
Co-authored-by: cole <cole.snyder@gmork.tech>
Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
Co-authored-by: ohad bitton <32278684+ohadbitt@users.noreply.github.com>
* Fix integration tests that should be unit tests
* Fix integration tests that should be unit tests
* Black
* Add unit-ish test for autoCorrectEndpoint boolean
* Black
* test fail
* test good
* format
* fix resource manager
* fix resource manager
* ResourceManagerTest fix
* ResourceManagerTest fix
* ResourceManagerTest fix
* tyr not to hang the tests
* format
---------
Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
* Test without these classes
* Test without these classes
* Test without these classes
* Test without these classes
* Test without these classes
* Test without these classes
* Test without these classes
* Test without these classes
* Test without these classes
* Test without these classes
* Test without these classes
* Test without these classes
* Test without these classes
* Test without these classes
* Test without these classes
* Test without these classes
* Test without these classes
* Test without these classes
* Test without these classes
* Test Ohad's proposal
* Test Ohad's proposal
* transient IOError
* transient IOError
* move getObjectMapper back to utils
* revert unrelated
* revert unrelated
* fix warning
* revert HttpClientProperties move to http folder
* try again
* format
* disable managed streamign test
* timeout test
* t
* dis q t
* redo test
* redo test
* no retry in cloud test
* no retry in cloud test
* fix vavr not used
* stop it !
* stop it !
* stop it !
* queuedClient test again?
* no managed , queuedClienttest minus ingestFromBlob_IngestionReportMethodIsNotTable_EmptyIngestionStatus
* format
* add again ingestFromBlob_IngestionReportMethodIsNotTable_EmptyIngestionStatus
* now with retries?
* retries not vavr?
* f
* nicer
* nicer
* nicer
---------
Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
* Fix capitalization of method names, and other non-functional improvements
* Fix capitalization of method names, and other non-functional improvements
* Fix black
* Revert breaking change
* Additional change required after merge
* Added autocrrectendpoint usage
* Added autocrrectendpoint usage
* Added isreserved hostname support and tests
* Maven reforamtting
* fixed clusterurl fix
* Following PR notes - added more tests, revamped isReservedHostName and fixed documentation
* With Formatting
* Changed from var to actual types
* Fixed IPV6 scenario
* Fixed formatting
* Fixed blocking on non local addresses
* Moved tests from e2e to unittests files + Other PR notes anout deprecated functions
* Added more test cases
* dont use timer if null
* dont use timer if null
* UserPromptTokenProvider public
* synchronized PublicAppTokenProviderBase
* synchronized PublicAppTokenProviderBase
* format
* add comment
* add comment
---------
Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
* Added ignore first record support + flag whether to test on managed streaming ingest or not
* Update ingest/src/test/java/com/microsoft/azure/kusto/ingest/E2ETest.java
Co-authored-by: AsafMah <asafmahlev@microsoft.com>
* Update ingest/src/test/java/com/microsoft/azure/kusto/ingest/E2ETest.java
Co-authored-by: AsafMah <asafmahlev@microsoft.com>
---------
Co-authored-by: AsafMah <asafmahlev@microsoft.com>
* The new Storage implementation hides the exceptions thrown in annotations. such as @UnexpectedResponseExceptionType(TableServiceErrorException.class)
* fix test
* better log
---------
Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
* working and nice
* fix tests
* format
* revert samples
* test streaming from blob
* revert revert test
* test
* format
* fix test
* revert
---------
Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
* Revert "Revert "Added props""
This reverts commit f40ad30d39.
* Fixed NPE
* Added tests
* Formatting
* Tests again
* Fixed NRE
* Upgrade mockito to fix tests
* Added according to spec
* Fallback to env
* Align name
* format
* format
* format
* Fixed tests
* Some comments
* Moved header logic away.
* Formatter
* Fixed null
* Removed append method
* FFormat
* remove unrelated test
* Optimize imports
* Align param order with .net
* format
* Naming
* Use real url
* PR fixes
* public
* format
* Update Utils.java
* start
* matcher
* clean
* matcher
* dragt
* not work
* Tests and all works well
* Tests and all works well
* clean all dirt
* fix format
* fix formatClientImpl
* databind conflict
* Formatting
* fix NPE
comments
* comment
* revert e2e
* fix NPEs !!
* format
Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
Co-authored-by: AsafMah <asafmahlev@microsoft.com>
George Banasios
Yihezkel Schoenbrun
ohad bitton
Cole
AsafMah
t-ronmoneta
Tanmaya Panda
ronmonetaMicro
Eitan Moed
asaharn