README
- ::BusConfigBusConfig::BusConfig
T
DeadLetter
T
DeliveryReport
T
DeliveryStatus
- ::EventBusEventBus::EventBus
- ::clear_dead_lettersEventBus::clear_dead_letters
- ::clear_historyEventBus::clear_history
- ::dead_letter_countEventBus::dead_letter_count
- ::dispatchEventBus::dispatch
- ::history_countEventBus::history_count
- ::publishEventBus::publish
- ::sort_subscribersEventBus::sort_subscribers
- ::subscribeEventBus::subscribe
- ::subscriber_countEventBus::subscriber_count
- ::unsubscribeEventBus::unsubscribe
- ::EventRecorderEventRecorder::EventRecorder
- ::clearEventRecorder::clear
- ::contains_topicEventRecorder::contains_topic
- ::countEventRecorder::count
- ::count_topicEventRecorder::count_topic
- ::handleEventRecorder::handle
- ::handlerEventRecorder::handler
- ::lastEventRecorder::last
- ::FakePublisherFakePublisher::FakePublisher
- ::emitFakePublisher::emit
- ::emit_payloadFakePublisher::emit_payload
- ::MessageMessage::Message
T
PublishMode
T
PublishReport
- ::SubscriberSubscriber::Subscriber
- ::TopicPatternTopicPattern::TopicPattern
- ::matchesTopicPattern::matches
V
assert_delivered
V
assert_matched
V
assert_rejected
V
collect_topics
V
escape_json
V
new_event_bus
V
report_to_json
V
standard_catalog_size
V
standard_messages
V
standard_route_cases
V
standard_topic_names
V
standard_topic_patterns
V
status_name
V
topic_matches

moonflow

A lightweight event bus and message abstraction layer for MoonBit.

event-bus

message

pubsub

moonbit

Download zip

Author

xvyve123

Version

0.1.0

License

MIT

Repository

github.com/xvyve123/2131

Last updated

2 months ago

Downloads

No dependencies

#username/moonflow

BusConfig

source

