terminalcost

type TerminalCost ¶

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

TerminalCost bounds what a completed workflow costs to poke: every call a completed instance can still receive in bulk must be answered without reading its whole history from the store each time. Those reads run one after another under the actor lock, so their cost grows with the history and the number of calls, and the client's completion wait queues behind them.

It runs one daprd with WorkflowsFastPath off (the fast path arms no per-result wake-ups) on a fault store that counts and slows full loads. Signing follows the env.

func New(t *testing.T) *TerminalCost

func (c *TerminalCost) Cleanup(t *testing.T)

func (c *TerminalCost) Execute(t *testing.T, ctx context.Context)

func (c *TerminalCost) Run(t *testing.T, ctx context.Context)