Package gov.llnl.gnem.apps.coda.calibration.standalone.data.client

Class EventLocalClient

java.lang.Object

gov.llnl.gnem.apps.coda.calibration.standalone.data.client.EventLocalClient

All Implemented Interfaces:

EventClient

@Component
@Primary
public class EventLocalClient
extends Object
implements EventClient

Constructor Summary

Constructors

Constructor	Description
EventLocalClient(ReferenceMwParametersService refEventService, ValidationMwParametersService valEventService, MeasuredMwsService measureService, CalibrationService calService, WaveformService waveformService)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<Event>	getEvent(String eventId)
reactor.core.publisher.Flux<MeasuredMwDetails>	getMeasuredEventDetails()
reactor.core.publisher.Flux<MeasuredMwParameters>	getMeasuredEvents()
reactor.core.publisher.Flux<ReferenceMwParameters>	getReferenceEvents()
reactor.core.publisher.Flux<String>	getUniqueEventIds()
reactor.core.publisher.Flux<ValidationMwParameters>	getValidationEvents()
reactor.core.publisher.Mono<String>	postReferenceEvents(List<ReferenceMwParameters> refEvents)
reactor.core.publisher.Mono<String>	postValidationEvents(List<ValidationMwParameters> valEvents)
reactor.core.publisher.Mono<Void>	removeReferenceEventsByEventId(List<String> evids)
reactor.core.publisher.Mono<Void>	removeValidationEventsByEventId(List<String> evids)
reactor.core.publisher.Flux<String>	toggleValidationEventsByEventId(List<String> evids)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

EventLocalClient

@Autowired
public EventLocalClient(ReferenceMwParametersService refEventService,
 ValidationMwParametersService valEventService,
 MeasuredMwsService measureService,
 CalibrationService calService,
 WaveformService waveformService)

Method Details

getReferenceEvents

public reactor.core.publisher.Flux<ReferenceMwParameters> getReferenceEvents()

Specified by:

getReferenceEvents in interface EventClient

postReferenceEvents

public reactor.core.publisher.Mono<String> postReferenceEvents(List<ReferenceMwParameters> refEvents)
                                                        throws com.fasterxml.jackson.core.JsonProcessingException

Specified by:

postReferenceEvents in interface EventClient

Throws:

com.fasterxml.jackson.core.JsonProcessingException

removeReferenceEventsByEventId

public reactor.core.publisher.Mono<Void> removeReferenceEventsByEventId(List<String> evids)

Specified by:

removeReferenceEventsByEventId in interface EventClient

getValidationEvents

public reactor.core.publisher.Flux<ValidationMwParameters> getValidationEvents()

Specified by:

getValidationEvents in interface EventClient

postValidationEvents

public reactor.core.publisher.Mono<String> postValidationEvents(List<ValidationMwParameters> valEvents)
                                                         throws com.fasterxml.jackson.core.JsonProcessingException

Specified by:

postValidationEvents in interface EventClient

Throws:

com.fasterxml.jackson.core.JsonProcessingException

removeValidationEventsByEventId

public reactor.core.publisher.Mono<Void> removeValidationEventsByEventId(List<String> evids)

Specified by:

removeValidationEventsByEventId in interface EventClient

toggleValidationEventsByEventId

public reactor.core.publisher.Flux<String> toggleValidationEventsByEventId(List<String> evids)

Specified by:

toggleValidationEventsByEventId in interface EventClient

getMeasuredEvents

public reactor.core.publisher.Flux<MeasuredMwParameters> getMeasuredEvents()

Specified by:

getMeasuredEvents in interface EventClient

getEvent

public reactor.core.publisher.Mono<Event> getEvent(String eventId)

Specified by:

getEvent in interface EventClient

getMeasuredEventDetails

public reactor.core.publisher.Flux<MeasuredMwDetails> getMeasuredEventDetails()

Specified by:

getMeasuredEventDetails in interface EventClient

getUniqueEventIds

public reactor.core.publisher.Flux<String> getUniqueEventIds()

Specified by:

getUniqueEventIds in interface EventClient