Skip to content

Commit 2ae20ce

Browse files
AbdelrahmanElawadyAbdelrahmanElawady
authored
Add volume workload (#1026)
* Add volume workload * Fix filter
1 parent 0c91f12 commit 2ae20ce

25 files changed

+304
-34
lines changed

‎go.work.sum

Lines changed: 39 additions & 0 deletions
Large diffs are not rendered by default.

‎grid-cli/internal/cmd/deploy.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ func DeployVM(ctx context.Context, t deployer.TFPluginClient, vm workloads.VM, m
2828
mounts = append(mounts, mount)
2929
}
3030
vm.NetworkName = networkName
31-
dl := workloads.NewDeployment(vm.Name, node, projectName, nil, networkName, mounts, nil, []workloads.VM{vm}, nil)
31+
dl := workloads.NewDeployment(vm.Name, node, projectName, nil, networkName, mounts, nil, []workloads.VM{vm}, nil, nil)
3232

3333
log.Info().Msg("deploying network")
3434
err = t.NetworkDeployer.Deploy(ctx, &network)
@@ -128,7 +128,7 @@ func DeployGatewayFQDN(ctx context.Context, t deployer.TFPluginClient, gateway w
128128

129129
// DeployZDBs deploys multiple zdbs
130130
func DeployZDBs(ctx context.Context, t deployer.TFPluginClient, projectName string, zdbs []workloads.ZDB, n int, node uint32) ([]workloads.ZDB, error) {
131-
dl := workloads.NewDeployment(projectName, node, projectName, nil, "", nil, zdbs, nil, nil)
131+
dl := workloads.NewDeployment(projectName, node, projectName, nil, "", nil, zdbs, nil, nil, nil)
132132
log.Info().Msgf("deploying zdbs")
133133
err := t.DeploymentDeployer.Deploy(ctx, &dl)
134134
if err != nil {

‎grid-client/deployer/deployment_deployer.go

Lines changed: 14 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,9 @@ func (d *DeploymentDeployer) GenerateVersionlessDeployments(ctx context.Context,
7878
for _, disk := range dl.Disks {
7979
newDl.Workloads = append(newDl.Workloads, disk.ZosWorkload())
8080
}
81+
for _, volume := range dl.Volumes {
82+
newDl.Workloads = append(newDl.Workloads, volume.ZosWorkload())
83+
}
8184
for _, zdb := range dl.Zdbs {
8285
newDl.Workloads = append(newDl.Workloads, zdb.ZosWorkload())
8386
}
@@ -418,6 +421,7 @@ func (d *DeploymentDeployer) Sync(ctx context.Context, dl *workloads.Deployment)
418421
zdbs := make([]workloads.ZDB, 0)
419422
qsfs := make([]workloads.QSFS, 0)
420423
disks := make([]workloads.Disk, 0)
424+
volumes := make([]workloads.Volume, 0)
421425

422426
for _, w := range deployment.Workloads {
423427
if !w.Result.State.IsOkay() {
@@ -458,15 +462,24 @@ func (d *DeploymentDeployer) Sync(ctx context.Context, dl *workloads.Deployment)
458462
}
459463

460464
disks = append(disks, disk)
465+
case zos.VolumeType:
466+
volume, err := workloads.NewVolumeFromWorkload(&w)
467+
if err != nil {
468+
log.Error().Err(err).Msgf("error parsing volume")
469+
continue
470+
}
471+
472+
volumes = append(volumes, volume)
461473
}
462474
}
463475

464-
dl.Match(disks, qsfs, zdbs, vms)
476+
dl.Match(disks, qsfs, zdbs, vms, volumes)
465477

466478
dl.Disks = disks
467479
dl.QSFS = qsfs
468480
dl.Zdbs = zdbs
469481
dl.Vms = vms
482+
dl.Volumes = volumes
470483

471484
return nil
472485
}

‎grid-client/deployer/deployment_deployer_test.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -720,7 +720,7 @@ func ExampleDeploymentDeployer_Deploy() {
720720
return
721721
}
722722

723-
dl := workloads.NewDeployment("vmdeployment", nodeID, "", nil, n.Name, nil, nil, []workloads.VM{vm}, nil)
723+
dl := workloads.NewDeployment("vmdeployment", nodeID, "", nil, n.Name, nil, nil, []workloads.VM{vm}, nil, nil)
724724
err = tfPluginClient.DeploymentDeployer.Deploy(context.Background(), &dl)
725725
if err != nil {
726726
fmt.Println(err)
@@ -779,8 +779,8 @@ func ExampleDeploymentDeployer_BatchDeploy() {
779779
return
780780
}
781781

782-
d1 := workloads.NewDeployment("vm1deployment", nodeID, "", nil, n.Name, nil, nil, []workloads.VM{vm1}, nil)
783-
d2 := workloads.NewDeployment("vm2deployment", nodeID, "", nil, n.Name, nil, nil, []workloads.VM{vm2}, nil)
782+
d1 := workloads.NewDeployment("vm1deployment", nodeID, "", nil, n.Name, nil, nil, []workloads.VM{vm1}, nil, nil)
783+
d2 := workloads.NewDeployment("vm2deployment", nodeID, "", nil, n.Name, nil, nil, []workloads.VM{vm2}, nil, nil)
784784
err = tfPluginClient.DeploymentDeployer.BatchDeploy(context.Background(), []*workloads.Deployment{&d1, &d2})
785785
if err != nil {
786786
fmt.Println(err)

‎grid-client/integration_tests/batch_gateway_name_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ func TestBatchGatewayNameDeployment(t *testing.T) {
6666
require.NoError(t, err)
6767
})
6868

69-
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID1, "", nil, network.Name, nil, nil, []workloads.VM{vm}, nil)
69+
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID1, "", nil, network.Name, nil, nil, []workloads.VM{vm}, nil, nil)
7070
err = tfPluginClient.DeploymentDeployer.Deploy(context.Background(), &dl)
7171
require.NoError(t, err)
7272

‎grid-client/integration_tests/batch_vm_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -76,8 +76,8 @@ func TestBatchVMDeployment(t *testing.T) {
7676
require.NoError(t, err)
7777
})
7878

79-
dl1 := workloads.NewDeployment(fmt.Sprintf("dl1_%s", generateRandString(10)), nodeID1, "", nil, network1.Name, nil, nil, []workloads.VM{vm1}, nil)
80-
dl2 := workloads.NewDeployment(fmt.Sprintf("dl2_%s", generateRandString(10)), nodeID2, "", nil, network2.Name, nil, nil, []workloads.VM{vm2}, nil)
79+
dl1 := workloads.NewDeployment(fmt.Sprintf("dl1_%s", generateRandString(10)), nodeID1, "", nil, network1.Name, nil, nil, []workloads.VM{vm1}, nil, nil)
80+
dl2 := workloads.NewDeployment(fmt.Sprintf("dl2_%s", generateRandString(10)), nodeID2, "", nil, network2.Name, nil, nil, []workloads.VM{vm2}, nil, nil)
8181
err = tfPluginClient.DeploymentDeployer.BatchDeploy(context.Background(), []*workloads.Deployment{&dl1, &dl2})
8282
require.NoError(t, err)
8383

‎grid-client/integration_tests/disk_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ func TestDiskDeployment(t *testing.T) {
3838
Description: "disk test",
3939
}
4040

41-
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, "", []workloads.Disk{disk}, nil, nil, nil)
41+
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, "", []workloads.Disk{disk}, nil, nil, nil, nil)
4242
err = tfPluginClient.DeploymentDeployer.Deploy(context.Background(), &dl)
4343
require.NoError(t, err)
4444

‎grid-client/integration_tests/gateway_name_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ func TestGatewayNameDeployment(t *testing.T) {
7979
require.NoError(t, err)
8080
})
8181

82-
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, nil, nil, []workloads.VM{vm}, nil)
82+
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, nil, nil, []workloads.VM{vm}, nil, nil)
8383
err = tfPluginClient.DeploymentDeployer.Deploy(context.Background(), &dl)
8484
require.NoError(t, err)
8585

‎grid-client/integration_tests/gatway_fqdn_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ func TestGatewayFQDNDeployment(t *testing.T) {
7070
require.NoError(t, err)
7171
})
7272

73-
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, nil, nil, []workloads.VM{vm}, nil)
73+
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, nil, nil, []workloads.VM{vm}, nil, nil)
7474
err = tfPluginClient.DeploymentDeployer.Deploy(context.Background(), &dl)
7575
require.NoError(t, err)
7676

‎grid-client/integration_tests/qsfs_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ func TestQSFSDeployment(t *testing.T) {
8282
metaZDBs = append(metaZDBs, zdb)
8383
}
8484

85-
dl1 := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, "", nil, append(dataZDBs, metaZDBs...), nil, nil)
85+
dl1 := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, "", nil, append(dataZDBs, metaZDBs...), nil, nil, nil)
8686
err = tfPluginClient.DeploymentDeployer.Deploy(context.Background(), &dl1)
8787
require.NoError(t, err)
8888

