chain_events

Documentation

Index

• Variables
• type GetEventTypes
• type GormStore
  • func NewGormStore(db *gorm.DB) *GormStore
  • func (s *GormStore) GetListenerStatus() (t *ListenerStatus, err error)
  • func (s *GormStore) UpdateListenerStatus(t *ListenerStatus) error
• type Listener
  • func NewListener(fc *client.Client, db Store, maxDiff uint64, interval time.Duration, ...) *Listener
  • func (l *Listener) Start() *Listener
  • func (l *Listener) Stop()
• type ListenerStatus
  • func (ListenerStatus) TableName() string
• type Store

Variables

var Event event // singleton of type event

Types

type GetEventTypes

type GetEventTypes func() []string

type GormStore

type GormStore struct {
	// contains filtered or unexported fields
}

func NewGormStore

func NewGormStore(db *gorm.DB) *GormStore

func (*GormStore) GetListenerStatus

func (s *GormStore) GetListenerStatus() (t *ListenerStatus, err error)

func (*GormStore) UpdateListenerStatus

func (s *GormStore) UpdateListenerStatus(t *ListenerStatus) error

type Listener

type Listener struct {
	// contains filtered or unexported fields
}

func NewListener

func NewListener(
	fc *client.Client,
	db Store,
	maxDiff uint64,
	interval time.Duration,
	getTypes GetEventTypes,
) *Listener

func (*Listener) Start

func (l *Listener) Start() *Listener

func (*Listener) Stop

func (l *Listener) Stop()

type ListenerStatus

type ListenerStatus struct {
	gorm.Model
	LatestHeight uint64
}

func (ListenerStatus) TableName

func (ListenerStatus) TableName() string

type Store

type Store interface {
	UpdateListenerStatus(s *ListenerStatus) error
	GetListenerStatus() (*ListenerStatus, error)
}

Store manages data regarding tokens.