Skip to content

Commit 2d5be06

Browse files
committed
feat(grpc): add grpc.WithNoProxy()
Longhorn 12304 Signed-off-by: Derek Su <derek.su@suse.com>
1 parent ed36950 commit 2d5be06

File tree

1 file changed

+55
-11
lines changed

1 file changed

+55
-11
lines changed

pkg/client/manager_client.go

Lines changed: 55 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,11 @@ func (cli *BackingImageManagerClient) Sync(name, uuid, checksum, fromAddress str
3232
return nil, fmt.Errorf("failed to sync backing image: missing required parameter")
3333
}
3434

35-
conn, err := grpc.NewClient(cli.Address, grpc.WithTransportCredentials(insecure.NewCredentials()))
35+
conn, err := grpc.NewClient(
36+
cli.Address,
37+
grpc.WithTransportCredentials(insecure.NewCredentials()),
38+
grpc.WithNoProxy(),
39+
)
3640
if err != nil {
3741
return nil, fmt.Errorf("cannot connect backing image manager service to %v: %v", cli.Address, err)
3842
}
@@ -66,7 +70,11 @@ func (cli *BackingImageManagerClient) Send(name, uuid, toAddress string) error {
6670
return fmt.Errorf("failed to send backing image: missing required parameter")
6771
}
6872

69-
conn, err := grpc.NewClient(cli.Address, grpc.WithTransportCredentials(insecure.NewCredentials()))
73+
conn, err := grpc.NewClient(
74+
cli.Address,
75+
grpc.WithTransportCredentials(insecure.NewCredentials()),
76+
grpc.WithNoProxy(),
77+
)
7078
if err != nil {
7179
return fmt.Errorf("cannot connect backing image manager service to %v: %v", cli.Address, err)
7280
}
@@ -93,7 +101,11 @@ func (cli *BackingImageManagerClient) Delete(name, uuid string) error {
93101
return fmt.Errorf("failed to delete backing image: missing required parameter")
94102
}
95103

96-
conn, err := grpc.NewClient(cli.Address, grpc.WithTransportCredentials(insecure.NewCredentials()))
104+
conn, err := grpc.NewClient(
105+
cli.Address,
106+
grpc.WithTransportCredentials(insecure.NewCredentials()),
107+
grpc.WithNoProxy(),
108+
)
97109
if err != nil {
98110
return fmt.Errorf("cannot connect backing image manager service to %v: %v", cli.Address, err)
99111
}
@@ -119,7 +131,11 @@ func (cli *BackingImageManagerClient) Get(name, uuid string) (*api.BackingImage,
119131
return nil, fmt.Errorf("failed to get backing image: missing required parameter")
120132
}
121133

122-
conn, err := grpc.NewClient(cli.Address, grpc.WithTransportCredentials(insecure.NewCredentials()))
134+
conn, err := grpc.NewClient(
135+
cli.Address,
136+
grpc.WithTransportCredentials(insecure.NewCredentials()),
137+
grpc.WithNoProxy(),
138+
)
123139
if err != nil {
124140
return nil, fmt.Errorf("cannot connect backing image manager service to %v: %v", cli.Address, err)
125141
}
@@ -144,7 +160,11 @@ func (cli *BackingImageManagerClient) Get(name, uuid string) (*api.BackingImage,
144160
}
145161

