notification

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

type NewNotification struct {
	TopicID uuid.UUID
	Message string
}

type NewNotificationTx struct {
	NewNotification
	AfterCreate func(ntf Notification) error
}

type Notification struct {
	ID        uuid.UUID
	TopicID   uuid.UUID
	Message   string
	CreatedAt time.Time
}

type Storer interface {
	WithinTran(fn func(s Storer) error) error
	Create(ntf Notification) error
	Delete(ntf Notification) error
	Query(pageNumber int, rowsPerPage int, topicID uuid.UUID) ([]Notification, error)
	QueryByID(id uuid.UUID) (Notification, error)
}