support

type ExprMapperFactory struct {
	// contains filtered or unexported fields
}

type OverrideExprMapper struct {
	// contains filtered or unexported fields
}

type TelemetryService interface {
	PipelineStarted(pipelineId, instanceId string, data map[string]interface{})
	StageStarted(pipelineId, instanceId, stageId string, data map[string]interface{})
	StageFinished(pipelineId, instanceId, stageId string, data map[string]interface{})
	PipelineFinished(pipelineId, instanceId string, data map[string]interface{})
}

type TimerCallback func(ctx activity.Context) (resume bool)

type TimerSupport interface {
	// HasTimer indicates if a timer already exists
	HasTimer(repeating bool) bool

	// CancelTimer cancels the existing timer
	CancelTimer(repeating bool)

	UpdateTimer(repeating bool)

	// CreateTimer creates a timer, note: can only have one active timer at a time for an activity
	CreateTimer(interval time.Duration, callback TimerCallback, repeating bool) error
}