@@ -173,7 +173,7 @@ func TestQSFSDeployment(t *testing.T) {
173173
require.NoError(t, err)
174174
})
175175

176-
dl2 := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, nil, append(dataZDBs, metaZDBs...), []workloads.VM{vm}, []workloads.QSFS{qsfs})
176+
dl2 := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, nil, append(dataZDBs, metaZDBs...), []workloads.VM{vm}, []workloads.QSFS{qsfs}, nil)
177177
err = tfPluginClient.DeploymentDeployer.Deploy(context.Background(), &dl2)
178178
require.NoError(t, err)
179179

‎grid-client/integration_tests/two_vms_same_network_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ func TestTwoVMsSameNetworkWithPublicIPV6(t *testing.T) {
7676
require.NoError(t, err)
7777
})
7878

79-
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, nil, nil, []workloads.VM{vm1, vm2}, nil)
79+
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, nil, nil, []workloads.VM{vm1, vm2}, nil, nil)
8080
err = tfPluginClient.DeploymentDeployer.Deploy(context.Background(), &dl)
8181
require.NoError(t, err)
8282

‎grid-client/integration_tests/vm_disk_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ func TestVMWithTwoDisk(t *testing.T) {
7373
require.NoError(t, err)
7474
})
7575

76-
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, []workloads.Disk{disk1, disk2}, nil, []workloads.VM{vm}, nil)
76+
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, []workloads.Disk{disk1, disk2}, nil, []workloads.VM{vm}, nil, nil)
7777
err = tfPluginClient.DeploymentDeployer.Deploy(context.Background(), &dl)
7878
require.NoError(t, err)
7979

‎grid-client/integration_tests/vm_gpu_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ func TestVMWithGPUDeployment(t *testing.T) {
8585
require.NoError(t, err)
8686
})
8787

88-
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, []workloads.Disk{disk}, nil, []workloads.VM{vm}, nil)
88+
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, []workloads.Disk{disk}, nil, []workloads.VM{vm}, nil, nil)
8989
err = tfPluginClient.DeploymentDeployer.Deploy(context.Background(), &dl)
9090
require.NoError(t, err)
9191

‎grid-client/integration_tests/vm_public_ip_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ func TestVMDeployment(t *testing.T) {
6262
require.NoError(t, err)
6363
})
6464

65-
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, nil, nil, []workloads.VM{vm}, nil)
65+
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, nil, nil, []workloads.VM{vm}, nil, nil)
6666
err = tfPluginClient.DeploymentDeployer.Deploy(context.Background(), &dl)
6767
require.NoError(t, err)
6868

‎grid-client/integration_tests/vm_volume_test.go

