7
7
8
8
"github.com/replicatedhq/kots/pkg/embeddedcluster"
9
9
"github.com/replicatedhq/kots/pkg/k8sutil"
10
+ "github.com/replicatedhq/kots/pkg/kotsutil"
10
11
"github.com/replicatedhq/kots/pkg/logger"
11
12
"github.com/replicatedhq/kots/pkg/store"
12
13
"github.com/replicatedhq/kots/pkg/util"
@@ -24,6 +25,8 @@ type GetEmbeddedClusterNodeJoinCommandResponse struct {
24
25
EndUserK0sConfigOverrides string `json:"endUserK0sConfigOverrides"`
25
26
MetricsBaseURL string `json:"metricsBaseURL"`
26
27
EmbeddedClusterVersion string `json:"embeddedClusterVersion"`
28
+ AirgapRegistryAddress string `json:"airgapRegistryAddress"`
29
+ IsAirgap bool `json:"isAirgap"`
27
30
}
28
31
29
32
type GenerateEmbeddedClusterNodeJoinCommandRequest struct {
@@ -163,6 +166,11 @@ func (h *Handler) GetEmbeddedClusterNodeJoinCommand(w http.ResponseWriter, r *ht
163
166
ecVersion = install .Spec .Config .Version
164
167
}
165
168
169
+ airgapRegistryAddress := ""
170
+ if install .Spec .AirGap {
171
+ airgapRegistryAddress , _ , _ = kotsutil .GetEmbeddedRegistryCreds (client )
172
+ }
173
+
166
174
JSON (w , http .StatusOK , GetEmbeddedClusterNodeJoinCommandResponse {
167
175
ClusterID : clusterID ,
168
176
K0sJoinCommand : k0sJoinCommand ,
@@ -171,5 +179,7 @@ func (h *Handler) GetEmbeddedClusterNodeJoinCommand(w http.ResponseWriter, r *ht
171
179
EndUserK0sConfigOverrides : endUserK0sConfigOverrides ,
172
180
MetricsBaseURL : install .Spec .MetricsBaseURL ,
173
181
EmbeddedClusterVersion : ecVersion ,
182
+ AirgapRegistryAddress : airgapRegistryAddress ,
183
+ IsAirgap : install .Spec .AirGap ,
174
184
})
175
185
}
0 commit comments