Crate cerk_runtime_threading

This is a package for CERK. CERK is an open source CloudEvents Router written in Rust with a MicroKernel architecture.

Introduction

CERK lets you route your CloudEvents between different different ports. Ports are transport layer bindings over which CloudEvents can be exchanged. It is built with modularity and portability in mind.

Components

CERK comes with a couple of prefabricated components, but implementing custom components is easy.

A good overview is provided on GitHub.

This Component: Threading Runtime

A Scheduler implementation for CERK based on the std::thread model.

std::sync::mpsc is used for the channels.

Examples

• Generator to MQTT
• Sequence to AMQP to Printer
• AMQP to Printer

Modules

channel

A channel implementation for CERK based on std::sync::mpsc.

Statics

THREADING_SCHEDULER

This is the pointer for the main function to start the scheduler.

Functions

threading_scheduler_start

This is the main function to start the scheduler.