Skip to content

Commit 735abce

Browse files
echistyakovmeta-codesync[bot]
authored andcommitted
Unexport WithHeader
Summary: TSIA Reviewed By: podtserkovskiy Differential Revision: D92340530 fbshipit-source-id: 1bceb3d555080a9472d0532ff843e810862b0693
1 parent 003043b commit 735abce

4 files changed

Lines changed: 7 additions & 7 deletions

File tree

thrift/lib/go/thrift/client.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -49,9 +49,9 @@ func WithProtocolID(id types.ProtocolID) ClientOption {
4949
}
5050
}
5151

52-
// WithHeader sets the transport to Header, protocol Header is implied here.
52+
// withHeader sets the transport to Header, protocol Header is implied here.
5353
// Deprecated: use WithUpgradeToRocket() instead.
54-
func WithHeader() ClientOption {
54+
func withHeader() ClientOption {
5555
return func(opts *clientConfig) {
5656
opts.transport = TransportIDHeader
5757
}

thrift/lib/go/thrift/client_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ func TestCustomClientOptions(t *testing.T) {
4949
require.Equal(t, types.ProtocolIDBinary, config.protocol)
5050
})
5151
t.Run("WithHeader", func(t *testing.T) {
52-
config := newClientConfig(WithHeader())
52+
config := newClientConfig(withHeader())
5353
require.Equal(t, TransportIDHeader, config.transport)
5454
})
5555
t.Run("WithUpgradeToRocket", func(t *testing.T) {
@@ -195,7 +195,7 @@ func TestNewClientCreation(t *testing.T) {
195195

196196
t.Run("Header", func(t *testing.T) {
197197
channel, err := NewClient(
198-
WithHeader(),
198+
withHeader(),
199199
WithDialer(func() (net.Conn, error) {
200200
return net.DialTimeout(addr.Network(), addr.String(), 5*time.Second)
201201
}),

thrift/lib/go/thrift/server_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -276,7 +276,7 @@ func TestALPN(t *testing.T) {
276276
require.NoError(t, err)
277277

278278
// Header
279-
client3, err := createAlpnClient(WithHeader(), tlsDialerOption)
279+
client3, err := createAlpnClient(withHeader(), tlsDialerOption)
280280
require.NoError(t, err)
281281
err = client3.Ping(context.TODO())
282282
require.NoError(t, err)
@@ -923,7 +923,7 @@ func TestRocketServerFallbackToHeader(t *testing.T) {
923923

924924
// Create header client to trigger header transport processing
925925
headerChannel, err := NewClient(
926-
WithHeader(),
926+
withHeader(),
927927
WithTLS(addr.String(), 5*time.Second, clientConfig),
928928
WithIoTimeout(5*time.Second),
929929
)

thrift/lib/go/thrift/utils_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -191,7 +191,7 @@ func generateSelfSignedCerts() (clientConfig *tls.Config, serverConfig *tls.Conf
191191
func getClientTransportOption(serverTransport TransportID) ClientOption {
192192
switch serverTransport {
193193
case TransportIDHeader:
194-
return WithHeader()
194+
return withHeader()
195195
case TransportIDUpgradeToRocket:
196196
return WithUpgradeToRocket()
197197
case TransportIDRocket:

0 commit comments

Comments
 (0)