ingest

Documentation

Index

• Constants
• Variables
• func NewContractsRegistry(client *ethclient.Client, chainID *big.Int) *contracts.Registry
• type Notifier
• type Service
  • func New(cfg config.Config) (*Service, error)
  • func (s *Service) GetStartBlockByEvent(voteOrProposal int64, votingType string) (int64, error)
  • func (s *Service) Run(ctx context.Context) error
• type Status
• type SystemContract
• type SystemContracts

Constants

const (
	OldExpired  Status = 2
	OldExecuted        = 3
	NewExecuted        = 5
	NewExpired         = 7
)

const (
	PROPOSAS_STATUS_EXECUTED = 3
)

Variables

var VotingEvents = map[string]int64{
	"qTokenHolderVote": 0,
	"rootNodeVote":     1,
	"rootNodeProposal": 2,
}

Functions

func NewContractsRegistry

func NewContractsRegistry(client *ethclient.Client, chainID *big.Int) *contracts.Registry

Types

type Notifier

type Notifier interface {
	NewTransaction(tx *data.Transaction)
	NewPayment(pmnt *data.Payment)
	SendNotifications(timestamp int64) error
}

type Service

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

Service ingests history.

func New

func New(cfg config.Config) (*Service, error)

New Service.

func (*Service) GetStartBlockByEvent

func (s *Service) GetStartBlockByEvent(voteOrProposal int64, votingType string) (int64, error)

func (*Service) Run

func (s *Service) Run(ctx context.Context) error

Run service.

type Status

type Status uint8

type SystemContract

type SystemContract struct {
	Contract       common.Address
	Implementation common.Address
	Key            string
}

type SystemContracts

type SystemContracts []SystemContract