chain_events

Documentation

Index

• Variables
• type GetEventTypes
• type GormStore
  • func NewGormStore(db *gorm.DB) *GormStore
  • func (s *GormStore) LockedStatus(fn func(status *ListenerStatus) error) error
• type Listener
  • func NewListener(logger *log.Logger, fc *client.Client, db Store, getTypes GetEventTypes, ...) *Listener
  • func (l *Listener) Start() *Listener
  • func (l *Listener) Stop()
• type ListenerStatus
  • func (ListenerStatus) TableName() string
• type LockError
  • func (e *LockError) Error() string
• type Store

Variables

var Event event // singleton of type event

Types

type GetEventTypes

type GetEventTypes func() ([]string, error)

type GormStore

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

func NewGormStore

func NewGormStore(db *gorm.DB) *GormStore

func (*GormStore) LockedStatus

func (s *GormStore) LockedStatus(fn func(status *ListenerStatus) error) error

LockedStatus runs a transaction on the database manipulating 'status' of type ListenerStatus. It takes a function 'fn' as argument. In the context of 'fn' 'status' is locked. Uses NOWAIT modifier on the lock so simultaneous requests can be ignored.

type Listener

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

func NewListener

func NewListener(
	logger *log.Logger,
	fc *client.Client,
	db Store,
	getTypes GetEventTypes,
	maxDiff uint64,
	interval time.Duration,
	startingHeight uint64,
) *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 LockError

type LockError struct {
	Err error
}

func (*LockError) Error

func (e *LockError) Error() string

type Store

type Store interface {
	LockedStatus(func(*ListenerStatus) error) error
}

Store manages data regarding tokens.