Documentation
¶
Index ¶
- func AutoMigrate(db *gorm.DB)
- type Event
- type EventLog
- func (e *EventLog) ClearPendingEvents(topic string) error
- func (e *EventLog) Confirm(id uuid.UUID, blockNumber uint64, timestamp uint64) (Event, error)
- func (e *EventLog) FindConfirmedEvents() ([]Event, error)
- func (e *EventLog) FindLastSynchronisedBlockNumber(topic string) (uint64, error)
- func (e *EventLog) FindPendingEvents() ([]Event, error)
- func (e *EventLog) Insert(event Event) (Event, error)
- func (e *EventLog) ResetFromBlockAndInsert(topic string, fromBlock uint64, events []Event) error
- type EventLogConfiguration
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AutoMigrate ¶
Types ¶
type Event ¶
type Event struct {
gorm.Model
ID uuid.UUID `gorm:"primaryKey"`
Type string `json:"type"`
Payload string `json:"payload"`
Version float64 `json:"version"`
Topic string `json:"topic"`
Cid string `json:"cid"`
Emitter string `json:"emitter"`
NewAccounts pq.StringArray `gorm:"type:text[]"`
Timestamp uint64 `json:"timestamp"`
BlockNumber uint64 `json:"blockNumber"`
}
type EventLog ¶
type EventLog struct {
// contains filtered or unexported fields
}
func NewEventLog ¶
func NewEventLog(eventLogConfiguration EventLogConfiguration) (*EventLog, error)
func (*EventLog) ClearPendingEvents ¶
func (*EventLog) FindConfirmedEvents ¶
func (*EventLog) FindLastSynchronisedBlockNumber ¶
func (*EventLog) FindPendingEvents ¶
Click to show internal directories.
Click to hide internal directories.