Close all listeners and source connections, in the global registry.

Listen method launch into the background all sources where the supervised daemon mode is required, in the global registry.

Register data source connection with `name` and options The source defines by connection options, in the global registry.

RegisterConnector function which creates new stream coneection by config and bind the connector to the `driver` name, in the global registry.

Source returns the source object registered with the `name`, in the global registry.

Subscribe some handler interface to processing the stream with `name`, in the global registry.

WithConfig custom.

WithConnect to the source.

WithConnectURL to the source.

WithDebug mode.

WithFormat of the messages.

WithObjectConfig converts Object to JSON storage config.

WithRawConfig storage config.

ErrUndefinedSourceDriver in case if source not exists.

Config of the source connection.

Option of the connection.