package
7.4.0+incompatible
Repository: https://github.com/magento-mcom/beats.git
Documentation: pkg.go.dev
# Functions
NewCoordinator create a new coordinator objects receiving the clientFactory and the runner.
NewSyncClient creates a new sync clients from the provided configuration, existing ACKs handlers defined in the configuration will be proxied by this object.
# Structs
Coordinator takes care of managing the function goroutine, it receives the list of functions that need to be executed and manage the goroutine.
SyncClient wraps an existing beat.Client and provide a sync interface.