Class GenericWorkflowClientImpl

java.lang.Object
io.temporal.internal.client.external.GenericWorkflowClientImpl
All Implemented Interfaces:
GenericWorkflowClient
public final class GenericWorkflowClientImpl extends Object implements GenericWorkflowClient

  • Constructor Summary

    Constructors
    Constructor
    Description
    GenericWorkflowClientImpl(io.temporal.serviceclient.WorkflowServiceStubs service, com.uber.m3.tally.Scope metricsScope)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    cancelActivity(io.temporal.api.workflowservice.v1.RequestCancelActivityExecutionRequest request)
     
    io.temporal.api.workflowservice.v1.CountActivityExecutionsResponse
    countActivities(io.temporal.api.workflowservice.v1.CountActivityExecutionsRequest request)
     
    io.temporal.api.workflowservice.v1.CountNexusOperationExecutionsResponse
    countNexusOperationExecutions(io.temporal.api.workflowservice.v1.CountNexusOperationExecutionsRequest request)
     
    io.temporal.api.workflowservice.v1.CountWorkflowExecutionsResponse
    countWorkflowExecutions(io.temporal.api.workflowservice.v1.CountWorkflowExecutionsRequest request)
     
    io.temporal.api.workflowservice.v1.CreateScheduleResponse
    createSchedule(io.temporal.api.workflowservice.v1.CreateScheduleRequest request)
     
    io.temporal.api.workflowservice.v1.DeleteNexusOperationExecutionResponse
    deleteNexusOperationExecution(io.temporal.api.workflowservice.v1.DeleteNexusOperationExecutionRequest request)
     
    io.temporal.api.workflowservice.v1.DeleteScheduleResponse
    deleteSchedule(io.temporal.api.workflowservice.v1.DeleteScheduleRequest request)
     
    io.temporal.api.workflowservice.v1.DescribeActivityExecutionResponse
    describeActivity(io.temporal.api.workflowservice.v1.DescribeActivityExecutionRequest request)
     
    io.temporal.api.workflowservice.v1.DescribeNexusOperationExecutionResponse
    describeNexusOperationExecution(io.temporal.api.workflowservice.v1.DescribeNexusOperationExecutionRequest request)
     
    io.temporal.api.workflowservice.v1.DescribeScheduleResponse
    describeSchedule(io.temporal.api.workflowservice.v1.DescribeScheduleRequest request)
     
    io.temporal.api.workflowservice.v1.DescribeWorkflowExecutionResponse
    describeWorkflowExecution(io.temporal.api.workflowservice.v1.DescribeWorkflowExecutionRequest request)
     
    io.temporal.api.workflowservice.v1.ExecuteMultiOperationResponse
    executeMultiOperation(io.temporal.api.workflowservice.v1.ExecuteMultiOperationRequest req, io.grpc.Deadline deadline)
     
    io.temporal.api.workflowservice.v1.GetWorkerBuildIdCompatibilityResponse
    getWorkerBuildIdCompatability(io.temporal.api.workflowservice.v1.GetWorkerBuildIdCompatibilityRequest req)
     
    io.temporal.api.workflowservice.v1.GetWorkerTaskReachabilityResponse
    GetWorkerTaskReachability(io.temporal.api.workflowservice.v1.GetWorkerTaskReachabilityRequest req)
     
    io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryResponse
    getWorkflowExecutionHistory(io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryRequest request)
     
    CompletableFuture<io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryResponse>
    getWorkflowExecutionHistoryAsync(io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryRequest request)
     
    io.temporal.api.workflowservice.v1.ListActivityExecutionsResponse
    listActivities(io.temporal.api.workflowservice.v1.ListActivityExecutionsRequest request)
     
    CompletableFuture<io.temporal.api.workflowservice.v1.ListActivityExecutionsResponse>
    listActivitiesAsync(io.temporal.api.workflowservice.v1.ListActivityExecutionsRequest request)
     
    CompletableFuture<io.temporal.api.workflowservice.v1.ListNexusOperationExecutionsResponse>
    listNexusOperationExecutionsAsync(io.temporal.api.workflowservice.v1.ListNexusOperationExecutionsRequest request)
     
    CompletableFuture<io.temporal.api.workflowservice.v1.ListSchedulesResponse>
    listSchedulesAsync(io.temporal.api.workflowservice.v1.ListSchedulesRequest request)
     
    io.temporal.api.workflowservice.v1.ListWorkflowExecutionsResponse
    listWorkflowExecutions(io.temporal.api.workflowservice.v1.ListWorkflowExecutionsRequest listRequest)
     
    CompletableFuture<io.temporal.api.workflowservice.v1.ListWorkflowExecutionsResponse>
    listWorkflowExecutionsAsync(io.temporal.api.workflowservice.v1.ListWorkflowExecutionsRequest listRequest)
     
    io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryResponse
    longPollHistory(io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryRequest request, io.grpc.Deadline deadline)
     
    CompletableFuture<io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryResponse>
    longPollHistoryAsync(io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryRequest request, io.grpc.Deadline deadline)
     
    io.temporal.api.workflowservice.v1.PatchScheduleResponse
    patchSchedule(io.temporal.api.workflowservice.v1.PatchScheduleRequest request)
     
    io.temporal.api.workflowservice.v1.PollActivityExecutionResponse
    pollActivity(io.temporal.api.workflowservice.v1.PollActivityExecutionRequest request)
     
    io.temporal.api.workflowservice.v1.PollActivityExecutionResponse
    pollActivity(io.temporal.api.workflowservice.v1.PollActivityExecutionRequest request, io.grpc.Deadline deadline)
     
    CompletableFuture<io.temporal.api.workflowservice.v1.PollActivityExecutionResponse>
    pollActivityAsync(io.temporal.api.workflowservice.v1.PollActivityExecutionRequest request, io.grpc.Deadline deadline)
     
    io.temporal.api.workflowservice.v1.PollNexusOperationExecutionResponse
    pollNexusOperationExecution(io.temporal.api.workflowservice.v1.PollNexusOperationExecutionRequest request, io.grpc.Deadline deadline)
     
    CompletableFuture<io.temporal.api.workflowservice.v1.PollNexusOperationExecutionResponse>
    pollNexusOperationExecutionAsync(io.temporal.api.workflowservice.v1.PollNexusOperationExecutionRequest request, io.grpc.Deadline deadline)
     
    CompletableFuture<io.temporal.api.workflowservice.v1.PollWorkflowExecutionUpdateResponse>
    pollUpdateAsync(io.temporal.api.workflowservice.v1.PollWorkflowExecutionUpdateRequest request, io.grpc.Deadline deadline)
     
    io.temporal.api.workflowservice.v1.QueryWorkflowResponse
    query(io.temporal.api.workflowservice.v1.QueryWorkflowRequest queryParameters)
     
    void
    requestCancel(io.temporal.api.workflowservice.v1.RequestCancelWorkflowExecutionRequest request)
     
    io.temporal.api.workflowservice.v1.RequestCancelNexusOperationExecutionResponse
    requestCancelNexusOperationExecution(io.temporal.api.workflowservice.v1.RequestCancelNexusOperationExecutionRequest request)
     
    io.temporal.api.workflowservice.v1.SignalWorkflowExecutionResponse
    signal(io.temporal.api.workflowservice.v1.SignalWorkflowExecutionRequest request)
     
    io.temporal.api.workflowservice.v1.SignalWithStartWorkflowExecutionResponse
    signalWithStart(io.temporal.api.workflowservice.v1.SignalWithStartWorkflowExecutionRequest request)
     
    io.temporal.api.workflowservice.v1.StartWorkflowExecutionResponse
    start(io.temporal.api.workflowservice.v1.StartWorkflowExecutionRequest request)
     
    io.temporal.api.workflowservice.v1.StartActivityExecutionResponse
    startActivity(io.temporal.api.workflowservice.v1.StartActivityExecutionRequest request)
     
    io.temporal.api.workflowservice.v1.StartNexusOperationExecutionResponse
    startNexusOperationExecution(io.temporal.api.workflowservice.v1.StartNexusOperationExecutionRequest request)
     
    void
    terminate(io.temporal.api.workflowservice.v1.TerminateWorkflowExecutionRequest request)
     
    void
    terminateActivity(io.temporal.api.workflowservice.v1.TerminateActivityExecutionRequest request)
     
    io.temporal.api.workflowservice.v1.TerminateNexusOperationExecutionResponse
    terminateNexusOperationExecution(io.temporal.api.workflowservice.v1.TerminateNexusOperationExecutionRequest request)
     
    io.temporal.api.workflowservice.v1.UpdateWorkflowExecutionResponse
    update(io.temporal.api.workflowservice.v1.UpdateWorkflowExecutionRequest updateParameters, io.grpc.Deadline deadline)
     
    io.temporal.api.workflowservice.v1.UpdateScheduleResponse
    updateSchedule(io.temporal.api.workflowservice.v1.UpdateScheduleRequest request)
     
    io.temporal.api.workflowservice.v1.UpdateWorkerBuildIdCompatibilityResponse
    updateWorkerBuildIdCompatability(io.temporal.api.workflowservice.v1.UpdateWorkerBuildIdCompatibilityRequest request)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • GenericWorkflowClientImpl

      public GenericWorkflowClientImpl(io.temporal.serviceclient.WorkflowServiceStubs service, com.uber.m3.tally.Scope metricsScope)

  • Method Details

    • start

      public io.temporal.api.workflowservice.v1.StartWorkflowExecutionResponse start(io.temporal.api.workflowservice.v1.StartWorkflowExecutionRequest request)
      Specified by:
      start in interface GenericWorkflowClient

    • signal

      public io.temporal.api.workflowservice.v1.SignalWorkflowExecutionResponse signal(io.temporal.api.workflowservice.v1.SignalWorkflowExecutionRequest request)
      Specified by:
      signal in interface GenericWorkflowClient

    • signalWithStart

      public io.temporal.api.workflowservice.v1.SignalWithStartWorkflowExecutionResponse signalWithStart(io.temporal.api.workflowservice.v1.SignalWithStartWorkflowExecutionRequest request)
      Specified by:
      signalWithStart in interface GenericWorkflowClient

    • requestCancel

      public void requestCancel(io.temporal.api.workflowservice.v1.RequestCancelWorkflowExecutionRequest request)
      Specified by:
      requestCancel in interface GenericWorkflowClient

    • terminate

      public void terminate(io.temporal.api.workflowservice.v1.TerminateWorkflowExecutionRequest request)
      Specified by:
      terminate in interface GenericWorkflowClient

    • longPollHistory

      public io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryResponse longPollHistory(@Nonnull io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryRequest request, @Nonnull io.grpc.Deadline deadline)
      Specified by:
      longPollHistory in interface GenericWorkflowClient

    • longPollHistoryAsync

      public CompletableFuture<io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryResponse> longPollHistoryAsync(@Nonnull io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryRequest request, @Nonnull io.grpc.Deadline deadline)
      Specified by:
      longPollHistoryAsync in interface GenericWorkflowClient

    • getWorkflowExecutionHistory

      public io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryResponse getWorkflowExecutionHistory(@Nonnull io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryRequest request)
      Specified by:
      getWorkflowExecutionHistory in interface GenericWorkflowClient

    • getWorkflowExecutionHistoryAsync

      public CompletableFuture<io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryResponse> getWorkflowExecutionHistoryAsync(@Nonnull io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryRequest request)
      Specified by:
      getWorkflowExecutionHistoryAsync in interface GenericWorkflowClient

    • query

      public io.temporal.api.workflowservice.v1.QueryWorkflowResponse query(io.temporal.api.workflowservice.v1.QueryWorkflowRequest queryParameters)
      Specified by:
      query in interface GenericWorkflowClient

    • listWorkflowExecutions

      public io.temporal.api.workflowservice.v1.ListWorkflowExecutionsResponse listWorkflowExecutions(io.temporal.api.workflowservice.v1.ListWorkflowExecutionsRequest listRequest)
      Specified by:
      listWorkflowExecutions in interface GenericWorkflowClient

    • listWorkflowExecutionsAsync

      public CompletableFuture<io.temporal.api.workflowservice.v1.ListWorkflowExecutionsResponse> listWorkflowExecutionsAsync(io.temporal.api.workflowservice.v1.ListWorkflowExecutionsRequest listRequest)
      Specified by:
      listWorkflowExecutionsAsync in interface GenericWorkflowClient

    • countWorkflowExecutions

      public io.temporal.api.workflowservice.v1.CountWorkflowExecutionsResponse countWorkflowExecutions(io.temporal.api.workflowservice.v1.CountWorkflowExecutionsRequest request)
      Specified by:
      countWorkflowExecutions in interface GenericWorkflowClient

    • createSchedule

      public io.temporal.api.workflowservice.v1.CreateScheduleResponse createSchedule(io.temporal.api.workflowservice.v1.CreateScheduleRequest request)
      Specified by:
      createSchedule in interface GenericWorkflowClient

    • listSchedulesAsync

      public CompletableFuture<io.temporal.api.workflowservice.v1.ListSchedulesResponse> listSchedulesAsync(io.temporal.api.workflowservice.v1.ListSchedulesRequest request)
      Specified by:
      listSchedulesAsync in interface GenericWorkflowClient

    • updateSchedule

      public io.temporal.api.workflowservice.v1.UpdateScheduleResponse updateSchedule(io.temporal.api.workflowservice.v1.UpdateScheduleRequest request)
      Specified by:
      updateSchedule in interface GenericWorkflowClient

    • patchSchedule

      public io.temporal.api.workflowservice.v1.PatchScheduleResponse patchSchedule(io.temporal.api.workflowservice.v1.PatchScheduleRequest request)
      Specified by:
      patchSchedule in interface GenericWorkflowClient

    • deleteSchedule

      public io.temporal.api.workflowservice.v1.DeleteScheduleResponse deleteSchedule(io.temporal.api.workflowservice.v1.DeleteScheduleRequest request)
      Specified by:
      deleteSchedule in interface GenericWorkflowClient

    • describeSchedule

      public io.temporal.api.workflowservice.v1.DescribeScheduleResponse describeSchedule(io.temporal.api.workflowservice.v1.DescribeScheduleRequest request)
      Specified by:
      describeSchedule in interface GenericWorkflowClient

    • describeWorkflowExecution

      public io.temporal.api.workflowservice.v1.DescribeWorkflowExecutionResponse describeWorkflowExecution(io.temporal.api.workflowservice.v1.DescribeWorkflowExecutionRequest request)
      Specified by:
      describeWorkflowExecution in interface GenericWorkflowClient

    • startNexusOperationExecution

      public io.temporal.api.workflowservice.v1.StartNexusOperationExecutionResponse startNexusOperationExecution(@Nonnull io.temporal.api.workflowservice.v1.StartNexusOperationExecutionRequest request)
      Specified by:
      startNexusOperationExecution in interface GenericWorkflowClient

    • describeNexusOperationExecution

      public io.temporal.api.workflowservice.v1.DescribeNexusOperationExecutionResponse describeNexusOperationExecution(@Nonnull io.temporal.api.workflowservice.v1.DescribeNexusOperationExecutionRequest request)
      Specified by:
      describeNexusOperationExecution in interface GenericWorkflowClient

    • pollNexusOperationExecution

      public io.temporal.api.workflowservice.v1.PollNexusOperationExecutionResponse pollNexusOperationExecution(@Nonnull io.temporal.api.workflowservice.v1.PollNexusOperationExecutionRequest request, @Nonnull io.grpc.Deadline deadline)
      Specified by:
      pollNexusOperationExecution in interface GenericWorkflowClient

    • pollNexusOperationExecutionAsync

      public CompletableFuture<io.temporal.api.workflowservice.v1.PollNexusOperationExecutionResponse> pollNexusOperationExecutionAsync(@Nonnull io.temporal.api.workflowservice.v1.PollNexusOperationExecutionRequest request, @Nonnull io.grpc.Deadline deadline)
      Specified by:
      pollNexusOperationExecutionAsync in interface GenericWorkflowClient

    • listNexusOperationExecutionsAsync

      public CompletableFuture<io.temporal.api.workflowservice.v1.ListNexusOperationExecutionsResponse> listNexusOperationExecutionsAsync(@Nonnull io.temporal.api.workflowservice.v1.ListNexusOperationExecutionsRequest request)
      Specified by:
      listNexusOperationExecutionsAsync in interface GenericWorkflowClient

    • countNexusOperationExecutions

      public io.temporal.api.workflowservice.v1.CountNexusOperationExecutionsResponse countNexusOperationExecutions(@Nonnull io.temporal.api.workflowservice.v1.CountNexusOperationExecutionsRequest request)
      Specified by:
      countNexusOperationExecutions in interface GenericWorkflowClient

    • requestCancelNexusOperationExecution

      public io.temporal.api.workflowservice.v1.RequestCancelNexusOperationExecutionResponse requestCancelNexusOperationExecution(@Nonnull io.temporal.api.workflowservice.v1.RequestCancelNexusOperationExecutionRequest request)
      Specified by:
      requestCancelNexusOperationExecution in interface GenericWorkflowClient

    • terminateNexusOperationExecution

      public io.temporal.api.workflowservice.v1.TerminateNexusOperationExecutionResponse terminateNexusOperationExecution(@Nonnull io.temporal.api.workflowservice.v1.TerminateNexusOperationExecutionRequest request)
      Specified by:
      terminateNexusOperationExecution in interface GenericWorkflowClient

    • deleteNexusOperationExecution

      public io.temporal.api.workflowservice.v1.DeleteNexusOperationExecutionResponse deleteNexusOperationExecution(@Nonnull io.temporal.api.workflowservice.v1.DeleteNexusOperationExecutionRequest request)
      Specified by:
      deleteNexusOperationExecution in interface GenericWorkflowClient

    • update

      public io.temporal.api.workflowservice.v1.UpdateWorkflowExecutionResponse update(@Nonnull io.temporal.api.workflowservice.v1.UpdateWorkflowExecutionRequest updateParameters, @Nonnull io.grpc.Deadline deadline)
      Specified by:
      update in interface GenericWorkflowClient

    • pollUpdateAsync

      public CompletableFuture<io.temporal.api.workflowservice.v1.PollWorkflowExecutionUpdateResponse> pollUpdateAsync(@Nonnull io.temporal.api.workflowservice.v1.PollWorkflowExecutionUpdateRequest request, @Nonnull io.grpc.Deadline deadline)
      Specified by:
      pollUpdateAsync in interface GenericWorkflowClient

    • updateWorkerBuildIdCompatability

      public io.temporal.api.workflowservice.v1.UpdateWorkerBuildIdCompatibilityResponse updateWorkerBuildIdCompatability(io.temporal.api.workflowservice.v1.UpdateWorkerBuildIdCompatibilityRequest request)
      Specified by:
      updateWorkerBuildIdCompatability in interface GenericWorkflowClient

    • getWorkerBuildIdCompatability

      public io.temporal.api.workflowservice.v1.GetWorkerBuildIdCompatibilityResponse getWorkerBuildIdCompatability(io.temporal.api.workflowservice.v1.GetWorkerBuildIdCompatibilityRequest req)
      Specified by:
      getWorkerBuildIdCompatability in interface GenericWorkflowClient

    • GetWorkerTaskReachability

      public io.temporal.api.workflowservice.v1.GetWorkerTaskReachabilityResponse GetWorkerTaskReachability(io.temporal.api.workflowservice.v1.GetWorkerTaskReachabilityRequest req)
      Specified by:
      GetWorkerTaskReachability in interface GenericWorkflowClient

    • executeMultiOperation

      public io.temporal.api.workflowservice.v1.ExecuteMultiOperationResponse executeMultiOperation(io.temporal.api.workflowservice.v1.ExecuteMultiOperationRequest req, @Nonnull io.grpc.Deadline deadline)
      Specified by:
      executeMultiOperation in interface GenericWorkflowClient

    • startActivity

      public io.temporal.api.workflowservice.v1.StartActivityExecutionResponse startActivity(io.temporal.api.workflowservice.v1.StartActivityExecutionRequest request)
      Specified by:
      startActivity in interface GenericWorkflowClient

    • pollActivity

      public io.temporal.api.workflowservice.v1.PollActivityExecutionResponse pollActivity(io.temporal.api.workflowservice.v1.PollActivityExecutionRequest request)
      Specified by:
      pollActivity in interface GenericWorkflowClient

    • pollActivity

      public io.temporal.api.workflowservice.v1.PollActivityExecutionResponse pollActivity(io.temporal.api.workflowservice.v1.PollActivityExecutionRequest request, @Nonnull io.grpc.Deadline deadline)
      Specified by:
      pollActivity in interface GenericWorkflowClient

    • pollActivityAsync

      public CompletableFuture<io.temporal.api.workflowservice.v1.PollActivityExecutionResponse> pollActivityAsync(io.temporal.api.workflowservice.v1.PollActivityExecutionRequest request, @Nonnull io.grpc.Deadline deadline)
      Specified by:
      pollActivityAsync in interface GenericWorkflowClient

    • describeActivity

      public io.temporal.api.workflowservice.v1.DescribeActivityExecutionResponse describeActivity(io.temporal.api.workflowservice.v1.DescribeActivityExecutionRequest request)
      Specified by:
      describeActivity in interface GenericWorkflowClient

    • cancelActivity

      public void cancelActivity(io.temporal.api.workflowservice.v1.RequestCancelActivityExecutionRequest request)
      Specified by:
      cancelActivity in interface GenericWorkflowClient

    • terminateActivity

      public void terminateActivity(io.temporal.api.workflowservice.v1.TerminateActivityExecutionRequest request)
      Specified by:
      terminateActivity in interface GenericWorkflowClient

    • listActivities

      public io.temporal.api.workflowservice.v1.ListActivityExecutionsResponse listActivities(io.temporal.api.workflowservice.v1.ListActivityExecutionsRequest request)
      Specified by:
      listActivities in interface GenericWorkflowClient

    • listActivitiesAsync

      public CompletableFuture<io.temporal.api.workflowservice.v1.ListActivityExecutionsResponse> listActivitiesAsync(io.temporal.api.workflowservice.v1.ListActivityExecutionsRequest request)
      Specified by:
      listActivitiesAsync in interface GenericWorkflowClient

    • countActivities

      public io.temporal.api.workflowservice.v1.CountActivityExecutionsResponse countActivities(io.temporal.api.workflowservice.v1.CountActivityExecutionsRequest request)
      Specified by:
      countActivities in interface GenericWorkflowClient