Documentation
¶
Index ¶
- 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() 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 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 ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 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{}
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{}
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{}
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
¶
- 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
- 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