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.