Class: Daytona::Sandbox
- Inherits:
-
Object
- Object
- Daytona::Sandbox
- Includes:
- Instrumentation
- Defined in:
- lib/daytona/sandbox.rb
Overview
rubocop:disable Metrics/ClassLength
Constant Summary collapse
- DEFAULT_TIMEOUT =
60- SANDBOX_METRIC_FIELD_BY_NAME =
{ 'daytona.sandbox.cpu.utilization' => :cpu_used_pct, 'daytona.sandbox.cpu.limit' => :cpu_count, 'daytona.sandbox.memory.usage' => :mem_used, 'daytona.sandbox.memory.limit' => :mem_total, 'daytona.sandbox.memory.cache' => :mem_cache, 'daytona.sandbox.filesystem.usage' => :disk_used, 'daytona.sandbox.filesystem.total' => :disk_total }.freeze
- SANDBOX_METRIC_NAMES =
SANDBOX_METRIC_FIELD_BY_NAME.keys.freeze
Instance Attribute Summary collapse
-
#auto_archive_interval ⇒ Float
Auto-archive interval in minutes.
-
#auto_delete_interval ⇒ Float
(negative value means disabled, 0 means delete immediately upon stopping).
-
#auto_destroy_at ⇒ String?
readonly
When the sandbox will be automatically destroyed (nil if no TTL is set).
-
#auto_pause_interval ⇒ Float
Auto-pause interval in minutes (0 means disabled).
-
#auto_stop_interval ⇒ Float
Auto-stop interval in minutes (0 means disabled).
-
#backup_created_at ⇒ String?
readonly
The creation timestamp of the last backup.
-
#backup_state ⇒ String
readonly
The state of the backup.
-
#build_info ⇒ DaytonaApiClient::BuildInfo?
readonly
Build information for the sandbox if it was created from a dynamic build.
- #code_interpreter ⇒ Daytona::CodeInterpreter readonly
- #computer_use ⇒ Daytona::ComputerUse readonly
- #config ⇒ Daytona::Config readonly
-
#cpu ⇒ Float
readonly
The CPU quota for the sandbox.
-
#created_at ⇒ String
readonly
The creation timestamp of the sandbox.
-
#daemon_version ⇒ String
readonly
The version of the daemon running in the sandbox.
-
#desired_state ⇒ DaytonaApiClient::SandboxDesiredState
readonly
The desired state of the sandbox.
-
#disk ⇒ Float
readonly
The disk quota for the sandbox.
-
#domain_allow_list ⇒ String?
readonly
Comma-separated list of allowed domains for the sandbox.
-
#env ⇒ Hash<String, String>?
readonly
Environment variables for the sandbox.
-
#error_reason ⇒ String
readonly
The error reason of the sandbox.
- #fs ⇒ Daytona::FileSystem readonly
- #git ⇒ Daytona::Git readonly
-
#gpu ⇒ Float
readonly
The GPU quota for the sandbox.
-
#id ⇒ String
readonly
The ID of the sandbox.
-
#labels ⇒ Hash<String, String>
Labels for the sandbox.
-
#last_activity_at ⇒ String
readonly
The last activity timestamp of the sandbox.
-
#memory ⇒ Float
readonly
The memory quota for the sandbox.
-
#network_allow_list ⇒ String?
readonly
Comma-separated list of allowed CIDR network addresses for the sandbox.
-
#network_block_all ⇒ Boolean?
readonly
Whether to block all network access for the sandbox.
-
#organization_id ⇒ String
readonly
The organization ID of the sandbox.
-
#outbound_proxy_url ⇒ String?
readonly
Outbound proxy URL to route the sandbox HTTP(S) traffic through.
- #process ⇒ Daytona::Process readonly
-
#public ⇒ Boolean
readonly
Whether the sandbox http preview is public.
- #sandbox_api ⇒ DaytonaApiClient::SandboxApi readonly
-
#snapshot ⇒ String
readonly
The snapshot used for the sandbox.
-
#state ⇒ DaytonaApiClient::SandboxState
readonly
The state of the sandbox.
-
#target ⇒ String
readonly
The target environment for the sandbox.
-
#toolbox_proxy_url ⇒ String
readonly
The toolbox proxy URL used to reach the sandbox's toolbox API.
-
#updated_at ⇒ String
readonly
The last update timestamp of the sandbox.
-
#user ⇒ String
readonly
The user associated with the project.
-
#volumes ⇒ Array<DaytonaApiClient::SandboxVolume>?
readonly
Volumes attached to the sandbox.
Class Method Summary collapse
Instance Method Summary collapse
-
#archive ⇒ void
Archives the sandbox, making it inactive and preserving its state.
-
#create_lsp_server(language_id:, path_to_project:) ⇒ Daytona::LspServer
Creates a new Language Server Protocol (LSP) server instance.
-
#create_signed_preview_url(port, expires_in_seconds = nil) ⇒ DaytonaApiClient::SignedPortPreviewUrl
Creates a signed preview URL for the sandbox at the specified port.
-
#create_snapshot(name:, timeout: DEFAULT_TIMEOUT) ⇒ void
Creates a snapshot from the current state of the Sandbox.
-
#create_ssh_access(expires_in_minutes) ⇒ DaytonaApiClient::SshAccessDto
Creates an SSH access token for the sandbox.
-
#delete(timeout = DEFAULT_TIMEOUT, wait: false) ⇒ void
Deletes the Sandbox.
-
#download_url(path, ttl_seconds: nil) ⇒ String
Creates a pre-signed URL for downloading a file from the Sandbox.
-
#experimental_create_snapshot(name:, timeout: DEFAULT_TIMEOUT) ⇒ Object
deprecated
Deprecated.
Use #create_snapshot instead. This method will be removed in a future version.
-
#experimental_fork(name: nil, timeout: DEFAULT_TIMEOUT) ⇒ Object
deprecated
Deprecated.
Use #fork instead. This method will be removed in a future version.
-
#expire_signed_preview_url(port, token) ⇒ void
Expires a signed preview URL for the sandbox at the specified port.
-
#fork(name: nil, timeout: DEFAULT_TIMEOUT) ⇒ Daytona::Sandbox
Forks the Sandbox, creating a new Sandbox with an identical filesystem.
-
#get_metrics(start_time = nil, end_time = nil) ⇒ Array<Daytona::SandboxMetrics>
Gets historical time-series resource usage metrics for the Sandbox.
-
#get_metrics_latest ⇒ Daytona::SandboxMetrics
Gets the most recent resource usage sample directly from the Sandbox daemon.
-
#get_user_home_dir ⇒ String
Gets the user's home directory path for the logged in user inside the Sandbox.
-
#get_work_dir ⇒ String
Gets the working directory path inside the Sandbox.
-
#initialize(sandbox_dto:, config:, sandbox_api:, subscription_manager:, otel_state: nil, analytics_api_url_provider: nil) ⇒ Sandbox
constructor
Internal — obtain sandboxes via Daytona::Daytona#create, Daytona::Daytona#get, or Daytona::Daytona#list rather than constructing directly.
-
#pause(timeout: DEFAULT_TIMEOUT) ⇒ void
Pauses the Sandbox, freezing all running processes.
-
#preview_url(port) ⇒ DaytonaApiClient::PortPreviewUrl
Retrieves the preview link for the sandbox at the specified port.
-
#recover(timeout = DEFAULT_TIMEOUT) ⇒ void
Recovers the Sandbox from a recoverable error and waits for it to be ready.
-
#refresh ⇒ void
Refresh the Sandbox data from the API.
-
#refresh_activity ⇒ void
Refreshes the sandbox activity to reset the timer for automated lifecycle management actions.
-
#resize(resources, timeout = DEFAULT_TIMEOUT) ⇒ void
Resizes the Sandbox resources.
-
#revoke_ssh_access(token) ⇒ void
Revokes an SSH access token for the sandbox.
-
#rotate_signing_key ⇒ void
Rotates the sandbox signing key, invalidating all previously signed URLs.
-
#start(timeout = DEFAULT_TIMEOUT) ⇒ void
Starts the Sandbox and waits for it to be ready.
-
#stop(timeout = DEFAULT_TIMEOUT, force: false) ⇒ void
Stops the Sandbox and waits for it to be stopped.
-
#ttl_minutes=(minutes) ⇒ void
Sets the TTL (time to live) for the Sandbox.
-
#update_env(env: nil, unset: nil) ⇒ void
Updates the Sandbox daemon's process environment.
-
#update_network_settings(network_block_all: nil, network_allow_list: nil, domain_allow_list: nil) ⇒ void
Updates outbound network policy on the runner (block all, restore access, or CIDR allow list).
-
#update_secrets(secrets) ⇒ void
Replaces the set of organization vault secrets mounted in the Sandbox.
-
#upload_url(path, ttl_seconds: nil) ⇒ String
Creates a pre-signed URL for uploading a file to the Sandbox.
-
#validate_ssh_access(token) ⇒ DaytonaApiClient::SshAccessValidationDto
Validates an SSH access token for the sandbox.
-
#wait_for_resize_complete(timeout = DEFAULT_TIMEOUT) ⇒ void
Waits for the Sandbox resize operation to complete.
-
#wait_for_sandbox_start(timeout = DEFAULT_TIMEOUT) ⇒ void
Waits for the Sandbox to reach the 'started' state.
-
#wait_for_sandbox_stop(timeout = DEFAULT_TIMEOUT) ⇒ void
Waits for the Sandbox to reach the 'stopped' state.
Methods included from Instrumentation
Constructor Details
#initialize(sandbox_dto:, config:, sandbox_api:, subscription_manager:, otel_state: nil, analytics_api_url_provider: nil) ⇒ Sandbox
Internal — obtain sandboxes via Daytona::Daytona#create, Daytona::Daytona#get, or Daytona::Daytona#list rather than constructing directly.
194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 |
# File 'lib/daytona/sandbox.rb', line 194 def initialize(sandbox_dto:, config:, sandbox_api:, subscription_manager:, otel_state: nil, analytics_api_url_provider: nil) # rubocop:disable Metrics/MethodLength @state_waiters = [] @waiter_mutex = Mutex.new process_response(sandbox_dto) @config = config @sandbox_api = sandbox_api @otel_state = otel_state @analytics_api_url_provider = analytics_api_url_provider @subscription_manager = subscription_manager @sub_id = nil @signing_key = nil @signing_key_fetched_at = 0 # Create toolbox API clients with dynamic configuration @toolbox_api_config = build_toolbox_api_config toolbox_api_config = @toolbox_api_config # Helper to create API client with authentication header create_authenticated_client = lambda do client = DaytonaToolboxApiClient::ApiClient.new(toolbox_api_config) client.default_headers['Authorization'] = "Bearer #{config.api_key || config.jwt_token}" client.default_headers['X-Daytona-Source'] = 'sdk-ruby' client.default_headers['X-Daytona-SDK-Version'] = Sdk::VERSION client.default_headers['X-Daytona-Organization-ID'] = config.organization_id if config.jwt_token client.user_agent = "sdk-ruby/#{Sdk::VERSION}" client end process_api = DaytonaToolboxApiClient::ProcessApi.new(create_authenticated_client.call) fs_api = DaytonaToolboxApiClient::FileSystemApi.new(create_authenticated_client.call) git_api = DaytonaToolboxApiClient::GitApi.new(create_authenticated_client.call) lsp_api = DaytonaToolboxApiClient::LspApi.new(create_authenticated_client.call) computer_use_api = DaytonaToolboxApiClient::ComputerUseApi.new(create_authenticated_client.call) interpreter_api = DaytonaToolboxApiClient::InterpreterApi.new(create_authenticated_client.call) info_api = DaytonaToolboxApiClient::InfoApi.new(create_authenticated_client.call) server_api = DaytonaToolboxApiClient::ServerApi.new(create_authenticated_client.call) system_api = DaytonaToolboxApiClient::SystemApi.new(create_authenticated_client.call) @process = Process.new( sandbox_id: id, toolbox_api: process_api, get_preview_link: proc { |port| preview_url(port) }, language: (labels || {}).fetch(CODE_TOOLBOX_LANGUAGE_LABEL, 'python'), otel_state: ) @fs = FileSystem.new(sandbox_id: id, toolbox_api: fs_api, otel_state:) @git = Git.new(sandbox_id: id, toolbox_api: git_api, otel_state:) @computer_use = ComputerUse.new(sandbox_id: id, toolbox_api: computer_use_api, otel_state:) @code_interpreter = CodeInterpreter.new( sandbox_id: id, toolbox_api: interpreter_api, get_preview_link: proc { |port| preview_url(port) }, otel_state: ) @lsp_api = lsp_api @info_api = info_api @server_api = server_api @system_api = system_api ensure_subscribed end |
Instance Attribute Details
#auto_archive_interval ⇒ Float
Returns Auto-archive interval in minutes.
133 134 135 |
# File 'lib/daytona/sandbox.rb', line 133 def auto_archive_interval @auto_archive_interval end |
#auto_delete_interval ⇒ Float
(negative value means disabled, 0 means delete immediately upon stopping)
137 138 139 |
# File 'lib/daytona/sandbox.rb', line 137 def auto_delete_interval @auto_delete_interval end |
#auto_destroy_at ⇒ String? (readonly)
Returns When the sandbox will be automatically destroyed (nil if no TTL is set).
149 150 151 |
# File 'lib/daytona/sandbox.rb', line 149 def auto_destroy_at @auto_destroy_at end |
#auto_pause_interval ⇒ Float
Returns Auto-pause interval in minutes (0 means disabled).
130 131 132 |
# File 'lib/daytona/sandbox.rb', line 130 def auto_pause_interval @auto_pause_interval end |
#auto_stop_interval ⇒ Float
Returns Auto-stop interval in minutes (0 means disabled).
127 128 129 |
# File 'lib/daytona/sandbox.rb', line 127 def auto_stop_interval @auto_stop_interval end |
#backup_created_at ⇒ String? (readonly)
Returns The creation timestamp of the last backup. Not returned by list results; call #refresh on each item to populate.
124 125 126 |
# File 'lib/daytona/sandbox.rb', line 124 def backup_created_at @backup_created_at end |
#backup_state ⇒ String (readonly)
Returns The state of the backup.
120 121 122 |
# File 'lib/daytona/sandbox.rb', line 120 def backup_state @backup_state end |
#build_info ⇒ DaytonaApiClient::BuildInfo? (readonly)
Returns Build information for the sandbox if it was created from a dynamic build. Not returned by list results; call #refresh on each item to populate.
146 147 148 |
# File 'lib/daytona/sandbox.rb', line 146 def build_info @build_info end |
#code_interpreter ⇒ Daytona::CodeInterpreter (readonly)
185 186 187 |
# File 'lib/daytona/sandbox.rb', line 185 def code_interpreter @code_interpreter end |
#computer_use ⇒ Daytona::ComputerUse (readonly)
182 183 184 |
# File 'lib/daytona/sandbox.rb', line 182 def computer_use @computer_use end |
#config ⇒ Daytona::Config (readonly)
167 168 169 |
# File 'lib/daytona/sandbox.rb', line 167 def config @config end |
#cpu ⇒ Float (readonly)
Returns The CPU quota for the sandbox.
99 100 101 |
# File 'lib/daytona/sandbox.rb', line 99 def cpu @cpu end |
#created_at ⇒ String (readonly)
Returns The creation timestamp of the sandbox.
152 153 154 |
# File 'lib/daytona/sandbox.rb', line 152 def created_at @created_at end |
#daemon_version ⇒ String (readonly)
Returns The version of the daemon running in the sandbox.
161 162 163 |
# File 'lib/daytona/sandbox.rb', line 161 def daemon_version @daemon_version end |
#desired_state ⇒ DaytonaApiClient::SandboxDesiredState (readonly)
Returns The desired state of the sandbox.
114 115 116 |
# File 'lib/daytona/sandbox.rb', line 114 def desired_state @desired_state end |
#disk ⇒ Float (readonly)
Returns The disk quota for the sandbox.
108 109 110 |
# File 'lib/daytona/sandbox.rb', line 108 def disk @disk end |
#domain_allow_list ⇒ String? (readonly)
Returns Comma-separated list of allowed domains for the sandbox. Not returned by list results; call #refresh on each item to populate.
89 90 91 |
# File 'lib/daytona/sandbox.rb', line 89 def domain_allow_list @domain_allow_list end |
#env ⇒ Hash<String, String>? (readonly)
Returns Environment variables for the sandbox. Not returned by list results; call #refresh on each item to populate.
71 72 73 |
# File 'lib/daytona/sandbox.rb', line 71 def env @env end |
#error_reason ⇒ String (readonly)
Returns The error reason of the sandbox.
117 118 119 |
# File 'lib/daytona/sandbox.rb', line 117 def error_reason @error_reason end |
#fs ⇒ Daytona::FileSystem (readonly)
176 177 178 |
# File 'lib/daytona/sandbox.rb', line 176 def fs @fs end |
#git ⇒ Daytona::Git (readonly)
179 180 181 |
# File 'lib/daytona/sandbox.rb', line 179 def git @git end |
#gpu ⇒ Float (readonly)
Returns The GPU quota for the sandbox.
102 103 104 |
# File 'lib/daytona/sandbox.rb', line 102 def gpu @gpu end |
#id ⇒ String (readonly)
Returns The ID of the sandbox.
58 59 60 |
# File 'lib/daytona/sandbox.rb', line 58 def id @id end |
#labels ⇒ Hash<String, String>
Returns Labels for the sandbox.
74 75 76 |
# File 'lib/daytona/sandbox.rb', line 74 def labels @labels end |
#last_activity_at ⇒ String (readonly)
Returns The last activity timestamp of the sandbox.
158 159 160 |
# File 'lib/daytona/sandbox.rb', line 158 def last_activity_at @last_activity_at end |
#memory ⇒ Float (readonly)
Returns The memory quota for the sandbox.
105 106 107 |
# File 'lib/daytona/sandbox.rb', line 105 def memory @memory end |
#network_allow_list ⇒ String? (readonly)
Returns Comma-separated list of allowed CIDR network addresses for the sandbox. Not returned by list results; call #refresh on each item to populate.
85 86 87 |
# File 'lib/daytona/sandbox.rb', line 85 def network_allow_list @network_allow_list end |
#network_block_all ⇒ Boolean? (readonly)
Returns Whether to block all network access for the sandbox. Not returned by list results; call #refresh on each item to populate.
81 82 83 |
# File 'lib/daytona/sandbox.rb', line 81 def network_block_all @network_block_all end |
#organization_id ⇒ String (readonly)
Returns The organization ID of the sandbox.
61 62 63 |
# File 'lib/daytona/sandbox.rb', line 61 def organization_id @organization_id end |
#outbound_proxy_url ⇒ String? (readonly)
Returns Outbound proxy URL to route the sandbox HTTP(S) traffic through. Not returned by list results; call #refresh on each item to populate.
93 94 95 |
# File 'lib/daytona/sandbox.rb', line 93 def outbound_proxy_url @outbound_proxy_url end |
#process ⇒ Daytona::Process (readonly)
173 174 175 |
# File 'lib/daytona/sandbox.rb', line 173 def process @process end |
#public ⇒ Boolean (readonly)
Returns Whether the sandbox http preview is public.
77 78 79 |
# File 'lib/daytona/sandbox.rb', line 77 def public @public end |
#sandbox_api ⇒ DaytonaApiClient::SandboxApi (readonly)
170 171 172 |
# File 'lib/daytona/sandbox.rb', line 170 def sandbox_api @sandbox_api end |
#snapshot ⇒ String (readonly)
Returns The snapshot used for the sandbox.
64 65 66 |
# File 'lib/daytona/sandbox.rb', line 64 def snapshot @snapshot end |
#state ⇒ DaytonaApiClient::SandboxState (readonly)
Returns The state of the sandbox.
111 112 113 |
# File 'lib/daytona/sandbox.rb', line 111 def state @state end |
#target ⇒ String (readonly)
Returns The target environment for the sandbox.
96 97 98 |
# File 'lib/daytona/sandbox.rb', line 96 def target @target end |
#toolbox_proxy_url ⇒ String (readonly)
Returns The toolbox proxy URL used to reach the sandbox's toolbox API.
164 165 166 |
# File 'lib/daytona/sandbox.rb', line 164 def toolbox_proxy_url @toolbox_proxy_url end |
#updated_at ⇒ String (readonly)
Returns The last update timestamp of the sandbox.
155 156 157 |
# File 'lib/daytona/sandbox.rb', line 155 def updated_at @updated_at end |
#user ⇒ String (readonly)
Returns The user associated with the project.
67 68 69 |
# File 'lib/daytona/sandbox.rb', line 67 def user @user end |
#volumes ⇒ Array<DaytonaApiClient::SandboxVolume>? (readonly)
Returns Volumes attached to the sandbox. Not returned by list results; call #refresh on each item to populate.
141 142 143 |
# File 'lib/daytona/sandbox.rb', line 141 def volumes @volumes end |
Class Method Details
.with_events(*method_names) ⇒ Object
21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 |
# File 'lib/daytona/sandbox.rb', line 21 def self.with_events(*method_names) method_names.each do |method_name| original = instance_method(method_name) visibility = if private_method_defined?(method_name, false) :private elsif protected_method_defined?(method_name, false) :protected else :public end define_method(method_name) do |*args, **kwargs, &blk| ensure_subscribed original.bind_call(self, *args, **kwargs, &blk) end case visibility when :private then private method_name when :protected then protected method_name end end end |
Instance Method Details
#archive ⇒ void
This method returns an undefined value.
Archives the sandbox, making it inactive and preserving its state. When sandboxes are archived, the entire filesystem state is moved to cost-effective object storage, making it possible to keep sandboxes available for an extended period. The tradeoff between archived and stopped states is that starting an archived sandbox takes more time, depending on its size. Sandbox must be stopped before archiving.
263 264 265 266 |
# File 'lib/daytona/sandbox.rb', line 263 def archive sandbox_api.archive_sandbox(id) refresh end |
#create_lsp_server(language_id:, path_to_project:) ⇒ Daytona::LspServer
Creates a new Language Server Protocol (LSP) server instance. The LSP server provides language-specific features like code completion, diagnostics, and more.
790 791 792 |
# File 'lib/daytona/sandbox.rb', line 790 def create_lsp_server(language_id:, path_to_project:) LspServer.new(language_id:, path_to_project:, toolbox_api: @lsp_api, sandbox_id: id, otel_state:) end |
#create_signed_preview_url(port, expires_in_seconds = nil) ⇒ DaytonaApiClient::SignedPortPreviewUrl
Creates a signed preview URL for the sandbox at the specified port.
615 616 617 |
# File 'lib/daytona/sandbox.rb', line 615 def create_signed_preview_url(port, expires_in_seconds = nil) sandbox_api.get_signed_port_preview_url(id, port, { expires_in_seconds: }) end |
#create_snapshot(name:, timeout: DEFAULT_TIMEOUT) ⇒ void
This method returns an undefined value.
Creates a snapshot from the current state of the Sandbox. The Sandbox will temporarily enter a 'snapshotting' state and return to its previous state when complete.
874 875 876 877 878 879 880 881 882 883 |
# File 'lib/daytona/sandbox.rb', line 874 def create_snapshot(name:, timeout: DEFAULT_TIMEOUT) with_timeout( timeout:, message: "Sandbox #{id} snapshot failed within the #{timeout} seconds timeout period", setup: proc { response = sandbox_api.create_sandbox_snapshot(id, DaytonaApiClient::CreateSandboxSnapshot.new(name:)) process_response(response) } ) { wait_for_snapshot_complete } end |
#create_ssh_access(expires_in_minutes) ⇒ DaytonaApiClient::SshAccessDto
Creates an SSH access token for the sandbox.
384 385 386 |
# File 'lib/daytona/sandbox.rb', line 384 def create_ssh_access(expires_in_minutes) sandbox_api.create_ssh_access(id, { expires_in_minutes: }) end |
#delete(timeout = DEFAULT_TIMEOUT, wait: false) ⇒ void
This method returns an undefined value.
Deletes the Sandbox.
By default returns as soon as the deletion request is accepted (matching
origin/main behavior). Pass wait: true to block until the Sandbox
reaches the destroyed state.
398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 |
# File 'lib/daytona/sandbox.rb', line 398 def delete(timeout = DEFAULT_TIMEOUT, wait: false) # rubocop:disable Metrics/AbcSize,Metrics/MethodLength begin process_response(sandbox_api.delete_sandbox(id)) rescue DaytonaApiClient::ApiError => e raise unless e.code == 404 apply_state(DaytonaApiClient::SandboxState::DESTROYED) end if wait refresh_data_safe else begin refresh rescue DaytonaApiClient::ApiError => e raise unless e.code == 404 apply_state(DaytonaApiClient::SandboxState::DESTROYED) end return end return if state.to_s == DaytonaApiClient::SandboxState::DESTROYED.to_s with_timeout( timeout:, message: "Sandbox #{id} failed to be destroyed within the #{timeout} seconds timeout period", setup: nil ) do wait_for_state( target_states: [DaytonaApiClient::SandboxState::DESTROYED], error_states: [DaytonaApiClient::SandboxState::ERROR, DaytonaApiClient::SandboxState::BUILD_FAILED], safe_refresh: true ) end ensure unsubscribe_from_events end |
#download_url(path, ttl_seconds: nil) ⇒ String
Creates a pre-signed URL for downloading a file from the Sandbox.
The URL works with any HTTP client without auth headers and stays valid across sandbox restarts (downloads succeed only while the sandbox is running). The signing key is cached locally for up to 15 seconds; if the key was rotated from another client, URLs may be rejected until the cache refreshes.
550 551 552 553 554 555 556 557 558 559 560 |
# File 'lib/daytona/sandbox.rb', line 550 def download_url(path, ttl_seconds: nil) Utils::FileUrlSigning.build_signed_file_url( @toolbox_proxy_url, id, '/files/download', 'GET', path, ensure_signing_key, ttl_seconds ) end |
#experimental_create_snapshot(name:, timeout: DEFAULT_TIMEOUT) ⇒ Object
Use #create_snapshot instead. This method will be removed in a future version.
Deprecated: Use create_snapshot instead. This method will be removed in a future version.
896 897 898 899 |
# File 'lib/daytona/sandbox.rb', line 896 def experimental_create_snapshot(name:, timeout: DEFAULT_TIMEOUT) warn('[DEPRECATION] `experimental_create_snapshot` is deprecated. Use `create_snapshot` instead.', uplevel: 1) create_snapshot(name:, timeout:) end |
#experimental_fork(name: nil, timeout: DEFAULT_TIMEOUT) ⇒ Object
Use #fork instead. This method will be removed in a future version.
Deprecated: Use fork instead. This method will be removed in a future version.
888 889 890 891 |
# File 'lib/daytona/sandbox.rb', line 888 def experimental_fork(name: nil, timeout: DEFAULT_TIMEOUT) warn('[DEPRECATION] `experimental_fork` is deprecated. Use `fork` instead.', uplevel: 1) fork(name:, timeout:) end |
#expire_signed_preview_url(port, token) ⇒ void
This method returns an undefined value.
Expires a signed preview URL for the sandbox at the specified port.
627 628 629 |
# File 'lib/daytona/sandbox.rb', line 627 def expire_signed_preview_url(port, token) sandbox_api.expire_signed_port_preview_url(id, port, token) end |
#fork(name: nil, timeout: DEFAULT_TIMEOUT) ⇒ Daytona::Sandbox
Forks the Sandbox, creating a new Sandbox with an identical filesystem. The forked Sandbox is a copy-on-write clone of the original. It starts with the same disk contents but operates independently from that point on.
846 847 848 849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 |
# File 'lib/daytona/sandbox.rb', line 846 def fork(name: nil, timeout: DEFAULT_TIMEOUT) # rubocop:disable Metrics/MethodLength forked_dto = nil with_timeout( timeout:, message: "Sandbox #{id} fork failed to become ready within the #{timeout} seconds timeout period", setup: proc { forked_dto = sandbox_api.fork_sandbox(id, DaytonaApiClient::ForkSandbox.new(name:)) } ) do forked = Sandbox.new( sandbox_dto: forked_dto, config:, sandbox_api:, subscription_manager: @subscription_manager, otel_state:, analytics_api_url_provider: @analytics_api_url_provider ) forked.wait_for_sandbox_start(timeout) return forked end end |
#get_metrics(start_time = nil, end_time = nil) ⇒ Array<Daytona::SandboxMetrics>
Gets historical time-series resource usage metrics for the Sandbox.
504 505 506 507 508 509 510 511 512 513 514 |
# File 'lib/daytona/sandbox.rb', line 504 def get_metrics(start_time = nil, end_time = nil) from, to = metrics_range(start_time, end_time) analytics_api_url = fetch_analytics_api_url if analytics_api_url && !analytics_api_url.empty? pivot_sandbox_metric_points(fetch_analytics_metrics(analytics_api_url, from, to)) else pivot_sandbox_metrics(fetch_proxy_metrics(from, to)) end rescue StandardError => e raise Sdk::Error, "Failed to get sandbox metrics: #{e.}" end |
#get_metrics_latest ⇒ Daytona::SandboxMetrics
Gets the most recent resource usage sample directly from the Sandbox daemon.
Unlike #get_metrics, which returns aggregated historical samples, this returns the single current reading without going through the telemetry backend.
490 491 492 493 494 |
# File 'lib/daytona/sandbox.rb', line 490 def get_metrics_latest sandbox_metrics_from_system_metrics(@system_api.get_system_metrics) rescue StandardError => e raise Sdk::Error, "Failed to get system metrics: #{e.}" end |
#get_user_home_dir ⇒ String
Gets the user's home directory path for the logged in user inside the Sandbox.
443 444 445 446 447 |
# File 'lib/daytona/sandbox.rb', line 443 def get_user_home_dir @info_api.get_user_home_dir.dir rescue *Sdk::API_ERROR_CLASSES => e raise Sdk.wrap_error(e, 'Failed to get user home directory') end |
#get_work_dir ⇒ String
Gets the working directory path inside the Sandbox.
457 458 459 460 461 |
# File 'lib/daytona/sandbox.rb', line 457 def get_work_dir @info_api.get_work_dir.dir rescue *Sdk::API_ERROR_CLASSES => e raise Sdk.wrap_error(e, 'Failed to get working directory path') end |
#pause(timeout: DEFAULT_TIMEOUT) ⇒ void
This method returns an undefined value.
Pauses the Sandbox, freezing all running processes.
Completes when the Sandbox has left the pausing state (paused, stopped,
archived, etc.); error states still raise.
907 908 909 910 911 912 913 914 915 916 917 918 919 920 921 922 |
# File 'lib/daytona/sandbox.rb', line 907 def pause(timeout: DEFAULT_TIMEOUT) with_timeout( timeout:, message: "Sandbox #{id} failed to pause within the #{timeout} seconds timeout period", setup: proc { sandbox_api.pause_sandbox(id) refresh } ) do error_states = [DaytonaApiClient::SandboxState::ERROR, DaytonaApiClient::SandboxState::BUILD_FAILED] exclude = [DaytonaApiClient::SandboxState::PAUSING] + error_states target_states = DaytonaApiClient::SandboxState.all_vars.reject { |s| exclude.include?(s) } wait_for_state(target_states:, error_states:) end end |
#preview_url(port) ⇒ DaytonaApiClient::PortPreviewUrl
Retrieves the preview link for the sandbox at the specified port. If the port is closed, it will be opened automatically. For private sandboxes, a token is included to grant access to the URL.
530 531 532 |
# File 'lib/daytona/sandbox.rb', line 530 def preview_url(port) sandbox_api.get_port_preview_url(id, port) end |
#recover(timeout = DEFAULT_TIMEOUT) ⇒ void
This method returns an undefined value.
Recovers the Sandbox from a recoverable error and waits for it to be ready.
688 689 690 691 692 693 694 695 696 697 698 699 700 701 |
# File 'lib/daytona/sandbox.rb', line 688 def recover(timeout = DEFAULT_TIMEOUT) with_timeout( timeout:, message: "Sandbox #{id} failed to recover within the #{timeout} seconds timeout period", setup: proc { process_response(sandbox_api.recover_sandbox(id)) } ) do wait_for_state( target_states: [DaytonaApiClient::SandboxState::STARTED], error_states: [DaytonaApiClient::SandboxState::ERROR, DaytonaApiClient::SandboxState::BUILD_FAILED] ) end rescue *Sdk::API_ERROR_CLASSES => e raise Sdk.wrap_error(e, 'Failed to recover sandbox') end |
#refresh ⇒ void
This method returns an undefined value.
Refresh the Sandbox data from the API.
634 635 636 |
# File 'lib/daytona/sandbox.rb', line 634 def refresh process_response(sandbox_api.get_sandbox(id)) end |
#refresh_activity ⇒ void
This method returns an undefined value.
Refreshes the sandbox activity to reset the timer for automated lifecycle management actions.
This method updates the sandbox's last activity timestamp without changing its state. It is useful for keeping long-running sessions alive while there is still user activity.
647 648 649 650 651 652 |
# File 'lib/daytona/sandbox.rb', line 647 def refresh_activity sandbox_api.update_last_activity(id) nil rescue *Sdk::API_ERROR_CLASSES => e raise Sdk.wrap_error(e, 'Failed to refresh sandbox activity') end |
#resize(resources, timeout = DEFAULT_TIMEOUT) ⇒ void
This method returns an undefined value.
Resizes the Sandbox resources.
Changes the CPU, memory, or disk allocation. Resizing a started sandbox accepts only CPU and memory increases. Disk resize requires a stopped sandbox; disk can only grow. GPU is not resizable — to change GPU, create a new sandbox.
741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 |
# File 'lib/daytona/sandbox.rb', line 741 def resize(resources, timeout = DEFAULT_TIMEOUT) raise Sdk::Error, 'Resources must not be nil' if resources.nil? if resources.gpu || resources.gpu_type raise Sdk::Error, 'Resize does not support changes to gpu or gpu_type — to change GPU, create a new sandbox' end with_timeout( timeout:, message: "Sandbox #{id} failed to resize within the #{timeout} seconds timeout period", setup: proc { resize_attrs = {} resize_attrs[:cpu] = resources.cpu if resources.cpu resize_attrs[:memory] = resources.memory if resources.memory resize_attrs[:disk] = resources.disk if resources.disk resize_request = DaytonaApiClient::ResizeSandbox.new(resize_attrs) process_response(sandbox_api.resize_sandbox(id, resize_request)) } ) { wait_for_resize_complete(timeout) } end |
#revoke_ssh_access(token) ⇒ void
This method returns an undefined value.
Revokes an SSH access token for the sandbox.
658 659 660 |
# File 'lib/daytona/sandbox.rb', line 658 def revoke_ssh_access(token) sandbox_api.revoke_ssh_access(id, token:) end |
#rotate_signing_key ⇒ void
This method returns an undefined value.
Rotates the sandbox signing key, invalidating all previously signed URLs.
598 599 600 601 602 |
# File 'lib/daytona/sandbox.rb', line 598 def rotate_signing_key @signing_key = @sandbox_api.rotate_signing_key(id) @signing_key_fetched_at = Time.now.to_f nil end |
#start(timeout = DEFAULT_TIMEOUT) ⇒ void
This method returns an undefined value.
Starts the Sandbox and waits for it to be ready.
666 667 668 669 670 671 672 673 674 675 676 677 |
# File 'lib/daytona/sandbox.rb', line 666 def start(timeout = DEFAULT_TIMEOUT) with_timeout( timeout:, message: "Sandbox #{id} failed to become ready within the #{timeout} seconds timeout period", setup: proc { process_response(sandbox_api.start_sandbox(id)) } ) do wait_for_state( target_states: [DaytonaApiClient::SandboxState::STARTED], error_states: [DaytonaApiClient::SandboxState::ERROR, DaytonaApiClient::SandboxState::BUILD_FAILED] ) end end |
#stop(timeout = DEFAULT_TIMEOUT, force: false) ⇒ void
This method returns an undefined value.
Stops the Sandbox and waits for it to be stopped.
708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 |
# File 'lib/daytona/sandbox.rb', line 708 def stop(timeout = DEFAULT_TIMEOUT, force: false) # rubocop:disable Metrics/MethodLength with_timeout( timeout:, message: "Sandbox #{id} failed to become stopped within the #{timeout} seconds timeout period", setup: proc { sandbox_api.stop_sandbox(id, { force: force }) refresh } ) do wait_for_state( target_states: [DaytonaApiClient::SandboxState::STOPPED, DaytonaApiClient::SandboxState::DESTROYED], error_states: [DaytonaApiClient::SandboxState::ERROR, DaytonaApiClient::SandboxState::BUILD_FAILED] ) end end |
#ttl_minutes=(minutes) ⇒ void
This method returns an undefined value.
Sets the TTL (time to live) for the Sandbox. The TTL is re-anchored from the current time. When it elapses the Sandbox is destroyed, regardless of its current state. Use 0 to disable.
374 375 376 377 378 |
# File 'lib/daytona/sandbox.rb', line 374 def ttl_minutes=(minutes) raise Sdk::Error, 'TTL must be a non-negative integer' if minutes.negative? sandbox_api.set_ttl(id, minutes) end |
#update_env(env: nil, unset: nil) ⇒ void
This method returns an undefined value.
Updates the Sandbox daemon's process environment. Newly spawned processes, sessions and PTYs inherit the change; already-running processes keep their existing environment.
473 474 475 476 477 478 |
# File 'lib/daytona/sandbox.rb', line 473 def update_env(env: nil, unset: nil) @server_api.update_env(DaytonaToolboxApiClient::UpdateEnvRequest.new(set: env, unset:)) nil rescue StandardError => e raise Sdk::Error, "Failed to update environment: #{e.}" end |
#update_network_settings(network_block_all: nil, network_allow_list: nil, domain_allow_list: nil) ⇒ void
This method returns an undefined value.
Updates outbound network policy on the runner (block all, restore access, or CIDR allow list).
299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 |
# File 'lib/daytona/sandbox.rb', line 299 def update_network_settings(network_block_all: nil, network_allow_list: nil, domain_allow_list: nil) if network_block_all.nil? && network_allow_list.nil? && domain_allow_list.nil? raise Sdk::Error, 'At least one of network_block_all, network_allow_list or domain_allow_list must be provided' end body = DaytonaApiClient::UpdateSandboxNetworkSettings.new( network_block_all:, network_allow_list:, domain_allow_list: ) data = sandbox_api.update_network_settings(id, body) @network_block_all = data.network_block_all @network_allow_list = data.network_allow_list @domain_allow_list = data.domain_allow_list end |
#update_secrets(secrets) ⇒ void
This method returns an undefined value.
Replaces the set of organization vault secrets mounted in the Sandbox. Pass an empty hash to detach all secrets. Rotated, attached or detached secrets take effect for outbound requests within seconds. New environment variables are only visible to processes spawned after the update; a Sandbox created without any secrets must be restarted for newly attached secrets to work.
329 330 331 332 333 334 335 |
# File 'lib/daytona/sandbox.rb', line 329 def update_secrets(secrets) body = DaytonaApiClient::UpdateSandboxSecrets.new( secrets: secrets.map { |env_var, secret_name| { env_var.to_s => secret_name.to_s } } ) data = sandbox_api.update_sandbox_secrets(id, body) process_response(data) end |
#upload_url(path, ttl_seconds: nil) ⇒ String
Creates a pre-signed URL for uploading a file to the Sandbox.
Send a POST request with the file as multipart/form-data. The URL works with any HTTP client without auth headers. The signing key is cached locally for up to 15 seconds; if the key was rotated from another client, URLs may be rejected until the cache refreshes.
578 579 580 581 582 583 584 585 586 587 588 |
# File 'lib/daytona/sandbox.rb', line 578 def upload_url(path, ttl_seconds: nil) Utils::FileUrlSigning.build_signed_file_url( @toolbox_proxy_url, id, '/files/upload-v2', 'POST', path, ensure_signing_key, ttl_seconds ) end |
#validate_ssh_access(token) ⇒ DaytonaApiClient::SshAccessValidationDto
Validates an SSH access token for the sandbox.
798 799 800 |
# File 'lib/daytona/sandbox.rb', line 798 def validate_ssh_access(token) sandbox_api.validate_ssh_access(token) end |
#wait_for_resize_complete(timeout = DEFAULT_TIMEOUT) ⇒ void
This method returns an undefined value.
Waits for the Sandbox resize operation to complete. Polls the Sandbox status until the state is no longer 'resizing'.
768 769 770 771 772 773 774 775 776 777 778 779 780 |
# File 'lib/daytona/sandbox.rb', line 768 def wait_for_resize_complete(timeout = DEFAULT_TIMEOUT) with_timeout( timeout:, message: "Sandbox #{id} resize did not complete within the #{timeout} seconds timeout period", setup: nil ) do error_states = [DaytonaApiClient::SandboxState::ERROR, DaytonaApiClient::SandboxState::BUILD_FAILED] exclude = [DaytonaApiClient::SandboxState::RESIZING] + error_states target_states = DaytonaApiClient::SandboxState.all_vars.reject { |s| exclude.include?(s) } wait_for_state(target_states:, error_states:) end end |
#wait_for_sandbox_start(timeout = DEFAULT_TIMEOUT) ⇒ void
This method returns an undefined value.
Waits for the Sandbox to reach the 'started' state. Polls the Sandbox status until it reaches the 'started' state or encounters an error.
807 808 809 810 811 812 813 814 815 816 817 818 |
# File 'lib/daytona/sandbox.rb', line 807 def wait_for_sandbox_start(timeout = DEFAULT_TIMEOUT) with_timeout( timeout:, message: "Sandbox #{id} failed to start within the #{timeout} seconds timeout period", setup: nil ) do wait_for_state( target_states: [DaytonaApiClient::SandboxState::STARTED], error_states: [DaytonaApiClient::SandboxState::ERROR, DaytonaApiClient::SandboxState::BUILD_FAILED] ) end end |
#wait_for_sandbox_stop(timeout = DEFAULT_TIMEOUT) ⇒ void
This method returns an undefined value.
Waits for the Sandbox to reach the 'stopped' state. Polls the Sandbox status until it reaches the 'stopped' state or encounters an error. Treats destroyed as stopped to cover ephemeral sandboxes that are automatically deleted after stopping.
826 827 828 829 830 831 832 833 834 835 836 837 |
# File 'lib/daytona/sandbox.rb', line 826 def wait_for_sandbox_stop(timeout = DEFAULT_TIMEOUT) with_timeout( timeout:, message: "Sandbox #{id} failed to stop within the #{timeout} seconds timeout period", setup: nil ) do wait_for_state( target_states: [DaytonaApiClient::SandboxState::STOPPED, DaytonaApiClient::SandboxState::DESTROYED], error_states: [DaytonaApiClient::SandboxState::ERROR, DaytonaApiClient::SandboxState::BUILD_FAILED] ) end end |