Struct Internal 

pub struct Internal { /* private fields */ }

Internal resource for SDK operations

This resource provides access to internal SDK functionality, including realtime credentials for WebSocket connections.

Implementations

impl Internal

pub fn new(client: Arc<ComposioClient>) -> Self

Create a new Internal resource

pub fn with_telemetry_context( client: Arc<ComposioClient>, telemetry_context: TelemetryContext, ) -> Self

Create a new Internal resource with custom telemetry context

pub async fn get_sdk_realtime_credentials( &self, ) -> Result<SDKRealtimeCredentialsResponse, ComposioError>

Get SDK realtime credentials

Retrieves credentials for establishing realtime WebSocket connections using Pusher. These credentials are used for receiving real-time events and updates from the Composio platform.

Returns

Returns SDKRealtimeCredentialsResponse containing:

• pusher_key: The Pusher API key for authentication
• project_id: The project identifier
• pusher_cluster: The Pusher cluster region (e.g., “us2”, “eu”)

Errors

Returns ComposioError if:

• The API request fails
• Authentication is invalid
• The response cannot be deserialized

Example

use composio_sdk::client::ComposioClient;
use composio_sdk::config::ComposioConfig;
use composio_sdk::models::internal::Internal;
use std::sync::Arc;

let config = ComposioConfig {
    api_key: "your-api-key".to_string(),
    ..Default::default()
};
let client = Arc::new(ComposioClient::from_config(config)?);
let internal = Internal::new(client);

let credentials = internal.get_sdk_realtime_credentials().await?;
println!("Pusher Key: {}", credentials.pusher_key);
println!("Project ID: {}", credentials.project_id);
println!("Cluster: {}", credentials.pusher_cluster);

Trait Implementations

impl Clone for Internal

fn clone(&self) -> Internal

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Resource for Internal

fn client(&self) -> &ComposioClient

Get the client reference

fn telemetry_context(&self) -> &TelemetryContext

Get telemetry context

fn sanitize_payload<T>(&self, payload: T) -> T

where T: Serialize + DeserializeOwned,

Sanitize payload by removing sensitive information

fn provider(&self) -> Option<String>

Get the provider name for telemetry

fn create_method_event( &self, function_name: &str, provider: Option<&str>, ) -> Option<TelemetryData>

Create a telemetry event for a method call

fn push_telemetry_event(&self, event: Event)

Push a telemetry event

fn trace_method<F, R>( &self, function_name: &str, provider: Option<&str>, f: F, ) -> R

where F: FnOnce() -> R,

Trace a method execution with telemetry

fn trace_method_with_error<F, R, E>( &self, function_name: &str, provider: Option<&str>, f: F, ) -> Result<R, E>

where F: FnOnce() -> Result<R, E>, E: Display,

Trace a method execution with error handling