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 Object implements csw.location.api.scaladsl.LocationService, LocationServiceCodecs, msocket.api.codecs.BasicCodecs

  • Constructor Details

    • LocationServiceClient

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

  • Method Details

    • 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<Instant> instantDec()
      Specified by:
      instantDec in interface CommonCodecs

    • instantEnc

      public io.bullet.borer.Encoder<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(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(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<URI> uriCodec()
      Specified by:
      uriCodec in interface LocationCodecsBase