146162
func (cli *BackingImageManagerClient) List() (map[string]*api.BackingImage, error) {
147-
conn, err := grpc.NewClient(cli.Address, grpc.WithTransportCredentials(insecure.NewCredentials()))
163+
conn, err := grpc.NewClient(
164+
cli.Address,
165+
grpc.WithTransportCredentials(insecure.NewCredentials()),
166+
grpc.WithNoProxy(),
167+
)
148168
if err != nil {
149169
return nil, fmt.Errorf("cannot connect backing image manager service to %v: %v", cli.Address, err)
150170
}
@@ -170,7 +190,11 @@ func (cli *BackingImageManagerClient) Fetch(name, uuid, checksum, dataSourceAddr
170190
return nil, fmt.Errorf("failed to fetch backing image: missing required parameter")
171191
}
172192

173-
conn, err := grpc.NewClient(cli.Address, grpc.WithTransportCredentials(insecure.NewCredentials()))
193+
conn, err := grpc.NewClient(
194+
cli.Address,
195+
grpc.WithTransportCredentials(insecure.NewCredentials()),
196+
grpc.WithNoProxy(),
197+
)
174198
if err != nil {
175199
return nil, fmt.Errorf("cannot connect backing image manager service to %v: %v", cli.Address, err)
176200
}
@@ -204,7 +228,11 @@ func (cli *BackingImageManagerClient) PrepareDownload(name, uuid string) (string
204228
return "", "", fmt.Errorf("failed to get backing image: missing required parameter")
205229
}
206230

207-
conn, err := grpc.NewClient(cli.Address, grpc.WithTransportCredentials(insecure.NewCredentials()))
231+
conn, err := grpc.NewClient(
232+
cli.Address,
233+
grpc.WithTransportCredentials(insecure.NewCredentials()),
234+
grpc.WithNoProxy(),
235+
)
208236
if err != nil {
209237
return "", "", fmt.Errorf("cannot connect backing image manager service to %v: %v", cli.Address, err)
210238
}
@@ -229,7 +257,11 @@ func (cli *BackingImageManagerClient) PrepareDownload(name, uuid string) (string
229257
}
230258

231259
func (cli *BackingImageManagerClient) VersionGet() (*meta.VersionOutput, error) {
232-
conn, err := grpc.NewClient(cli.Address, grpc.WithTransportCredentials(insecure.NewCredentials()))
260+
conn, err := grpc.NewClient(
261+
cli.Address,
262+
grpc.WithTransportCredentials(insecure.NewCredentials()),
263+
grpc.WithNoProxy(),
264+
)
233265
if err != nil {
234266
return nil, fmt.Errorf("cannot connect backing image manager service to %v: %v", cli.Address, err)
235267
}
@@ -258,7 +290,11 @@ func (cli *BackingImageManagerClient) VersionGet() (*meta.VersionOutput, error)
258290
}
259291

260292
func (cli *BackingImageManagerClient) Watch() (*api.BackingImageStream, error) {
261-
conn, err := grpc.NewClient(cli.Address, grpc.WithTransportCredentials(insecure.NewCredentials()))
293+
conn, err := grpc.NewClient(
294+
cli.Address,
295+
grpc.WithTransportCredentials(insecure.NewCredentials()),
296+
grpc.WithNoProxy(),
297+
)
262298
if err != nil {
263299
return nil, fmt.Errorf("cannot connect backing image manager service to %v: %v", cli.Address, err)
264300
}
@@ -281,7 +317,11 @@ func (cli *BackingImageManagerClient) BackupCreate(name, uuid, checksum, backupT
281317
return fmt.Errorf("failed to create backup backing image: missing required parameter")
282318
}
283319

284-
conn, err := grpc.NewClient(cli.Address, grpc.WithTransportCredentials(insecure.NewCredentials()))
320+
conn, err := grpc.NewClient(
321+
cli.Address,
322+
grpc.WithTransportCredentials(insecure.NewCredentials()),
323+
grpc.WithNoProxy(),
324+
)
285325
if err != nil {
286326
return fmt.Errorf("failed to connect backing image manager service to %v: %v", cli.Address, err)
287327
}
@@ -319,7 +359,11 @@ func (cli *BackingImageManagerClient) BackupStatus(name string) (*api.BackupStat
319359
return nil, fmt.Errorf("failed to get backup backing image status: missing required parameter")
320360
}
321361

322-
conn, err := grpc.NewClient(cli.Address, grpc.WithTransportCredentials(insecure.NewCredentials()))
362+
conn, err := grpc.NewClient(
363+
cli.Address,
364+
grpc.WithTransportCredentials(insecure.NewCredentials()),
365+
grpc.WithNoProxy(),
366+
)
323367
if err != nil {
324368
return nil, fmt.Errorf("failed to connect backing image manager service to %v: %v", cli.Address, err)
325369
}

0 commit comments

Comments
 (0)