CreateObserverConnector will create observer connector component.

GetDefaultConfigs default configs.

NewTestNotifierWithRabbitMq will create a notifier instance with rabbitmq.

NewTestNotifierWithWS will create a notifier instance for websockets flow.

NewTestWebServer creates a new test web server.

NewWSClient creates a new http server with websocket handler.

WaitTimeout will wait on sync group with timeout.

TestWebServer defines a test web server instance.

ObserverConnector defines the observer connector behaviour.

PublisherHandler defines publisher behaviour.