worker

Documentation

Index

• Constants
• func Emissions(f func(Emission))
• func EthereumAnnouncements(f func(EthereumAnnouncement))
• func GetEthereumBlockLogs(f func(EthereumBlockLog))
• func GetEthereumHintedBlocks(f func(EthereumHintedBlock))
• func GetSolanaBufferedParsedTransactions(f func(SolanaBufferedParsedTransactions))
• func GetSolanaBufferedTransfers(f func(SolanaBufferedTransfers))
• type Emission
  • func NewEthereumEmission() *Emission
  • func NewSolanaEmission() *Emission
• type EthereumAnnouncement
• type EthereumAppFees
• type EthereumApplicationEvent
• type EthereumApplicationTransfer
• type EthereumBlockLog
• type EthereumDecoratedTransaction
• type EthereumDecoratedTransfer
• type EthereumHintedBlock
• type EthereumWorkerDecorator
• type SolanaAppFees
• type SolanaBufferedParsedTransactions
• type SolanaBufferedTransfers
• type SolanaDecoratedTransfer
• type SolanaParsedTransaction
• type SolanaWinnerAnnouncement
• type SolanaWork

Constants

const (
	TopicEthereumAnnouncements = "worker.ethereum.announcements"
	TopicEthereumBlockLogs     = "worker.ethereum.blocks" // into apps server
	TopicEthereumServerWork    = "worker.server.work"     // into worker

	TopicSolanaParsedTransactions = "worker.solana.parsed_transactions"
	TopicSolanaBufferedTransfers  = "worker.solana.buffered_transfers"
	TopicSolanaServerWork         = "worker.solana.server.work"

	TopicEmissions = "worker.emissions"
)

Functions

func Emissions

func Emissions(f func(Emission))

func EthereumAnnouncements

func EthereumAnnouncements(f func(EthereumAnnouncement))

func GetEthereumBlockLogs

func GetEthereumBlockLogs(f func(EthereumBlockLog))

func GetEthereumHintedBlocks

func GetEthereumHintedBlocks(f func(EthereumHintedBlock))

func GetSolanaBufferedParsedTransactions

func GetSolanaBufferedParsedTransactions(f func(SolanaBufferedParsedTransactions))

func GetSolanaBufferedTransfers

func GetSolanaBufferedTransfers(f func(SolanaBufferedTransfers))

Types

type Emission

type Emission = worker.Emission

func NewEthereumEmission

func NewEthereumEmission() *Emission

func NewSolanaEmission

func NewSolanaEmission() *Emission

type EthereumAnnouncement

type EthereumAnnouncement = worker.EthereumAnnouncement

type EthereumAppFees

type EthereumAppFees = worker.EthereumAppFees

type EthereumApplicationEvent

type EthereumApplicationEvent = worker.EthereumApplicationEvent

type EthereumApplicationTransfer

type EthereumApplicationTransfer = worker.EthereumApplicationTransfer

type EthereumBlockLog

type EthereumBlockLog = worker.EthereumBlockLog

type EthereumDecoratedTransaction

type EthereumDecoratedTransaction = worker.EthereumDecoratedTransaction

type EthereumDecoratedTransfer

type EthereumDecoratedTransfer = worker.EthereumDecoratedTransfer

type EthereumHintedBlock

type EthereumHintedBlock = worker.EthereumHintedBlock

type EthereumWorkerDecorator

type EthereumWorkerDecorator = worker.EthereumWorkerDecorator

type SolanaAppFees

type SolanaAppFees = worker.SolanaAppFees

type SolanaBufferedParsedTransactions

type SolanaBufferedParsedTransactions = worker.SolanaBufferedParsedTransactions

type SolanaBufferedTransfers

type SolanaBufferedTransfers = worker.SolanaBufferedTransfers

type SolanaDecoratedTransfer

type SolanaDecoratedTransfer = worker.SolanaDecoratedTransfer

type SolanaParsedTransaction

type SolanaParsedTransaction = worker.SolanaParsedTransaction

type SolanaWinnerAnnouncement

type SolanaWinnerAnnouncement = worker.SolanaWinnerAnnouncement

type SolanaWork

type SolanaWork = worker.SolanaWork