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

Class EventWebClient

java.lang.Object

gov.llnl.gnem.apps.coda.calibration.gui.data.client.EventWebClient

All Implemented Interfaces:

EventClient

@Component
public class EventWebClient
extends Object
implements EventClient

Constructor Summary

Constructors

Constructor	Description
EventWebClient(org.springframework.web.reactive.function.client.WebClient client)

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> events)
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

EventWebClient

@Autowired
public EventWebClient(org.springframework.web.reactive.function.client.WebClient client)

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

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

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> events)
                                                         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

getUniqueEventIds

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

Specified by:

getUniqueEventIds in interface EventClient