Documentation
¶
Index ¶
- func EventLoop(ctx context.Context, watchEvents chan fsnotify.Event, fileName string, ...)
- func NewRouter(logger logger.Logger) *message.Router
- func Run(ctx context.Context, factory LaunchFactory, settings config.SettingsAccessor, ...) error
- func StartRouter(r *message.Router)
- func StopRouter(r *message.Router)
- type LaunchFactory
- type Launcher
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EventLoop ¶
func EventLoop(ctx context.Context, watchEvents chan fsnotify.Event, fileName string, launch func(fsnotify.Event))
EventLoop main event loop.
Types ¶
type LaunchFactory ¶
type LaunchFactory func(client *conn.MQTTConnection, pub message.Publisher, manager conn.SubscriptionManager) Launcher
LaunchFactory returns new launcher instance
type Launcher ¶
type Launcher interface {
// Run triggers the launch process.
Run(cleanSession bool, settings config.SettingsAccessor, cli map[string]interface{}, logger logger.Logger) error
// Stop invokes launcher exit.
Stop()
}
Launcher interface enables app launching.
func NewMockLauncher ¶
func NewMockLauncher(client *conn.MQTTConnection, pub message.Publisher, manager conn.SubscriptionManager) Launcher
NewMockLauncher creates mock launcher for testing purposes
Source Files
Click to show internal directories.
Click to hide internal directories.