summaryrefslogtreecommitdiffstats
path: root/src/ncm/pkg/module/providernet.go
diff options
context:
space:
mode:
authorEric Multanen <eric.w.multanen@intel.com>2020-05-28 17:25:30 -0700
committerEric Multanen <eric.w.multanen@intel.com>2020-06-02 14:00:07 -0700
commita6e2a3a65a6e4f3f1d964578ae4e60c6f9dd1184 (patch)
treeab7fa1157f9b98840b0482592c886da61e62cc6d /src/ncm/pkg/module/providernet.go
parentad7782cbf83c11f152a6457f3808a4da99a1ae56 (diff)
Reorganize ncm packages to align with architecture
Reorginize the ncm packges to delineate - cluster provider and cluster management - virtual and provider netowrk intent management - intent scheduler - internal ovn4k8s network controller Overall, no code changes, just moving things around. Issue-ID: MULTICLOUD-1029 Signed-off-by: Eric Multanen <eric.w.multanen@intel.com> Change-Id: I3d43c7e4eb6f285b51c0385ba18626d3511a14f5
Diffstat (limited to 'src/ncm/pkg/module/providernet.go')
-rw-r--r--src/ncm/pkg/module/providernet.go182
1 files changed, 0 insertions, 182 deletions
diff --git a/src/ncm/pkg/module/providernet.go b/src/ncm/pkg/module/providernet.go
deleted file mode 100644
index a1cbe940..00000000
--- a/src/ncm/pkg/module/providernet.go
+++ /dev/null
@@ -1,182 +0,0 @@
-/*
- * Copyright 2020 Intel Corporation, Inc
- *
- * 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 module
-
-import (
- "github.com/onap/multicloud-k8s/src/orchestrator/pkg/infra/db"
-
- pkgerrors "github.com/pkg/errors"
-)
-
-// ProviderNet contains the parameters needed for dynamic networks
-type ProviderNet struct {
- Metadata Metadata `json:"metadata"`
- Spec ProviderNetSpec `json:"spec"`
-}
-
-type ProviderNetSpec struct {
- CniType string `json:"cniType" yaml:"cniType"`
- Ipv4Subnets []Ipv4Subnet `json:"ipv4Subnets" yaml:"ipv4Subnets"`
- ProviderNetType string `json:"providerNetType" yaml:"providerNetType"`
- Vlan Vlan `json:"vlan" yaml:"vlan"`
-}
-
-// structure for the Network Custom Resource
-type CrProviderNet struct {
- ApiVersion string `yaml:"apiVersion"`
- Kind string `yaml:"kind"`
- ProviderNet ProviderNet `yaml:",inline"`
-}
-
-const PROVIDER_NETWORK_APIVERSION = "k8s.plugin.opnfv.org/v1alpha1"
-const PROVIDER_NETWORK_KIND = "ProviderNetwork"
-
-// ProviderNetKey is the key structure that is used in the database
-type ProviderNetKey struct {
- ClusterProviderName string `json:"provider"`
- ClusterName string `json:"cluster"`
- ProviderNetName string `json:"providernet"`
-}
-
-// Manager is an interface exposing the ProviderNet functionality
-type ProviderNetManager interface {
- CreateProviderNet(pr ProviderNet, clusterProvider, cluster string, exists bool) (ProviderNet, error)
- GetProviderNet(name, clusterProvider, cluster string) (ProviderNet, error)
- GetProviderNets(clusterProvider, cluster string) ([]ProviderNet, error)
- DeleteProviderNet(name, clusterProvider, cluster string) error
-}
-
-// ProviderNetClient implements the Manager
-// It will also be used to maintain some localized state
-type ProviderNetClient struct {
- db ClientDbInfo
-}
-
-// NewProviderNetClient returns an instance of the ProviderNetClient
-// which implements the Manager
-func NewProviderNetClient() *ProviderNetClient {
- return &ProviderNetClient{
- db: ClientDbInfo{
- storeName: "cluster",
- tagMeta: "networkmetadata",
- },
- }
-}
-
-// CreateProviderNet - create a new ProviderNet
-func (v *ProviderNetClient) CreateProviderNet(p ProviderNet, clusterProvider, cluster string, exists bool) (ProviderNet, error) {
-
- //Construct key and tag to select the entry
- key := ProviderNetKey{
- ClusterProviderName: clusterProvider,
- ClusterName: cluster,
- ProviderNetName: p.Metadata.Name,
- }
-
- //Check if cluster exists
- _, err := NewClusterClient().GetCluster(clusterProvider, cluster)
- if err != nil {
- return ProviderNet{}, pkgerrors.New("Unable to find the cluster")
- }
-
- //Check if this ProviderNet already exists
- _, err = v.GetProviderNet(p.Metadata.Name, clusterProvider, cluster)
- if err == nil && !exists {
- return ProviderNet{}, pkgerrors.New("ProviderNet already exists")
- }
-
- err = db.DBconn.Insert(v.db.storeName, key, nil, v.db.tagMeta, p)
- if err != nil {
- return ProviderNet{}, pkgerrors.Wrap(err, "Creating DB Entry")
- }
-
- return p, nil
-}
-
-// GetProviderNet returns the ProviderNet for corresponding name
-func (v *ProviderNetClient) GetProviderNet(name, clusterProvider, cluster string) (ProviderNet, error) {
-
- //Construct key and tag to select the entry
- key := ProviderNetKey{
- ClusterProviderName: clusterProvider,
- ClusterName: cluster,
- ProviderNetName: name,
- }
-
- value, err := db.DBconn.Find(v.db.storeName, key, v.db.tagMeta)
- if err != nil {
- return ProviderNet{}, pkgerrors.Wrap(err, "Get ProviderNet")
- }
-
- //value is a byte array
- if value != nil {
- cp := ProviderNet{}
- err = db.DBconn.Unmarshal(value[0], &cp)
- if err != nil {
- return ProviderNet{}, pkgerrors.Wrap(err, "Unmarshalling Value")
- }
- return cp, nil
- }
-
- return ProviderNet{}, pkgerrors.New("Error getting ProviderNet")
-}
-
-// GetProviderNetList returns all of the ProviderNet for corresponding name
-func (v *ProviderNetClient) GetProviderNets(clusterProvider, cluster string) ([]ProviderNet, error) {
-
- //Construct key and tag to select the entry
- key := ProviderNetKey{
- ClusterProviderName: clusterProvider,
- ClusterName: cluster,
- ProviderNetName: "",
- }
-
- var resp []ProviderNet
- values, err := db.DBconn.Find(v.db.storeName, key, v.db.tagMeta)
- if err != nil {
- return []ProviderNet{}, pkgerrors.Wrap(err, "Get ProviderNets")
- }
-
- for _, value := range values {
- cp := ProviderNet{}
- err = db.DBconn.Unmarshal(value, &cp)
- if err != nil {
- return []ProviderNet{}, pkgerrors.Wrap(err, "Unmarshalling Value")
- }
- resp = append(resp, cp)
- }
-
- return resp, nil
-}
-
-// Delete the ProviderNet from database
-func (v *ProviderNetClient) DeleteProviderNet(name, clusterProvider, cluster string) error {
-
- //Construct key and tag to select the entry
- key := ProviderNetKey{
- ClusterProviderName: clusterProvider,
- ClusterName: cluster,
- ProviderNetName: name,
- }
-
- err := db.DBconn.Remove(v.db.storeName, key)
- if err != nil {
- return pkgerrors.Wrap(err, "Delete ProviderNet Entry;")
- }
-
- return nil
-}