Skip to main content

Crate iii_sdk

Crate iii_sdk 

Source

Re-exports§

pub use builtin_triggers::IIITrigger;
pub use builtin_triggers::StreamCallRequest;
pub use builtin_triggers::StreamEventDetail;
pub use builtin_triggers::StreamEventType;
pub use builtin_triggers::StreamJoinLeaveCallRequest;
pub use builtin_triggers::StreamJoinLeaveTriggerConfig;
pub use builtin_triggers::StreamTriggerConfig;
pub use channels::ChannelDirection;
pub use channels::ChannelItem;
pub use channels::ChannelReader;
pub use channels::ChannelWriter;
pub use channels::StreamChannelRef;
pub use channels::extract_channel_refs;
pub use channels::is_channel_ref;
pub use error::IIIError;
pub use iii::FunctionInfo;
pub use iii::FunctionRef;
pub use iii::FunctionsAvailableGuard;
pub use iii::III;
pub use iii::IIIAsyncFn;
pub use iii::IIIConnectionState;
pub use iii::IIIFn;
pub use iii::IntoFunctionHandler;
pub use iii::IntoFunctionRegistration;
pub use iii::RegisterFunction;
pub use iii::RegisterTriggerType;
pub use iii::TriggerInfo;
pub use iii::TriggerTypeInfo;
pub use iii::TriggerTypeRef;
pub use iii::WorkerInfo;
pub use iii::WorkerMetadata;
pub use iii::iii_async_fn;
pub use iii::iii_fn;
pub use logger::Logger;
pub use protocol::EnqueueResult;
pub use protocol::ErrorBody;
pub use protocol::FunctionMessage;
pub use protocol::HttpAuthConfig;
pub use protocol::HttpInvocationConfig;
pub use protocol::HttpMethod;
pub use protocol::Message;
pub use protocol::RegisterFunctionMessage;
pub use protocol::RegisterServiceMessage;
pub use protocol::RegisterTriggerInput;
pub use protocol::RegisterTriggerMessage;
pub use protocol::RegisterTriggerTypeMessage;
pub use protocol::TriggerAction;
pub use protocol::TriggerRequest;
pub use stream::UpdateBuilder;
pub use structs::AuthInput;
pub use structs::AuthResult;
pub use structs::MiddlewareFunctionInput;
pub use structs::OnFunctionRegistrationInput;
pub use structs::OnFunctionRegistrationResult;
pub use structs::OnTriggerRegistrationInput;
pub use structs::OnTriggerRegistrationResult;
pub use structs::OnTriggerTypeRegistrationInput;
pub use structs::OnTriggerTypeRegistrationResult;
pub use triggers::Trigger;
pub use triggers::TriggerConfig;
pub use triggers::TriggerHandler;
pub use types::ApiRequest;
pub use types::ApiResponse;
pub use types::Channel;
pub use types::DeleteResult;
pub use types::FieldPath;
pub use types::SetResult;
pub use types::StreamAuthInput;
pub use types::StreamAuthResult;
pub use types::StreamDeleteInput;
pub use types::StreamGetInput;
pub use types::StreamJoinResult;
pub use types::StreamListGroupsInput;
pub use types::StreamListInput;
pub use types::StreamSetInput;
pub use types::StreamUpdateInput;
pub use types::UpdateOp;
pub use types::UpdateResult;
pub use telemetry::context::current_span_id;
pub use telemetry::context::current_trace_id;
pub use telemetry::context::extract_baggage;
pub use telemetry::context::extract_context;
pub use telemetry::context::extract_traceparent;
pub use telemetry::context::get_all_baggage;
pub use telemetry::context::get_baggage_entry;
pub use telemetry::context::inject_baggage;
pub use telemetry::context::inject_traceparent;
pub use telemetry::context::remove_baggage_entry;
pub use telemetry::context::set_baggage_entry;
pub use telemetry::flush_otel;
pub use telemetry::get_meter;
pub use telemetry::get_tracer;
pub use telemetry::http_instrumentation::execute_traced_request;
pub use telemetry::init_otel;
pub use telemetry::is_initialized;
pub use telemetry::shutdown_otel;
pub use telemetry::types::OtelConfig;
pub use telemetry::types::ReconnectionConfig;
pub use telemetry::with_span;

Modules§

builtin_triggers
channels
error
iii
logger
protocol
stream
Stream update builder.
structs
telemetry
triggers
types

Structs§

InitOptions
Configuration options passed to register_worker.

Enums§

SpanKind
SpanKind describes the relationship between the Span, its parents, and its children in a trace.
SpanStatus
The status of a Span.
Value
Represents any valid JSON value.

Functions§

register_worker
Create and return a connected SDK instance. The WebSocket connection is established automatically in a dedicated background thread with its own tokio runtime.