ingest

Documentation

Index

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

Constants

const (
	ProposalStatusExecuted = 5
)

Variables

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

Functions

func NewContractsRegistry

func NewContractsRegistry(client *ethclient.Client, cfg config.ContractsRegistry) *contracts.Registry

Types

type Notifier

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

type Provider

type Provider interface {
	GetStatus(opts *bind.CallOpts, _id *big.Int) (uint8, error)
	GetProposal(opts *bind.CallOpts, _id *big.Int) (generated.IVotingBaseProposal, error)
	GetProposalStats(opts *bind.CallOpts, _proposalId *big.Int) (generated.IVotingVotingStats, error)
}

type Service

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

Service ingests history.

func New

func New(ctx context.Context, 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 SystemContract

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

type SystemContracts

type SystemContracts []SystemContract