/* tslint:disable */
/* eslint-disable */
export function start(): void;
export function roundTripBytes(bytes: Uint8Array): Uint8Array;
export function bridgeRivetErrorPrefix(): string;
export function awaitPromise(promise: Promise<any>): Promise<any>;
export function uint8ArrayFromBytes(bytes: Uint8Array): Uint8Array;
export class ActorContext {
  free(): void;
  keepAwake(promise: Promise<any>): void;
  saveState(payload: any): Promise<void>;
  waitUntil(promise: Promise<any>): void;
  abortSignal(): any;
  connectConn(params: Uint8Array, request: any): Promise<ConnHandle>;
  requestSave(opts: any): void;
  registerTask(promise: Promise<any>): void;
  runtimeState(): any;
  endKeepAwake(region_id: number): void;
  setRunWakeAt(timestamp_ms?: number | null): Promise<void>;
  beginKeepAwake(): number;
  inspectorSnapshot(): object;
  endOnStateChange(): void;
  restartRunHandler(): void;
  beginOnStateChange(): void;
  requestSaveAndWait(opts: any): Promise<void>;
  verifyInspectorAuth(bearer_token?: string | null): Promise<void>;
  endWebsocketCallback(region_id: number): void;
  beginStateTransaction(timeout_ms?: number | null): Promise<ActorStateTransaction>;
  beginWebsocketCallback(): number;
  dirtyHibernatableConns(): Array<any>;
  saveStateAndWorkflowBatch(writes: any): Promise<void>;
  kv(): Kv;
  waitForTrackedShutdownWork(): Promise<boolean>;
  takePendingHibernationChanges(): Array<any>;
  key(): any;
  constructor();
  sql(): SqliteDb;
  waitForTrackedShutdownWorkUnbounded(): Promise<void>;
  name(): string;
  conns(): Array<any>;
  queue(): Queue;
  sleep(): void;
  state(): Uint8Array;
  region(): string;
  destroy(): void;
  actorId(): string;
  schedule(): Schedule;
  broadcast(name: string, args: Uint8Array): void;
  setAlarm(timestamp_ms?: number | null): void;
}
export class ActorFactory {
  free(): void;
  constructor(callbacks: any, config: any);
}
export class ActorStateTransaction {
  private constructor();
  free(): void;
  commit(payload: any): Promise<void>;
  execute(sql: string, params: any): Promise<any>;
  rollback(): Promise<void>;
}
export class CancellationToken {
  free(): void;
  onCancelled(callback: Function): void;
  constructor();
  cancel(): void;
  aborted(): boolean;
}
export class ConnHandle {
  private constructor();
  free(): void;
  disconnect(reason?: string | null): Promise<void>;
  isHibernatable(): boolean;
  id(): string;
  send(name: string, args: Uint8Array): void;
  state(): Uint8Array;
  params(): Uint8Array;
  setState(state: Uint8Array): void;
}
export class CoreRegistry {
  free(): void;
  handleServerlessRequest(req: any, on_stream_event: Function, cancel_token: CancellationToken, config: any): Promise<any>;
  constructor();
  serve(config: any): Promise<void>;
  register(name: string, factory: ActorFactory): void;
  shutdown(): Promise<void>;
}
export class Kv {
  private constructor();
  free(): void;
  delete(key: Uint8Array): Promise<void>;
  listRange(start: Uint8Array, end: Uint8Array, options: any): Promise<any>;
  listPrefix(prefix: Uint8Array, options: any): Promise<any>;
  batchDelete(keys: Array<any>): Promise<void>;
  deleteRange(start: Uint8Array, end: Uint8Array): Promise<void>;
  get(key: Uint8Array): Promise<any>;
  put(key: Uint8Array, value: Uint8Array): Promise<void>;
  batchGet(keys: Array<any>): Promise<any>;
  batchPut(entries: Array<any>): Promise<void>;
}
export class Queue {
  private constructor();
  free(): void;
  nextBatch(options: any, signal?: CancellationToken | null): Promise<Array<any>>;
  tryNextBatch(options: any): Array<any>;
  waitForNames(names: any, options: any, signal?: CancellationToken | null): Promise<QueueMessage>;
  enqueueAndWait(name: string, body: Uint8Array, options: any, signal?: CancellationToken | null): Promise<Uint8Array | undefined>;
  inspectMessages(): Promise<Array<any>>;
  completePersisted(message_id: bigint, expected_name: string, response?: Uint8Array | null): Promise<boolean>;
  waitForNamesAvailable(names: any, options: any): Promise<void>;
  send(name: string, body: Uint8Array): Promise<QueueMessage>;
  reset(): Promise<void>;
  maxSize(): number;
}
export class QueueMessage {
  private constructor();
  free(): void;
  createdAt(): number;
  isCompletable(): boolean;
  id(): bigint;
  body(): Uint8Array;
  name(): string;
  complete(response: any): Promise<void>;
}
export class Schedule {
  private constructor();
  free(): void;
  cronEvery(name: string, interval_ms: number, action_name: string, args: Uint8Array, max_history?: number | null): Promise<void>;
  cronDelete(name: string): Promise<boolean>;
  cronHistory(name: string, limit?: number | null): Promise<any>;
  at(timestamp_ms: number, action_name: string, args: Uint8Array): Promise<string>;
  get(id: string): Promise<any>;
  list(): Promise<any>;
  after(duration_ms: number, action_name: string, args: Uint8Array): Promise<string>;
  cancel(id: string): Promise<boolean>;
  cronGet(name: string): Promise<any>;
  cronSet(name: string, expression: string, timezone: string | null | undefined, action_name: string, args: Uint8Array, max_history?: number | null): Promise<void>;
  cronList(): Promise<any>;
}
export class SqliteDb {
  private constructor();
  free(): void;
  executeBatch(statements: any): Promise<any>;
  beginTransaction(timeout_ms?: number | null, name?: string | null): Promise<SqliteTransaction>;
  run(sql: string, params: any): Promise<any>;
  exec(sql: string): Promise<any>;
  close(): Promise<void>;
  query(sql: string, params: any): Promise<any>;
  execute(sql: string, params: any): Promise<any>;
}
export class SqliteTransaction {
  private constructor();
  free(): void;
  exec(sql: string): Promise<any>;
  commit(): Promise<void>;
  execute(sql: string, params: any): Promise<any>;
  rollback(): Promise<void>;
}
export class WebSocketHandle {
  private constructor();
  free(): void;
  setEventCallback(callback: Function): void;
  send(data: Uint8Array, binary: boolean): void;
  close(code?: number | null, reason?: string | null): Promise<void>;
}

