Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Azure.Monitor.Ingestion] Add Concurrency Upload method #31074

Merged
merged 22 commits into from
Sep 23, 2022
Merged

[Azure.Monitor.Ingestion] Add Concurrency Upload method #31074

Show file tree
Hide file tree
Changes from 5 commits
Commits
Show all changes
22 commits
Select commit Hold shift + click to select a range
dca3de2
wip
nisha-bhatia Sep 12, 2022
5087ea9
Merge remote-tracking branch 'upstream/main' into addConcurrency
nisha-bhatia Sep 12, 2022
3ce16c4
wip
nisha-bhatia Sep 12, 2022
c8560a9
wip
nisha-bhatia Sep 13, 2022
d8b6f64
wip
nisha-bhatia Sep 13, 2022
d65bc76
wip
nisha-bhatia Sep 15, 2022
c13c5b1
wip
nisha-bhatia Sep 16, 2022
aede3a5
wip
nisha-bhatia Sep 16, 2022
c5e520b
wip
nisha-bhatia Sep 19, 2022
d12e916
wip
nisha-bhatia Sep 19, 2022
929e94e
Update CHANGELOG.md
nisha-bhatia Sep 20, 2022
58775c4
add internal
nisha-bhatia Sep 20, 2022
d989610
wip
nisha-bhatia Sep 20, 2022
8352660
wip
nisha-bhatia Sep 20, 2022
f315c90
Update ConcurrencyMultiThreadAsync.json
nisha-bhatia Sep 20, 2022
6ff04e8
wip
nisha-bhatia Sep 21, 2022
dee1ea7
wip
nisha-bhatia Sep 22, 2022
4a51494
Merge remote-tracking branch 'upstream/main' into addConcurrency
nisha-bhatia Sep 22, 2022
7d09e8c
Update ConcurrencyMultiThreadAsync.json
nisha-bhatia Sep 22, 2022
6a60341
Merge remote-tracking branch 'upstream/main' into addConcurrency
nisha-bhatia Sep 23, 2022
c5449bc
wip
nisha-bhatia Sep 23, 2022
42ea061
update changelog for release
nisha-bhatia Sep 23, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 7 additions & 0 deletions sdk/monitor/Azure.Monitor.Ingestion/api/Azure.Monitor.Ingestion.net461.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@ public LogsIngestionClient(System.Uri endpoint, Azure.Core.TokenCredential crede
public virtual Azure.Core.Pipeline.HttpPipeline Pipeline { get { throw null; } }
public virtual Azure.Response Upload(string ruleId, string streamName, Azure.Core.RequestContent content, string contentEncoding = "gzip", Azure.RequestContext context = null) { throw null; }
public virtual System.Threading.Tasks.Task<Azure.Response> UploadAsync(string ruleId, string streamName, Azure.Core.RequestContent content, string contentEncoding = "gzip", Azure.RequestContext context = null) { throw null; }
public virtual System.Threading.Tasks.Task<Azure.Response<Azure.Monitor.Ingestion.UploadLogsResult>> UploadAsync<T>(string ruleId, string streamName, System.Collections.Generic.IEnumerable<T> logEntries, Azure.Monitor.Ingestion.UploadLogsOptions options, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; }
public virtual System.Threading.Tasks.Task<Azure.Response<Azure.Monitor.Ingestion.UploadLogsResult>> UploadAsync<T>(string ruleId, string streamName, System.Collections.Generic.IEnumerable<T> logEntries, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; }
public virtual Azure.Response<Azure.Monitor.Ingestion.UploadLogsResult> Upload<T>(string ruleId, string streamName, System.Collections.Generic.IEnumerable<T> logEntries, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; }
}
Expand All @@ -25,6 +26,12 @@ internal UploadLogsError() { }
public Azure.ResponseError Error { get { throw null; } }
public System.Collections.Generic.IEnumerable<object> FailedLogs { get { throw null; } }
}
public partial class UploadLogsOptions
{
public UploadLogsOptions() { }
public int MaxConcurrency { get { throw null; } set { } }
public Azure.Core.Serialization.ObjectSerializer ObjectSerializer { get { throw null; } set { } }
nisha-bhatia marked this conversation as resolved.
Show resolved Hide resolved
}
public partial class UploadLogsResult
{
internal UploadLogsResult() { }
Expand Down
7 changes: 7 additions & 0 deletions sdk/monitor/Azure.Monitor.Ingestion/api/Azure.Monitor.Ingestion.net5.0.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@ public LogsIngestionClient(System.Uri endpoint, Azure.Core.TokenCredential crede
public virtual Azure.Core.Pipeline.HttpPipeline Pipeline { get { throw null; } }
public virtual Azure.Response Upload(string ruleId, string streamName, Azure.Core.RequestContent content, string contentEncoding = "gzip", Azure.RequestContext context = null) { throw null; }
public virtual System.Threading.Tasks.Task<Azure.Response> UploadAsync(string ruleId, string streamName, Azure.Core.RequestContent content, string contentEncoding = "gzip", Azure.RequestContext context = null) { throw null; }
public virtual System.Threading.Tasks.Task<Azure.Response<Azure.Monitor.Ingestion.UploadLogsResult>> UploadAsync<T>(string ruleId, string streamName, System.Collections.Generic.IEnumerable<T> logEntries, Azure.Monitor.Ingestion.UploadLogsOptions options, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; }
public virtual System.Threading.Tasks.Task<Azure.Response<Azure.Monitor.Ingestion.UploadLogsResult>> UploadAsync<T>(string ruleId, string streamName, System.Collections.Generic.IEnumerable<T> logEntries, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; }
public virtual Azure.Response<Azure.Monitor.Ingestion.UploadLogsResult> Upload<T>(string ruleId, string streamName, System.Collections.Generic.IEnumerable<T> logEntries, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; }
}
Expand All @@ -25,6 +26,12 @@ internal UploadLogsError() { }
public Azure.ResponseError Error { get { throw null; } }
public System.Collections.Generic.IEnumerable<object> FailedLogs { get { throw null; } }
}
public partial class UploadLogsOptions
{
public UploadLogsOptions() { }
public int MaxConcurrency { get { throw null; } set { } }
public Azure.Core.Serialization.ObjectSerializer ObjectSerializer { get { throw null; } set { } }
}
public partial class UploadLogsResult
{
internal UploadLogsResult() { }
Expand Down
7 changes: 7 additions & 0 deletions sdk/monitor/Azure.Monitor.Ingestion/api/Azure.Monitor.Ingestion.netstandard2.0.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@ public LogsIngestionClient(System.Uri endpoint, Azure.Core.TokenCredential crede
public virtual Azure.Core.Pipeline.HttpPipeline Pipeline { get { throw null; } }
public virtual Azure.Response Upload(string ruleId, string streamName, Azure.Core.RequestContent content, string contentEncoding = "gzip", Azure.RequestContext context = null) { throw null; }
public virtual System.Threading.Tasks.Task<Azure.Response> UploadAsync(string ruleId, string streamName, Azure.Core.RequestContent content, string contentEncoding = "gzip", Azure.RequestContext context = null) { throw null; }
public virtual System.Threading.Tasks.Task<Azure.Response<Azure.Monitor.Ingestion.UploadLogsResult>> UploadAsync<T>(string ruleId, string streamName, System.Collections.Generic.IEnumerable<T> logEntries, Azure.Monitor.Ingestion.UploadLogsOptions options, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; }
public virtual System.Threading.Tasks.Task<Azure.Response<Azure.Monitor.Ingestion.UploadLogsResult>> UploadAsync<T>(string ruleId, string streamName, System.Collections.Generic.IEnumerable<T> logEntries, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; }
public virtual Azure.Response<Azure.Monitor.Ingestion.UploadLogsResult> Upload<T>(string ruleId, string streamName, System.Collections.Generic.IEnumerable<T> logEntries, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; }
}
Expand All @@ -25,6 +26,12 @@ internal UploadLogsError() { }
public Azure.ResponseError Error { get { throw null; } }
public System.Collections.Generic.IEnumerable<object> FailedLogs { get { throw null; } }
}
public partial class UploadLogsOptions
{
public UploadLogsOptions() { }
public int MaxConcurrency { get { throw null; } set { } }
public Azure.Core.Serialization.ObjectSerializer ObjectSerializer { get { throw null; } set { } }
}
public partial class UploadLogsResult
{
internal UploadLogsResult() { }
Expand Down
Loading