Package csw.location.api.client

Class LocationServiceClient

java.lang.Object

csw.location.api.client.LocationServiceClient

All Implemented Interfaces:

LocationCodecs, LocationCodecsBase, LocationServiceCodecs, csw.location.api.scaladsl.LocationService, CommonCodecs, msocket.api.codecs.BasicCodecs

public class LocationServiceClient
extends java.lang.Object
implements csw.location.api.scaladsl.LocationService, LocationServiceCodecs, msocket.api.codecs.BasicCodecs

Nested Class Summary

Nested classes/interfaces inherited from interface csw.prefix.codecs.CommonCodecs

CommonCodecs.Timestamp, CommonCodecs.Timestamp$

Constructor Summary

Constructors

Constructor	Description
LocationServiceClient(msocket.api.Transport<LocationRequest> httpTransport, msocket.api.Transport<LocationStreamRequest> websocketTransport, akka.actor.typed.ActorSystem<?> actorSystem)

Method Summary

Modifier and Type	Method	Description
io.bullet.borer.Codec<ComponentId>	componentIdCodec()
io.bullet.borer.Codec<ConnectionInfo>	connectionInfoCodec()
io.bullet.borer.Codec<akka.Done>	doneCodec()
<L extends Location> scala.concurrent.Future<scala.Option<L>>	find(TypedConnection<L> connection)
io.bullet.borer.Codec<scala.concurrent.duration.FiniteDuration>	finiteDurationCodec()
io.bullet.borer.AdtEncodingStrategy	flatAdtEncoding()
io.bullet.borer.Decoder<java.time.Instant>	instantDec()
io.bullet.borer.Encoder<java.time.Instant>	instantEnc()
scala.concurrent.Future<scala.collection.immutable.List<Location>>	list()
scala.concurrent.Future<scala.collection.immutable.List<Location>>	list(ComponentType componentType)
scala.concurrent.Future<scala.collection.immutable.List<Location>>	list(ConnectionType connectionType)
scala.concurrent.Future<scala.collection.immutable.List<Location>>	list(java.lang.String hostname)
scala.concurrent.Future<scala.collection.immutable.List<Location>>	listByPrefix(java.lang.String prefix)
protected io.bullet.borer.Codec<Location>	locationCodecValue()
io.bullet.borer.Codec<LocationRequest>	locationHttpMessageCodec()
msocket.api.ErrorProtocol<LocationRequest>	locationHttpMessageErrorProtocol()
io.bullet.borer.Codec<LocationServiceError>	LocationServiceErrorCodec()
io.bullet.borer.Codec<LocationStreamRequest>	locationWebsocketMessageCodec()
msocket.api.ErrorProtocol<LocationStreamRequest>	locationWebsocketMessageErrorProtocol()
io.bullet.borer.Codec<Metadata>	metadataCodec()
io.bullet.borer.Codec<NetworkType>	networkType()
io.bullet.borer.Codec<Prefix>	prefixCodec()
scala.concurrent.Future<csw.location.api.scaladsl.RegistrationResult>	register(Registration registration)
io.bullet.borer.Codec<Registration>	registrationCodec()
<L extends Location> scala.concurrent.Future<scala.Option<L>>	resolve(TypedConnection<L> connection, scala.concurrent.duration.FiniteDuration within)
msocket.api.Subscription	subscribe(Connection connection, scala.Function1<TrackingEvent,scala.runtime.BoxedUnit> callback)
io.bullet.borer.Codec<akka.util.Timeout>	timeoutInSecondsCodec()
CommonCodecs.Timestamp$	Timestamp()
akka.stream.scaladsl.Source<TrackingEvent,msocket.api.Subscription>	track(Connection connection)
io.bullet.borer.Codec<TrackingEvent>	trackingEventCodec()
scala.concurrent.Future<akka.Done>	unregister(Connection connection)
scala.concurrent.Future<akka.Done>	unregisterAll()
io.bullet.borer.Codec<java.net.URI>	uriCodec()

Methods inherited from class java.lang.Object

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

Methods inherited from interface msocket.api.codecs.BasicCodecs

eitherCodec

Methods inherited from interface csw.prefix.codecs.CommonCodecs

enumCodec

Methods inherited from interface csw.location.api.codec.LocationCodecs

locationCodec

Methods inherited from interface csw.location.api.codec.LocationCodecsBase

connectionCodec

Constructor Detail

LocationServiceClient

public LocationServiceClient(msocket.api.Transport<LocationRequest> httpTransport,
                             msocket.api.Transport<LocationStreamRequest> websocketTransport,
                             akka.actor.typed.ActorSystem<?> actorSystem)

Method Detail

LocationServiceErrorCodec

public io.bullet.borer.Codec<LocationServiceError> LocationServiceErrorCodec()

Specified by:

LocationServiceErrorCodec in interface LocationServiceCodecs

Timestamp

public CommonCodecs.Timestamp$ Timestamp()

componentIdCodec

public io.bullet.borer.Codec<ComponentId> componentIdCodec()

Specified by:

componentIdCodec in interface LocationCodecsBase

connectionInfoCodec

public io.bullet.borer.Codec<ConnectionInfo> connectionInfoCodec()

Specified by:

connectionInfoCodec in interface LocationCodecsBase

