diff options
Diffstat (limited to 'src/ncm/pkg/module/providernet.go')
| -rw-r--r-- | src/ncm/pkg/module/providernet.go | 182 |
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 -} |