Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BaseProcessor ¶
func NewBaseProcessor ¶
func NewBaseProcessor(cdc *codec.Codec, queueConnector *queue.QueueConnector, httpClient *httpClient.HTTP, txBroadcaster *broadcaster.TxBroadcaster, name string, impl Processor) *BaseProcessor
NewBaseProcessor creates a new BaseProcessor.
func (*BaseProcessor) String ¶
func (bp *BaseProcessor) String() string
String implements Service by returning a string representation of the service.
type CheckpointProcessor ¶
type CheckpointProcessor struct {
BaseProcessor
// contains filtered or unexported fields
}
CheckpointProcessor - processor for checkpoint queue.
func NewCheckpointProcessor ¶
func NewCheckpointProcessor(rootchainAbi *abi.ABI) *CheckpointProcessor
NewCheckpointProcessor - add rootchain abi to checkpoint processor
func (*CheckpointProcessor) HandleCheckpointNoAck ¶
func (cp *CheckpointProcessor) HandleCheckpointNoAck()
HandleCheckpointNoAck - Checkpoint No-Ack handler 1. Fetch latest checkpoint time from rootchain 2. check if elapsed time is more than NoAck Wait time. 3. Send NoAck to heimdall if required.
func (*CheckpointProcessor) RegisterTasks ¶
func (cp *CheckpointProcessor) RegisterTasks()
RegisterTasks - Registers checkpoint related tasks with machinery
func (*CheckpointProcessor) Start ¶
func (cp *CheckpointProcessor) Start() error
Start - consumes messages from checkpoint queue and call processMsg
func (*CheckpointProcessor) Stop ¶
func (cp *CheckpointProcessor) Stop()
Stop stops all necessary go routines
type ClerkProcessor ¶
type ClerkProcessor struct {
BaseProcessor
// contains filtered or unexported fields
}
ClerkProcessor - sync state/deposit events
func NewClerkProcessor ¶
func NewClerkProcessor(stateSenderAbi *abi.ABI) *ClerkProcessor
NewClerkProcessor - add statesender abi to clerk processor
func (*ClerkProcessor) RegisterTasks ¶
func (cp *ClerkProcessor) RegisterTasks()
RegisterTasks - Registers clerk related tasks with machinery
func (*ClerkProcessor) Start ¶
func (cp *ClerkProcessor) Start() error
Start starts new block subscription
type ContractCheckpoint ¶
type ContractCheckpoint struct {
// contains filtered or unexported fields
}
ContractCheckpoint contract checkpoint
func NewContractCheckpoint ¶
func NewContractCheckpoint(_newStart uint64, _newEnd uint64, _currentHeaderBlock *HeaderBlock) *ContractCheckpoint
NewContractCheckpoint creates contract checkpoint
func (ContractCheckpoint) String ¶
func (c ContractCheckpoint) String() string
type FeeProcessor ¶
type FeeProcessor struct {
BaseProcessor
// contains filtered or unexported fields
}
FeeProcessor - process fee related events
func NewFeeProcessor ¶
func NewFeeProcessor(stakingInfoAbi *abi.ABI) *FeeProcessor
NewFeeProcessor - add abi to clerk processor
func (*FeeProcessor) RegisterTasks ¶
func (fp *FeeProcessor) RegisterTasks()
RegisterTasks - Registers clerk related tasks with machinery
func (*FeeProcessor) Start ¶
func (fp *FeeProcessor) Start() error
Start starts new block subscription
type HeaderBlock ¶
type HeaderBlock struct {
// contains filtered or unexported fields
}
HeaderBlock header block
type HeimdallCheckpoint ¶
type HeimdallCheckpoint struct {
// contains filtered or unexported fields
}
HeimdallCheckpoint heimdall checkpoint
func NewHeimdallCheckpoint ¶
func NewHeimdallCheckpoint(_start uint64, _end uint64) *HeimdallCheckpoint
NewHeimdallCheckpoint creates new heimdall checkpoint object
type ProcessorService ¶
type ProcessorService struct {
// Base service
common.BaseService
// contains filtered or unexported fields
}
ProcessorService starts and stops all event processors
func NewProcessorService ¶
func NewProcessorService( cdc *codec.Codec, queueConnector *queue.QueueConnector, httpClient *httpClient.HTTP, txBroadcaster *broadcaster.TxBroadcaster, ) *ProcessorService
NewProcessorService returns new service object for processing queue msg
func (*ProcessorService) OnStart ¶
func (processorService *ProcessorService) OnStart() error
OnStart starts new block subscription
func (*ProcessorService) OnStop ¶
func (processorService *ProcessorService) OnStop()
OnStop stops all necessary go routines
type Result ¶
type Result struct {
Result uint64 `json:"result"`
}
Result represents single req result
type SpanProcessor ¶
type SpanProcessor struct {
BaseProcessor
// contains filtered or unexported fields
}
SpanProcessor - process span related events
func (*SpanProcessor) Start ¶
func (sp *SpanProcessor) Start() error
Start starts new block subscription
type StakingProcessor ¶
type StakingProcessor struct {
BaseProcessor
// contains filtered or unexported fields
}
StakingProcessor - process staking related events
func NewStakingProcessor ¶
func NewStakingProcessor(stakingInfoAbi *abi.ABI) *StakingProcessor
NewStakingProcessor - add abi to staking processor
func (*StakingProcessor) RegisterTasks ¶
func (sp *StakingProcessor) RegisterTasks()
RegisterTasks - Registers staking tasks with machinery
func (*StakingProcessor) Start ¶
func (sp *StakingProcessor) Start() error
Start starts new block subscription
Source Files