Crate iii_sdk 

Re-exports

pub use error::Error;

pub use error::InvocationError;

pub use iii::TelemetryOptions;

pub use iii::IIIClient;

pub use iii::RegisterFunction;

pub use iii::RegisterTriggerType;

pub use iii::WorkerIdentityMode;

pub use protocol::Message;

pub use protocol::TriggerAction;

pub use stream_provider::IStream;

pub use structs::MiddlewareFunctionInput;

pub use types::StreamRequest;

pub use types::StreamResponse;

Modules

builtin_triggers

channel

Public channel types. (Stage 1 submodule grouping.)

channels

engine

Engine function and trigger ids, mirroring the Node SDK constants.

error

errors

Public error types. (Stage 1 submodule grouping.)

helpers

Helper free functions that operate on an IIIClient instance.

iii

protocol

runtime

Public runtime/worker types. (Stage 1 submodule grouping.)

stream_provider

structs

trigger

Public trigger types. (Stage 1 submodule grouping.)

triggers

types

Structs

EnqueueResult

Result returned when a function is invoked with TriggerAction.Enqueue.

InitOptions

Configuration options passed to register_worker.

Constants

DEFAULT_ENGINE_URL

Register the worker with a iii instance, returns a connected worker client. The WebSocket connection is established automatically in a dedicated background thread with its own tokio runtime.

Functions

engine_url_from_env

Resolves the engine address from the environment: III_URL, else DEFAULT_ENGINE_URL.

register_worker

register_worker_from_env

Register the worker using the engine address from the environment.