Documentation
¶
Index ¶
Constants ¶
View Source
const DEFAULT_TABLE = "projections"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Base ¶
type Base struct {
projection_usecase.Base
// contains filtered or unexported fields
}
Base is a bas for projection which keeps track of last handled event height using relational database. It implements Id() and GetLastHandledEventHeight() of projection interface.
func NewRDbBase ¶
Create a new Base using table name in the RDb to keep the projection handling records
func NewRDbBaseWithOptions ¶
func (*Base) GetLastHandledEventHeight ¶
Implements projection.GetLastHandledEventHeight()
type Options ¶
type Options struct {
// Customize table name in the RDb to keep the projection block handling records
MaybeTable *string
}
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store is an implementation of the RDbStore
Source Files
Click to show internal directories.
Click to hide internal directories.