Class: Temporalio::Connection::TestService

Inherits:
Service
  • Object
show all
Defined in:
lib/temporalio/connection/test_service.rb

Overview

A class for making TestService RPCs

This is normally accessed via Temoralio::Connection#test_service.

Instance Method Summary collapse

Constructor Details

#initialize(core_connection) ⇒ TestService

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns a new instance of TestService.



11
12
13
 
# File 'lib/temporalio/connection/test_service.rb', line 11

def initialize(core_connection)
  super(core_connection, :test_service)
end

Instance Method Details

#get_current_time(metadata: {}, timeout: nil) ⇒ Temporalio::Api::TestService::V1::GetCurrentTimeResponse

Parameters:

  • metadata (Hash<String, String>) (defaults to: {}) —

    Headers used on the RPC call. Keys here override client-level RPC metadata keys.

  • timeout (Integer) (defaults to: nil) —

    Optional RPC deadline to set for each RPC call.

Returns:



85
86
87
88
89
 
# File 'lib/temporalio/connection/test_service.rb', line 85

def get_current_time(metadata: {}, timeout: nil)
  response = call(:get_current_time, '', metadata, timeout)

  Temporalio::Api::TestService::V1::GetCurrentTimeResponse.decode(response)
end

#lock_time_skipping(request, metadata: {}, timeout: nil) ⇒ Temporalio::Api::TestService::V1::LockTimeSkippingResponse

Parameters:

  • request (Temporalio::Api::TestService::V1::LockTimeSkippingRequest)
  • metadata (Hash<String, String>) (defaults to: {}) —

    Headers used on the RPC call. Keys here override client-level RPC metadata keys.

  • timeout (Integer) (defaults to: nil) —

    Optional RPC deadline to set for each RPC call.

Returns:



21
22
23
24
25
26
 
# File 'lib/temporalio/connection/test_service.rb', line 21

def lock_time_skipping(request, metadata: {}, timeout: nil)
  encoded = Temporalio::Api::TestService::V1::LockTimeSkippingRequest.encode(request)
  response = call(:lock_time_skipping, encoded, metadata, timeout)

  Temporalio::Api::TestService::V1::LockTimeSkippingResponse.decode(response)
end

#sleep(request, metadata: {}, timeout: nil) ⇒ Temporalio::Api::TestService::V1::SleepResponse

Parameters:

  • request (Temporalio::Api::TestService::V1::SleepRequest)
  • metadata (Hash<String, String>) (defaults to: {}) —

    Headers used on the RPC call. Keys here override client-level RPC metadata keys.

  • timeout (Integer) (defaults to: nil) —

    Optional RPC deadline to set for each RPC call.

Returns:



47
48
49
50
51
52
 
# File 'lib/temporalio/connection/test_service.rb', line 47

def sleep(request, metadata: {}, timeout: nil)
  encoded = Temporalio::Api::TestService::V1::SleepRequest.encode(request)
  response = call(:sleep, encoded, metadata, timeout)

  Temporalio::Api::TestService::V1::SleepResponse.decode(response)
end

#sleep_until(request, metadata: {}, timeout: nil) ⇒ Temporalio::Api::TestService::V1::SleepResponse

Parameters:

  • request (Temporalio::Api::TestService::V1::SleepUntilRequest)
  • metadata (Hash<String, String>) (defaults to: {}) —

    Headers used on the RPC call. Keys here override client-level RPC metadata keys.

  • timeout (Integer) (defaults to: nil) —

    Optional RPC deadline to set for each RPC call.

Returns:



60
61
62
63
64
65
 
# File 'lib/temporalio/connection/test_service.rb', line 60

def sleep_until(request, metadata: {}, timeout: nil)
  encoded = Temporalio::Api::TestService::V1::SleepUntilRequest.encode(request)
  response = call(:sleep_until, encoded, metadata, timeout)

  Temporalio::Api::TestService::V1::SleepResponse.decode(response)
end

#unlock_time_skipping(request, metadata: {}, timeout: nil) ⇒ Temporalio::Api::TestService::V1::UnlockTimeSkippingResponse

Parameters:

  • request (Temporalio::Api::TestService::V1::UnlockTimeSkippingRequest)
  • metadata (Hash<String, String>) (defaults to: {}) —

    Headers used on the RPC call. Keys here override client-level RPC metadata keys.

  • timeout (Integer) (defaults to: nil) —

    Optional RPC deadline to set for each RPC call.

Returns:



34
35
36
37
38
39
 
# File 'lib/temporalio/connection/test_service.rb', line 34

def unlock_time_skipping(request, metadata: {}, timeout: nil)
  encoded = Temporalio::Api::TestService::V1::UnlockTimeSkippingRequest.encode(request)
  response = call(:unlock_time_skipping, encoded, metadata, timeout)

  Temporalio::Api::TestService::V1::UnlockTimeSkippingResponse.decode(response)
end

#unlock_time_skipping_with_sleep(request, metadata: {}, timeout: nil) ⇒ Temporalio::Api::TestService::V1::SleepResponse

Parameters:

  • request (Temporalio::Api::TestService::V1::SleepRequest)
  • metadata (Hash<String, String>) (defaults to: {}) —

    Headers used on the RPC call. Keys here override client-level RPC metadata keys.

  • timeout (Integer) (defaults to: nil) —

    Optional RPC deadline to set for each RPC call.

Returns:



73
74
75
76
77
78
 
# File 'lib/temporalio/connection/test_service.rb', line 73

def unlock_time_skipping_with_sleep(request, metadata: {}, timeout: nil)
  encoded = Temporalio::Api::TestService::V1::SleepRequest.encode(request)
  response = call(:unlock_time_skipping_with_sleep, encoded, metadata, timeout)

  Temporalio::Api::TestService::V1::SleepResponse.decode(response)
end