|
35 | 35 | %% Types |
36 | 36 | -type worker_nodes() :: [node()]. |
37 | 37 | -type max_workers() :: non_neg_integer(). |
38 | | --type max_retries() :: pos_integer(). |
| 38 | +-type max_retries() :: pos_integer() | infinity. |
39 | 39 | -type client() :: pid(). |
40 | 40 | -type pending() :: queue:queue(mfa()). |
41 | 41 | -type running() :: [{pid(), mfa()}]. |
@@ -92,7 +92,7 @@ start_link(Nodes, Client, MaxWorkers, MaxRetries) -> |
92 | 92 | stop(Name) -> |
93 | 93 | gen_server:call(Name, stop). |
94 | 94 |
|
95 | | --spec execute(atom(), mfa()) -> ok. |
| 95 | +-spec execute(atom(), {module(), atom(), [term()]}) -> ok. |
96 | 96 | execute(Name, MFA) -> |
97 | 97 | gen_server:call(Name, {execute, MFA}). |
98 | 98 |
|
@@ -353,7 +353,7 @@ log_permanent_failure(Type, Error, MFA) -> |
353 | 353 |
|
354 | 354 |
|
355 | 355 | %% Executes MFA MaxRetries times |
356 | | --spec execute_do(mfa(), non_neg_integer() | infinity, non_neg_integer()) -> result(). |
| 356 | +-spec execute_do(mfa(), max_retries(), non_neg_integer()) -> result(). |
357 | 357 | execute_do(_MFA, 0, _RetryTimeout) -> |
358 | 358 | {error, max_retries}; |
359 | 359 | execute_do(MFA = {Mod, Fun, Args}, infinity, RetryTimeout) -> |
|
0 commit comments