Categorygithub.com/xmlking/toolkit/broker/cloudevents
modulepackage
0.5.2
Repository: https://github.com/xmlking/toolkit.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
6
Dependents
6
Files
190 SLOC

# README

CloudEvents

Broker implementation provides queuing, backpressure, filtering

CloudEvents has multiple transports (http, pubsub, kafka...) available

Concepts

Actors

  • Event Source
  • Event Sink
  • Broker

Messaging patterns

  • Fire and Forgot
  • Request and Response

# Functions

No description provided by the author
Context appContext to trigger terminate signal.
Name of the service.
NewBroker creates and returns a new Broker based on the packages within.
No description provided by the author
No description provided by the author
No description provided by the author
WithRecoveryHandler sets the function for recovering from a panic.

# Constants

No description provided by the author

# Variables

No description provided by the author

# Structs

No description provided by the author
No description provided by the author
No description provided by the author

# Interfaces

Broker is an interface used for asynchronous messaging.
No description provided by the author

# Type aliases

Handler is used to process messages via a subscription of a topic.
No description provided by the author
No description provided by the author
RecoveryHandler is a function that is called when the recovery middleware recovers from a panic.
No description provided by the author