-
Notifications
You must be signed in to change notification settings - Fork 8
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.
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
refactor: Consolidated SessionServices into common #194
base: main
Are you sure you want to change the base?
Conversation
f7a47c5
to
046dafe
Compare
Logger = loggerFactory?.CreateLogger<T>(); | ||
chunkSubmitSize_ = chunkSubmitSize; | ||
} | ||
public readonly ChannelPool ChannelPool; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why do you need the channel pool to be public?
|
||
|
||
#pragma warning restore CS1591 | ||
public readonly TaskOptions TaskOptions; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why do we need to store the task options? That is the role of core, isn't it?
Seconds = 300, | ||
}, | ||
MaxRetries = 3, | ||
Priority = 1, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think a Priority of 2 would be better by default (2 is neither the minimum, nor the maximum).
partitions ?? | ||
(string.IsNullOrEmpty(defaultTaskOptions.PartitionId) | ||
? Enumerable.Empty<string>() | ||
: new List<string> | ||
{ | ||
defaultTaskOptions.PartitionId, | ||
}), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
That's core responsibility
public SessionService CreateSession(TaskOptions taskOptions = null) | ||
{ | ||
ControlPlaneConnection(); | ||
|
||
return new SessionService(GrpcPool, | ||
LoggerFactory, | ||
taskOptions); | ||
taskOptions ?? SessionService.GetDefaultTaskOptions(EngineType.Symphony), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Options are not impacted in other clients ?
No description provided.