doneCodec

public io.bullet.borer.Codec<akka.Done> doneCodec()

Specified by:

doneCodec in interface msocket.api.codecs.BasicCodecs

find

public <L extends Location> scala.concurrent.Future<scala.Option<L>> find(TypedConnection<L> connection)

Specified by:

find in interface csw.location.api.scaladsl.LocationService

finiteDurationCodec

public io.bullet.borer.Codec<scala.concurrent.duration.FiniteDuration> finiteDurationCodec()

Specified by:

finiteDurationCodec in interface CommonCodecs

flatAdtEncoding

public io.bullet.borer.AdtEncodingStrategy flatAdtEncoding()

Specified by:

flatAdtEncoding in interface CommonCodecs

instantDec

public io.bullet.borer.Decoder<java.time.Instant> instantDec()

Specified by:

instantDec in interface CommonCodecs

instantEnc

public io.bullet.borer.Encoder<java.time.Instant> instantEnc()

Specified by:

instantEnc in interface CommonCodecs

list

public scala.concurrent.Future<scala.collection.immutable.List<Location>> list()

Specified by:

list in interface csw.location.api.scaladsl.LocationService

list

public scala.concurrent.Future<scala.collection.immutable.List<Location>> list(ComponentType componentType)

Specified by:

list in interface csw.location.api.scaladsl.LocationService

list

public scala.concurrent.Future<scala.collection.immutable.List<Location>> list(java.lang.String hostname)

Specified by:

list in interface csw.location.api.scaladsl.LocationService

list

public scala.concurrent.Future<scala.collection.immutable.List<Location>> list(ConnectionType connectionType)

Specified by:

list in interface csw.location.api.scaladsl.LocationService

listByPrefix

public scala.concurrent.Future<scala.collection.immutable.List<Location>> listByPrefix(java.lang.String prefix)

Specified by:

listByPrefix in interface csw.location.api.scaladsl.LocationService

locationCodecValue

protected io.bullet.borer.Codec<Location> locationCodecValue()

Specified by:

locationCodecValue in interface LocationCodecsBase

locationHttpMessageCodec

public io.bullet.borer.Codec<LocationRequest> locationHttpMessageCodec()

Specified by:

locationHttpMessageCodec in interface LocationServiceCodecs

locationHttpMessageErrorProtocol

public msocket.api.ErrorProtocol<LocationRequest> locationHttpMessageErrorProtocol()

Specified by:

locationHttpMessageErrorProtocol in interface LocationServiceCodecs

locationWebsocketMessageCodec

public io.bullet.borer.Codec<LocationStreamRequest> locationWebsocketMessageCodec()

Specified by:

locationWebsocketMessageCodec in interface LocationServiceCodecs

locationWebsocketMessageErrorProtocol

public msocket.api.ErrorProtocol<LocationStreamRequest> locationWebsocketMessageErrorProtocol()

Specified by:

locationWebsocketMessageErrorProtocol in interface LocationServiceCodecs

metadataCodec

public io.bullet.borer.Codec<Metadata> metadataCodec()

Specified by:

metadataCodec in interface LocationCodecsBase

networkType

public io.bullet.borer.Codec<NetworkType> networkType()

Specified by:

networkType in interface LocationCodecsBase

prefixCodec

public io.bullet.borer.Codec<Prefix> prefixCodec()

Specified by:

prefixCodec in interface CommonCodecs

register

public scala.concurrent.Future<csw.location.api.scaladsl.RegistrationResult> register(Registration registration)

Specified by:

register in interface csw.location.api.scaladsl.LocationService

registrationCodec

public io.bullet.borer.Codec<Registration> registrationCodec()

Specified by:

registrationCodec in interface LocationCodecsBase

resolve

public <L extends Location> scala.concurrent.Future<scala.Option<L>> resolve(TypedConnection<L> connection,
                                                                             scala.concurrent.duration.FiniteDuration within)

Specified by:

resolve in interface csw.location.api.scaladsl.LocationService

subscribe

public msocket.api.Subscription subscribe(Connection connection,
                                          scala.Function1<TrackingEvent,scala.runtime.BoxedUnit> callback)

Specified by:

subscribe in interface csw.location.api.scaladsl.LocationService

timeoutInSecondsCodec

public io.bullet.borer.Codec<akka.util.Timeout> timeoutInSecondsCodec()

Specified by:

timeoutInSecondsCodec in interface msocket.api.codecs.BasicCodecs

track

public akka.stream.scaladsl.Source<TrackingEvent,msocket.api.Subscription> track(Connection connection)

Specified by:

track in interface csw.location.api.scaladsl.LocationService

trackingEventCodec

public io.bullet.borer.Codec<TrackingEvent> trackingEventCodec()

Specified by:

trackingEventCodec in interface LocationCodecsBase

unregister

public scala.concurrent.Future<akka.Done> unregister(Connection connection)

Specified by:

unregister in interface csw.location.api.scaladsl.LocationService

unregisterAll

public scala.concurrent.Future<akka.Done> unregisterAll()

Specified by:

unregisterAll in interface csw.location.api.scaladsl.LocationService

uriCodec

public io.bullet.borer.Codec<java.net.URI> uriCodec()

Specified by:

uriCodec in interface LocationCodecsBase