1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
|
/*-
* ============LICENSE_START==========================================
* OPENECOMP - DCAE
* ===================================================================
* Copyright (c) 2017 AT&T Intellectual Property. All rights reserved.
* ===================================================================
* 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.
* ============LICENSE_END============================================
*/
@GenModel(modelDirectory="/ncomp-cdap-model/src/main/xcore-gen")
package org.openecomp.ncomp.cdap
import org.openecomp.ncomp.core.NamedEntity
class CdapAdaptor {
}
class CdapCluster extends NamedEntity, CdapApi {
String baseUrl
long pollingFrequency = "300000"
boolean remote = "false"
contains unordered CdapConfiguration[] configurations
contains unordered CdapNamespace[] namespaces opposite cluster
op void poll()
}
class CdapApi {
op String createNamespace(String namespace)
op String deleteNamespace(String namespace)
op String deployApp(String namespace, String jarfile)
op String loadArtifact(String namespace, String artifactName, String jarfile, String version)
op String loadArtifactWithConfig(String namespace, String artifactName, String jarfile, String version, String config)
op String deleteArtifact(String namespace, String artifactName, String artifactVersion)
op String startFlow(String namespace, String appName, String flowId, String extraArgs)
op String startWorker(String namespace, String appName, String workerId, String extraArgs)
op String startService(String namespace, String appName, String serviceId, String extraArgs)
op String startApp(String namespace, String appName)
op String stopApp(String namespace, String appName, String programTypes)
op String deleteApp(String namespace, String appName)
op String loadPreferencesApp(String namespace, String prefsFile, String appId)
op String loadPreferencesFlow(String namespace, String prefsFile, String appId, String flowId)
op String loadPreferencesNameSpace(String namespace, String prefsFile)
op String setPreferencesApp(String namespace, String prefsString, String appId)
op String setPreferencesFlow(String namespace, String prefsString, String appId, String flowId)
op String setPreferencesWorker(String namespace, String prefsString, String appId, String workerId)
op String setPreferencesService(String namespace, String prefsString, String appId, String serviceId)
op String setPreferencesNameSpace(String namespace, String prefsString)
op String setFlowRunTimeArgs(String namespace, String appId, String flowId, String args)
op String setFlowletInstances(String namespace, String appId, String flowId, String flowletId, int nInstances)
op String stopFlow(String namespace, String appId, String flowId)
op String stopWorker(String namespace, String appId, String workerId)
op String stopService(String namespace, String appId, String serviceId)
op String truncateDataSet(String namespace, String datasetName)
op String deleteDataset(String namespace, String datasetName)
op String createStream(String namespace, String newStreamId)
op String deleteStream(String namespace, String streamId)
op String[] getStreamEvents(String namespace, String streamId, String startTime, String endTime, int limit)
op String[] getStreamStats(String namespace, String streamId, String startTime, String endTime, int limit)
op String sendEventToStream(String namespace, String streamId, String event)
op String trucateStream(String namespace, String streamId)
op String setStreamProperties(String namespace, String streamId, String propsFile)
op String restartApp(String namespace, String appId, String progTypes)
op String createApp(String namespace, String appId, String artifactName, String artifactVersion, String scope)
op String createAppWithConfig(String namespace, String appId, String artifactName, String artifactVersion, String scope,
String appConfig)
op String setDatasetProperties(String namespace, String datasetName, String datasetProperties)
op String setStreamTTL(String namespace, String streamName, int ttlSeconds)
op String suspendSchedule(String namespace, String appId, String scheduleId)
op String resumeSchedule(String namespace, String appId, String scheduleId)
}
class CdapConfiguration extends NamedEntity {
String value
String source
}
class CdapNamespace extends NamedEntity {
String description
contains unordered CdapKeyPair[] config
contains unordered CdapDataset[] datasets
contains unordered CdapApplication[] applications
refers CdapCluster cluster opposite namespaces
}
class CdapKeyPair extends NamedEntity {
String value
}
class CdapEntityWithPreferences extends NamedEntity {
contains unordered CdapKeyPair[] preferences
}
class CdapDataset extends NamedEntity {
String ^type
contains unordered CdapKeyPair[] properties
contains CdapDatasetSchema schema
}
class CdapDatasetSchema extends NamedEntity {
String ^type
contains CdapDatasetSchemaField[] fields
}
class CdapDatasetSchemaField extends NamedEntity {
String ^type
}
class CdapApplication extends NamedEntity {
String ^type
String ^id
String version
String description
contains CdapArtifact artifact
}
class CdapArtifact extends NamedEntity {
String version
String scope
}
|
