RelativityManagerKeplerService
sealed class RelativityManagerKeplerService : KeplerServiceBase, IRelativityManagerService, IDisposable
using Polly;
using System;
using System.Collections.Generic;
using System.Runtime.CompilerServices;
using System.Threading;
using System.Threading.Tasks;
namespace Relativity.Transfer.Kepler
{
internal sealed class RelativityManagerKeplerService : KeplerServiceBase, IRelativityManagerService, IDisposable
{
public RelativityManagerKeplerService(RelativityConnectionInfo connectionInfo, ClientConfiguration configuration, ITransferLog log)
: base(connectionInfo, configuration, log)
{
}
[AsyncStateMachine(typeof(<GetInstanceSettingsAsync>d__1))]
public Task<IEnumerable<InstanceSetting>> GetInstanceSettingsAsync(CancellationToken token)
{
<GetInstanceSettingsAsync>d__1 stateMachine = default(<GetInstanceSettingsAsync>d__1);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<IEnumerable<InstanceSetting>>.Create();
stateMachine.<>4__this = this;
stateMachine.token = token;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
[AsyncStateMachine(typeof(<GetCloudInstanceAsync>d__2))]
public Task<bool> GetCloudInstanceAsync(CancellationToken token)
{
<GetCloudInstanceAsync>d__2 stateMachine = default(<GetCloudInstanceAsync>d__2);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<bool>.Create();
stateMachine.<>4__this = this;
stateMachine.token = token;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public Task<string> (int workspaceId, CancellationToken token)
{
if (workspaceId < 1 && workspaceId != -1)
throw new ArgumentOutOfRangeException("workspaceId");
<>c__DisplayClass3_0 <>4__this;
return RetrySyntaxAsync.WaitAndRetryAsync(Policy.Handle<Exception>(), base.MaxRetryAttempts, (Func<int, TimeSpan>)((int retryAttempt) => TimeSpan.FromSeconds(Math.Pow(2, (double)retryAttempt))), (Action<Exception, TimeSpan>)delegate(Exception exception, TimeSpan span) {
base.Log.LogError(exception, $"""{span}", Array.Empty<object>());
}).ExecuteAsync<string>((Func<CancellationToken, Task<string>>)delegate {
<>c__DisplayClass3_0.<<GetBcpSharePathAsync>b__2>d stateMachine = default(<>c__DisplayClass3_0.<<GetBcpSharePathAsync>b__2>d);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<string>.Create();
stateMachine.<>4__this = <>4__this;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}, token);
}
[AsyncStateMachine(typeof(<GetSingleInstanceSettingAsync>d__4))]
public Task<InstanceSetting> GetSingleInstanceSettingAsync(string section, string name, CancellationToken token)
{
<GetSingleInstanceSettingAsync>d__4 stateMachine = default(<GetSingleInstanceSettingAsync>d__4);
stateMachine.<>t__builder = AsyncTaskMethodBuilder<InstanceSetting>.Create();
stateMachine.<>4__this = this;
stateMachine.section = section;
stateMachine.name = name;
stateMachine.token = token;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
public void Dispose()
{
}
}
}