warpy_sync

package
v0.2.211 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 15, 2024 License: MIT Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BlockDownloader 

type BlockDownloader struct {
	*task.Task

	Output        chan *BlockInfoPayload
	OutputPollTxs chan uint64
	// contains filtered or unexported fields
}

func NewBlockDownloader 

func NewBlockDownloader(config *config.Config) (self *BlockDownloader)

When started, this task checks database for the latest block synced and store the result in lastSyncedBlockHeight field Then, compare lastSyncedBlockHeight to the current external network's block height and loads info for all of the missing blocks for the indicated range Lastly, it emits to the Output channel block's height, block's hash and all transactions that this block contains and update lastSyncedBlockHeight to the last processed block

func (*BlockDownloader) WithEthClient 

func (self *BlockDownloader) WithEthClient(ethClient *ethclient.Client) *BlockDownloader

func (*BlockDownloader) WithInitStartBlockHeight 

func (self *BlockDownloader) WithInitStartBlockHeight(db *gorm.DB, syncedComponent model.SyncedComponent) *BlockDownloader

func (*BlockDownloader) WithMonitor 

func (self *BlockDownloader) WithMonitor(monitor monitoring.Monitor) *BlockDownloader

func (*BlockDownloader) WithPollerCron added in v0.2.186 

func (self *BlockDownloader) WithPollerCron() *BlockDownloader

type BlockInfoPayload 

type BlockInfoPayload struct {
	Transactions []*types.Transaction
	Height       uint64
	Hash         string
	Timestamp    uint64
}

type Controller 

type Controller struct {
	*task.Task
}

func NewController 

func NewController(config *config.Config) (self *Controller, err error)

type Input 

type Input struct {
	Function string   `json:"function"`
	Points   int64    `json:"points"`
	AdminId  string   `json:"adminId"`
	Members  []Member `json:"members"`
	NoBoost  bool     `json:"noBoost"`
}

func (Input) MarshalJSON 

func (input Input) MarshalJSON() ([]byte, error)

type InteractionPayload 

type InteractionPayload struct {
	FromAddress string
	Points      int64
}

type LastSyncedBlockPayload 

type LastSyncedBlockPayload struct {
	Height    uint64
	Hash      string
	Timestamp uint64
}

type Member 

type Member struct {
	Id     string   `json:"id"`
	Roles  []string `json:"roles"`
	TxId   string   `json:"txId"`
	Points int64    `json:"points"`
}

type PollerDeposit added in v0.2.192 

type PollerDeposit struct {
	*task.Task

	Output chan *[]InteractionPayload
	// contains filtered or unexported fields
}

func NewPollerDeposit added in v0.2.192 

func NewPollerDeposit(config *config.Config) (self *PollerDeposit)

func (*PollerDeposit) WithDB added in v0.2.192 

func (self *PollerDeposit) WithDB(db *gorm.DB) *PollerDeposit

func (*PollerDeposit) WithInputChannel added in v0.2.192 

func (self *PollerDeposit) WithInputChannel(v chan uint64) *PollerDeposit

func (*PollerDeposit) WithMonitor added in v0.2.192 

func (self *PollerDeposit) WithMonitor(monitor monitoring.Monitor) *PollerDeposit

type SommelierTransactionPayload 

type SommelierTransactionPayload struct {
	Transaction *types.Transaction
	FromAddress string
	Block       *BlockInfoPayload
	Method      *abi.Method
	ParsedInput []byte
	Input       map[string]interface{}
}

type Store 

type Store struct {
	*task.Processor[*LastSyncedBlockPayload, *LastSyncedBlockPayload]
	// contains filtered or unexported fields
}

Store is responsible for saving last synced block height in sync_state table It updates the table periodically to not overload database with updates done each time after new block has been processed

func NewStore 

func NewStore(config *config.Config) (self *Store)

func (*Store) WithDb 

func (self *Store) WithDb(v *gorm.DB) *Store

func (*Store) WithInputChannel 

func (self *Store) WithInputChannel(v chan *LastSyncedBlockPayload) *Store

func (*Store) WithMonitor 

func (self *Store) WithMonitor(v monitoring.Monitor) *Store

func (*Store) WithSyncedComponent 

func (self *Store) WithSyncedComponent(syncedComponent model.SyncedComponent) *Store

type StoreDeposit added in v0.2.192 

type StoreDeposit struct {
	*task.Task
	// contains filtered or unexported fields
}

func NewStoreDeposit added in v0.2.192 

func NewStoreDeposit(config *config.Config) (self *StoreDeposit)

func (*StoreDeposit) WithDB added in v0.2.192 

func (self *StoreDeposit) WithDB(db *gorm.DB) *StoreDeposit

func (*StoreDeposit) WithInputChannel added in v0.2.192 

func (self *StoreDeposit) WithInputChannel(v chan *SommelierTransactionPayload) *StoreDeposit

func (*StoreDeposit) WithMonitor added in v0.2.192 

func (self *StoreDeposit) WithMonitor(monitor monitoring.Monitor) *StoreDeposit

type SyncerDelta 

type SyncerDelta struct {
	*task.Task

	Output                   chan *LastSyncedBlockPayload
	OutputInteractionPayload chan *[]InteractionPayload
	// contains filtered or unexported fields
}

func NewSyncerDelta 

func NewSyncerDelta(config *config.Config) (self *SyncerDelta)

This task receives block info in the input channel, iterate through all of the block's transactions in order to check if any of it contains Redstone data and if so - writes an interaction to Warpy. It emits block height and block hash in the Output channel

func (*SyncerDelta) WithInputChannel 

func (self *SyncerDelta) WithInputChannel(v chan *BlockInfoPayload) *SyncerDelta

func (*SyncerDelta) WithMonitor 

func (self *SyncerDelta) WithMonitor(monitor monitoring.Monitor) *SyncerDelta

type SyncerDeposit added in v0.2.192 

type SyncerDeposit struct {
	*task.Task

	Output                   chan *LastSyncedBlockPayload
	OutputTransactionPayload chan *SommelierTransactionPayload
	// contains filtered or unexported fields
}

func NewSyncerDeposit added in v0.2.192 

func NewSyncerDeposit(config *config.Config) (self *SyncerDeposit)

This task receives block info in the input channel, iterate through all of the block's transactions in order to check if any contains Sommelier transaction and saves transaction in the db

func (*SyncerDeposit) WithContractAbi added in v0.2.192 

func (self *SyncerDeposit) WithContractAbi(contractAbi *abi.ABI) *SyncerDeposit

func (*SyncerDeposit) WithDb added in v0.2.192 

func (self *SyncerDeposit) WithDb(v *gorm.DB) *SyncerDeposit

func (*SyncerDeposit) WithInputChannel added in v0.2.192 

func (self *SyncerDeposit) WithInputChannel(v chan *BlockInfoPayload) *SyncerDeposit

func (*SyncerDeposit) WithMonitor added in v0.2.192 

func (self *SyncerDeposit) WithMonitor(monitor monitoring.Monitor) *SyncerDeposit

type Writer 

type Writer struct {
	*task.Task
	// contains filtered or unexported fields
}

func NewWriter 

func NewWriter(config *config.Config) (self *Writer)

func (*Writer) WithInputChannel 

func (self *Writer) WithInputChannel(v chan *[]InteractionPayload) *Writer

func (*Writer) WithMonitor 

func (self *Writer) WithMonitor(monitor monitoring.Monitor) *Writer

func (*Writer) WithSequencerClient 

func (self *Writer) WithSequencerClient(sequencerClient *sequencer.Client) *Writer

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.