Package csw.command.api.client

Class CommandServiceClient

java.lang.Object

csw.command.api.client.CommandServiceClient

All Implemented Interfaces:

CommandServiceCodecs, csw.command.api.scaladsl.CommandService, ParamCodecs, ParamCodecsBase, CommonCodecs, msocket.api.codecs.BasicCodecs

public class CommandServiceClient
extends Object
implements csw.command.api.scaladsl.CommandService, CommandServiceCodecs

Nested Class Summary

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

CommonCodecs.Timestamp, CommonCodecs.Timestamp$

Constructor Summary

Constructors

Constructor	Description
CommandServiceClient(msocket.api.Transport<CommandServiceRequest> httpTransport, msocket.api.Transport<CommandServiceStreamRequest> websocketTransport, akka.actor.typed.ActorSystem<?> actorSystem)

Method Summary

Modifier and Type	Method	Description
io.bullet.borer.Codec<Angle>	angleCodec()
io.bullet.borer.Decoder<byte[]>	bytesDec()
io.bullet.borer.Encoder<byte[]>	bytesEnc()
io.bullet.borer.Decoder<Character>	characterDec()
io.bullet.borer.Encoder<Character>	characterEnc()
io.bullet.borer.Decoder<Object>	charDec()
io.bullet.borer.Encoder<Object>	charEnc()
io.bullet.borer.Codec<Choice>	choiceCodec()
io.bullet.borer.Codec<CommandIssue>	commandIssueCodecValue()
io.bullet.borer.Codec<CommandName>	commandNameCodec()
protected io.bullet.borer.Codec<CommandResponse>	commandResponseCodecValue()
msocket.api.ErrorProtocol<CommandServiceRequest>	CommandServiceHttpErrorProtocol()
msocket.api.ErrorProtocol<CommandServiceStreamRequest>	CommandServiceWebsocketErrorProtocol()
io.bullet.borer.Codec<ControlCommand>	controlCommandCodec()
io.bullet.borer.Codec<Coords.Coord>	coordCodecValue()
io.bullet.borer.Codec<CurrentState>	currentStateCodecValue()
io.bullet.borer.Codec<akka.Done>	doneCodec()
io.bullet.borer.Codec<Event>	eventCodec()
io.bullet.borer.Codec<EventName>	eventNameCodec()
io.bullet.borer.Codec<scala.concurrent.duration.FiniteDuration>	finiteDurationCodec()
io.bullet.borer.AdtEncodingStrategy	flatAdtEncoding()
io.bullet.borer.Codec<CommandServiceRequest>	httpCodecsValue()
io.bullet.borer.Codec<Id>	idCodec()
io.bullet.borer.Decoder<Instant>	instantDec()
io.bullet.borer.Encoder<Instant>	instantEnc()
io.bullet.borer.Decoder<Byte[]>	javaByteArrayDec()
io.bullet.borer.Encoder<Byte[]>	javaByteArrayEnc()
io.bullet.borer.Codec<ObsId>	obsIdCodec()
scala.concurrent.Future<CommandResponse.OnewayResponse>	oneway(ControlCommand controlCommand)
scala.concurrent.Future<CommandResponse.MatchingResponse>	onewayAndMatch(ControlCommand controlCommand, StateMatcher stateMatcher)
io.bullet.borer.Decoder<Parameter<?>>	paramDecExistential()
io.bullet.borer.Encoder<Parameter<?>>	paramEncExistential()
io.bullet.borer.Codec<Prefix>	prefixCodec()
io.bullet.borer.Codec<ProperMotion>	properMotionCodec()
scala.concurrent.Future<CommandResponse.SubmitResponse>	query(Id commandRunId)
scala.concurrent.Future<CommandResponse.SubmitResponse>	queryFinal(Id commandRunId, akka.util.Timeout timeout)
io.bullet.borer.Codec<Result>	resultCodec()
io.bullet.borer.Codec<Sequence>	sequenceCodec()
io.bullet.borer.Codec<SequenceCommand>	sequenceCommandCodec()
io.bullet.borer.Codec<StateName>	stateNameCodec()
io.bullet.borer.Codec<StateVariable>	stateVariableCodecValue()
scala.concurrent.Future<CommandResponse.SubmitResponse>	submit(ControlCommand controlCommand)
scala.concurrent.Future<scala.collection.immutable.List<CommandResponse.SubmitResponse>>	submitAllAndWait(scala.collection.immutable.List<ControlCommand> submitCommands, akka.util.Timeout timeout)
scala.concurrent.Future<CommandResponse.SubmitResponse>	submitAndWait(ControlCommand controlCommand, akka.util.Timeout timeout)
akka.stream.scaladsl.Source<CurrentState,msocket.api.Subscription>	subscribeCurrentState(scala.collection.immutable.Set<StateName> names)
msocket.api.Subscription	subscribeCurrentState(scala.collection.immutable.Set<StateName> names, scala.Function1<CurrentState,scala.runtime.BoxedUnit> callback)
msocket.api.Subscription	subscribeCurrentState(scala.Function1<CurrentState,scala.runtime.BoxedUnit> callback)
io.bullet.borer.Codec<Coords.Tag>	tagCodec()
io.bullet.borer.Codec<TAITime>	taiTimeCodec()
io.bullet.borer.Codec<akka.util.Timeout>	timeoutInSecondsCodec()
CommonCodecs.Timestamp$	Timestamp()
io.bullet.borer.Codec<UTCTime>	utcTimeCodec()
scala.concurrent.Future<CommandResponse.ValidateResponse>	validate(ControlCommand controlCommand)
io.bullet.borer.Codec<CommandServiceStreamRequest>	websocketCodecs()

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.command.api.scaladsl.CommandService

