Documentation
¶
Index ¶
Constants ¶
View Source
const ( // BatchWFTypeName is the workflow type BatchWFTypeName = "temporal-sys-batch-workflow" BatchWFTypeProtobufName = "temporal-sys-batch-workflow-protobuf" NamespaceDivision = "TemporalBatcher" AdminNamespaceDivision = "TemporalAdminBatcher" )
View Source
const ( // BatchOperationTypeMemo stores batch operation type in memo BatchOperationTypeMemo = "batch_operation_type" // BatchReasonMemo stores batch operation reason in memo BatchReasonMemo = "batch_operation_reason" // BatchOperationStatsMemo stores batch operation stats in memo BatchOperationStatsMemo = "batch_operation_stats" // BatchTypeTerminate is batch type for terminating workflows BatchTypeTerminate = "terminate" // BatchTypeCancel is the batch type for canceling workflows BatchTypeCancel = "cancel" // BatchTypeSignal is batch type for signaling workflows BatchTypeSignal = "signal" // BatchTypeDelete is batch type for deleting workflows BatchTypeDelete = "delete" // BatchTypeReset is batch type for resetting workflows BatchTypeReset = "reset" // BatchTypeUpdateOptions is batch type for updating the options of workflow executions BatchTypeUpdateOptions = "update_options" // BatchTypeUnpauseActivities is batch type for unpausing activities BatchTypeUnpauseActivities = "unpause_activities" // BatchTypeUpdateActivitiesOptions is batch type for updating the options of activities BatchTypeUpdateActivitiesOptions = "update_activity_options" // BatchTypeResetActivities is batch type for resetting activities BatchTypeResetActivities = "reset_activities" )
Variables ¶
View Source
var ( OpenBatchOperationQuery = fmt.Sprintf("%s = '%s' AND %s = %d", sadefs.TemporalNamespaceDivision, NamespaceDivision, sadefs.ExecutionStatus, int(enumspb.WORKFLOW_EXECUTION_STATUS_RUNNING), ) OpenAdminBatchOperationQuery = fmt.Sprintf("%s = '%s' AND %s = %d", sadefs.TemporalNamespaceDivision, AdminNamespaceDivision, sadefs.ExecutionStatus, int(enumspb.WORKFLOW_EXECUTION_STATUS_RUNNING), ) )
Functions ¶
func NewResult ¶ added in v1.2.0
func NewResult( dc *dynamicconfig.Collection, params activityDeps, ) fxResult
func ValidateBatchOperation ¶ added in v1.2.0
func ValidateBatchOperation(params *workflowservice.StartBatchOperationRequest) error
nolint:revive,cognitive-complexity
Types ¶
type BatchOperationStats ¶ added in v1.2.0
type HeartBeatDetails ¶
type HeartBeatDetails struct {
PageToken []byte
CurrentPage int
// This is just an estimation for visibility
TotalEstimate int64
// Number of workflows processed successfully
SuccessCount int
// Number of workflows that give up due to errors.
ErrorCount int
}
HeartBeatDetails is the struct for heartbeat details
func BatchWorkflowProtobuf ¶ added in v1.2.0
func BatchWorkflowProtobuf(ctx workflow.Context, batchParams *batchspb.BatchOperationInput) (HeartBeatDetails, error)
BatchWorkflowProtobuf is the workflow that runs a batch job of resetting workflows.
Click to show internal directories.
Click to hide internal directories.