trait Actions extends AnyRef
Service that the SDK (in the user service) implements to make actions available to the proxy
- Annotations
- @AkkaGrpcGenerated()
- Source
- Actions.scala
- Alphabetic
- By Inheritance
- Actions
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def handleStreamed(in: Source[ActionCommand, NotUsed]): Source[ActionResponse, NotUsed]
Handle a full duplex streamed command.
Handle a full duplex streamed command. The first message in will contain the request metadata, including the service name and command name. It will not have an associated payload set. This will be followed by zero to many messages in with a payload, but no service name or command name set. Zero or more replies may be sent, each containing either a direct reply, a forward or a failure, and each may contain many side effects. If the underlying transport supports per stream metadata, rather than per message metadata, then that metadata will only be included in the metadata of the first message. In contrast, if the underlying transport supports per message metadata, there will be no metadata on the first message, the metadata will instead be found on each subsequent message. The semantics of stream closure in this protocol map 1:1 with the semantics of gRPC stream closure, that is, when the client closes the stream, the stream is considered half closed, and the server should eventually, but not necessarily immediately, close the stream with a status code and trailers. If however the server closes the stream with a status code and trailers, the stream is immediately considered completely closed, and no further messages sent by the client will be handled by the server. Either the client or the server may cancel the stream at any time, cancellation is indicated through an HTTP2 stream RST message.
- abstract def handleStreamedIn(in: Source[ActionCommand, NotUsed]): Future[ActionResponse]
Handle a streamed in command.
Handle a streamed in command. The first message in will contain the request metadata, including the service name and command name. It will not have an associated payload set. This will be followed by zero to many messages in with a payload, but no service name or command name set. If the underlying transport supports per stream metadata, rather than per message metadata, then that metadata will only be included in the metadata of the first message. In contrast, if the underlying transport supports per message metadata, there will be no metadata on the first message, the metadata will instead be found on each subsequent message. The semantics of stream closure in this protocol map 1:1 with the semantics of gRPC stream closure, that is, when the client closes the stream, the stream is considered half closed, and the server should eventually, but not necessarily immediately, send a response message with a status code and trailers. If however the server sends a response message before the client closes the stream, the stream is completely closed, and the client should handle this and stop sending more messages. Either the client or the server may cancel the stream at any time, cancellation is indicated through an HTTP2 stream RST message.
- abstract def handleStreamedOut(in: ActionCommand): Source[ActionResponse, NotUsed]
Handle a streamed out command.
Handle a streamed out command. The input command will contain the service name, command name, request metadata and the command payload. Zero or more replies may be sent, each containing either a direct reply, a forward or a failure, and each may contain many side effects. The stream to the client will be closed when the this stream is closed, with the same status as this stream is closed with. Either the client or the server may cancel the stream at any time, cancellation is indicated through an HTTP2 stream RST message.
- abstract def handleUnary(in: ActionCommand): Future[ActionResponse]
Handle a unary command.
Handle a unary command. The input command will contain the service name, command name, request metadata and the command payload. The reply may contain a direct reply, a forward or a failure, and it may contain many side effects.
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- def +(other: String): String
- def ->[B](y: B): (Actions, B)
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def ensuring(cond: (Actions) => Boolean, msg: => Any): Actions
- def ensuring(cond: (Actions) => Boolean): Actions
- def ensuring(cond: Boolean, msg: => Any): Actions
- def ensuring(cond: Boolean): Actions
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)
- def formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from Actions toStringFormat[Actions] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @deprecated @inline()
- Deprecated
(Since version 2.12.16) Use
formatString.format(value)
instead ofvalue.formatted(formatString)
, or use thef""
string interpolator. In Java 15 and later,formatted
resolves to the new method in String which has reversed parameters.
- def →[B](y: B): (Actions, B)
- Implicit
- This member is added by an implicit conversion from Actions toArrowAssoc[Actions] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @deprecated
- Deprecated
(Since version 2.13.0) Use
->
instead. If you still wish to display it as one character, consider using a font with programming ligatures such as Fira Code.