Class: Daytona::Daytona

Inherits:
Object
  • Object
show all
Includes:
Instrumentation
Defined in:
lib/daytona/daytona.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Instrumentation

included

Constructor Details

#initialize(config = Config.new) ⇒ Daytona

Returns a new instance of Daytona.

Parameters:

  • config (Daytona::Config) (defaults to: Config.new)

    Configuration options. Defaults to Daytona::Config.new



35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
# File 'lib/daytona/daytona.rb', line 35

def initialize(config = Config.new)
  @config = config
  ensure_access_token_defined

  otel_enabled = config._experimental&.dig('otel_enabled') || config.read_env('DAYTONA_EXPERIMENTAL_OTEL_ENABLED') == 'true'
  @otel_state = (::Daytona.init_otel(Sdk::VERSION) if otel_enabled)

  @api_client = build_api_client
  @sandbox_api = DaytonaApiClient::SandboxApi.new(api_client)
  @config_api = DaytonaApiClient::ConfigApi.new(api_client)
  @volume = VolumeService.new(DaytonaApiClient::VolumesApi.new(api_client), otel_state:)
  @object_storage_api = DaytonaApiClient::ObjectStorageApi.new(api_client)
  @snapshots_api = DaytonaApiClient::SnapshotsApi.new(api_client)
  @snapshot = SnapshotService.new(snapshots_api:, object_storage_api:, default_region_id: config.target,
                                  otel_state:)
end

Instance Attribute Details

#api_clientDaytonaApiClient (readonly)

Returns:

  • (DaytonaApiClient)


17
18
19
# File 'lib/daytona/daytona.rb', line 17

def api_client
  @api_client
end

#configDaytona::Config (readonly)

Returns:



14
15
16
# File 'lib/daytona/daytona.rb', line 14

def config
  @config
end

#object_storage_apiDaytonaApiClient::ObjectStorageApi (readonly)

Returns:

  • (DaytonaApiClient::ObjectStorageApi)


26
27
28
# File 'lib/daytona/daytona.rb', line 26

def object_storage_api
  @object_storage_api
end

#sandbox_apiDaytonaApiClient::SandboxApi (readonly)

Returns:

  • (DaytonaApiClient::SandboxApi)


20
21
22
# File 'lib/daytona/daytona.rb', line 20

def sandbox_api
  @sandbox_api
end

#snapshotDaytona::SnapshotService (readonly)



32
33
34
# File 'lib/daytona/daytona.rb', line 32

def snapshot
  @snapshot
end

#snapshots_apiDaytonaApiClient::SnapshotsApi (readonly)

Returns:

  • (DaytonaApiClient::SnapshotsApi)


29
30
31
# File 'lib/daytona/daytona.rb', line 29

def snapshots_api
  @snapshots_api
end

#volumeDaytona::VolumeService (readonly)



23
24
25
# File 'lib/daytona/daytona.rb', line 23

def volume
  @volume
end

Instance Method Details

#closevoid

This method returns an undefined value.

Shuts down OTel providers, flushing any pending telemetry data.



55
56
57
58
# File 'lib/daytona/daytona.rb', line 55

def close
  ::Daytona.shutdown_otel(@otel_state)
  @otel_state = nil
end

#create(params = nil, on_snapshot_create_logs: nil) ⇒ Daytona::Sandbox

Creates a sandbox with the specified parameters

Parameters:

Returns:

Raises:



65
66
67
68
69
70
71
72
73
74
75
76
77
78
# File 'lib/daytona/daytona.rb', line 65

def create(params = nil, on_snapshot_create_logs: nil)
  if params.nil?
    params = CreateSandboxFromSnapshotParams.new(language: CodeLanguage::PYTHON)
  elsif params.language.nil?
    params.language = CodeLanguage::PYTHON
  end

  unless CodeLanguage::ALL.include?(params.language.to_s.to_sym)
    raise ArgumentError,
          "Invalid #{CODE_TOOLBOX_LANGUAGE_LABEL}: #{params.language}. Supported languages: #{CodeLanguage::ALL.join(', ')}"
  end

  _create(params, on_snapshot_create_logs:)
end

#delete(sandbox) ⇒ void

This method returns an undefined value.

Deletes a Sandbox.

Parameters:



84
# File 'lib/daytona/daytona.rb', line 84

def delete(sandbox) = sandbox.delete

#get(id) ⇒ Daytona::Sandbox

Gets a Sandbox by its ID.

Parameters:

  • id (String)

Returns:



90
91
92
93
# File 'lib/daytona/daytona.rb', line 90

def get(id)
  sandbox_dto = sandbox_api.get_sandbox(id)
  to_sandbox(sandbox_dto:)
end

#list(labels = {}, page: nil, limit: nil) ⇒ Daytona::PaginatedResource

Lists Sandboxes filtered by labels.

Parameters:

  • labels (Hash<String, String>) (defaults to: {})
  • page (Integer, Nil) (defaults to: nil)
  • limit (Integer, Nil) (defaults to: nil)

Returns:

Raises:



102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
# File 'lib/daytona/daytona.rb', line 102

def list(labels = {}, page: nil, limit: nil)
  raise Sdk::Error, 'page must be positive integer' if page && page < 1

  raise Sdk::Error, 'limit must be positive integer' if limit && limit < 1

  response = sandbox_api.list_sandboxes_paginated(labels: JSON.dump(labels), page:, limit:)

  PaginatedResource.new(
    total: response.total,
    page: response.page,
    total_pages: response.total_pages,
    items: response.items.map do |sandbox_dto|
      to_sandbox(sandbox_dto:)
    end
  )
end

#start(sandbox, timeout = Sandbox::DEFAULT_TIMEOUT) ⇒ void

This method returns an undefined value.

Starts a Sandbox and waits for it to be ready.

Parameters:

  • sandbox (Daytona::Sandbox)
  • timeout (Numeric) (defaults to: Sandbox::DEFAULT_TIMEOUT)

    Maximum wait time in seconds (defaults to 60 s).



124
# File 'lib/daytona/daytona.rb', line 124

def start(sandbox, timeout = Sandbox::DEFAULT_TIMEOUT) = sandbox.start(timeout)

#stop(sandbox, timeout = Sandbox::DEFAULT_TIMEOUT) ⇒ void

This method returns an undefined value.

Stops a Sandbox and waits for it to be stopped.

Parameters:

  • sandbox (Daytona::Sandbox)
  • timeout (Numeric) (defaults to: Sandbox::DEFAULT_TIMEOUT)

    Maximum wait time in seconds (defaults to 60 s).



131
# File 'lib/daytona/daytona.rb', line 131

def stop(sandbox, timeout = Sandbox::DEFAULT_TIMEOUT) = sandbox.stop(timeout)