subscribeCurrentState$default$1

Methods inherited from interface csw.prefix.codecs.CommonCodecs

enumCodec

Methods inherited from interface csw.params.core.formats.ParamCodecs

commandResponseCodec, coordCodec

Methods inherited from interface csw.params.core.formats.ParamCodecsBase

arrayDataCodec, matrixDataCodec, paramCodec, paramCoreCodec, waCodec

Constructor Details

CommandServiceClient

public CommandServiceClient(msocket.api.Transport<CommandServiceRequest> httpTransport,
 msocket.api.Transport<CommandServiceStreamRequest> websocketTransport,
 akka.actor.typed.ActorSystem<?> actorSystem)

Method Details

CommandServiceHttpErrorProtocol

public msocket.api.ErrorProtocol<CommandServiceRequest> CommandServiceHttpErrorProtocol()

Specified by:

CommandServiceHttpErrorProtocol in interface CommandServiceCodecs

CommandServiceWebsocketErrorProtocol

public msocket.api.ErrorProtocol<CommandServiceStreamRequest> CommandServiceWebsocketErrorProtocol()

Specified by:

CommandServiceWebsocketErrorProtocol in interface CommandServiceCodecs

Timestamp

public CommonCodecs.Timestamp$ Timestamp()

angleCodec

public io.bullet.borer.Codec<Angle> angleCodec()

Specified by:

angleCodec in interface ParamCodecsBase

bytesDec

public io.bullet.borer.Decoder<byte[]> bytesDec()

Specified by:

bytesDec in interface ParamCodecsBase

bytesEnc

public io.bullet.borer.Encoder<byte[]> bytesEnc()

Specified by:

bytesEnc in interface ParamCodecsBase

charDec

public io.bullet.borer.Decoder<Object> charDec()

Specified by:

charDec in interface ParamCodecsBase

charEnc

public io.bullet.borer.Encoder<Object> charEnc()

Specified by:

charEnc in interface ParamCodecsBase

characterDec

public io.bullet.borer.Decoder<Character> characterDec()

Specified by:

characterDec in interface ParamCodecsBase

characterEnc

public io.bullet.borer.Encoder<Character> characterEnc()

Specified by:

characterEnc in interface ParamCodecsBase

choiceCodec

public io.bullet.borer.Codec<Choice> choiceCodec()

Specified by:

choiceCodec in interface ParamCodecsBase

commandIssueCodecValue

public io.bullet.borer.Codec<CommandIssue> commandIssueCodecValue()

Specified by:

commandIssueCodecValue in interface ParamCodecsBase

commandNameCodec

public io.bullet.borer.Codec<CommandName> commandNameCodec()

Specified by:

commandNameCodec in interface ParamCodecsBase

commandResponseCodecValue

protected io.bullet.borer.Codec<CommandResponse> commandResponseCodecValue()

Specified by:

commandResponseCodecValue in interface ParamCodecsBase

controlCommandCodec

public io.bullet.borer.Codec<ControlCommand> controlCommandCodec()

Specified by:

controlCommandCodec in interface ParamCodecsBase

coordCodecValue

public io.bullet.borer.Codec<Coords.Coord> coordCodecValue()

Specified by:

coordCodecValue in interface ParamCodecsBase

currentStateCodecValue

public io.bullet.borer.Codec<CurrentState> currentStateCodecValue()

Specified by:

currentStateCodecValue in interface ParamCodecsBase

doneCodec

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

Specified by:

doneCodec in interface msocket.api.codecs.BasicCodecs

eventCodec

public io.bullet.borer.Codec<Event> eventCodec()

Specified by:

eventCodec in interface ParamCodecsBase

eventNameCodec

public io.bullet.borer.Codec<EventName> eventNameCodec()

Specified by:

eventNameCodec in interface ParamCodecsBase

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

httpCodecsValue

public io.bullet.borer.Codec<CommandServiceRequest> httpCodecsValue()

Specified by:

httpCodecsValue in interface CommandServiceCodecs

idCodec

public io.bullet.borer.Codec<Id> idCodec()

Specified by:

idCodec in interface ParamCodecsBase

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

javaByteArrayDec

public io.bullet.borer.Decoder<Byte[]> javaByteArrayDec()

Specified by:

javaByteArrayDec in interface ParamCodecsBase

javaByteArrayEnc

public io.bullet.borer.Encoder<Byte[]> javaByteArrayEnc()

Specified by:

