Struct DeliveryBus 

pub struct DeliveryBus { /* private fields */ }

Cross-service message delivery.

Services use this to deliver messages to other services without direct dependencies between service crates. The server wires up the delivery functions at startup.

Implementations

impl DeliveryBus

pub fn new() -> Self

pub fn with_cognito_jwt_verifier( self, verifier: Arc<dyn CognitoJwtVerifier>, ) -> Self

pub fn with_kms_hook(self, hook: Arc<dyn KmsHook>) -> Self

pub fn kms_encrypt( &self, account_id: &str, region: &str, key_id: &str, plaintext: &[u8], service_principal: &str, encryption_context: HashMap<String, String>, ) -> Result<String, String>

Encrypt plaintext with the supplied KMS key. Returns Err when no KMS hook is wired or the encryption fails.

pub fn kms_decrypt( &self, account_id: &str, ciphertext_b64: &str, service_principal: &str, encryption_context: HashMap<String, String>, ) -> Result<Vec<u8>, String>

Decrypt a KMS ciphertext blob. Returns Err when no KMS hook is wired or the decryption fails.

pub fn verify_cognito_jwt( &self, account_id: &str, user_pool_arn: &str, token: &str, ) -> Result<Value, String>

Verify a Cognito JWT against a user pool. Returns Err when no verifier is wired or when the token fails validation.

pub fn with_cloudwatch_metrics( self, sender: Arc<dyn CloudwatchDelivery>, ) -> Self

pub fn put_cloudwatch_metric( &self, account_id: &str, region: &str, namespace: &str, metric_name: &str, value: f64, unit: Option<&str>, dimensions: BTreeMap<String, String>, timestamp_ms: i64, )

Publish a CloudWatch metric data point. Silently no-ops when no CloudWatch sender is wired (in-process tests not exercising the metrics path).

pub fn with_cloudwatch_logs( self, sender: Arc<dyn CloudwatchLogsDelivery>, ) -> Self

pub fn put_log_events( &self, account_id: &str, log_group_name: &str, log_stream_name: &str, events: &[(i64, String)], )

Put log events to a CloudWatch Logs log group / stream. Silently no-ops when no CloudWatch Logs sender is wired.

pub fn with_ses_dispatcher( self, dispatcher: Arc<dyn SesSendEmailDispatcher>, ) -> Self

pub fn with_ecs_task_runner(self, runner: Arc<dyn EcsTaskRunner>) -> Self

pub fn with_elbv2_target_registration( self, reg: Arc<dyn Elbv2TargetRegistration>, ) -> Self

pub fn register_elbv2_targets( &self, account_id: &str, target_group_arn: &str, targets: Vec<(String, Option<i64>)>, )

Register targets with an ELBv2 target group. Silently no-ops when no ELBv2 target registration hook is wired.

pub fn deregister_elbv2_targets( &self, account_id: &str, target_group_arn: &str, targets: Vec<(String, Option<i64>)>, )

Deregister targets from an ELBv2 target group. Silently no-ops when no ELBv2 target registration hook is wired.

pub fn send_ses_email( &self, account_id: &str, from: &str, to: Vec<String>, cc: Vec<String>, bcc: Vec<String>, subject: Option<&str>, text_body: Option<&str>, html_body: Option<&str>, ) -> Result<(), String>

Send an email via SES. Returns Err when no SES dispatcher is wired or the underlying impl rejects (bad source/dest).

pub fn run_ecs_task( &self, account_id: &str, cluster: &str, task_definition: &str, launch_type: Option<&str>, count: usize, ) -> Result<(), String>

Run an ECS task. Returns Err when no ECS runner is wired or the impl rejects (unknown cluster / task definition).

pub fn with_s3(self, sender: Arc<dyn S3Delivery>) -> Self

pub fn with_firehose(self, sender: Arc<dyn FirehoseDelivery>) -> Self

pub fn put_record_to_firehose(&self, delivery_stream_arn: &str, data: &[u8])

Send a single record to a Firehose delivery stream by ARN. Silently no-ops when no Firehose sender is wired (in-process tests). Production wiring goes through fakecloud_firehose.

pub fn put_object_to_s3( &self, account_id: &str, bucket: &str, key: &str, body: Vec<u8>, content_type: Option<&str>, ) -> Result<(), String>

Write content to S3. Returns Err when no S3 writer is wired or when the underlying impl rejects the bucket / payload.

pub fn get_object_from_s3( &self, account_id: &str, bucket: &str, key: &str, ) -> Result<Vec<u8>, String>

Read content from S3. Returns Err when no S3 client is wired or when the underlying impl cannot resolve the object.

pub fn with_sqs(self, sender: Arc<dyn SqsDelivery>) -> Self

pub fn with_sns(self, sender: Arc<dyn SnsDelivery>) -> Self

pub fn with_eventbridge(self, sender: Arc<dyn EventBridgeDelivery>) -> Self

pub fn with_lambda(self, invoker: Arc<dyn LambdaDelivery>) -> Self

pub fn with_kinesis(self, sender: Arc<dyn KinesisDelivery>) -> Self

pub fn put_record_to_kinesis( &self, stream_arn: &str, data: &str, partition_key: &str, )

Put a record to a Kinesis Data Stream identified by ARN. Silently no-ops when no Kinesis sender is wired.

pub fn with_stepfunctions(self, starter: Arc<dyn StepFunctionsDelivery>) -> Self

pub fn send_to_sqs( &self, queue_arn: &str, message_body: &str, attributes: &HashMap<String, String>, )

Send a message to an SQS queue identified by ARN.

pub fn send_to_sqs_with_attrs( &self, queue_arn: &str, message_body: &str, message_attributes: &HashMap<String, SqsMessageAttribute>, message_group_id: Option<&str>, message_dedup_id: Option<&str>, )

Send a message to an SQS queue with message attributes and FIFO fields.

pub fn try_send_to_sqs_with_attrs( &self, queue_arn: &str, message_body: &str, message_attributes: &HashMap<String, SqsMessageAttribute>, message_group_id: Option<&str>, message_dedup_id: Option<&str>, ) -> Result<(), SqsDeliveryError>

Fallible SQS send — returns Err when the target queue does not exist, so callers (Scheduler) can route to a DLQ. Returns Err(QueueNotFound) when no SQS sender is wired up at all, matching the “target unreachable” semantics Scheduler relies on.

pub fn publish_to_sns( &self, topic_arn: &str, message: &str, subject: Option<&str>, )

Publish a message to an SNS topic identified by ARN.

pub fn put_event_to_eventbridge( &self, source: &str, detail_type: &str, detail: &str, event_bus_name: &str, )

Put an event onto an EventBridge bus in the default account.

pub fn put_event_to_eventbridge_for_account( &self, source: &str, detail_type: &str, detail: &str, event_bus_name: &str, target_account_id: &str, )

Put an event onto an EventBridge bus in a specific account. Used by Scheduler to deliver to cross-account event buses.

pub async fn invoke_lambda( &self, function_arn: &str, payload: &str, ) -> Option<Result<Vec<u8>, String>>

Invoke a Lambda function identified by ARN.

pub fn send_to_kinesis(&self, stream_arn: &str, data: &str, partition_key: &str)

Put a record to a Kinesis stream identified by ARN.

pub fn start_stepfunctions_execution( &self, state_machine_arn: &str, input: &str, )

Start a Step Functions execution identified by state machine ARN.

Trait Implementations

impl Default for DeliveryBus

fn default() -> Self

Returns the “default value” for a type.