NexusOperationInvocationData()

Author: gow

chasm/lib/nexusoperation/operation.go

@@ -40,8 +40,8 @@ type OperationStore interface {
 	OnNexusOperationFailed(ctx chasm.MutableContext, operation *Operation, cause *failurepb.Failure) error
 	OnNexusOperationTimedOut(ctx chasm.MutableContext, operation *Operation, cause *failurepb.Failure) error
 	OnNexusOperationCompleted(ctx chasm.MutableContext, operation *Operation, result *commonpb.Payload, links []*commonpb.Link) error
-	// GetNexusOperationInvocationData loads invocation data (Input, Header, NexusLink) from the scheduled history event.
-	GetNexusOperationInvocationData(ctx chasm.Context, operation *Operation) (InvocationData, error)
+	// NexusOperationInvocationData loads invocation data (Input, Header, NexusLink) from the scheduled history event.
+	NexusOperationInvocationData(ctx chasm.Context, operation *Operation) (InvocationData, error)
 }
 
 // Operation is a CHASM component that represents a Nexus operation.
@@ -170,7 +170,7 @@ func (o *Operation) loadStartArgs(
 		// TODO: For standalone operations, load invocation data from the operation state.
 		return startArgs{}, serviceerror.NewInternal("no store available to load invocation data")
 	}
-	invocationData, err := store.GetNexusOperationInvocationData(ctx, o)
+	invocationData, err := store.NexusOperationInvocationData(ctx, o)
 	if err != nil {
 		return startArgs{}, err
 	}

chasm/lib/workflow/workflow.go

@@ -311,8 +311,8 @@ func (w *Workflow) PendingNexusOperationCount() int {
 	return len(w.Operations)
 }
 
-// GetNexusOperationInvocationData loads invocation data from the scheduled history event.
-func (w *Workflow) GetNexusOperationInvocationData(
+// NexusOperationInvocationData loads invocation data from the scheduled history event.
+func (w *Workflow) NexusOperationInvocationData(
 	ctx chasm.Context,
 	op *nexusoperation.Operation,
 ) (nexusoperation.InvocationData, error) {