Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NotificationService ¶
type NotificationService struct {
// contains filtered or unexported fields
}
func NewNotificationService ¶
func NewNotificationService(msgQueue queue.MessageQueue, queueNames []string, notifRepo notification.NotificationSender) NotificationService
func (*NotificationService) StartListening ¶
func (r *NotificationService) StartListening(ctx context.Context)
type WatcherService ¶
type WatcherService struct {
// contains filtered or unexported fields
}
func NewWatcherService ¶
func NewWatcherService(dockerCli *dockerClient.Client, msgQueue queue.MessageQueue, queueName string, eventFilters []string) WatcherService
func (*WatcherService) StartWatching ¶
func (r *WatcherService) StartWatching(ctx context.Context)
Blocking function! run it as a goroutine
Source Files
Click to show internal directories.
Click to hide internal directories.