ATEST-562
This commit is contained in:
12
Readme.md
12
Readme.md
@ -92,17 +92,17 @@ curl -H "Content-Type: application/json" -X POST -d '{"regex": "AMPLT|PHASE"}' h
|
|||||||
{
|
{
|
||||||
"backend":"sf-databuffer",
|
"backend":"sf-databuffer",
|
||||||
"channels":[
|
"channels":[
|
||||||
"Channel_01",
|
"Channel_01_AMPLT",
|
||||||
"Channel_02",
|
"Channel_02_AMPLT",
|
||||||
"Channel_03"
|
"Channel_03_PHASE"
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"backend":"sf-archiverappliance",
|
"backend":"sf-archiverappliance",
|
||||||
"channels":[
|
"channels":[
|
||||||
"Channel_01",
|
"Channel_01_AMPLT",
|
||||||
"Channel_04",
|
"Channel_04_PHASE",
|
||||||
"Channel_05"
|
"Channel_05_AMPLT"
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
|
@ -69,7 +69,7 @@ public class QueryManagerImpl implements QueryManager {
|
|||||||
|
|
||||||
public Collection<ChannelInfos> getChannelInfos(ChannelNameRequest request) {
|
public Collection<ChannelInfos> getChannelInfos(ChannelNameRequest request) {
|
||||||
// set backends if not defined yet
|
// set backends if not defined yet
|
||||||
channelNameCache.setBackends(request.getChannels());
|
channelNameCache.configureBackends(request.getChannels());
|
||||||
|
|
||||||
Stream<ChannelInfos> stream = request.getRequestsByBackend().entrySet().stream()
|
Stream<ChannelInfos> stream = request.getRequestsByBackend().entrySet().stream()
|
||||||
.filter(entry ->
|
.filter(entry ->
|
||||||
@ -94,7 +94,7 @@ public class QueryManagerImpl implements QueryManager {
|
|||||||
@Override
|
@Override
|
||||||
public List<Entry<DAQQueryElement, Stream<Triple<BackendQuery, ChannelName, ?>>>> getEvents(DAQQueries queries) {
|
public List<Entry<DAQQueryElement, Stream<Triple<BackendQuery, ChannelName, ?>>>> getEvents(DAQQueries queries) {
|
||||||
// set backends if not defined yet
|
// set backends if not defined yet
|
||||||
channelNameCache.setBackends(queries);
|
channelNameCache.configureBackends(queries);
|
||||||
|
|
||||||
List<Entry<DAQQueryElement, Stream<Triple<BackendQuery, ChannelName, ?>>>> results =
|
List<Entry<DAQQueryElement, Stream<Triple<BackendQuery, ChannelName, ?>>>> results =
|
||||||
new ArrayList<>(queries.getQueries().size());
|
new ArrayList<>(queries.getQueries().size());
|
||||||
|
Reference in New Issue
Block a user