batcher

package
v1.32.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 15, 2026 License: MIT Imports: 40 Imported by: 0

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"
	// BatchOperationVisibilityQueryMemo stores the batch operation's visibility query in memo
	BatchOperationVisibilityQueryMemo = "batch_operation_visibility_query"
	// BatchOperationExecutionsMemo stores the batch operation's explicit target
	// executions (as opposed to a visibility query) in memo, encoded as a
	// []*commonpb.Execution.
	BatchOperationExecutionsMemo = "batch_operation_executions"

	// BatchTypeTerminateWorkflows is batch type for terminating workflows
	BatchTypeTerminateWorkflows = "terminate"
	// BatchTypeCancelWorkflows is batch type for canceling workflows
	BatchTypeCancelWorkflows = "cancel"
	// BatchTypeSignalWorkflows is batch type for signaling workflows
	BatchTypeSignalWorkflows = "signal"
	// BatchTypeDeleteWorkflows is batch type for deleting workflows
	BatchTypeDeleteWorkflows = "delete"
	// BatchTypeResetWorkflows is batch type for resetting workflows
	BatchTypeResetWorkflows = "reset"
	// BatchTypeUpdateWorkflowOptions is batch type for updating the options of workflow executions
	BatchTypeUpdateWorkflowOptions = "update_options"

	// BatchTypeTerminateActivities is batch type for terminating activities
	BatchTypeTerminateActivities = "terminate_activities"
	// BatchTypeCancelActivities is batch type for canceling activities
	BatchTypeCancelActivities = "cancel_activities"
	// BatchTypeDeleteActivities is batch type for deleting activities
	BatchTypeDeleteActivities = "delete_activities"
	// BatchTypeResetActivities is batch type for resetting activities
	BatchTypeResetActivities = "reset_activities"
	// BatchTypeUnpauseActivities is batch type for unpausing activities
	BatchTypeUnpauseActivities = "unpause_activities"
	// BatchTypeUpdateActivitiesOptions is batch type for updating the options of activities
	BatchTypeUpdateActivitiesOptions = "update_activity_options"
)

Variables

Functions

func NewResult

func NewResult(
	dc *dynamicconfig.Collection,
	params activityDeps,
) fxResult

func ValidateBatchOperation

func ValidateBatchOperation(params *workflowservice.StartBatchOperationRequest) error

nolint:revive,cognitive-complexity

Types

type AdminBatcherRateLimiter

type AdminBatcherRateLimiter quotas.RequestRateLimiter

func AdminBatcherRateLimiterProvider

func AdminBatcherRateLimiterProvider(
	dc *dynamicconfig.Collection,
	serviceResolver membership.ServiceResolver,
	logger log.Logger,
) AdminBatcherRateLimiter

type BatchOperationStats

type BatchOperationStats struct {
	NumSuccess int
	NumFailure int
}

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

func BatchWorkflowProtobuf(ctx workflow.Context, batchParams *batchspb.BatchOperationInput) (HeartBeatDetails, error)

BatchWorkflowProtobuf is the workflow that runs a batch job of resetting workflows.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL