view

Documentation

Index

• type View
  • func StartView(sqlClient *sql.DB) (*View, error)
  • func (v *View) AllCurrentSequences(db string) ([]*repository.CurrentSequence, error)
  • func (v *View) AllFailedEvents(db string) ([]*repository.FailedEvent, error)
  • func (v *View) ClearView(db, viewName string) error
  • func (v *View) GetCurrentSequence(db, viewName string) (*repository.CurrentSequence, error)
  • func (v *View) GetLatestStylingFailedEvent(sequence uint64) (*global_view.FailedEvent, error)
  • func (v *View) GetLatestStylingSequence() (*global_view.CurrentSequence, error)
  • func (v *View) Health() (err error)
  • func (v *View) ProcessedStylingFailedEvent(failedEvent *global_view.FailedEvent) error
  • func (v *View) ProcessedStylingSequence(event *models.Event) error
  • func (v *View) PutStyling(policy *model.LabelPolicyView, event *models.Event) error
  • func (v *View) RemoveFailedEvent(database string, failedEvent *repository.FailedEvent) error
  • func (v *View) StylingByAggregateIDAndState(aggregateID string, state int32) (*model.LabelPolicyView, error)
  • func (v *View) UpdateStylingSpoolerRunTimestamp() error

Types

type View

type View struct {
	Db *gorm.DB
}

func StartView

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

func (*View) AllCurrentSequences

func (v *View) AllCurrentSequences(db string) ([]*repository.CurrentSequence, error)

func (*View) AllFailedEvents

func (v *View) AllFailedEvents(db string) ([]*repository.FailedEvent, error)

func (*View) ClearView

func (v *View) ClearView(db, viewName string) error

func (*View) GetCurrentSequence

func (v *View) GetCurrentSequence(db, viewName string) (*repository.CurrentSequence, error)

func (*View) GetLatestStylingFailedEvent

func (v *View) GetLatestStylingFailedEvent(sequence uint64) (*global_view.FailedEvent, error)

func (*View) GetLatestStylingSequence

func (v *View) GetLatestStylingSequence() (*global_view.CurrentSequence, error)

func (*View) Health

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

func (*View) ProcessedStylingFailedEvent

func (v *View) ProcessedStylingFailedEvent(failedEvent *global_view.FailedEvent) error

func (*View) ProcessedStylingSequence

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

func (*View) PutStyling

func (v *View) PutStyling(policy *model.LabelPolicyView, event *models.Event) error

func (*View) RemoveFailedEvent

func (v *View) RemoveFailedEvent(database string, failedEvent *repository.FailedEvent) error

func (*View) StylingByAggregateIDAndState

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

func (*View) UpdateStylingSpoolerRunTimestamp

func (v *View) UpdateStylingSpoolerRunTimestamp() error