view

package
v1.87.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 20, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type View

type View struct {
	Db *gorm.DB
}

func StartView

func StartView(sqlClient *sql.DB) (*View, error)

func (*View) DeleteNotifyUser

func (v *View) DeleteNotifyUser(userID string, event *models.Event) error

func (*View) GetLatestNotificationFailedEvent

func (v *View) GetLatestNotificationFailedEvent(sequence uint64) (*repository.FailedEvent, error)

func (*View) GetLatestNotificationSequence

func (v *View) GetLatestNotificationSequence() (*repository.CurrentSequence, error)

func (*View) GetLatestNotifyUserFailedEvent

func (v *View) GetLatestNotifyUserFailedEvent(sequence uint64) (*repository.FailedEvent, error)

func (*View) GetLatestNotifyUserSequence

func (v *View) GetLatestNotifyUserSequence() (*repository.CurrentSequence, error)

func (*View) Health

func (v *View) Health() (err error)

func (*View) NotifyUserByID

func (v *View) NotifyUserByID(userID string) (*model.NotifyUser, error)

func (*View) NotifyUsersByOrgID

func (v *View) NotifyUsersByOrgID(orgID string) ([]*model.NotifyUser, error)

func (*View) ProcessedNotificationFailedEvent

func (v *View) ProcessedNotificationFailedEvent(failedEvent *repository.FailedEvent) error

func (*View) ProcessedNotificationSequence

func (v *View) ProcessedNotificationSequence(event *models.Event) error

func (*View) ProcessedNotifyUserFailedEvent

func (v *View) ProcessedNotifyUserFailedEvent(failedEvent *repository.FailedEvent) error

func (*View) ProcessedNotifyUserSequence

func (v *View) ProcessedNotifyUserSequence(event *models.Event) error

func (*View) PutNotifyUser

func (v *View) PutNotifyUser(user *model.NotifyUser, event *models.Event) error

func (*View) StylingByAggregateIDAndState

func (v *View) StylingByAggregateIDAndState(aggregateID, labelPolicyTableVar string, state int32) (*model.LabelPolicyView, error)

func (*View) UpdateNotificationSpoolerRunTimestamp

func (v *View) UpdateNotificationSpoolerRunTimestamp() error

func (*View) UpdateNotifyUserSpoolerRunTimestamp

func (v *View) UpdateNotifyUserSpoolerRunTimestamp() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL