Skip to content

Commit 87ed045

Browse files
vancexuvancexu
committed
Add implementation
1 parent 1f0676e commit 87ed045

File tree

5 files changed

+463
-0
lines changed

5 files changed

+463
-0
lines changed

‎src/main/java/com/uber/cadence/internal/metrics/ServiceMethod.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,14 @@ public class ServiceMethod {
2929
MetricsType.CADENCE_METRICS_PREFIX + "ListClosedWorkflowExecutions";
3030
public static final String LIST_OPEN_WORKFLOW_EXECUTIONS =
3131
MetricsType.CADENCE_METRICS_PREFIX + "ListOpenWorkflowExecutions";
32+
public static final String LIST_WORKFLOW_EXECUTIONS =
33+
MetricsType.CADENCE_METRICS_PREFIX + "ListWorkflowExecutions";
34+
public static final String SCAN_WORKFLOW_EXECUTIONS =
35+
MetricsType.CADENCE_METRICS_PREFIX + "ScanWorkflowExecutions";
36+
public static final String COUNT_WORKFLOW_EXECUTIONS =
37+
MetricsType.CADENCE_METRICS_PREFIX + "CountWorkflowExecutions";
38+
public static final String GET_SEARCH_ATTRIBUTES =
39+
MetricsType.CADENCE_METRICS_PREFIX + "GetSearchAttributes";
3240
public static final String POLL_FOR_ACTIVITY_TASK =
3341
MetricsType.CADENCE_METRICS_PREFIX + "PollForActivityTask";
3442
public static final String POLL_FOR_DECISION_TASK =

‎src/main/java/com/uber/cadence/internal/sync/TestActivityEnvironmentInternal.java

Lines changed: 77 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,9 @@
2121
import com.uber.cadence.ActivityType;
2222
import com.uber.cadence.BadRequestError;
2323
import com.uber.cadence.CancellationAlreadyRequestedError;
24+
import com.uber.cadence.ClientVersionNotSupportedError;
25+
import com.uber.cadence.CountWorkflowExecutionsRequest;
26+
import com.uber.cadence.CountWorkflowExecutionsResponse;
2427
import com.uber.cadence.DeprecateDomainRequest;
2528
import com.uber.cadence.DescribeDomainRequest;
2629
import com.uber.cadence.DescribeDomainResponse;
@@ -31,6 +34,7 @@
3134
import com.uber.cadence.DomainAlreadyExistsError;
3235
import com.uber.cadence.DomainNotActiveError;
3336
import com.uber.cadence.EntityNotExistsError;
37+
import com.uber.cadence.GetSearchAttributesResponse;
3438
import com.uber.cadence.GetWorkflowExecutionHistoryRequest;
3539
import com.uber.cadence.GetWorkflowExecutionHistoryResponse;
3640
import com.uber.cadence.InternalServiceError;
@@ -41,6 +45,8 @@
4145
import com.uber.cadence.ListDomainsResponse;
4246
import com.uber.cadence.ListOpenWorkflowExecutionsRequest;
4347
import com.uber.cadence.ListOpenWorkflowExecutionsResponse;
48+
import com.uber.cadence.ListWorkflowExecutionsRequest;
49+
import com.uber.cadence.ListWorkflowExecutionsResponse;
4450
import com.uber.cadence.PollForActivityTaskRequest;
4551
import com.uber.cadence.PollForActivityTaskResponse;
4652
import com.uber.cadence.PollForDecisionTaskRequest;
@@ -55,6 +61,8 @@
5561
import com.uber.cadence.RequestCancelWorkflowExecutionRequest;
5662
import com.uber.cadence.ResetStickyTaskListRequest;
5763
import com.uber.cadence.ResetStickyTaskListResponse;
64+
import com.uber.cadence.ResetWorkflowExecutionRequest;
65+
import com.uber.cadence.ResetWorkflowExecutionResponse;
5866
import com.uber.cadence.RespondActivityTaskCanceledByIDRequest;
5967
import com.uber.cadence.RespondActivityTaskCanceledRequest;
6068
import com.uber.cadence.RespondActivityTaskCompletedByIDRequest;
@@ -471,6 +479,13 @@ public StartWorkflowExecutionResponse SignalWithStartWorkflowExecution(
471479
return impl.SignalWithStartWorkflowExecution(signalWithStartRequest);
472480
}
473481

482+
@Override
483+
public ResetWorkflowExecutionResponse ResetWorkflowExecution(
484+
ResetWorkflowExecutionRequest resetRequest)
485+
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError, DomainNotActiveError, LimitExceededError, ClientVersionNotSupportedError, TException {
486+
return impl.ResetWorkflowExecution(resetRequest);
487+
}
488+
474489
@Override
475490
public void TerminateWorkflowExecution(TerminateWorkflowExecutionRequest terminateRequest)
476491
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError,
@@ -494,6 +509,33 @@ public ListClosedWorkflowExecutionsResponse ListClosedWorkflowExecutions(
494509
return impl.ListClosedWorkflowExecutions(listRequest);
495510
}
496511

512+
@Override
513+
public ListWorkflowExecutionsResponse ListWorkflowExecutions(
514+
ListWorkflowExecutionsRequest listRequest)
515+
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError, ClientVersionNotSupportedError, TException {
516+
return impl.ListWorkflowExecutions(listRequest);
517+
}
518+
519+
@Override
520+
public ListWorkflowExecutionsResponse ScanWorkflowExecutions(
521+
ListWorkflowExecutionsRequest listRequest)
522+
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError, ClientVersionNotSupportedError, TException {
523+
return impl.ScanWorkflowExecutions(listRequest);
524+
}
525+
526+
@Override
527+
public CountWorkflowExecutionsResponse CountWorkflowExecutions(
528+
CountWorkflowExecutionsRequest countRequest)
529+
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError, ClientVersionNotSupportedError, TException {
530+
return impl.CountWorkflowExecutions(countRequest);
531+
}
532+
533+
@Override
534+
public GetSearchAttributesResponse GetSearchAttributes()
535+
throws InternalServiceError, ServiceBusyError, ClientVersionNotSupportedError, TException {
536+
return impl.GetSearchAttributes();
537+
}
538+
497539
@Override
498540
public void RespondQueryTaskCompleted(RespondQueryTaskCompletedRequest completeRequest)
499541
throws BadRequestError, InternalServiceError, EntityNotExistsError, TException {
@@ -680,6 +722,13 @@ public void SignalWithStartWorkflowExecution(
680722
impl.SignalWithStartWorkflowExecution(signalWithStartRequest, resultHandler);
681723
}
682724

725+
@Override
726+
public void ResetWorkflowExecution(
727+
ResetWorkflowExecutionRequest resetRequest, AsyncMethodCallback resultHandler)
728+
throws TException {
729+
impl.ResetWorkflowExecution(resetRequest, resultHandler);
730+
}
731+
683732
@Override
684733
public void TerminateWorkflowExecution(
685734
TerminateWorkflowExecutionRequest terminateRequest, AsyncMethodCallback resultHandler)
@@ -701,6 +750,34 @@ public void ListClosedWorkflowExecutions(
701750
impl.ListClosedWorkflowExecutions(listRequest, resultHandler);
702751
}
703752

753+
@Override
754+
public void ListWorkflowExecutions(
755+
ListWorkflowExecutionsRequest listRequest, AsyncMethodCallback resultHandler)
756+
throws TException {
757+
impl.ListWorkflowExecutions(listRequest, resultHandler);
758+
}
759+
760+
@Override
761+
public void ScanWorkflowExecutions(
762+
ListWorkflowExecutionsRequest listRequest, AsyncMethodCallback resultHandler)
763+
throws TException {
764+
impl.ScanWorkflowExecutions(listRequest, resultHandler);
765+
}
766+
767+
@Override
768+
public void CountWorkflowExecutions(
769+
CountWorkflowExecutionsRequest countRequest, AsyncMethodCallback resultHandler)
770+
throws TException {
771+
impl.CountWorkflowExecutions(countRequest, resultHandler);
772+
}
773+
774+
@Override
775+
public void GetSearchAttributes(
776+
AsyncMethodCallback resultHandler)
777+
throws TException {
778+
impl.GetSearchAttributes(resultHandler);
779+
}
780+
704781
@Override
705782
public void RespondQueryTaskCompleted(
706783
RespondQueryTaskCompletedRequest completeRequest, AsyncMethodCallback resultHandler)

‎src/main/java/com/uber/cadence/internal/sync/TestWorkflowEnvironmentInternal.java

Lines changed: 81 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,9 @@
1919

2020
import com.uber.cadence.BadRequestError;
2121
import com.uber.cadence.CancellationAlreadyRequestedError;
22+
import com.uber.cadence.ClientVersionNotSupportedError;
23+
import com.uber.cadence.CountWorkflowExecutionsRequest;
24+
import com.uber.cadence.CountWorkflowExecutionsResponse;
2225
import com.uber.cadence.DeprecateDomainRequest;
2326
import com.uber.cadence.DescribeDomainRequest;
2427
import com.uber.cadence.DescribeDomainResponse;
@@ -29,6 +32,7 @@
2932
import com.uber.cadence.DomainAlreadyExistsError;
3033
import com.uber.cadence.DomainNotActiveError;
3134
import com.uber.cadence.EntityNotExistsError;
35+
import com.uber.cadence.GetSearchAttributesResponse;
3236
import com.uber.cadence.GetWorkflowExecutionHistoryRequest;
3337
import com.uber.cadence.GetWorkflowExecutionHistoryResponse;
3438
import com.uber.cadence.InternalServiceError;
@@ -39,6 +43,8 @@
3943
import com.uber.cadence.ListDomainsResponse;
4044
import com.uber.cadence.ListOpenWorkflowExecutionsRequest;
4145
import com.uber.cadence.ListOpenWorkflowExecutionsResponse;
46+
import com.uber.cadence.ListWorkflowExecutionsRequest;
47+
import com.uber.cadence.ListWorkflowExecutionsResponse;
4248
import com.uber.cadence.PollForActivityTaskRequest;
4349
import com.uber.cadence.PollForActivityTaskResponse;
4450
import com.uber.cadence.PollForDecisionTaskRequest;
@@ -53,6 +59,8 @@
5359
import com.uber.cadence.RequestCancelWorkflowExecutionRequest;
5460
import com.uber.cadence.ResetStickyTaskListRequest;
5561
import com.uber.cadence.ResetStickyTaskListResponse;
62+
import com.uber.cadence.ResetWorkflowExecutionRequest;
63+
import com.uber.cadence.ResetWorkflowExecutionResponse;
5664
import com.uber.cadence.RespondActivityTaskCanceledByIDRequest;
5765
import com.uber.cadence.RespondActivityTaskCanceledRequest;
5866
import com.uber.cadence.RespondActivityTaskCompletedByIDRequest;
@@ -326,6 +334,14 @@ public StartWorkflowExecutionResponse SignalWithStartWorkflowExecution(
326334
return impl.SignalWithStartWorkflowExecution(signalWithStartRequest);
327335
}
328336

337+
@Override
338+
public ResetWorkflowExecutionResponse ResetWorkflowExecution(
339+
ResetWorkflowExecutionRequest resetRequest)
340+
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError,
341+
DomainNotActiveError, LimitExceededError, ClientVersionNotSupportedError, TException {
342+
return impl.ResetWorkflowExecution(resetRequest);
343+
}
344+
329345
@Override
330346
public void TerminateWorkflowExecution(TerminateWorkflowExecutionRequest terminateRequest)
331347
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError,
@@ -349,6 +365,36 @@ public ListClosedWorkflowExecutionsResponse ListClosedWorkflowExecutions(
349365
return impl.ListClosedWorkflowExecutions(listRequest);
350366
}
351367

368+
@Override
369+
public ListWorkflowExecutionsResponse ListWorkflowExecutions(
370+
ListWorkflowExecutionsRequest listRequest)
371+
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError,
372+
ClientVersionNotSupportedError, TException {
373+
return impl.ListWorkflowExecutions(listRequest);
374+
}
375+
376+
@Override
377+
public ListWorkflowExecutionsResponse ScanWorkflowExecutions(
378+
ListWorkflowExecutionsRequest listRequest)
379+
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError,
380+
ClientVersionNotSupportedError, TException {
381+
return impl.ScanWorkflowExecutions(listRequest);
382+
}
383+
384+
@Override
385+
public CountWorkflowExecutionsResponse CountWorkflowExecutions(
386+
CountWorkflowExecutionsRequest countRequest)
387+
throws BadRequestError, InternalServiceError, EntityNotExistsError, ServiceBusyError,
388+
ClientVersionNotSupportedError, TException {
389+
return impl.CountWorkflowExecutions(countRequest);
390+
}
391+
392+
@Override
393+
public GetSearchAttributesResponse GetSearchAttributes()
394+
throws InternalServiceError, ServiceBusyError, ClientVersionNotSupportedError, TException {
395+
return impl.GetSearchAttributes();
396+
}
397+
352398
@Override
353399
public void RespondQueryTaskCompleted(RespondQueryTaskCompletedRequest completeRequest)
354400
throws BadRequestError, InternalServiceError, EntityNotExistsError, TException {
@@ -535,6 +581,13 @@ public void SignalWithStartWorkflowExecution(
535581
impl.SignalWithStartWorkflowExecution(signalWithStartRequest, resultHandler);
536582
}
537583

584+
@Override
585+
public void ResetWorkflowExecution(
586+
ResetWorkflowExecutionRequest resetRequest, AsyncMethodCallback resultHandler)
587+
throws TException {
588+
impl.ResetWorkflowExecution(resetRequest, resultHandler);
589+
}
590+
538591
@Override
539592
public void TerminateWorkflowExecution(
540593
TerminateWorkflowExecutionRequest terminateRequest, AsyncMethodCallback resultHandler)
@@ -556,6 +609,34 @@ public void ListClosedWorkflowExecutions(
556609
impl.ListClosedWorkflowExecutions(listRequest, resultHandler);
557610
}
558611

612+
@Override
613+
public void ListWorkflowExecutions(
614+
ListWorkflowExecutionsRequest listRequest, AsyncMethodCallback resultHandler)
615+
throws TException {
616+
impl.ListWorkflowExecutions(listRequest, resultHandler);
617+
}
618+
619+
@Override
620+
public void ScanWorkflowExecutions(
621+
ListWorkflowExecutionsRequest listRequest, AsyncMethodCallback resultHandler)
622+
throws TException {
623+
impl.ScanWorkflowExecutions(listRequest, resultHandler);
624+
}
625+
626+
@Override
627+
public void CountWorkflowExecutions(
628+
CountWorkflowExecutionsRequest countRequest, AsyncMethodCallback resultHandler)
629+
throws TException {
630+
impl.CountWorkflowExecutions(countRequest, resultHandler);
631+
}
632+
633+
@Override
634+
public void GetSearchAttributes(
635+
AsyncMethodCallback resultHandler)
636+
throws TException {
637+
impl.GetSearchAttributes();
638+
}
639+
559640
@Override
560641
public void RespondQueryTaskCompleted(
561642
RespondQueryTaskCompletedRequest completeRequest, AsyncMethodCallback resultHandler)

0 commit comments

Comments
 (0)