MCPcopy
hub / github.com/riverqueue/river / Run

Method Run

cmd/river/rivercli/command.go:25–25  ·  view source on GitHub ↗
(ctx context.Context, opts TOpts)

Source from the content-addressed store, hash-verified

23// CommandBase.
24type Command[TOpts CommandOpts] interface {
25 Run(ctx context.Context, opts TOpts) (bool, error)
26 GetCommandBase() *CommandBase
27 SetCommandBase(b *CommandBase)
28}

Callers 15

TestResumableStepFunction · 0.65
TestResumableStepCursorFunction · 0.65
Test_JobListCursor_jobListCursorFromJobAndParamsFunction · 0.65
Test_JobListCursor_MarshalJSONFunction · 0.65
TestClientDriverPluginFunction · 0.65
TestClientPilotPluginFunction · 0.65
Test_SubscriptionManagerFunction · 0.65
TestDefaultClientRetryPolicy_NextRetryFunction · 0.65
TestDefaultRetryPolicy_retrySecondsWithoutJitterFunction · 0.65
TestJobCompleteTxFunction · 0.65
TestMetadataSetFunction · 0.65
TestWorkFuncFunction · 0.65

Calls

no outgoing calls

Tested by 15

TestResumableStepFunction · 0.52
TestResumableStepCursorFunction · 0.52
Test_JobListCursor_jobListCursorFromJobAndParamsFunction · 0.52
Test_JobListCursor_MarshalJSONFunction · 0.52
TestClientDriverPluginFunction · 0.52
TestClientPilotPluginFunction · 0.52
Test_SubscriptionManagerFunction · 0.52
TestDefaultClientRetryPolicy_NextRetryFunction · 0.52
TestDefaultRetryPolicy_retrySecondsWithoutJitterFunction · 0.52
TestJobCompleteTxFunction · 0.52
TestMetadataSetFunction · 0.52
TestWorkFuncFunction · 0.52