Documentation
¶
Index ¶
- Variables
- func NewAnalyzerTask(db *store.DB, logger *logrus.Logger) pipeline.Task
- func NewCleanupTask(db *store.DB, logger *logrus.Logger) pipeline.Task
- func NewFetcherTask(rpc *client.Client, logger *logrus.Logger) pipeline.Task
- func NewLogger(log *logrus.Logger) pipeline.Logger
- func NewParserTask(logger *logrus.Logger) pipeline.Task
- func NewPersistorTask(db *store.DB, logger *logrus.Logger) pipeline.Task
- func NewPipeline(db *store.DB, rpc *client.Client, logger *logrus.Logger) (*indexingPipeline, error)
- func VersionString() string
- type AnalyzerTask
- type CleanupTask
- type FetcherTask
- type ParserTask
- type Payload
- type PayloadFactory
- type PersistorTask
Constants ¶
This section is empty.
Variables ¶
View Source
var ( AppName = "avalanche-indexer" AppVersion = "0.9.0" GitCommit = "-" GoVersion = "-" )
Functions ¶
func NewPipeline ¶
func VersionString ¶
func VersionString() string
Types ¶
type AnalyzerTask ¶
type AnalyzerTask struct {
// contains filtered or unexported fields
}
func (AnalyzerTask) GetName ¶
func (t AnalyzerTask) GetName() string
type CleanupTask ¶
type CleanupTask struct {
// contains filtered or unexported fields
}
func (CleanupTask) GetName ¶
func (t CleanupTask) GetName() string
type FetcherTask ¶
type FetcherTask struct {
// contains filtered or unexported fields
}
func (FetcherTask) GetName ¶
func (t FetcherTask) GetName() string
type ParserTask ¶
type ParserTask struct {
// contains filtered or unexported fields
}
func (*ParserTask) GetName ¶
func (t *ParserTask) GetName() string
type Payload ¶
type Payload struct { ID string SyncTime time.Time Processed bool // Fetched properties NodeVersion string NetworkName string Height int64 Peers []client.Peer Blockchains []client.Blockchain CurrentValidators []client.Validator CurrentDelegators []client.Delegator PendingValidators []client.Validator PendingDelegators []client.Delegator MinStake *client.MinStakeResponse RawTxFee *client.TxFeeResponse Balances map[string]*client.Balance // Calculated properties ActiveStakeAmount int64 PendingStakeAmount int64 MinValidatorStake int64 MinDelegatorStake int64 TxFee int64 CreationTxFee int64 // Mapped properties NetworkMetric *model.NetworkMetric Validators []model.Validator ValidatorSeq []model.ValidatorSeq Delegations []model.Delegation }
func NewPayload ¶
func NewPayload() *Payload
func (*Payload) HeightChanged ¶
func (*Payload) MarkAsProcessed ¶
func (p *Payload) MarkAsProcessed()
type PayloadFactory ¶
type PayloadFactory struct { }
func NewPayloadFactory ¶
func NewPayloadFactory() PayloadFactory
func (PayloadFactory) GetPayload ¶
func (p PayloadFactory) GetPayload(int64) pipeline.Payload
type PersistorTask ¶
type PersistorTask struct {
// contains filtered or unexported fields
}
func (PersistorTask) GetName ¶
func (t PersistorTask) GetName() string
Source Files
¶
Click to show internal directories.
Click to hide internal directories.