pub(all) struct BusConfig {
  mode : PublishMode
  keep_history : Bool
  keep_dead_letters : Bool
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

BusConfig controls dispatch behavior.

BusConfig::BusConfig

source

fn BusConfig::BusConfig(mode? : PublishMode, keep_history? : Bool, keep_dead_letters? : Bool) -> BusConfig

DeadLetter

source

pub(all) struct DeadLetter {
  message : Message
  subscriber_id : String
  reason : String
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

DeadLetter keeps messages that were rejected by at least one subscriber.

DeliveryReport

source

pub(all) struct DeliveryReport {
  subscriber_id : String
  topic : String
  status : DeliveryStatus
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

DeliveryReport is one subscriber's dispatch result.

DeliveryStatus

source

pub(all) enum DeliveryStatus {
  Ack
  Rejected(String)
  Skipped(String)
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

DeliveryStatus describes how a subscriber handled a message.

EventBus

source

pub(all) struct EventBus {
  config : BusConfig
  subscribers : Array[Subscriber]
  history : Array[Message]
  dead_letters : Array[DeadLetter]
} derive(@moonbitlang/core/debug.Debug
Debug)

EventBus is an in-memory event hub for tests, tools, and embedded apps.

EventBus::EventBus

source

fn EventBus::EventBus(config? : BusConfig) -> EventBus

EventBus::clear_dead_letters

source

fn EventBus::clear_dead_letters(self : EventBus) -> Unit

EventBus::clear_history

source

fn EventBus::clear_history(self : EventBus) -> Unit

EventBus::dead_letter_count

source

fn EventBus::dead_letter_count(self : EventBus) -> Int

EventBus::dispatch

source

fn EventBus::dispatch(self : EventBus, message : Message) -> PublishReport

EventBus::history_count

source

fn EventBus::history_count(self : EventBus) -> Int

EventBus::publish

source

fn EventBus::publish(self : EventBus, topic : StringView, payload? : StringView, source? : StringView, trace_id? : StringView, tags? : ArrayView[String], headers? : Map[String, String]) -> PublishReport

EventBus::sort_subscribers

source

fn EventBus::sort_subscribers(self : EventBus) -> Unit

fn EventBus::subscribe(self : EventBus, id : StringView, pattern : StringView, handler : (Message) -> DeliveryStatus, priority? : Int, once? : Bool) -> Unit

EventBus::subscriber_count

source

fn EventBus::subscriber_count(self : EventBus) -> Int

EventBus::unsubscribe

source

fn EventBus::unsubscribe(self : EventBus, id : StringView) -> Bool

EventRecorder

source

pub(all) struct EventRecorder {
  name : String
  messages : Array[Message]
} derive(@moonbitlang/core/debug.Debug
Debug)

EventRecorder is a small in-memory probe for tests.

EventRecorder::EventRecorder

source

fn EventRecorder::EventRecorder(name? : StringView) -> EventRecorder

EventRecorder::clear

source

fn EventRecorder::clear(self : EventRecorder) -> Unit

EventRecorder::contains_topic

source

fn EventRecorder::contains_topic(self : EventRecorder, topic : StringView) -> Bool

EventRecorder::count

source

fn EventRecorder::count(self : EventRecorder) -> Int

EventRecorder::count_topic

source

fn EventRecorder::count_topic(self : EventRecorder, topic : StringView) -> Int

EventRecorder::handle

source

fn EventRecorder::handle(self : EventRecorder, message : Message) -> DeliveryStatus

EventRecorder::handler

source

fn EventRecorder::handler(self : EventRecorder) -> ((Message) -> DeliveryStatus)

EventRecorder::last

source

fn EventRecorder::last(self : EventRecorder) -> Message?

FakePublisher

source

pub(all) struct FakePublisher {
  bus : EventBus
  source : String
} derive(@moonbitlang/core/debug.Debug
Debug)

FakePublisher::FakePublisher

source

fn FakePublisher::FakePublisher(bus : EventBus, source? : StringView) -> FakePublisher

FakePublisher::emit

source

fn FakePublisher::emit(self : FakePublisher, topic : StringView) -> PublishReport

FakePublisher::emit_payload

source

fn FakePublisher::emit_payload(self : FakePublisher, topic : StringView, payload : StringView) -> PublishReport

Message

source

pub(all) struct Message {
  id : String
  topic : String
  payload : String
  source : String
  trace_id : String
  tags : Array[String]
  headers : Map[String, String]
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

Message carries a topic, payload, and lightweight metadata.

Message::Message

source

fn Message::Message(id : StringView, topic : StringView, payload? : StringView, source? : StringView, trace_id? : StringView, tags? : ArrayView[String], headers? : Map[String, String]) -> Message

PublishMode

source

pub(all) enum PublishMode {
  ContinueOnError
  StopOnError
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

PublishMode controls whether dispatch continues after a handler failure.

PublishReport

source

pub(all) struct PublishReport {
  message_id : String
  topic : String
  matched : Int
  delivered : Int
  rejected : Int
  skipped : Int
  reports : Array[DeliveryReport]
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

PublishReport summarizes one publish operation.

Subscriber

source

pub(all) struct Subscriber {
  id : String
  pattern : TopicPattern
  priority : Int
  once : Bool
  active : Bool
  handler : (Message) -> DeliveryStatus
} derive(@moonbitlang/core/debug.Debug
Debug)

Subscriber records routing information and the callback to invoke.

Subscriber::Subscriber

source

fn Subscriber::Subscriber(id : StringView, pattern : StringView, handler : (Message) -> DeliveryStatus, priority? : Int, once? : Bool) -> Subscriber

TopicPattern

source

pub(all) struct TopicPattern {
  pattern : String
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

TopicPattern is the route expression used by subscribers.

TopicPattern::TopicPattern

source

fn TopicPattern::TopicPattern(pattern : StringView) -> TopicPattern

TopicPattern::matches

source

fn TopicPattern::matches(self : TopicPattern, topic : StringView) -> Bool

assert_delivered

source

fn assert_delivered(report : PublishReport, expected : Int) -> Unit

assert_matched

source

fn assert_matched(report : PublishReport, expected : Int) -> Unit

assert_rejected

source

fn assert_rejected(report : PublishReport, expected : Int) -> Unit

collect_topics

source

fn collect_topics(messages : ArrayView[Message]) -> Array[String]

escape_json

source

fn escape_json(input : StringView) -> String

new_event_bus

source

fn new_event_bus(config? : BusConfig) -> EventBus

report_to_json

source

fn report_to_json(report : PublishReport) -> String

standard_catalog_size

source

fn standard_catalog_size() -> Int

standard_messages

source

fn standard_messages() -> Array[Message]

standard_route_cases

source

fn standard_route_cases() -> Array[(String, String, Bool)]

standard_topic_names

source

fn standard_topic_names() -> Array[String]

Built-in topic and message catalog for examples, smoke tests, and demos.

standard_topic_patterns

source

fn standard_topic_patterns() -> Array[TopicPattern]

status_name

source

fn status_name(status : DeliveryStatus) -> String

topic_matches

source

fn topic_matches(pattern : StringView, topic : StringView) -> Bool

Source Files

Install

Download zip

A lightweight event bus and message abstraction layer for MoonBit.

event-busmessagepubsubmoonbit

xvyve123

MIT

github.com/xvyve123/2131

Updated 2 months ago

28 downloads

Site source Report issue Modules Skills CLI Build queue Statistics

moonflow

#username/moonflow

#BusConfig

#BusConfig::BusConfig

#DeadLetter

#DeliveryReport

#DeliveryStatus

#EventBus

#EventBus::EventBus

#EventBus::clear_dead_letters

#EventBus::clear_history

#EventBus::dead_letter_count

#EventBus::dispatch

#EventBus::history_count

#EventBus::publish

#EventBus::sort_subscribers

#EventBus::subscribe

#EventBus::subscriber_count

#EventBus::unsubscribe

#EventRecorder

#EventRecorder::EventRecorder

#EventRecorder::clear

#EventRecorder::contains_topic

#EventRecorder::count

#EventRecorder::count_topic

#EventRecorder::handle

#EventRecorder::handler

#EventRecorder::last

#FakePublisher

#FakePublisher::FakePublisher

#FakePublisher::emit

#FakePublisher::emit_payload

#Message

#Message::Message

#PublishMode

#PublishReport

#Subscriber

#Subscriber::Subscriber

#TopicPattern

#TopicPattern::TopicPattern

#TopicPattern::matches

#assert_delivered

#assert_matched

#assert_rejected

#collect_topics

#escape_json

#new_event_bus

#report_to_json

#standard_catalog_size

#standard_messages

#standard_route_cases

#standard_topic_names

#standard_topic_patterns

#status_name

#topic_matches

Source Files

BusConfig

BusConfig::BusConfig

DeadLetter

DeliveryReport

DeliveryStatus

EventBus

EventBus::EventBus

EventBus::clear_dead_letters

EventBus::clear_history

EventBus::dead_letter_count

EventBus::dispatch

EventBus::history_count

EventBus::publish

EventBus::sort_subscribers

EventBus::subscribe

EventBus::subscriber_count

EventBus::unsubscribe

EventRecorder

EventRecorder::EventRecorder

EventRecorder::clear

EventRecorder::contains_topic

EventRecorder::count

EventRecorder::count_topic

EventRecorder::handle

EventRecorder::handler

EventRecorder::last

FakePublisher

FakePublisher::FakePublisher

FakePublisher::emit

FakePublisher::emit_payload

Message

Message::Message

PublishMode

PublishReport

Subscriber

Subscriber::Subscriber

TopicPattern

TopicPattern::TopicPattern

TopicPattern::matches

assert_delivered

assert_matched

assert_rejected

collect_topics

escape_json

new_event_bus

report_to_json

standard_catalog_size

standard_messages

standard_route_cases

standard_topic_names

standard_topic_patterns

status_name

topic_matches