package workflow_entity
Ordering
- Alphabetic
Visibility
- Public
- Protected
Type Members
- final case class EndTransition(unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[EndTransition] with Product with Serializable
- Annotations
- @SerialVersionUID()
- final case class ExecuteStep(commandId: Long = 0L, stepName: String = "", input: Option[Any] = _root_.scala.None, userState: Option[Any] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ExecuteStep] with Product with Serializable
- Annotations
- @SerialVersionUID()
- final case class GetNextStep(commandId: Long = 0L, stepName: String = "", result: Option[Any] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[GetNextStep] with Product with Serializable
- Annotations
- @SerialVersionUID()
- final case class NoTransition(unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[NoTransition] with Product with Serializable
- Annotations
- @SerialVersionUID()
- final case class Pause(unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[Pause] with Product with Serializable
- Annotations
- @SerialVersionUID()
- final case class RecoverStrategy(maxRetries: Int = 0, failoverTo: Option[StepTransition] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[RecoverStrategy] with Product with Serializable
- Annotations
- @SerialVersionUID()
- final case class StepConfig(stepName: String = "", stepTimeout: Option[Duration] = _root_.scala.None, recoverStrategy: Option[RecoverStrategy] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[StepConfig] with Product with Serializable
- Annotations
- @SerialVersionUID()
- final case class StepDeferredCall(serviceName: String = "", commandName: String = "", payload: Option[Any] = _root_.scala.None, metadata: Option[Metadata] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[StepDeferredCall] with Product with Serializable
- serviceName
The name of the service to perform the side effect on.
- commandName
The name of the command.
- payload
The payload of the command.
- metadata
The metadata to include with the side effect
- Annotations
- @SerialVersionUID()
- final case class StepExecuted(result: Option[Any] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[StepExecuted] with Product with Serializable
- Annotations
- @SerialVersionUID()
- final case class StepExecutionFailed(errorMessage: String = "", unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[StepExecutionFailed] with Product with Serializable
- Annotations
- @SerialVersionUID()
- final case class StepResponse(commandId: Long = 0L, stepName: String = "", response: Response = kalix.protocol.workflow_entity.StepResponse.Response.Empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[StepResponse] with Product with Serializable
- Annotations
- @SerialVersionUID()
- final case class StepTransition(stepName: String = "", input: Option[Any] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[StepTransition] with Product with Serializable
- Annotations
- @SerialVersionUID()
- final case class WorkflowClientAction(action: WorkflowClientAction.Action = kalix.protocol.workflow_entity.WorkflowClientAction.Action.Empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[WorkflowClientAction] with Product with Serializable
TODO rename
TODO rename
- Annotations
- @SerialVersionUID()
- final case class WorkflowConfig(workflowTimeout: Option[Duration] = _root_.scala.None, failoverTo: Option[StepTransition] = _root_.scala.None, failoverRecoverStrategy: Option[RecoverStrategy] = _root_.scala.None, defaultStepConfig: Option[StepConfig] = _root_.scala.None, stepConfigs: Seq[StepConfig] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[WorkflowConfig] with Product with Serializable
- failoverTo
in case of workflow timeout
- defaultStepConfig
step_name is ignored
- Annotations
- @SerialVersionUID()
- final case class WorkflowEffect(commandId: Long = 0L, clientAction: Option[WorkflowClientAction] = _root_.scala.None, userState: Option[Any] = _root_.scala.None, transition: Transition = kalix.protocol.workflow_entity.WorkflowEffect.Transition.Empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[WorkflowEffect] with Product with Serializable
A reply to a command or state execution TODO rename it
A reply to a command or state execution TODO rename it
- commandId
The id of the command being replied to. Must match the input command.
- clientAction
The action to take
- Annotations
- @SerialVersionUID()
- trait WorkflowEntities extends AnyRef
Service that the SDK (in the user service) implements to make workflow available to the proxy
Service that the SDK (in the user service) implements to make workflow available to the proxy
- Annotations
- @AkkaGrpcGenerated()
- final case class WorkflowEntityInit(serviceName: String = "", entityId: String = "", userState: Option[Any] = _root_.scala.None, finished: Boolean = false, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[WorkflowEntityInit] with Product with Serializable
The init message.
The init message. This will always be the first message sent to the workflow when it is loaded.
- serviceName
The name of the service that this entity is a part of.
- entityId
The ID of the workflow.
- userState
If present the workflow should initialise its state using this field.
- finished
Marker for the sdk that initialized workflow has been finished.
- Annotations
- @SerialVersionUID()
- final case class WorkflowStreamIn(message: Message = kalix.protocol.workflow_entity.WorkflowStreamIn.Message.Empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[WorkflowStreamIn] with Product with Serializable
Input message type for the gRPC stream in.
Input message type for the gRPC stream in.
- Annotations
- @SerialVersionUID()
- final case class WorkflowStreamOut(message: Message = kalix.protocol.workflow_entity.WorkflowStreamOut.Message.Empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[WorkflowStreamOut] with Product with Serializable
Output message type for the gRPC stream out.
Output message type for the gRPC stream out.
- Annotations
- @SerialVersionUID()
Value Members
- object EndTransition extends GeneratedMessageCompanion[EndTransition]
- object ExecuteStep extends GeneratedMessageCompanion[ExecuteStep]
- object GetNextStep extends GeneratedMessageCompanion[GetNextStep]
- object NoTransition extends GeneratedMessageCompanion[NoTransition]
- object Pause extends GeneratedMessageCompanion[Pause]
- object RecoverStrategy extends GeneratedMessageCompanion[RecoverStrategy]
- object StepConfig extends GeneratedMessageCompanion[StepConfig]
- object StepDeferredCall extends GeneratedMessageCompanion[StepDeferredCall]
- object StepExecuted extends GeneratedMessageCompanion[StepExecuted]
- object StepExecutionFailed extends GeneratedMessageCompanion[StepExecutionFailed]
- object StepResponse extends GeneratedMessageCompanion[StepResponse]
- object StepTransition extends GeneratedMessageCompanion[StepTransition]
- object WorkflowClientAction extends GeneratedMessageCompanion[WorkflowClientAction]
- object WorkflowConfig extends GeneratedMessageCompanion[WorkflowConfig]
- object WorkflowEffect extends GeneratedMessageCompanion[WorkflowEffect]
- object WorkflowEntities extends ServiceDescription
- Annotations
- @AkkaGrpcGenerated()
- object WorkflowEntitiesHandler
- Annotations
- @ApiMayChange() @AkkaGrpcGenerated()
- object WorkflowEntityInit extends GeneratedMessageCompanion[WorkflowEntityInit]
- object WorkflowEntityProto extends GeneratedFileObject
- object WorkflowStreamIn extends GeneratedMessageCompanion[WorkflowStreamIn]
- object WorkflowStreamOut extends GeneratedMessageCompanion[WorkflowStreamOut]