Documentation
¶
Index ¶
- Constants
- func NewBeginTransactionTask(store *store.Store) pipeline.Task
- func NewCommitTransactionTask(store *store.Store) pipeline.Task
- func NewDealFetcherTask(client *client.Client) pipeline.Task
- func NewEpochFetcherTask(client *client.Client) pipeline.Task
- func NewEpochParserTask() pipeline.Task
- func NewEpochPersistorTask(store *store.Store) pipeline.Task
- func NewEventPersistorTask(store *store.Store) pipeline.Task
- func NewEventSequencerTask(store *store.Store) pipeline.Task
- func NewMinerFetcherTask(client *client.Client) pipeline.Task
- func NewMinerParserTask() pipeline.Task
- func NewMinerPersistorTask(store *store.Store) pipeline.Task
- func NewSink(store *store.Store) pipeline.Sink
- func NewSource(cfg *config.Config, client *client.Client, store *store.Store) (pipeline.Source, error)
- func NewTransactionFetcherTask(client *client.Client) pipeline.Task
- func NewTransactionParserTask() pipeline.Task
- func NewTransactionPersistorTask(store *store.Store) pipeline.Task
- func StartPipeline(cfg *config.Config, client *client.Client, store *store.Store) error
- type BeginTransactionTask
- type CommitTransactionTask
- type DealFetcherTask
- type EpochFetcherTask
- type EpochParserTask
- type EpochPersistorTask
- type EventPersistorTask
- type EventSequencerTask
- type MinerFetcherTask
- type MinerParserTask
- type MinerPersistorTask
- type PayloadFactory
- type TransactionFetcherTask
- type TransactionParserTask
- type TransactionPersistorTask
Constants ¶
const BeginTransactionTaskName = "BeginTransaction"
BeginTransactionTaskName represents the name of the task
const CommitTransactionTaskName = "CommitTransaction"
CommitTransactionTaskName represents the name of the task
const DealFetcherTaskName = "DealFetcher"
DealFetcherTaskName represents the name of the task
const EpochFetcherTaskName = "EpochFetcher"
EpochFetcherTaskName represents the name of the task
const EpochParserTaskName = "EpochParser"
EpochParserTaskName represents the name of the task
const EpochPersistorTaskName = "EpochPersistor"
EpochPersistorTaskName represents the name of the task
const EventPersistorTaskName = "EventPersistor"
EventPersistorTaskName represents the name of the task
const EventSequencerTaskName = "EventSequencer"
EventSequencerTaskName represents the name of the task
const MinerFetcherTaskName = "MinerFetcher"
MinerFetcherTaskName represents the name of the task
const MinerParserTaskName = "MinerParser"
MinerParserTaskName represents the name of the task
const MinerPersistorTaskName = "MinerPersistor"
MinerPersistorTaskName represents the name of the task
const TransactionFetcherTaskName = "TransactionFetcher"
TransactionFetcherTaskName represents the name of the task
const TransactionParserTaskName = "TransactionParser"
TransactionParserTaskName represents the name of the task
const TransactionPersistorTaskName = "TransactionPersistor"
TransactionPersistorTaskName represents the name of the task
Variables ¶
This section is empty.
Functions ¶
func NewBeginTransactionTask ¶
NewBeginTransactionTask creates the task
func NewCommitTransactionTask ¶
NewCommitTransactionTask creates the task
func NewDealFetcherTask ¶
NewDealFetcherTask creates the task
func NewEpochFetcherTask ¶
NewEpochFetcherTask creates the task
func NewEpochParserTask ¶
NewEpochParserTask creates the task
func NewEpochPersistorTask ¶
NewEpochPersistorTask creates the task
func NewEventPersistorTask ¶
NewEventPersistorTask creates the task
func NewEventSequencerTask ¶
NewEventSequencerTask creates the task
func NewMinerFetcherTask ¶
NewMinerFetcherTask creates the task
func NewMinerParserTask ¶
NewMinerParserTask creates the task
func NewMinerPersistorTask ¶
NewMinerPersistorTask creates the task
func NewSource ¶
func NewSource(cfg *config.Config, client *client.Client, store *store.Store) (pipeline.Source, error)
NewSource creates a pipeline source
func NewTransactionFetcherTask ¶
NewTransactionFetcherTask creates the task
func NewTransactionParserTask ¶
NewTransactionParserTask creates the task
func NewTransactionPersistorTask ¶
NewTransactionPersistorTask creates the task
Types ¶
type BeginTransactionTask ¶
type BeginTransactionTask struct {
// contains filtered or unexported fields
}
BeginTransactionTask starts a database transaction
func (*BeginTransactionTask) GetName ¶
func (t *BeginTransactionTask) GetName() string
GetName returns the task name
type CommitTransactionTask ¶
type CommitTransactionTask struct {
// contains filtered or unexported fields
}
CommitTransactionTask commits the database transaction
func (*CommitTransactionTask) GetName ¶
func (t *CommitTransactionTask) GetName() string
GetName returns the task name
type DealFetcherTask ¶
type DealFetcherTask struct {
// contains filtered or unexported fields
}
DealFetcherTask fetches raw deal data
func (*DealFetcherTask) GetName ¶
func (t *DealFetcherTask) GetName() string
GetName returns the task name
type EpochFetcherTask ¶
type EpochFetcherTask struct {
// contains filtered or unexported fields
}
EpochFetcherTask fetches raw epoch data
func (*EpochFetcherTask) GetName ¶
func (t *EpochFetcherTask) GetName() string
GetName returns the task name
type EpochParserTask ¶
type EpochParserTask struct {
// contains filtered or unexported fields
}
EpochParserTask transforms raw epoch data
func (*EpochParserTask) GetName ¶
func (t *EpochParserTask) GetName() string
GetName returns the task name
type EpochPersistorTask ¶
type EpochPersistorTask struct {
// contains filtered or unexported fields
}
EpochPersistorTask stores epochs in the database
func (*EpochPersistorTask) GetName ¶
func (t *EpochPersistorTask) GetName() string
GetName returns the task name
type EventPersistorTask ¶
type EventPersistorTask struct {
// contains filtered or unexported fields
}
EventPersistorTask stores events in the database
func (*EventPersistorTask) GetName ¶
func (t *EventPersistorTask) GetName() string
GetName returns the task name
type EventSequencerTask ¶
type EventSequencerTask struct {
// contains filtered or unexported fields
}
EventSequencerTask creates network events
func (*EventSequencerTask) GetName ¶
func (t *EventSequencerTask) GetName() string
GetName returns the task name
type MinerFetcherTask ¶
type MinerFetcherTask struct {
// contains filtered or unexported fields
}
MinerFetcherTask fetches raw miner data
func (*MinerFetcherTask) GetName ¶
func (t *MinerFetcherTask) GetName() string
GetName returns the task name
type MinerParserTask ¶
type MinerParserTask struct {
// contains filtered or unexported fields
}
MinerParserTask transforms raw miner data
func (*MinerParserTask) GetName ¶
func (t *MinerParserTask) GetName() string
GetName returns the task name
type MinerPersistorTask ¶
type MinerPersistorTask struct {
// contains filtered or unexported fields
}
MinerPersistorTask stores miners in the database
func (*MinerPersistorTask) GetName ¶
func (t *MinerPersistorTask) GetName() string
GetName returns the task name
type PayloadFactory ¶
type PayloadFactory struct{}
PayloadFactory creates payloads
func NewPayloadFactory ¶
func NewPayloadFactory() *PayloadFactory
NewPayloadFactory creates a payload factory
func (*PayloadFactory) GetPayload ¶
func (pf *PayloadFactory) GetPayload(height int64) pipeline.Payload
GetPayload returns a payload for a given height
type TransactionFetcherTask ¶
type TransactionFetcherTask struct {
// contains filtered or unexported fields
}
TransactionFetcherTask fetches raw transaction data
func (*TransactionFetcherTask) GetName ¶
func (t *TransactionFetcherTask) GetName() string
GetName returns the task name
type TransactionParserTask ¶
type TransactionParserTask struct {
// contains filtered or unexported fields
}
TransactionParserTask transforms raw transaction data
func (*TransactionParserTask) GetName ¶
func (t *TransactionParserTask) GetName() string
GetName returns the task name
type TransactionPersistorTask ¶
type TransactionPersistorTask struct {
// contains filtered or unexported fields
}
TransactionPersistorTask stores transactions in the database
func (*TransactionPersistorTask) GetName ¶
func (t *TransactionPersistorTask) GetName() string
GetName returns the task name
Source Files
¶
- begin_transaction_task.go
- commit_transaction_task.go
- deal_fetcher_task.go
- epoch_fetcher_task.go
- epoch_parser_task.go
- epoch_persistor_task.go
- event_persistor_task.go
- event_sequencer_task.go
- indexing.go
- metrics.go
- miner_fetcher_task.go
- miner_parser_task.go
- miner_persistor_task.go
- payload.go
- sink.go
- source.go
- transaction_fetcher_task.go
- transaction_parser_task.go
- transaction_persistor_task.go