export type InitInput = RequestInfo | URL | Response | BufferSource | WebAssembly.Module;

export interface InitOutput {
  readonly memory: WebAssembly.Memory;
  readonly __wbg_actorcontext_free: (a: number, b: number) => void;
  readonly __wbg_actorfactory_free: (a: number, b: number) => void;
  readonly __wbg_actorstatetransaction_free: (a: number, b: number) => void;
  readonly __wbg_cancellationtoken_free: (a: number, b: number) => void;
  readonly __wbg_connhandle_free: (a: number, b: number) => void;
  readonly __wbg_coreregistry_free: (a: number, b: number) => void;
  readonly __wbg_kv_free: (a: number, b: number) => void;
  readonly __wbg_queuemessage_free: (a: number, b: number) => void;
  readonly __wbg_sqlitedb_free: (a: number, b: number) => void;
  readonly __wbg_sqlitetransaction_free: (a: number, b: number) => void;
  readonly __wbg_websockethandle_free: (a: number, b: number) => void;
  readonly actorcontext_abortSignal: (a: number) => [number, number, number];
  readonly actorcontext_actorId: (a: number) => [number, number];
  readonly actorcontext_beginKeepAwake: (a: number) => number;
  readonly actorcontext_beginOnStateChange: (a: number) => void;
  readonly actorcontext_beginStateTransaction: (a: number, b: number, c: number) => any;
  readonly actorcontext_beginWebsocketCallback: (a: number) => number;
  readonly actorcontext_broadcast: (a: number, b: number, c: number, d: number, e: number) => void;
  readonly actorcontext_connectConn: (a: number, b: number, c: number, d: any) => any;
  readonly actorcontext_conns: (a: number) => any;
  readonly actorcontext_destroy: (a: number) => [number, number];
  readonly actorcontext_dirtyHibernatableConns: (a: number) => any;
  readonly actorcontext_endKeepAwake: (a: number, b: number) => void;
  readonly actorcontext_endOnStateChange: (a: number) => void;
  readonly actorcontext_endWebsocketCallback: (a: number, b: number) => void;
  readonly actorcontext_inspectorSnapshot: (a: number) => [number, number, number];
  readonly actorcontext_keepAwake: (a: number, b: any) => void;
  readonly actorcontext_key: (a: number) => [number, number, number];
  readonly actorcontext_kv: (a: number) => number;
  readonly actorcontext_name: (a: number) => [number, number];
  readonly actorcontext_new: () => [number, number, number];
  readonly actorcontext_region: (a: number) => [number, number];
  readonly actorcontext_registerTask: (a: number, b: any) => void;
  readonly actorcontext_requestSave: (a: number, b: any) => void;
  readonly actorcontext_requestSaveAndWait: (a: number, b: any) => any;
  readonly actorcontext_restartRunHandler: (a: number) => [number, number];
  readonly actorcontext_runtimeState: (a: number) => any;
  readonly actorcontext_saveState: (a: number, b: any) => any;
  readonly actorcontext_saveStateAndWorkflowBatch: (a: number, b: any) => any;
  readonly actorcontext_setAlarm: (a: number, b: number, c: number) => [number, number];
  readonly actorcontext_setRunWakeAt: (a: number, b: number, c: number) => any;
  readonly actorcontext_sleep: (a: number) => [number, number];
  readonly actorcontext_sql: (a: number) => number;
  readonly actorcontext_state: (a: number) => [number, number];
  readonly actorcontext_takePendingHibernationChanges: (a: number) => any;
  readonly actorcontext_verifyInspectorAuth: (a: number, b: number, c: number) => any;
  readonly actorcontext_waitForTrackedShutdownWork: (a: number) => any;
  readonly actorcontext_waitForTrackedShutdownWorkUnbounded: (a: number) => any;
  readonly actorcontext_waitUntil: (a: number, b: any) => void;
  readonly actorfactory_new: (a: any, b: any) => [number, number, number];
  readonly actorstatetransaction_commit: (a: number, b: any) => any;
  readonly actorstatetransaction_execute: (a: number, b: number, c: number, d: any) => any;
  readonly actorstatetransaction_rollback: (a: number) => any;
  readonly awaitPromise: (a: any) => any;
  readonly bridgeRivetErrorPrefix: () => [number, number];
  readonly cancellationtoken_aborted: (a: number) => number;
  readonly cancellationtoken_cancel: (a: number) => void;
  readonly cancellationtoken_new: () => number;
  readonly cancellationtoken_onCancelled: (a: number, b: any) => void;
  readonly connhandle_disconnect: (a: number, b: number, c: number) => any;
  readonly connhandle_id: (a: number) => [number, number];
  readonly connhandle_isHibernatable: (a: number) => number;
  readonly connhandle_params: (a: number) => [number, number];
  readonly connhandle_send: (a: number, b: number, c: number, d: number, e: number) => void;
  readonly connhandle_setState: (a: number, b: number, c: number) => void;
  readonly connhandle_state: (a: number) => [number, number];
  readonly coreregistry_handleServerlessRequest: (a: number, b: any, c: any, d: number, e: any) => any;
  readonly coreregistry_new: () => number;
  readonly coreregistry_register: (a: number, b: number, c: number, d: number) => [number, number];
  readonly coreregistry_serve: (a: number, b: any) => any;
  readonly coreregistry_shutdown: (a: number) => any;
  readonly kv_batchDelete: (a: number, b: any) => any;
  readonly kv_batchGet: (a: number, b: any) => any;
  readonly kv_batchPut: (a: number, b: any) => any;
  readonly kv_delete: (a: number, b: number, c: number) => any;
  readonly kv_deleteRange: (a: number, b: number, c: number, d: number, e: number) => any;
  readonly kv_get: (a: number, b: number, c: number) => any;
  readonly kv_listPrefix: (a: number, b: number, c: number, d: any) => any;
  readonly kv_listRange: (a: number, b: number, c: number, d: number, e: number, f: any) => any;
  readonly kv_put: (a: number, b: number, c: number, d: number, e: number) => any;
  readonly queue_completePersisted: (a: number, b: bigint, c: number, d: number, e: number, f: number) => any;
  readonly queue_enqueueAndWait: (a: number, b: number, c: number, d: number, e: number, f: any, g: number) => any;
  readonly queue_inspectMessages: (a: number) => any;
  readonly queue_maxSize: (a: number) => number;
  readonly queue_nextBatch: (a: number, b: any, c: number) => any;
  readonly queue_reset: (a: number) => any;
  readonly queue_send: (a: number, b: number, c: number, d: number, e: number) => any;
  readonly queue_tryNextBatch: (a: number, b: any) => [number, number, number];
  readonly queue_waitForNames: (a: number, b: any, c: any, d: number) => any;
  readonly queue_waitForNamesAvailable: (a: number, b: any, c: any) => any;
  readonly queuemessage_body: (a: number) => [number, number];
  readonly queuemessage_complete: (a: number, b: any) => any;
  readonly queuemessage_createdAt: (a: number) => number;
  readonly queuemessage_id: (a: number) => bigint;
  readonly queuemessage_isCompletable: (a: number) => number;
  readonly queuemessage_name: (a: number) => [number, number];
  readonly roundTripBytes: (a: number, b: number) => [number, number];
  readonly schedule_after: (a: number, b: number, c: number, d: number, e: number, f: number) => any;
  readonly schedule_at: (a: number, b: number, c: number, d: number, e: number, f: number) => any;
  readonly schedule_cancel: (a: number, b: number, c: number) => any;
  readonly schedule_cronDelete: (a: number, b: number, c: number) => any;
  readonly schedule_cronEvery: (a: number, b: number, c: number, d: number, e: number, f: number, g: number, h: number, i: number, j: number) => any;
  readonly schedule_cronGet: (a: number, b: number, c: number) => any;
  readonly schedule_cronHistory: (a: number, b: number, c: number, d: number, e: number) => any;
  readonly schedule_cronList: (a: number) => any;
  readonly schedule_cronSet: (a: number, b: number, c: number, d: number, e: number, f: number, g: number, h: number, i: number, j: number, k: number, l: number, m: number) => any;
  readonly schedule_get: (a: number, b: number, c: number) => any;
  readonly schedule_list: (a: number) => any;
  readonly sqlitedb_beginTransaction: (a: number, b: number, c: number, d: number, e: number) => any;
  readonly sqlitedb_close: (a: number) => any;
  readonly sqlitedb_exec: (a: number, b: number, c: number) => any;
  readonly sqlitedb_execute: (a: number, b: number, c: number, d: any) => any;
  readonly sqlitedb_executeBatch: (a: number, b: any) => any;
  readonly sqlitedb_query: (a: number, b: number, c: number, d: any) => any;
  readonly sqlitedb_run: (a: number, b: number, c: number, d: any) => any;
  readonly sqlitetransaction_commit: (a: number) => any;
  readonly sqlitetransaction_exec: (a: number, b: number, c: number) => any;
  readonly sqlitetransaction_execute: (a: number, b: number, c: number, d: any) => any;
  readonly sqlitetransaction_rollback: (a: number) => any;
  readonly uint8ArrayFromBytes: (a: number, b: number) => any;
  readonly websockethandle_close: (a: number, b: number, c: number, d: number) => any;
  readonly websockethandle_send: (a: number, b: number, c: number, d: number) => [number, number];
  readonly websockethandle_setEventCallback: (a: number, b: any) => void;
  readonly start: () => void;
  readonly actorcontext_queue: (a: number) => number;
  readonly actorcontext_schedule: (a: number) => number;
  readonly __wbg_schedule_free: (a: number, b: number) => void;
  readonly __wbg_queue_free: (a: number, b: number) => void;
  readonly __wbindgen_malloc: (a: number, b: number) => number;
  readonly __wbindgen_realloc: (a: number, b: number, c: number, d: number) => number;
  readonly __wbindgen_exn_store: (a: number) => void;
  readonly __externref_table_alloc: () => number;
  readonly __wbindgen_export_4: WebAssembly.Table;
  readonly __wbindgen_free: (a: number, b: number, c: number) => void;
  readonly __wbindgen_export_6: WebAssembly.Table;
  readonly __externref_table_dealloc: (a: number) => void;
  readonly closure1975_externref_shim: (a: number, b: number, c: any) => void;
  readonly closure2334_externref_shim: (a: number, b: number, c: any) => void;
  readonly closure2571_externref_shim: (a: number, b: number, c: any, d: any) => void;
  readonly __wbindgen_start: () => void;
}

export type SyncInitInput = BufferSource | WebAssembly.Module;
/**
* Instantiates the given `module`, which can either be bytes or
* a precompiled `WebAssembly.Module`.
*
* @param {{ module: SyncInitInput }} module - Passing `SyncInitInput` directly is deprecated.
*
* @returns {InitOutput}
*/
export function initSync(module: { module: SyncInitInput } | SyncInitInput): InitOutput;

/**
* If `module_or_path` is {RequestInfo} or {URL}, makes a request and
* for everything else, calls `WebAssembly.instantiate` directly.
*
* @param {{ module_or_path: InitInput | Promise<InitInput> }} module_or_path - Passing `InitInput` directly is deprecated.
*
* @returns {Promise<InitOutput>}
*/
export default function __wbg_init (module_or_path?: { module_or_path: InitInput | Promise<InitInput> } | InitInput | Promise<InitInput>): Promise<InitOutput>;