types can now be private

Author: maxdml

dbos/system_database.go

@@ -50,9 +50,9 @@ type systemDatabase interface {
 
 	// Communication (special steps)
 	send(ctx context.Context, input WorkflowSendInput) error
-	recv(ctx context.Context, input RecvInput) (any, error)
+	recv(ctx context.Context, input recvInput) (any, error)
 	setEvent(ctx context.Context, input WorkflowSetEventInput) error
-	getEvent(ctx context.Context, input GetEventInput) (any, error)
+	getEvent(ctx context.Context, input getEventInput) (any, error)
 
 	// Timers (special steps)
 	sleep(ctx context.Context, duration time.Duration) (time.Duration, error)
@@ -1510,7 +1510,7 @@ func (s *sysDB) send(ctx context.Context, input WorkflowSendInput) error {
 }
 
 // Recv is a special type of step that receives a message destined for a given workflow
-func (s *sysDB) recv(ctx context.Context, input RecvInput) (any, error) {
+func (s *sysDB) recv(ctx context.Context, input recvInput) (any, error) {
 	functionName := "DBOS.recv"
 
 	// Get workflow state from context
@@ -1733,7 +1733,7 @@ func (s *sysDB) setEvent(ctx context.Context, input WorkflowSetEventInput) error
 	return nil
 }
 
-func (s *sysDB) getEvent(ctx context.Context, input GetEventInput) (any, error) {
+func (s *sysDB) getEvent(ctx context.Context, input getEventInput) (any, error) {
 	functionName := "DBOS.getEvent"
 
 	// Get workflow state from context (optional for GetEvent as we can get an event from outside a workflow)

dbos/workflow.go

@@ -1083,7 +1083,6 @@ func (c *dbosContext) RunAsStep(_ DBOSContext, fn StepFunc, opts ...StepOption)
 /******* WORKFLOW COMMUNICATIONS ********/
 /****************************************/
 
-
 func (c *dbosContext) Send(_ DBOSContext, destinationID string, message any, topic string) error {
 	return c.systemDB.send(c, WorkflowSendInput{
 		DestinationID: destinationID,
@@ -1110,14 +1109,14 @@ func Send[P any](ctx DBOSContext, destinationID string, message P, topic string)
 	return ctx.Send(ctx, destinationID, message, topic)
 }
 
-// RecvInput defines the parameters for receiving messages sent to this workflow.
-type RecvInput struct {
+// recvInput defines the parameters for receiving messages sent to this workflow.
+type recvInput struct {
 	Topic   string        // Topic to listen for (empty string receives from default topic)
 	Timeout time.Duration // Maximum time to wait for a message
 }
 
 func (c *dbosContext) Recv(_ DBOSContext, topic string, timeout time.Duration) (any, error) {
-	input := RecvInput{
+	input := recvInput{
 		Topic:   topic,
 		Timeout: timeout,
 	}
@@ -1185,15 +1184,15 @@ func SetEvent[P any](ctx DBOSContext, key string, message P) error {
 	return ctx.SetEvent(ctx, key, message)
 }
 
-// GetEventInput defines the parameters for retrieving an event from a workflow.
-type GetEventInput struct {
+// getEventInput defines the parameters for retrieving an event from a workflow.
+type getEventInput struct {
 	TargetWorkflowID string        // Workflow ID to get the event from
 	Key              string        // Event key to retrieve
 	Timeout          time.Duration // Maximum time to wait for the event to be set
 }
 
 func (c *dbosContext) GetEvent(_ DBOSContext, targetWorkflowID string, key string, timeout time.Duration) (any, error) {
-	input := GetEventInput{
+	input := getEventInput{
 		TargetWorkflowID: targetWorkflowID,
 		Key:              key,
 		Timeout:          timeout,