Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewSource ¶
func NewSource(config *config.Module, sourceFilter engine.DataSourceFilter, checkpoint *engine.Checkpoint, redisClient rueidis.Client) (engine.DataSource, error)
NewSource creates a new near dataSource.
Types ¶
type Option ¶
type Option struct {
// BlockStart is the block height on Arweave that the worker should start from.
BlockStart *big.Int `json:"block_start" mapstructure:"block_start"`
// BlockTarget is the block height on Arweave that the worker should stop at.
BlockTarget *big.Int `json:"block_target" mapstructure:"block_target"`
// ConcurrentBlockRequests is the number of blocks to request concurrently.
ConcurrentBlockRequests *uint64 `json:"concurrent_block_requests" mapstructure:"concurrent_block_requests"`
}
type Task ¶
func (Task) BuildActivity ¶
BuildActivity builds an activity from the task.
func (Task) GetNetwork ¶
func (Task) GetTimestamp ¶
Click to show internal directories.
Click to hide internal directories.