durable_object

Types

AlarmInvocationInfo

pub type AlarmInvocationInfo {
  AlarmInvocationInfo(retry_count: Int, is_retry: Bool)
}

Constructors

AlarmInvocationInfo(retry_count: Int, is_retry: Bool)

GetOptions

</>

pub type GetOptions {
  GetOptions(allow_concurrency: Bool, no_cache: Bool)
}

Constructors

GetOptions(allow_concurrency: Bool, no_cache: Bool)

Id

</>

pub type Id

Namespace

</>

pub type Namespace

NonConcurrentPromise

</>

pub type NonConcurrentPromise(t)

Sql

</>

pub type Sql

SqlStorageCursor

</>

pub type SqlStorageCursor

State

</>

pub type State

Storage

</>

pub type Storage

Stub

</>

pub type Stub

UpdateOptions

</>

pub type UpdateOptions {
  UpdateOptions(allow_unconfirmed: Bool, no_cache: Bool)
}

Constructors

UpdateOptions(allow_unconfirmed: Bool, no_cache: Bool)

Values

alarm_invocation_info_decoder

</>

pub fn alarm_invocation_info_decoder(
  ,
) -> decode.Decoder(AlarmInvocationInfo)

await

</>

pub fn await(
  p: NonConcurrentPromise(t),
  then: fn(t) -> NonConcurrentPromise(u),
) -> NonConcurrentPromise(u)

block_concurrency_while

</>

pub fn block_concurrency_while(
  state: State,
  action: fn() -> promise.Promise(t),
) -> NonConcurrentPromise(t)

database_size

</>

pub fn database_size(storage: Sql) -> Int

delete_alarm

</>

pub fn delete_alarm(
  storage: Storage,
) -> NonConcurrentPromise(Nil)

equals

</>

pub fn equals(id: Id, other: Id) -> Bool

exec

</>

pub fn exec(
  storage: Sql,
  query: String,
  bindings: List(String),
) -> SqlStorageCursor

get

</>

pub fn get(
  namespace: Namespace,
  id: Id,
  location_hint: option.Option(String),
) -> Stub

get_alarm

</>

pub fn get_alarm(
  storage: Storage,
) -> NonConcurrentPromise(Result(Int, Nil))

get_default

</>

pub fn get_default() -> GetOptions

get_many

</>

pub fn get_many(
  storage: Storage,
  keys: List(String),
  options: GetOptions,
) -> NonConcurrentPromise(Result(dynamic.Dynamic, Nil))

get_one

</>

pub fn get_one(
  storage: Storage,
  key: String,
  options: GetOptions,
) -> NonConcurrentPromise(Result(dynamic.Dynamic, Nil))

id_from_name

</>

pub fn id_from_name(namespace: Namespace, name: String) -> Id

id_from_string

</>

pub fn id_from_string(namespace: Namespace, id: String) -> Id

This is the string value of the objects id, not its name.

jurisdiction

</>

pub fn jurisdiction(
  namespace: Namespace,
  jurisdiction: String,
) -> Namespace

name

</>

pub fn name(id: Id) -> String

new_unique_id

</>

pub fn new_unique_id(jurisdiction: option.Option(String)) -> Id

put_one

</>

pub fn put_one(
  storage: Storage,
  key: String,
  value: json.Json,
  options: UpdateOptions,
) -> NonConcurrentPromise(Nil)

resolve

</>

pub fn resolve(value: t) -> NonConcurrentPromise(t)

rpc

</>

pub fn rpc(
  stub: Stub,
  method: String,
  args: List(json.Json),
) -> promise.Promise(Result(json.Json, String))

set_alarm

</>

pub fn set_alarm(
  storage: Storage,
  scheduled_time: Int,
) -> NonConcurrentPromise(Nil)

sql

</>

pub fn sql(storage: Storage) -> Sql

state_id

</>

pub fn state_id(state: State) -> Id

storage

</>

pub fn storage(state: State) -> Storage

stub_id

</>

pub fn stub_id(stub: Stub) -> Id

to_promise

</>

pub fn to_promise(
  p: NonConcurrentPromise(t),
) -> promise.Promise(t)

to_string

</>

pub fn to_string(id: Id) -> String

update_default

</>

pub fn update_default() -> UpdateOptions