blob: 7398b9b2267b9dc1892e92269a978db1d5428f41 [file] [log] [blame]
// Copyright Istio Authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package containerregistry
import (
"fmt"
"io"
"net"
)
import (
"github.com/apache/dubbo-go-pixiu/pkg/test/env"
"github.com/apache/dubbo-go-pixiu/pkg/test/framework/components/cluster"
"github.com/apache/dubbo-go-pixiu/pkg/test/framework/components/namespace"
"github.com/apache/dubbo-go-pixiu/pkg/test/framework/resource"
testKube "github.com/apache/dubbo-go-pixiu/pkg/test/kube"
"github.com/apache/dubbo-go-pixiu/pkg/test/scopes"
)
const (
service = "container-registry"
ns = "container-registry"
)
var (
_ Instance = &kubeComponent{}
_ io.Closer = &kubeComponent{}
)
type kubeComponent struct {
id resource.ID
ns namespace.Instance
cluster cluster.Cluster
address string
}
func newKube(ctx resource.Context, cfg Config) (Instance, error) {
c := &kubeComponent{
cluster: ctx.Clusters().GetOrDefault(cfg.Cluster),
}
c.id = ctx.TrackResource(c)
var err error
scopes.Framework.Info("=== BEGIN: Deploy container registry server ===")
defer func() {
if err != nil {
err = fmt.Errorf("container registry deployment failed: %v", err)
scopes.Framework.Infof("=== FAILED: Deploy container registry server ===")
_ = c.Close()
} else {
scopes.Framework.Info("=== SUCCEEDED: Deploy container registry server ===")
}
}()
c.ns, err = namespace.New(ctx, namespace.Config{
Prefix: ns,
})
if err != nil {
return nil, fmt.Errorf("could not create %q namespace for container registry server install; err: %v", ns, err)
}
// apply YAML
if err := c.cluster.ApplyYAMLFiles(c.ns.Name(), env.ContainerRegistryServerInstallFilePath); err != nil {
return nil, fmt.Errorf("failed to apply rendered %s, err: %v", env.ContainerRegistryServerInstallFilePath, err)
}
if _, _, err = testKube.WaitUntilServiceEndpointsAreReady(c.cluster, c.ns.Name(), service); err != nil {
scopes.Framework.Infof("Error waiting for container registry service to be available: %v", err)
return nil, err
}
c.address = net.JoinHostPort(fmt.Sprintf("%s.%s", service, c.ns.Name()), "1338")
scopes.Framework.Infof("container registry server in-cluster address: %s", c.address)
return c, nil
}
func (c *kubeComponent) ID() resource.ID {
return c.id
}
// Close implements io.Closer.
func (c *kubeComponent) Close() error {
return nil
}
func (c *kubeComponent) Address() string {
return c.address
}