notification

type DatabaseNotificationStore struct {
	// contains filtered or unexported fields
}

type MemoryNotificationStore struct {
	// contains filtered or unexported fields
}

type MemoryNotifier struct {
	// contains filtered or unexported fields
}

type NotificationProcessor interface {
	common.Component
	Process(ctx context.Context) error
	Trigger(ctx context.Context, triggerMsg TriggerMessage)
}

type NotificationStore interface {
	GetAllPendingNotifications(ctx context.Context) (map[string][]model.Notification, error)
	GetNotifications(ctx context.Context, collecitonID string) ([]model.Notification, error)
	AddNotification(ctx context.Context, notification model.Notification) error
	RemoveNotifications(ctx context.Context, notifications []model.Notification) error
}

type Notifier interface {
	Notify(ctx context.Context, notifications []model.Notification) error
}

type PulsarNotifier struct {
	// contains filtered or unexported fields
}

type SimpleNotificationProcessor struct {
	// contains filtered or unexported fields
}

type TriggerMessage struct {
	Msg        model.Notification
	ResultChan chan error
}