lib/temporalio/client/connection/test_service.rb



# frozen_string_literal: true

# Generated code.  DO NOT EDIT!

require 'temporalio/api'
require 'temporalio/client/connection/service'
require 'temporalio/internal/bridge/client'

module Temporalio
  class Client
    class Connection
      # TestService API.
      class TestService < Service
        # @!visibility private
        def initialize(connection)
          super(connection, Internal::Bridge::Client::SERVICE_TEST)
        end

        # Calls TestService.LockTimeSkipping API call.
        #
        # @param request [Temporalio::Api::TestService::V1::LockTimeSkippingRequest] API request.
        # @param rpc_options [RPCOptions, nil] Advanced RPC options.
        # @return [Temporalio::Api::TestService::V1::LockTimeSkippingResponse] API response.
        def lock_time_skipping(request, rpc_options: nil)
          invoke_rpc(
            rpc: 'lock_time_skipping',
            request_class: Temporalio::Api::TestService::V1::LockTimeSkippingRequest,
            response_class: Temporalio::Api::TestService::V1::LockTimeSkippingResponse,
            request:,
            rpc_options:
          )
        end

        # Calls TestService.UnlockTimeSkipping API call.
        #
        # @param request [Temporalio::Api::TestService::V1::UnlockTimeSkippingRequest] API request.
        # @param rpc_options [RPCOptions, nil] Advanced RPC options.
        # @return [Temporalio::Api::TestService::V1::UnlockTimeSkippingResponse] API response.
        def unlock_time_skipping(request, rpc_options: nil)
          invoke_rpc(
            rpc: 'unlock_time_skipping',
            request_class: Temporalio::Api::TestService::V1::UnlockTimeSkippingRequest,
            response_class: Temporalio::Api::TestService::V1::UnlockTimeSkippingResponse,
            request:,
            rpc_options:
          )
        end

        # Calls TestService.Sleep API call.
        #
        # @param request [Temporalio::Api::TestService::V1::SleepRequest] API request.
        # @param rpc_options [RPCOptions, nil] Advanced RPC options.
        # @return [Temporalio::Api::TestService::V1::SleepResponse] API response.
        def sleep(request, rpc_options: nil)
          invoke_rpc(
            rpc: 'sleep',
            request_class: Temporalio::Api::TestService::V1::SleepRequest,
            response_class: Temporalio::Api::TestService::V1::SleepResponse,
            request:,
            rpc_options:
          )
        end

        # Calls TestService.SleepUntil API call.
        #
        # @param request [Temporalio::Api::TestService::V1::SleepUntilRequest] API request.
        # @param rpc_options [RPCOptions, nil] Advanced RPC options.
        # @return [Temporalio::Api::TestService::V1::SleepResponse] API response.
        def sleep_until(request, rpc_options: nil)
          invoke_rpc(
            rpc: 'sleep_until',
            request_class: Temporalio::Api::TestService::V1::SleepUntilRequest,
            response_class: Temporalio::Api::TestService::V1::SleepResponse,
            request:,
            rpc_options:
          )
        end

        # Calls TestService.UnlockTimeSkippingWithSleep API call.
        #
        # @param request [Temporalio::Api::TestService::V1::SleepRequest] API request.
        # @param rpc_options [RPCOptions, nil] Advanced RPC options.
        # @return [Temporalio::Api::TestService::V1::SleepResponse] API response.
        def unlock_time_skipping_with_sleep(request, rpc_options: nil)
          invoke_rpc(
            rpc: 'unlock_time_skipping_with_sleep',
            request_class: Temporalio::Api::TestService::V1::SleepRequest,
            response_class: Temporalio::Api::TestService::V1::SleepResponse,
            request:,
            rpc_options:
          )
        end

        # Calls TestService.GetCurrentTime API call.
        #
        # @param request [Google::Protobuf::Empty] API request.
        # @param rpc_options [RPCOptions, nil] Advanced RPC options.
        # @return [Temporalio::Api::TestService::V1::GetCurrentTimeResponse] API response.
        def get_current_time(request, rpc_options: nil)
          invoke_rpc(
            rpc: 'get_current_time',
            request_class: Google::Protobuf::Empty,
            response_class: Temporalio::Api::TestService::V1::GetCurrentTimeResponse,
            request:,
            rpc_options:
          )
        end
      end
    end
  end
end