package
0.0.0-20220223163014-aecaba93849e
Repository: https://github.com/mudkipme/timburr.git
Documentation: pkg.go.dev
# Packages
No description provided by the author
# Functions
DefaultSubscriber creates a subscriber based on config.yml.
NewMetadataWatcher creates a new metadata watcher with a kafka consumer.
NewSubscriber creates a new subscriber.
NewSubscription creates a new subscription with configuration and rule.
# Structs
BasicSubscription can subscribe to kafka topics and handle task to task runner.
MetadataWatcher watches the change of topics and notify event channels.
MetadataWatcherEvent defines an event, it's either the topics in kafka changes, or an error occurs.
RegexSubscription can subscribe to topics matching regular expression, and watch for changes of topics.
Subscriber can subscribe to mutiple rules to consume messages.
SubScriberConfig contains configuration of kafka.
SubscriptionConfig is the configuration for all subscriptions.
# Interfaces
Subscription contains basic subscription and regex subscription.