Lines changed: 89 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,89 @@
1+
package integration
2+
3+
import (
4+
"context"
5+
"fmt"
6+
"strings"
7+
"testing"
8+
9+
"github.com/stretchr/testify/require"
10+
"github.com/threefoldtech/tfgrid-sdk-go/grid-client/deployer"
11+
"github.com/threefoldtech/tfgrid-sdk-go/grid-client/workloads"
12+
)
13+
14+
func TestVMWithVolume(t *testing.T) {
15+
tfPluginClient, err := setup()
16+
if err != nil {
17+
t.Skipf("plugin creation failed: %v", err)
18+
}
19+
20+
publicKey, privateKey, err := GenerateSSHKeyPair()
21+
require.NoError(t, err)
22+
23+
nodes, err := deployer.FilterNodes(
24+
context.Background(),
25+
tfPluginClient,
26+
generateNodeFilter(WithFreeSRU(3)),
27+
[]uint64{*convertGBToBytes(1)},
28+
nil,
29+
[]uint64{*convertGBToBytes(minRootfs)},
30+
1,
31+
)
32+
if err != nil {
33+
t.Skipf("no available nodes found: %v", err)
34+
}
35+
36+
nodeID := uint32(nodes[0].NodeID)
37+
38+
network := generateBasicNetwork([]uint32{nodeID})
39+
40+
volume := workloads.Volume{
41+
Name: "volume",
42+
SizeGB: 1,
43+
}
44+
45+
vm := workloads.VM{
46+
Name: "vm",
47+
NetworkName: network.Name,
48+
CPU: minCPU,
49+
Memory: int(minMemory) * 1024,
50+
RootfsSize: int(minRootfs) * 1024,
51+
Planetary: true,
52+
Flist: "https://hub.grid.tf/tf-official-apps/base:latest.flist",
53+
Entrypoint: "/sbin/zinit init",
54+
EnvVars: map[string]string{
55+
"SSH_KEY": publicKey,
56+
},
57+
Mounts: []workloads.Mount{
58+
{DiskName: volume.Name, MountPoint: "/volume"},
59+
},
60+
}
61+
62+
err = tfPluginClient.NetworkDeployer.Deploy(context.Background(), &network)
63+
require.NoError(t, err)
64+
65+
t.Cleanup(func() {
66+
err = tfPluginClient.NetworkDeployer.Cancel(context.Background(), &network)
67+
require.NoError(t, err)
68+
})
69+
70+
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, nil, nil, []workloads.VM{vm}, nil, []workloads.Volume{volume})
71+
err = tfPluginClient.DeploymentDeployer.Deploy(context.Background(), &dl)
72+
require.NoError(t, err)
73+
74+
t.Cleanup(func() {
75+
err = tfPluginClient.DeploymentDeployer.Cancel(context.Background(), &dl)
76+
require.NoError(t, err)
77+
})
78+
79+
v, err := tfPluginClient.State.LoadVMFromGrid(context.Background(), nodeID, vm.Name, dl.Name)
80+
require.NoError(t, err)
81+
require.NotEmpty(t, v.PlanetaryIP)
82+
83+
resVolume, err := tfPluginClient.State.LoadVolumeFromGrid(context.Background(), nodeID, volume.Name, dl.Name)
84+
require.NoError(t, err)
85+
require.Equal(t, volume, resVolume)
86+
res, err := RemoteRun("root", v.PlanetaryIP, "mount", privateKey)
87+
require.NoError(t, err)
88+
strings.Contains(res, "volume on /volume type virtiofs")
89+
}

‎grid-client/integration_tests/vms_private_ips_test.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ func TestDeploymentsDeploy(t *testing.T) {
6262
}
6363
})
6464

65-
d1 := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, nil, nil, []workloads.VM{vm1}, nil)
65+
d1 := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, nil, nil, []workloads.VM{vm1}, nil, nil)
6666
err = tfPluginClient.DeploymentDeployer.Deploy(context.Background(), &d1)
6767
if err != nil {
6868
t.Fatal(err)
@@ -75,7 +75,7 @@ func TestDeploymentsDeploy(t *testing.T) {
7575
}
7676
})
7777

