Documentation ¶
Index ¶
- type View
- 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, instanceID string) (*global_view.FailedEvent, error)
- func (v *View) GetLatestStylingSequence(instanceID string) (*global_view.CurrentSequence, error)
- func (v *View) GetLatestStylingSequences() ([]*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, instanceID string, state int32) (*model.LabelPolicyView, error)
- func (v *View) UpdateStylingSpoolerRunTimestamp() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type View ¶
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) GetCurrentSequence ¶
func (v *View) GetCurrentSequence(db, viewName string) ([]*repository.CurrentSequence, error)
func (*View) GetLatestStylingFailedEvent ¶
func (v *View) GetLatestStylingFailedEvent(sequence uint64, instanceID string) (*global_view.FailedEvent, error)
func (*View) GetLatestStylingSequence ¶
func (v *View) GetLatestStylingSequence(instanceID string) (*global_view.CurrentSequence, error)
func (*View) GetLatestStylingSequences ¶
func (v *View) GetLatestStylingSequences() ([]*global_view.CurrentSequence, error)
func (*View) ProcessedStylingFailedEvent ¶
func (v *View) ProcessedStylingFailedEvent(failedEvent *global_view.FailedEvent) error
func (*View) ProcessedStylingSequence ¶
func (*View) PutStyling ¶
func (*View) RemoveFailedEvent ¶
func (v *View) RemoveFailedEvent(database string, failedEvent *repository.FailedEvent) error
func (*View) StylingByAggregateIDAndState ¶
func (*View) UpdateStylingSpoolerRunTimestamp ¶
Click to show internal directories.
Click to hide internal directories.