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
|
/*
* ============LICENSE_START==========================================
* org.onap.music
* ===================================================================
* Copyright (c) 2017 AT&T Intellectual Property
* ===================================================================
* 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=============================================
* ====================================================================
*/
package org.onap.music.service;
import java.util.List;
import java.util.Map;
import org.onap.music.datastore.PreparedQueryObject;
import org.onap.music.exceptions.MusicLockingException;
import org.onap.music.exceptions.MusicQueryException;
import org.onap.music.exceptions.MusicServiceException;
import org.onap.music.lockingservice.cassandra.MusicLockState;
import org.onap.music.main.ResultType;
import org.onap.music.main.ReturnType;
import org.onap.music.datastore.*;
import com.datastax.driver.core.ResultSet;
public interface MusicCoreService {
// Core Music Database Methods
public ReturnType eventualPut(PreparedQueryObject queryObject);
public ReturnType eventualPut_nb(PreparedQueryObject queryObject,String keyspace,String tablename,String primaryKey);
public ReturnType criticalPut(String keyspaceName, String tableName, String primaryKey,
PreparedQueryObject queryObject, String lockId, Condition conditionInfo);
public ResultType nonKeyRelatedPut(PreparedQueryObject queryObject, String consistency)
throws MusicServiceException;
public ResultSet get(PreparedQueryObject queryObject) throws MusicServiceException;
public ResultSet atomicGet(String keyspaceName, String tableName, String primaryKey,
PreparedQueryObject queryObject) throws MusicServiceException, MusicLockingException, MusicQueryException;
public ReturnType atomicPutWithDeleteLock(String keyspaceName, String tableName, String primaryKey,
PreparedQueryObject queryObject, Condition conditionInfo) throws MusicLockingException;
public ResultSet atomicGetWithDeleteLock(String keyspaceName, String tableName, String primaryKey,
PreparedQueryObject queryObject) throws MusicServiceException, MusicLockingException;
public ReturnType atomicPut(String keyspaceName, String tableName, String primaryKey,
PreparedQueryObject queryObject, Condition conditionInfo)
throws MusicLockingException, MusicQueryException, MusicServiceException;
public ResultSet criticalGet(String keyspaceName, String tableName, String primaryKey,
PreparedQueryObject queryObject, String lockId) throws MusicServiceException;
// Core Music Locking Service Methods
public String createLockReference(String fullyQualifiedKey); // lock name
public ReturnType acquireLockWithLease(String key, String lockReference, long leasePeriod)
throws MusicLockingException, MusicQueryException, MusicServiceException; // key,lock id,time
public ReturnType acquireLock(String key, String lockReference)
throws MusicLockingException, MusicQueryException, MusicServiceException; // key,lock id
public ResultType createTable(String keyspace, String table, PreparedQueryObject tableQueryObject,
String consistency) throws MusicServiceException;
public ResultSet quorumGet(PreparedQueryObject query);
public String whoseTurnIsIt(String fullyQualifiedKey);// lock name
public void destroyLockRef(String lockId);
//public MusicLockState destroyLockRef(String fullyQualifiedKey, String lockReference); // lock name, lock id
//public MusicLockState voluntaryReleaseLock(String fullyQualifiedKey, String lockReference)
// throws MusicLockingException;// lock name,lock id
public void deleteLock(String lockName) throws MusicLockingException;
//public MusicLockState forciblyReleaseLock(String fullyQualifiedKey, String lockReference) throws MusicLockingException, MusicServiceException, MusicQueryException;
public List<String> getLockQueue(String fullyQualifiedKey)
throws MusicServiceException, MusicQueryException, MusicLockingException;
public long getLockQueueSize(String fullyQualifiedKey)
throws MusicServiceException, MusicQueryException, MusicLockingException;
public Map<String, Object> validateLock(String lockName);
public MusicLockState releaseLock(String lockId, boolean voluntaryRelease);
}
|