78-
d2 := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, nil, nil, []workloads.VM{vm1}, nil)
78+
d2 := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, nil, nil, []workloads.VM{vm1}, nil, nil)
7979
err = tfPluginClient.DeploymentDeployer.Deploy(context.Background(), &d2)
8080
if err != nil {
8181
t.Fatal(err)
@@ -181,15 +181,15 @@ func TestDeploymentsBatchDeploy(t *testing.T) {
181181
}
182182
})
183183

184-
d1 := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID1, "", nil, network.Name, nil, nil, []workloads.VM{vm1, vm1, vm1}, nil)
184+
d1 := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID1, "", nil, network.Name, nil, nil, []workloads.VM{vm1, vm1, vm1}, nil, nil)
185185
d1.Vms[1].Name = vm2Name
186186
d1.Vms[2].Name = vm3Name
187187

188-
d2 := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID1, "", nil, network.Name, nil, nil, []workloads.VM{vm1, vm1, vm1}, nil)
188+
d2 := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID1, "", nil, network.Name, nil, nil, []workloads.VM{vm1, vm1, vm1}, nil, nil)
189189
d2.Vms[1].Name = vm2Name
190190
d2.Vms[2].Name = vm3Name
191191

192-
d3 := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID2, "", nil, network.Name, nil, nil, []workloads.VM{vm1, vm1, vm1}, nil)
192+
d3 := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID2, "", nil, network.Name, nil, nil, []workloads.VM{vm1, vm1, vm1}, nil, nil)
193193
d3.Vms[1].Name = vm2Name
194194
d3.Vms[2].Name = vm3Name
195195

‎grid-client/integration_tests/wireguard_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ func TestWG(t *testing.T) {
6565
require.NoError(t, err)
6666
})
6767

68-
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, nil, nil, []workloads.VM{vm}, nil)
68+
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, network.Name, nil, nil, []workloads.VM{vm}, nil, nil)
6969
err = tfPluginClient.DeploymentDeployer.Deploy(context.Background(), &dl)
7070
require.NoError(t, err)
7171

‎grid-client/integration_tests/zdb_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ func TestZDBDeployment(t *testing.T) {
4949
Mode: zos.ZDBModeUser,
5050
}
5151

52-
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, "", nil, []workloads.ZDB{zdb}, nil, nil)
52+
dl := workloads.NewDeployment(fmt.Sprintf("dl_%s", generateRandString(10)), nodeID, "", nil, "", nil, []workloads.ZDB{zdb}, nil, nil, nil)
5353
err = tfPluginClient.DeploymentDeployer.Deploy(context.Background(), &dl)
5454
require.NoError(t, err)
5555

‎grid-client/state/state.go

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -69,6 +69,16 @@ func (st *State) LoadDiskFromGrid(ctx context.Context, nodeID uint32, name strin
6969
return workloads.NewDiskFromWorkload(&wl)
7070
}
7171

72+
// LoadVolumeFromGrid loads a volume from grid
73+
func (st *State) LoadVolumeFromGrid(ctx context.Context, nodeID uint32, name string, deploymentName string) (workloads.Volume, error) {
74+
wl, dl, err := st.GetWorkloadInDeployment(ctx, nodeID, name, deploymentName)
75+
if err != nil {
76+
return workloads.Volume{}, errors.Wrapf(err, "could not get workload from node %d within deployment %v", nodeID, dl)
77+
}
78+
79+
return workloads.NewVolumeFromWorkload(&wl)
80+
}
81+
7282
// LoadGatewayFQDNFromGrid loads a gateway FQDN proxy from grid
7383
func (st *State) LoadGatewayFQDNFromGrid(ctx context.Context, nodeID uint32, name string, deploymentName string) (workloads.GatewayFQDNProxy, error) {
7484
wl, dl, err := st.GetWorkloadInDeployment(ctx, nodeID, name, deploymentName)

0 commit comments

Comments
 (0)