javaByteArrayEnc in interface ParamCodecsBase

obsIdCodec

public io.bullet.borer.Codec<ObsId> obsIdCodec()

Specified by:

obsIdCodec in interface ParamCodecsBase

oneway

public scala.concurrent.Future<CommandResponse.OnewayResponse> oneway(ControlCommand controlCommand)

Specified by:

oneway in interface csw.command.api.scaladsl.CommandService

onewayAndMatch

public scala.concurrent.Future<CommandResponse.MatchingResponse> onewayAndMatch(ControlCommand controlCommand,
 StateMatcher stateMatcher)

Specified by:

onewayAndMatch in interface csw.command.api.scaladsl.CommandService

paramDecExistential

public io.bullet.borer.Decoder<Parameter<?>> paramDecExistential()

Specified by:

paramDecExistential in interface ParamCodecsBase

paramEncExistential

public io.bullet.borer.Encoder<Parameter<?>> paramEncExistential()

Specified by:

paramEncExistential in interface ParamCodecsBase

prefixCodec

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

Specified by:

prefixCodec in interface CommonCodecs

properMotionCodec

public io.bullet.borer.Codec<ProperMotion> properMotionCodec()

Specified by:

properMotionCodec in interface ParamCodecsBase

query

public scala.concurrent.Future<CommandResponse.SubmitResponse> query(Id commandRunId)

Specified by:

query in interface csw.command.api.scaladsl.CommandService

queryFinal

public scala.concurrent.Future<CommandResponse.SubmitResponse> queryFinal(Id commandRunId,
 akka.util.Timeout timeout)

Specified by:

queryFinal in interface csw.command.api.scaladsl.CommandService

resultCodec

public io.bullet.borer.Codec<Result> resultCodec()

Specified by:

resultCodec in interface ParamCodecsBase

sequenceCodec

public io.bullet.borer.Codec<Sequence> sequenceCodec()

Specified by:

sequenceCodec in interface ParamCodecsBase

sequenceCommandCodec

public io.bullet.borer.Codec<SequenceCommand> sequenceCommandCodec()

Specified by:

sequenceCommandCodec in interface ParamCodecsBase

stateNameCodec

public io.bullet.borer.Codec<StateName> stateNameCodec()

Specified by:

stateNameCodec in interface ParamCodecsBase

stateVariableCodecValue

public io.bullet.borer.Codec<StateVariable> stateVariableCodecValue()

Specified by:

stateVariableCodecValue in interface ParamCodecsBase

submit

public scala.concurrent.Future<CommandResponse.SubmitResponse> submit(ControlCommand controlCommand)

Specified by:

submit in interface csw.command.api.scaladsl.CommandService

submitAllAndWait

public scala.concurrent.Future<scala.collection.immutable.List<CommandResponse.SubmitResponse>> submitAllAndWait(scala.collection.immutable.List<ControlCommand> submitCommands,
 akka.util.Timeout timeout)

Specified by:

submitAllAndWait in interface csw.command.api.scaladsl.CommandService

submitAndWait

public scala.concurrent.Future<CommandResponse.SubmitResponse> submitAndWait(ControlCommand controlCommand,
 akka.util.Timeout timeout)

Specified by:

submitAndWait in interface csw.command.api.scaladsl.CommandService

subscribeCurrentState

public akka.stream.scaladsl.Source<CurrentState,msocket.api.Subscription> subscribeCurrentState(scala.collection.immutable.Set<StateName> names)

Specified by:

subscribeCurrentState in interface csw.command.api.scaladsl.CommandService

subscribeCurrentState

public msocket.api.Subscription subscribeCurrentState(scala.Function1<CurrentState,scala.runtime.BoxedUnit> callback)

Specified by:

subscribeCurrentState in interface csw.command.api.scaladsl.CommandService

subscribeCurrentState

public msocket.api.Subscription subscribeCurrentState(scala.collection.immutable.Set<StateName> names,
 scala.Function1<CurrentState,scala.runtime.BoxedUnit> callback)

Specified by:

subscribeCurrentState in interface csw.command.api.scaladsl.CommandService

tagCodec

public io.bullet.borer.Codec<Coords.Tag> tagCodec()

Specified by:

tagCodec in interface ParamCodecsBase

taiTimeCodec

public io.bullet.borer.Codec<TAITime> taiTimeCodec()

Specified by:

taiTimeCodec in interface ParamCodecsBase

timeoutInSecondsCodec

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

Specified by:

timeoutInSecondsCodec in interface msocket.api.codecs.BasicCodecs

utcTimeCodec

public io.bullet.borer.Codec<UTCTime> utcTimeCodec()

Specified by:

utcTimeCodec in interface ParamCodecsBase

validate

public scala.concurrent.Future<CommandResponse.ValidateResponse> validate(ControlCommand controlCommand)

Specified by:

validate in interface csw.command.api.scaladsl.CommandService

websocketCodecs

public io.bullet.borer.Codec<CommandServiceStreamRequest> websocketCodecs()

Specified by:

websocketCodecs in interface CommandServiceCodecs