package org.openecomp.sdc.be.dao.cassandra.schema.tables;
import com.datastax.driver.core.DataType;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.openecomp.sdc.be.dao.cassandra.schema.ITableDescription;
import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
return "resources";
}
+ @Getter
+ @AllArgsConstructor
enum ArtifactFieldsDescription {
DATA("data", DataType.blob(), false);
- private String name;
- private DataType type;
- private boolean indexed;
+ private final String name;
+ private final DataType type;
+ private final boolean indexed;
- ArtifactFieldsDescription(String name, DataType type, boolean indexed) {
- this.name = name;
- this.type = type;
- this.indexed = indexed;
- }
-
- public String getName() {
- return name;
- }
-
- public DataType getType() {
- return type;
- }
-
- public boolean isIndexed() {
- return indexed;
- }
}
@Override
package org.openecomp.sdc.be.dao.cassandra.schema.tables;
import com.datastax.driver.core.DataType;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.openecomp.sdc.be.dao.cassandra.schema.ITableDescription;
import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
return AuditingTypesConstants.AUTH_EVENT_TYPE;
}
+ @Getter
+ @AllArgsConstructor
enum AEFieldsDescription {
URL("url", DataType.varchar(), false),
REQUEST_ID("request_id", DataType.varchar(), true),
STATUS("status", DataType.varchar(), false),
DESC("description", DataType.varchar(), false);
- private String name;
- private DataType type;
- private boolean indexed;
+ private final String name;
+ private final DataType type;
+ private final boolean indexed;
- AEFieldsDescription(String name, DataType type, boolean indexed) {
- this.name = name;
- this.type = type;
- this.indexed = indexed;
- }
-
- public String getName() {
- return name;
- }
-
- public DataType getType() {
- return type;
- }
-
- public boolean isIndexed() {
- return indexed;
- }
}
}
package org.openecomp.sdc.be.dao.cassandra.schema.tables;
import com.datastax.driver.core.DataType;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.openecomp.sdc.be.dao.cassandra.schema.ITableDescription;
import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
protected abstract void updateColumnDistribDescription(final Map<String, ImmutablePair<DataType, Boolean>> columns);
-
+ @Getter
+ @AllArgsConstructor
enum DistFieldsDescription {
ACTION("action", DataType.varchar(), true),
STATUS("status", DataType.varchar(), false),
REQUEST_ID("request_id", DataType.varchar(), false),
SERVICE_INST_ID("service_instance_id", DataType.varchar(), false);
- private String name;
- private DataType type;
- private boolean indexed;
-
- DistFieldsDescription(String name, DataType type, boolean indexed) {
- this.name = name;
- this.type = type;
- this.indexed = indexed;
- }
-
- public String getName() {
- return name;
- }
-
- public DataType getType() {
- return type;
- }
+ private final String name;
+ private final DataType type;
+ private final boolean indexed;
- public boolean isIndexed() {
- return indexed;
- }
}
}
package org.openecomp.sdc.be.dao.cassandra.schema.tables;
import com.datastax.driver.core.DataType;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
public class DistribDeployEventTableDesc extends DistribBaseEventTableDesc {
-
@Override
public String getTableName() {
return AuditingTypesConstants.DISTRIBUTION_DEPLOY_EVENT_TYPE;
}
+ @Getter
+ @AllArgsConstructor
enum DSEFieldsDescription {
MODIFIER("modifier", DataType.varchar(), false),
CURR_VERSION("curr_version", DataType.varchar(), false),
RESOURCE_NAME("resource_name", DataType.varchar(), false),
RESOURCE_TYPE("resource_type", DataType.varchar(), false);
- private String name;
- private DataType type;
- private boolean indexed;
-
- DSEFieldsDescription(String name, DataType type, boolean indexed) {
- this.name = name;
- this.type = type;
- this.indexed = indexed;
- }
-
- public String getName() {
- return name;
- }
-
- public DataType getType() {
- return type;
- }
+ private final String name;
+ private final DataType type;
+ private final boolean indexed;
- public boolean isIndexed() {
- return indexed;
- }
}
}
package org.openecomp.sdc.be.dao.cassandra.schema.tables;
import com.datastax.driver.core.DataType;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
return AuditingTypesConstants.DISTRIBUTION_DOWNLOAD_EVENT_TYPE;
}
+ @Getter
+ @AllArgsConstructor
enum DSEFieldsDescription {
CONSUMER_ID("consumer_Id", DataType.varchar(), false),
RESOURCE_URL("resource_URL", DataType.varchar(), false);
- private String name;
- private DataType type;
- private boolean indexed;
+ private final String name;
+ private final DataType type;
+ private final boolean indexed;
- DSEFieldsDescription(String name, DataType type, boolean indexed) {
- this.name = name;
- this.type = type;
- this.indexed = indexed;
- }
-
- public String getName() {
- return name;
- }
-
- public DataType getType() {
- return type;
- }
-
- public boolean isIndexed() {
- return indexed;
- }
}
}
package org.openecomp.sdc.be.dao.cassandra.schema.tables;
import com.datastax.driver.core.DataType;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
return AuditingTypesConstants.DISTRIBUTION_ENGINE_EVENT_TYPE;
}
+ @Getter
+ @AllArgsConstructor
enum DEEFieldsDescription {
CONSUMER_ID("consumer_id", DataType.varchar(), false),
ROLE("role", DataType.varchar(), false),
DSTATUS_TOPIC("dstatus_topic", DataType.varchar(), false),
DNOTIF_TOPIC("dnotif_topic", DataType.varchar(), false);
- private String name;
- private DataType type;
- private boolean indexed;
+ private final String name;
+ private final DataType type;
+ private final boolean indexed;
- DEEFieldsDescription(String name, DataType type, boolean indexed) {
- this.name = name;
- this.type = type;
- this.indexed = indexed;
- }
-
- public String getName() {
- return name;
- }
-
- public DataType getType() {
- return type;
- }
-
- public boolean isIndexed() {
- return indexed;
- }
}
}
package org.openecomp.sdc.be.dao.cassandra.schema.tables;
import com.datastax.driver.core.DataType;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
return AuditingTypesConstants.DISTRIBUTION_NOTIFICATION_EVENT_TYPE;
}
+ @Getter
+ @AllArgsConstructor
enum DNEFieldsDescription {
TOPIC_NAME("topic_name", DataType.varchar(), false),
MODIFIER("modifier", DataType.varchar(), false),
VNF_WORKLOAD_CONTEXT("vnf_workload_context", DataType.varchar(), false),
TENANT("tenant", DataType.varchar(), false);
- private String name;
- private DataType type;
- private boolean indexed;
+ private final String name;
+ private final DataType type;
+ private final boolean indexed;
- DNEFieldsDescription(String name, DataType type, boolean indexed) {
- this.name = name;
- this.type = type;
- this.indexed = indexed;
- }
-
- public String getName() {
- return name;
- }
-
- public DataType getType() {
- return type;
- }
-
- public boolean isIndexed() {
- return indexed;
- }
}
}
package org.openecomp.sdc.be.dao.cassandra.schema.tables;
import com.datastax.driver.core.DataType;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.openecomp.sdc.be.dao.cassandra.schema.ITableDescription;
import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
return AuditingTypesConstants.ECOMP_OPERATIONAL_ENV_EVENT_TYPE;
}
+ @Getter
+ @AllArgsConstructor
enum EcompOpEnvFieldsDescription {
ACTION("action", DataType.varchar(), false),
OPERATIONAL_ENVIRONMENT_NAME("operational_environment_name", DataType.varchar(), false),
OPERATIONAL_ENVIRONMENT_ACTION("operational_environment_action", DataType.varchar(), false),
TENANT_CONTEXT("tenant_context", DataType.varchar(), false);
- private String name;
- private DataType type;
- private boolean indexed;
+ private final String name;
+ private final DataType type;
+ private final boolean indexed;
- EcompOpEnvFieldsDescription(String name, DataType type, boolean indexed) {
- this.name = name;
- this.type = type;
- this.indexed = indexed;
- }
-
- public String getName() {
- return name;
- }
-
- public DataType getType() {
- return type;
- }
-
- public boolean isIndexed() {
- return indexed;
- }
}
}
package org.openecomp.sdc.be.dao.cassandra.schema.tables;
import com.datastax.driver.core.DataType;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.openecomp.sdc.be.dao.cassandra.schema.ITableDescription;
import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
return AuditingTypesConstants.EXTERNAL_API_EVENT_TYPE;
}
+ @Getter
+ @AllArgsConstructor
enum EGAEFieldsDescription {
ACTION("action", DataType.varchar(), true),
STATUS("status", DataType.varchar(), false),
CURR_ARTIFACT_UUID( "curr_artifact_uuid", DataType.varchar(), false),
ARTIFACT_DATA( "artifact_data", DataType.varchar(), false);
- private String name;
- private DataType type;
- private boolean indexed;
+ private final String name;
+ private final DataType type;
+ private final boolean indexed;
- EGAEFieldsDescription(String name, DataType type, boolean indexed) {
- this.name = name;
- this.type = type;
- this.indexed = indexed;
- }
-
- public String getName() {
- return name;
- }
-
- public DataType getType() {
- return type;
- }
-
- public boolean isIndexed() {
- return indexed;
- }
}
}
import com.datastax.driver.core.DataType;
import com.google.common.collect.Lists;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.openecomp.sdc.be.dao.cassandra.schema.ITableDescription;
import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
return AuditingTypesConstants.FEATURE_TOGGLE_STATE;
}
+ @Getter
+ @AllArgsConstructor
enum FeatureToggleEventFieldsDescription {
ENABLED("enabled", DataType.varchar(), false),
STRATEGY_ID("strategy_id", DataType.varchar(), false),
PARAMETERS("parameters", DataType.varchar(), false);
- private String name;
- private DataType type;
- private boolean indexed;
-
- FeatureToggleEventFieldsDescription(String name, DataType type, boolean indexed) {
- this.name = name;
- this.type = type;
- this.indexed = indexed;
- }
-
- public String getName() {
- return name;
- }
-
- public DataType getType() {
- return type;
- }
-
- public boolean isIndexed() {
- return indexed;
- }
+ private final String name;
+ private final DataType type;
+ private final boolean indexed;
}
}
package org.openecomp.sdc.be.dao.cassandra.schema.tables;
import com.datastax.driver.core.DataType;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.openecomp.sdc.be.dao.cassandra.schema.ITableDescription;
import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
return AuditingTypesConstants.GET_CATEGORY_HIERARCHY_EVENT_TYPE;
}
+ @Getter
+ @AllArgsConstructor
enum DEEFieldsDescription {
ACTION("action", DataType.varchar(), true),
STATUS("status", DataType.varchar(), false),
REQUEST_ID("request_id", DataType.varchar(), false),
MODIFIER("modifier", DataType.varchar(), false);
- private String name;
- private DataType type;
- private boolean indexed;
+ private final String name;
+ private final DataType type;
+ private final boolean indexed;
- DEEFieldsDescription(String name, DataType type, boolean indexed) {
- this.name = name;
- this.type = type;
- this.indexed = indexed;
- }
-
- public String getName() {
- return name;
- }
-
- public DataType getType() {
- return type;
- }
-
- public boolean isIndexed() {
- return indexed;
- }
}
}
package org.openecomp.sdc.be.dao.cassandra.schema.tables;
import com.datastax.driver.core.DataType;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.openecomp.sdc.be.dao.cassandra.schema.ITableDescription;
import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
return AuditingTypesConstants.DISTRIBUTION_GET_UEB_CLUSTER_EVENT_TYPE;
}
+ @Getter
+ @AllArgsConstructor
enum DEEFieldsDescription {
ACTION("action", DataType.varchar(), true),
STATUS("status", DataType.varchar(), false),
REQUEST_ID("request_Id", DataType.varchar(), false),
SERVICE_INST_ID("service_Instance_Id", DataType.varchar(), false);
- private String name;
- private DataType type;
- private boolean indexed;
+ private final String name;
+ private final DataType type;
+ private final boolean indexed;
- DEEFieldsDescription(String name, DataType type, boolean indexed) {
- this.name = name;
- this.type = type;
- this.indexed = indexed;
- }
-
- public String getName() {
- return name;
- }
-
- public DataType getType() {
- return type;
- }
-
- public boolean isIndexed() {
- return indexed;
- }
}
}
package org.openecomp.sdc.be.dao.cassandra.schema.tables;
import com.datastax.driver.core.DataType;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.openecomp.sdc.be.dao.cassandra.schema.ITableDescription;
import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
return AuditingTypesConstants.GET_USERS_LIST_EVENT_TYPE;
}
+ @Getter
+ @AllArgsConstructor
enum DEEFieldsDescription {
ACTION("action", DataType.varchar(), true),
STATUS("status", DataType.varchar(), false),
REQUEST_ID("request_id", DataType.varchar(), false),
MODIFIER("modifier", DataType.varchar(), false);
- private String name;
- private DataType type;
- private boolean indexed;
+ private final String name;
+ private final DataType type;
+ private final boolean indexed;
- DEEFieldsDescription(String name, DataType type, boolean indexed) {
- this.name = name;
- this.type = type;
- this.indexed = indexed;
- }
-
- public String getName() {
- return name;
- }
-
- public DataType getType() {
- return type;
- }
-
- public boolean isIndexed() {
- return indexed;
- }
}
}
package org.openecomp.sdc.be.dao.cassandra.schema.tables;
import com.datastax.driver.core.DataType;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.openecomp.sdc.be.dao.cassandra.schema.ITableDescription;
import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
return MIGRATION_TASKS_TABLE;
}
+ @Getter
+ @AllArgsConstructor
enum SdcRepoFieldsDescription {
MAJOR_VERSION("major_version", DataType.bigint(), true),
MINOR_VERSION("minor_version", DataType.bigint(), false),
DESCRIPTION("description", DataType.varchar(), false),
EXECUTION_TIME("execution_time", DataType.cdouble(), false);
- private String fieldName;
- private boolean isIndexed;
- private DataType fieldType;
+ private final String fieldName;
+ private final DataType fieldType;
+ private final boolean isIndexed;
- SdcRepoFieldsDescription(String fieldName, DataType dataType, boolean indexed ) {
- this.fieldName = fieldName;
- this.fieldType = dataType;
- this.isIndexed = indexed;
- }
-
- public String getFieldName() {
- return fieldName;
- }
-
- public boolean isIndexed() {
- return isIndexed;
- }
-
- public DataType getFieldType() {
- return fieldType;
- }
}
}
package org.openecomp.sdc.be.dao.cassandra.schema.tables;
import com.datastax.driver.core.DataType;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.openecomp.sdc.be.dao.cassandra.schema.ITableDescription;
import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
return AuditingTypesConstants.EXTERNAL_API_EVENT_TYPE;
}
+ @Getter
+ @AllArgsConstructor
enum EGAEFieldsDescription {
ACTION("action", DataType.varchar(), true),
STATUS("status", DataType.varchar(), false),
CURR_ARTIFACT_UUID( "curr_artifact_uuid", DataType.varchar(), false),
ARTIFACT_DATA( "artifact_data", DataType.varchar(), false);
- private String name;
- private DataType type;
- private boolean indexed;
+ private final String name;
+ private final DataType type;
+ private final boolean indexed;
- EGAEFieldsDescription(String name, DataType type, boolean indexed) {
- this.name = name;
- this.type = type;
- this.indexed = indexed;
- }
-
- public String getName() {
- return name;
- }
-
- public DataType getType() {
- return type;
- }
-
- public boolean isIndexed() {
- return indexed;
- }
}
}
package org.openecomp.sdc.be.dao.cassandra.schema.tables;
import com.datastax.driver.core.DataType;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.openecomp.sdc.be.dao.cassandra.schema.ITableDescription;
import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
return OPERATIONAL_ENVIRONMENT_TABLE;
}
+ @Getter
+ @AllArgsConstructor
enum SdcOperationalEnvironmentFieldsDescription {
//there is also PK field "environmentID"
TENANT("tenant", DataType.varchar(), false),
STATUS("status",DataType.varchar() ,true),
LAST_MODIFIED("last_modified",DataType.timestamp() ,false);
- private String fieldName;
- private boolean isIndexed;
- private DataType fieldType;
+ private final String fieldName;
+ private final DataType fieldType;
+ private final boolean isIndexed;
- SdcOperationalEnvironmentFieldsDescription(String fieldName, DataType dataType, boolean indexed ) {
- this.fieldName = fieldName;
- this.fieldType = dataType;
- this.isIndexed = indexed;
- }
-
- public String getFieldName() {
- return fieldName;
- }
-
- public boolean isIndexed() {
- return isIndexed;
- }
-
- public DataType getFieldType() {
- return fieldType;
- }
}
}
package org.openecomp.sdc.be.dao.cassandra.schema.tables;
import com.datastax.driver.core.DataType;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.openecomp.sdc.be.dao.cassandra.schema.ITableDescription;
import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
public String getTableName() {
return "sdcSchemaFiles";
}
-
+
+ @Getter
+ @AllArgsConstructor
enum SdcSchemaFilesFieldsDescription {
FILE_NAME("fileName", DataType.varchar(), false),
PAYLOAD("payload", DataType.blob(), false),
CHECKSUM("checksum", DataType.varchar(), false);
- private String name;
- private DataType type;
- private boolean indexed;
+ private final String name;
+ private final DataType type;
+ private final boolean indexed;
- SdcSchemaFilesFieldsDescription(String name, DataType type, boolean indexed) {
- this.name = name;
- this.type = type;
- this.indexed = indexed;
- }
-
- public String getName() {
- return name;
- }
-
- public DataType getType() {
- return type;
- }
-
- public boolean isIndexed() {
- return indexed;
- }
}
}
import com.datastax.driver.core.DataType;
import com.datastax.driver.mapping.annotations.Column;
-import org.apache.commons.lang3.tuple.ImmutablePair;
-import org.openecomp.sdc.be.dao.cassandra.schema.ITableDescription;
-import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
-
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import org.apache.commons.lang3.tuple.ImmutablePair;
+import org.openecomp.sdc.be.dao.cassandra.schema.ITableDescription;
+import org.openecomp.sdc.be.resources.data.auditing.AuditingTypesConstants;
public class UserAccessEventTableDescription implements ITableDescription {
@Override
return AuditingTypesConstants.USER_ACCESS_EVENT_TYPE;
}
+ @Getter
+ @AllArgsConstructor
enum UAEFieldsDescription {
- REQUEST_ID("request_Id", DataType.varchar(), false), USER("USER", DataType.varchar(), false), ACTION("action",
- DataType.varchar(), true), STATUS("status", DataType.varchar(), false), DESCRIPTION("description",
- DataType.varchar(),
- false), SERVICE_INSTANCE_ID("service_instance_id", DataType.varchar(), false);
-
- @Column
- private String modifier;
+ REQUEST_ID("request_Id", DataType.varchar(), false),
+ USER("USER", DataType.varchar(), false),
+ ACTION("action", DataType.varchar(), true),
+ STATUS("status", DataType.varchar(), false),
+ DESCRIPTION("description", DataType.varchar(), false),
+ SERVICE_INSTANCE_ID("service_instance_id", DataType.varchar(), false);
- private String name;
- private DataType type;
- private boolean indexed;
+ private final String name;
+ private final DataType type;
+ private final boolean indexed;
- UAEFieldsDescription(String name, DataType type, boolean indexed) {
- this.name = name;
- this.type = type;
- this.indexed = indexed;
- }
-
- public String getName() {
- return name;
- }
-
- public DataType getType() {
- return type;
- }
-
- public boolean isIndexed() {
- return indexed;
- }
}
}
return associateForwardingPathToComponent(topologyTemplateVertex,forwardingPaths);
}
- private StorageOperationStatus associateNodeFilterToResource(GraphVertex topologyTemplateVertex,
- TopologyTemplate topologyTemplate) {
- Map<String, CINodeFilterDataDefinition> nodeFilters =
- topologyTemplate.getNodeFilterComponents();
- return associateNodeFiltersToComponent(topologyTemplateVertex, nodeFilters);
- }
-
private StorageOperationStatus associateCapPropertiesToResource(GraphVertex topologyTemplateVertex, TopologyTemplate topologyTemplate) {
Map<String, MapCapabilityProperty> calculatedCapProperties = topologyTemplate
.getCalculatedCapabilitiesProperties();
return StorageOperationStatus.OK;
}
- public StorageOperationStatus associateNodeFiltersToComponent(GraphVertex nodeTypeVertex,
- Map<String, CINodeFilterDataDefinition> filterMaps) {
- if (filterMaps != null && !filterMaps.isEmpty()) {
- Either<GraphVertex, StorageOperationStatus> assosiateElementToData = associateElementToData
- (nodeTypeVertex, VertexTypeEnum.NODE_FILTER_TEMPLATE,
- EdgeLabelEnum.NODE_FILTER_TEMPLATE, filterMaps);
- if (assosiateElementToData.isRight()) {
- return assosiateElementToData.right().value();
- }
- }
- return StorageOperationStatus.OK;
- }
-
private JanusGraphOperationStatus setForwardingGraphPropertiesFromGraph(GraphVertex componentV, TopologyTemplate topologyTemplate) {
Either<Map<String, ForwardingPathDataDefinition>, JanusGraphOperationStatus> result = getDataFromGraph(componentV, EdgeLabelEnum.FORWARDING_PATH);
if (result.isLeft()) {
return dataType;
}
- private Map<String, AttributeDataDefinition> getAttributesFromComponentV(final GraphVertex componentV) {
- final Map<String, Object> jsonMetada = componentV.getMetadataJson();
- final Map<String, AttributeDataDefinition> attributeDataDefinitionMap = new HashMap<>();
- if (MapUtils.isNotEmpty(jsonMetada)) {
- final Object attributes = jsonMetada.get(ToscaTagNamesEnum.ATTRIBUTES.getElementName());
- if (attributes instanceof Map) {
- final Map<String, Object> map = (Map<String, Object>) attributes;
- attributeDataDefinitionMap.putAll(map.values().stream().map(attributeMap -> {
- final AttributeDataDefinition attributeDef = new AttributeDataDefinition();
- final String name = (String) ((Map<String, Object>) attributeMap).get("name");
- attributeDef.setName(name);
- final String type = (String) ((Map<String, Object>) attributeMap).get("type");
- attributeDef.setType(type);
- final String description = (String) ((Map<String, Object>) attributeMap).get("description");
- attributeDef.setDescription(description);
- final Object _default = ((Map<String, Object>) attributeMap).get("_default");
- attributeDef.set_default(_default);
- final String status = (String) ((Map<String, Object>) attributeMap).get("status");
- attributeDef.setStatus(status);
- final EntrySchema entry_schema = (EntrySchema) ((Map<String, Object>) attributeMap).get("entry_schema");
- attributeDef.setEntry_schema(entry_schema);
- return attributeDef;
- }).collect(Collectors.toMap(AttributeDataDefinition::getName, a -> a)));
- }
- }
- return attributeDataDefinitionMap;
- }
-
protected JanusGraphOperationStatus setResourceCategoryFromGraphV(Vertex vertex, CatalogComponent catalogComponent) {
List<CategoryDefinition> categories = new ArrayList<>();
SubCategoryDefinition subcategory;
}
- /**
- *
- * convert between graph Node object to Java object
- *
- * @param capabilityTypeData
- * @return
- */
- protected CapabilityTypeDefinition convertCTDataToCTDefinition(CapabilityTypeData capabilityTypeData) {
- log.debug("The object returned after create capability is {}", capabilityTypeData);
-
- return new CapabilityTypeDefinition(capabilityTypeData.getCapabilityTypeDataDefinition());
- }
-
/**
*
* Add capability type to graph.
return result;
}
- private Either<DataTypeDefinition, JanusGraphOperationStatus> getDataTypeUsingName(String name) {
- String uid = UniqueIdBuilder.buildDataTypeUid(name);
- return getDataTypeByUid(uid);
- }
-
public Either<String, JanusGraphOperationStatus> checkInnerType(PropertyDataDefinition propDataDef) {
String propertyType = propDataDef.getType();