chain_events

Documentation

Index

• Variables
• type GetEventTypes
• type GormStore
  • func (s *GormStore) LockedStatus(fn func(status *ListenerStatus) error) error
• type Listener
  • func NewListener(fc flow_helpers.FlowClient, db Store, getTypes GetEventTypes, maxDiff uint64, ...) Listener
• type ListenerImpl
  • func (l *ListenerImpl) Start() Listener
  • func (l *ListenerImpl) Stop()
• type ListenerOption
  • func WithSystemService(svc system.Service) ListenerOption
• type ListenerStatus
  • func (ListenerStatus) TableName() string
• type LockError
  • func (e *LockError) Error() string
• type Store
  • func NewGormStore(db *gorm.DB) Store

Variables

var ChainEvent chainEvent // singleton of type event

Types

type GetEventTypes

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

type GormStore

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

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.

type Listener

type Listener interface {
	Start() Listener
	Stop()
}

func NewListener

func NewListener(
	fc flow_helpers.FlowClient,
	db Store,
	getTypes GetEventTypes,
	maxDiff uint64,
	interval time.Duration,
	startingHeight uint64,
	opts ...ListenerOption,
) Listener

type ListenerImpl

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

func (*ListenerImpl) Start

func (l *ListenerImpl) Start() Listener

func (*ListenerImpl) Stop

func (l *ListenerImpl) Stop()

type ListenerOption

type ListenerOption func(*ListenerImpl)

func WithSystemService

func WithSystemService(svc system.Service) ListenerOption

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.

func NewGormStore

func NewGormStore(db *gorm.DB) Store