runtimestate

func AddEvent ¶

func AddEvent(s *protos.OrchestrationRuntimeState, e *protos.HistoryEvent) error

AddEvent appends a new history event to the orchestration history

func ApplyActions ¶

func ApplyActions(s *protos.OrchestrationRuntimeState, customStatus *wrapperspb.StringValue, actions []*protos.OrchestratorAction, currentTraceContext *protos.TraceContext) (bool, error)

ApplyActions takes a set of actions and updates its internal state, including populating the outbox.

func CancelPending ¶

func CancelPending(s *protos.OrchestrationRuntimeState)

useful for abruptly stopping any execution of an orchestration from the backend

func CompletedTime ¶

func CompletedTime(s *protos.OrchestrationRuntimeState) (time.Time, error)

func CreatedTime ¶

func CreatedTime(s *protos.OrchestrationRuntimeState) (time.Time, error)

func FailureDetails ¶

func FailureDetails(s *protos.OrchestrationRuntimeState) (*protos.TaskFailureDetails, error)

func GetStartedTime ¶

func GetStartedTime(s *protos.OrchestrationRuntimeState) time.Time

func Input ¶

func Input(s *protos.OrchestrationRuntimeState) (*wrapperspb.StringValue, error)

func IsCompleted ¶

func IsCompleted(s *protos.OrchestrationRuntimeState) bool

func IsValid ¶

func IsValid(s *protos.OrchestrationRuntimeState) bool

func LastUpdatedTime ¶

func LastUpdatedTime(s *protos.OrchestrationRuntimeState) (time.Time, error)

func Name ¶

func Name(s *protos.OrchestrationRuntimeState) (string, error)

func NewOrchestrationRuntimeState ¶

func NewOrchestrationRuntimeState(instanceID string, customStatus *wrapperspb.StringValue, existingHistory []*protos.HistoryEvent) *protos.OrchestrationRuntimeState

func Output ¶

func Output(s *protos.OrchestrationRuntimeState) (*wrapperspb.StringValue, error)

func RuntimeStatus ¶

func RuntimeStatus(s *protos.OrchestrationRuntimeState) protos.OrchestrationStatus

func String ¶

func String(s *protos.OrchestrationRuntimeState) string