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) (engine.DataSource, error)
NewSource creates a new arweave dataSource.
Types ¶
type Filter ¶
type Filter struct {
OwnerAddresses []string `yaml:"owner_addresses"`
// BundlrOnly is a tag, indicating that only transactions of Bundlr nodes are pulled.
BundlrOnly bool `yaml:"bundlr_only"`
// BundlrAddresses is a list of addresses that are considered Bundlr nodes.
// If BundlrOnly is true, the field needs to be ignored.
BundlrAddresses []string `yaml:"bundlr_addresses"`
}
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 ¶ added in v0.4.13
BuildActivity builds an activity from the task.
func (Task) GetNetwork ¶
func (Task) GetTimestamp ¶
Click to show internal directories.
Click to hide internal directories.