tcpdump
COPY --from=ubuntu /opt/E2Manager/router.txt /opt/E2Manager/router.txt
-COPY --from=ubuntu /opt/E2Manager/kube_config.yml /opt/E2Manager/kube_config.yml
COPY --from=ubuntu /opt/E2Manager/main /opt/E2Manager/main
COPY --from=ubuntu /opt/E2Manager/resources/configuration.yaml /opt/E2Manager/resources/configuration.yaml
COPY --from=ubuntu /opt/E2Manager/resources/rmr.verbose /tmp/rmr.verbose
RoutingManager struct {
BaseUrl string
}
- Kubernetes struct {
+/* Kubernetes struct {
ConfigPath string
KubeNamespace string
- }
+ }*/
NotificationResponseBuffer int
BigRedButtonTimeoutSec int
MaxRnibConnectionAttempts int
config.populateHttpConfig(viper.Sub("http"))
config.populateLoggingConfig(viper.Sub("logging"))
config.populateRoutingManagerConfig(viper.Sub("routingManager"))
- config.populateKubernetesConfig(viper.Sub("kubernetes"))
+ //config.populateKubernetesConfig(viper.Sub("kubernetes"))
config.NotificationResponseBuffer = viper.GetInt("notificationResponseBuffer")
config.BigRedButtonTimeoutSec = viper.GetInt("bigRedButtonTimeoutSec")
config.MaxRnibConnectionAttempts = viper.GetInt("maxRnibConnectionAttempts")
c.RoutingManager.BaseUrl = rmConfig.GetString("baseUrl")
}
-func (c *Configuration) populateKubernetesConfig(rmConfig *viper.Viper) {
+/*func (c *Configuration) populateKubernetesConfig(rmConfig *viper.Viper) {
if rmConfig == nil {
panic(fmt.Sprintf("#configuration.populateKubernetesConfig - failed to populate Kubernetes configuration: The entry 'kubernetes' not found\n"))
}
c.Kubernetes.ConfigPath = rmConfig.GetString("configPath")
c.Kubernetes.KubeNamespace = rmConfig.GetString("kubeNamespace")
-}
+}*/
func (c *Configuration) populateGlobalRicIdConfig(globalRicIdConfig *viper.Viper) {
if globalRicIdConfig == nil {
return fmt.Sprintf("{logging.logLevel: %s, http.port: %d, rmr: { port: %d, maxMsgSize: %d}, routingManager.baseUrl: %s, "+
"notificationResponseBuffer: %d, bigRedButtonTimeoutSec: %d, maxRnibConnectionAttempts: %d, "+
"rnibRetryIntervalMs: %d, keepAliveResponseTimeoutMs: %d, keepAliveDelayMs: %d, e2tInstanceDeletionTimeoutMs: %d, "+
- "globalRicId: { plmnId: %s, ricNearRtId: %s, kubernetes: {configPath: %s, kubeNamespace: %s}}",
+ "globalRicId: { plmnId: %s, ricNearRtId: %s}",//, kubernetes: {configPath: %s, kubeNamespace: %s}}",
c.Logging.LogLevel,
c.Http.Port,
c.Rmr.Port,
c.E2TInstanceDeletionTimeoutMs,
c.GlobalRicId.PlmnId,
c.GlobalRicId.RicNearRtId,
- c.Kubernetes.ConfigPath,
- c.Kubernetes.KubeNamespace,
+/* c.Kubernetes.ConfigPath,
+ c.Kubernetes.KubeNamespace,*/
)
}
assert.NotNil(t, config.GlobalRicId)
assert.NotEmpty(t, config.GlobalRicId.PlmnId)
assert.NotEmpty(t, config.GlobalRicId.RicNearRtId)
- assert.NotEmpty(t, config.Kubernetes.KubeNamespace)
- assert.NotEmpty(t, config.Kubernetes.ConfigPath)
+/* assert.NotEmpty(t, config.Kubernetes.KubeNamespace)
+ assert.NotEmpty(t, config.Kubernetes.ConfigPath)*/
}
func TestStringer(t *testing.T) {
"logging": map[string]interface{}{"logLevel": "info"},
"http": map[string]interface{}{"port": 3800},
"routingManager": map[string]interface{}{"baseUrl": "http://iltlv740.intl.att.com:8080/ric/v1/handles/"},
- "kubernetes": map[string]interface{}{"kubeNamespace": "test", "ConfigPath": "test"},
+ //"kubernetes": map[string]interface{}{"kubeNamespace": "test", "ConfigPath": "test"},
}
buf, err := yaml.Marshal(yamlMap)
if err != nil {
func() { ParseConfiguration() })
}
-func TestKubernetesConfigNotFoundFailure(t *testing.T) {
+/*func TestKubernetesConfigNotFoundFailure(t *testing.T) {
configPath := "../resources/configuration.yaml"
configPathTmp := "../resources/configuration.yaml_tmp"
err := os.Rename(configPath, configPathTmp)
}
assert.PanicsWithValue(t, "#configuration.populateKubernetesConfig - failed to populate Kubernetes configuration: The entry 'kubernetes' not found\n",
func() { ParseConfiguration() })
-}
+}*/
# The Jenkins job requires a tag to build the Docker image.
# Global-JJB script assumes this file is in the repo root.
---
-tag: 4.4.7
+tag: 4.4.8
google.golang.org/appengine v1.6.1 // indirect
gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15 // indirect
gopkg.in/yaml.v2 v2.2.8
+ k8s.io/apimachinery v0.17.0
k8s.io/client-go v0.17.0
)
return nil
}
- go m.kubernetesManager.DeletePod(e2tInstance.PodName)
+ //go m.kubernetesManager.DeletePod(e2tInstance.PodName)
err := m.markE2tInstanceToBeDeleted(e2tInstance)
if err != nil {
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/mock"
"io/ioutil"
- "k8s.io/apimachinery/pkg/runtime"
- "k8s.io/client-go/kubernetes/fake"
+ //"k8s.io/apimachinery/pkg/runtime"
+ //"k8s.io/client-go/kubernetes/fake"
"net/http"
"testing"
"time"
httpClientMock := &mocks.HttpClientMock{}
rmClient := clients.NewRoutingManagerClient(log, config, httpClientMock)
associationManager := NewE2TAssociationManager(log, rnibDataService, e2tInstancesManager, rmClient)
- kubernetesManager := initKubernetesManagerTest(t)
+ //kubernetesManager := initKubernetesManagerTest(t)
- shutdownManager := NewE2TShutdownManager(log, config, rnibDataService, e2tInstancesManager, associationManager, kubernetesManager)
+ /*shutdownManager := NewE2TShutdownManager(log, config, rnibDataService, e2tInstancesManager, associationManager, kubernetesManager)
- return shutdownManager, readerMock, writerMock, httpClientMock, kubernetesManager
+ return shutdownManager, readerMock, writerMock, httpClientMock, kubernetesManager*/
+ shutdownManager := NewE2TShutdownManager(log, config, rnibDataService, e2tInstancesManager, associationManager, nil)
+
+ return shutdownManager, readerMock, writerMock, httpClientMock, nil
}
func TestShutdownSuccess1OutOf3Instances(t *testing.T) {
writerMock.AssertExpectations(t)
httpClientMock.AssertExpectations(t)
}
-
+/*
func TestShutdownSuccess2Instance2Rans(t *testing.T) {
shutdownManager, readerMock, writerMock, httpClientMock,kubernetesManager := initE2TShutdownManagerTest(t)
writerMock.AssertExpectations(t)
httpClientMock.AssertExpectations(t)
})
-}
\ No newline at end of file
+}*/
\ No newline at end of file
import (
"e2mgr/configuration"
- "e2mgr/e2managererrors"
"e2mgr/logger"
- metaV1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/client-go/kubernetes"
- "k8s.io/client-go/tools/clientcmd"
- "path/filepath"
)
type KubernetesManager struct {
func NewKubernetesManager(logger *logger.Logger, config *configuration.Configuration) *KubernetesManager {
return &KubernetesManager{
Logger: logger,
- ClientSet: createClientSet(logger, config),
+ //ClientSet: createClientSet(logger, config),
Config: config,
}
}
-func createClientSet(logger *logger.Logger, config *configuration.Configuration) kubernetes.Interface {
+/*func createClientSet(logger *logger.Logger, config *configuration.Configuration) kubernetes.Interface {
absConfigPath,err := filepath.Abs(config.Kubernetes.ConfigPath)
if err != nil {
return nil
}
return clientSet
-}
+}*/
-func (km KubernetesManager) DeletePod(podName string) error {
+/*func (km KubernetesManager) DeletePod(podName string) error {
km.Logger.Infof("#KubernetesManager.DeletePod - POD name: %s ", podName)
if km.ClientSet == nil {
km.Logger.Infof("#KubernetesManager.DeletePod - POD %s was deleted", podName)
return nil
-}
\ No newline at end of file
+}*/
\ No newline at end of file
// platform project (RICP).
package managers
-
+/*
import (
"e2mgr/configuration"
Annotations: map[string]string{},
},
}
-}
\ No newline at end of file
+}
+*/
\ No newline at end of file
e2tInstanceDeletionTimeoutMs: 15000
globalRicId:
plmnId: 131014
- ricNearRtId: 556670
-kubernetes:
- configPath: ./kube_config.yml
- kubeNamespace: ricplt
\ No newline at end of file
+ ricNearRtId: 556670
\ No newline at end of file