make wrappedFn private

Author: PhakornKiong

dbos/queue.go

@@ -243,7 +243,7 @@ func (qr *queueRunner) run(ctx *dbosContext) {
 					}
 				}
 
-				_, err := registeredWorkflow.WrappedFunction(ctx, input, WithWorkflowID(workflow.id))
+				_, err := registeredWorkflow.wrappedFunction(ctx, input, WithWorkflowID(workflow.id))
 				if err != nil {
 					qr.logger.Error("Error running queued workflow", "error", err)
 				}

dbos/recovery.go

@@ -59,7 +59,7 @@ func recoverPendingWorkflows(ctx *dbosContext, executorIDs []string) ([]Workflow
 			WithWorkflowID(workflow.ID),
 		}
 		// Create a workflow context from the executor context
-		handle, err := registeredWorkflow.WrappedFunction(ctx, workflow.Input, opts...)
+		handle, err := registeredWorkflow.wrappedFunction(ctx, workflow.Input, opts...)
 		if err != nil {
 			return nil, err
 		}

dbos/workflow.go

@@ -270,7 +270,7 @@ func (h *workflowHandleProxy[R]) GetWorkflowID() string {
 type wrappedWorkflowFunc func(ctx DBOSContext, input any, opts ...WorkflowOption) (WorkflowHandle[any], error)
 
 type WorkflowRegistryEntry struct {
-	WrappedFunction wrappedWorkflowFunc
+	wrappedFunction wrappedWorkflowFunc
 	MaxRetries      int
 	Name            string
 	FQN             string // Fully qualified name of the workflow function
@@ -290,7 +290,7 @@ func registerWorkflow(ctx DBOSContext, workflowFQN string, fn wrappedWorkflowFun
 
 	// Check if workflow already exists and store atomically using LoadOrStore
 	entry := WorkflowRegistryEntry{
-		WrappedFunction: fn,
+		wrappedFunction: fn,
 		FQN:             workflowFQN,
 		MaxRetries:      maxRetries,
 		Name:            customName,