-
Notifications
You must be signed in to change notification settings - Fork 623
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
MaxRequestsPerConn cluster param was added #1747
base: trunk
Are you sure you want to change the base?
MaxRequestsPerConn cluster param was added #1747
Conversation
@martin-sucha Hello, will be glad to receive your review on this PR! |
conn.go
Outdated
@@ -257,7 +257,7 @@ func (s *Session) dialWithoutObserver(ctx context.Context, host *HostInfo, cfg * | |||
errorHandler: errorHandler, | |||
compressor: cfg.Compressor, | |||
session: s, | |||
streams: streams.New(cfg.ProtoVersion), | |||
streams: s.streamIDGenerator(cfg.ProtoVersion), |
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.
what if we call it newStreamIDGenerator
?
Also is it obligatory to pass config there if we access cfg from attached type?
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.
Fixed, renamed and moved the function to the streams
package.
host_source.go
Outdated
defer h.mu.Unlock() | ||
addr, _ := h.connectAddressLocked() | ||
return net.JoinHostPort(addr.String(), strconv.Itoa(h.port)) | ||
h.mu.Lock() |
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 don't think it makes sense to format files which were not touched by the fix.
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.
ba0fac8
to
88405bb
Compare
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.
LGTM
88405bb
to
00ad04d
Compare
00ad04d
to
65fc5c4
Compare
The pull request #1747 for the Cassandra gocql driver adds a new cluster parameter
MaxRequestsPerConn
. This parameter allows users to configure the maximum number of requests per connection, enhancing the driver's configurability. Functionality was adopted from similar PR from the ScyllaDB project: scylladb#113Closes #1679