projection

type NotificationOverview ¶

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

This projection is a simple example of a projection that listens to all events and projects a list of the 10 most recent notifications.

func NewNotificationOverview(
	storeManager fluxcore.StoreManager,
	register *eventsourcing.Register,
) *NotificationOverview

func (n *NotificationOverview) Project(ctx context.Context)

func (n *NotificationOverview) RecentNotifications() []NotificationOverviewEntry

type NotificationOverviewEntry ¶

type NotificationOverviewEntry struct {
	Id        string
	Title     string
	Servity   model.NotificationServity
	CreatedAt time.Time
}

type NotificationView ¶

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

NotificationView is project that creates a query table that lists all notifications.

func NewNotificationView(
	db *sql.DB,
	storeManager fluxcore.StoreManager,
	register *eventsourcing.Register,
) *NotificationView

func (v *NotificationView) Project(ctx context.Context)

type NotificationViewState ¶

type NotificationViewState struct {
	LastVersion core.Version `json:"last_version"`
}

func (s *NotificationViewState) Scan(value interface{}) error