view

Documentation

Index

• type View
  • func StartView(sqlClient *sql.DB) (*View, error)
  • func (v *View) DeleteNotifyUser(userID string, event *models.Event) error
  • func (v *View) GetLatestNotificationFailedEvent(sequence uint64) (*repository.FailedEvent, error)
  • func (v *View) GetLatestNotificationSequence() (*repository.CurrentSequence, error)
  • func (v *View) GetLatestNotifyUserFailedEvent(sequence uint64) (*repository.FailedEvent, error)
  • func (v *View) GetLatestNotifyUserSequence() (*repository.CurrentSequence, error)
  • func (v *View) Health() (err error)
  • func (v *View) LabelPolicyByAggregateIDAndState(aggregateID, labelPolicyTableVar string, state int32) (*model.LabelPolicyView, error)
  • func (v *View) MailTemplateByAggregateID(aggregateID string, mailTemplateTableVar string) (*model.MailTemplateView, error)
  • func (v *View) MessageTextByIDs(aggregateID, textType, lang, messageTextTableVar string) (*model.MessageTextView, error)
  • func (v *View) NotifyUserByID(userID string) (*model.NotifyUser, error)
  • func (v *View) NotifyUsersByOrgID(orgID string) ([]*model.NotifyUser, error)
  • func (v *View) ProcessedNotificationFailedEvent(failedEvent *repository.FailedEvent) error
  • func (v *View) ProcessedNotificationSequence(event *models.Event) error
  • func (v *View) ProcessedNotifyUserFailedEvent(failedEvent *repository.FailedEvent) error
  • func (v *View) ProcessedNotifyUserSequence(event *models.Event) error
  • func (v *View) PutNotifyUser(user *model.NotifyUser, event *models.Event) error
  • func (v *View) UpdateNotificationSpoolerRunTimestamp() error
  • func (v *View) UpdateNotifyUserSpoolerRunTimestamp() error

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) LabelPolicyByAggregateIDAndState

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

func (*View) MailTemplateByAggregateID

func (v *View) MailTemplateByAggregateID(aggregateID string, mailTemplateTableVar string) (*model.MailTemplateView, error)

func (*View) MessageTextByIDs

func (v *View) MessageTextByIDs(aggregateID, textType, lang, messageTextTableVar string) (*model.MessageTextView, 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) UpdateNotificationSpoolerRunTimestamp

func (v *View) UpdateNotificationSpoolerRunTimestamp() error

func (*View) UpdateNotifyUserSpoolerRunTimestamp

func (v *View) UpdateNotifyUserSpoolerRunTimestamp() error