processor

Documentation

Index

• func Logger(name string) log.Logger
• type BaseProcessor
  • func NewBaseProcessor(cdc codec.Codec, queueConnector *queue.QueueConnector, ...) *BaseProcessor
  • func (bp *BaseProcessor) Stop()
  • func (bp *BaseProcessor) String() string
• type CheckpointContext
• type CheckpointProcessor
  • func NewCheckpointProcessor(rootchainAbi *abi.ABI) *CheckpointProcessor
  • func (cp *CheckpointProcessor) RegisterTasks()
  • func (cp *CheckpointProcessor) Start() error
  • func (cp *CheckpointProcessor) Stop()
• type ClerkContext
• type ClerkProcessor
  • func NewClerkProcessor(stateSenderAbi *abi.ABI) *ClerkProcessor
  • func (cp *ClerkProcessor) RegisterTasks()
  • func (cp *ClerkProcessor) Start() error
• type ContractCheckpoint
  • func NewContractCheckpoint(_newStart uint64, _newEnd uint64, _currentHeaderBlock *HeaderBlock) *ContractCheckpoint
  • func (c ContractCheckpoint) String() string
• type FeeProcessor
  • func NewFeeProcessor(stakingInfoAbi *abi.ABI) *FeeProcessor
  • func (fp *FeeProcessor) RegisterTasks()
  • func (fp *FeeProcessor) Start() error
• type HeaderBlock
• type MilestoneContext
• type MilestoneProcessor
  • func (mp *MilestoneProcessor) RegisterTasks()
  • func (mp *MilestoneProcessor) Start() error
  • func (mp *MilestoneProcessor) Stop()
• type Processor
• type ProcessorService
  • func NewProcessorService(cdc codec.Codec, queueConnector *queue.QueueConnector, ...) *ProcessorService
  • func (processorService *ProcessorService) OnStart() error
  • func (processorService *ProcessorService) OnStop()
• type SpanProcessor
  • func (sp *SpanProcessor) RegisterTasks()
  • func (sp *SpanProcessor) Start() error
  • func (sp *SpanProcessor) Stop()
• type StakingProcessor
  • func NewStakingProcessor(stakingInfoAbi *abi.ABI) *StakingProcessor
  • func (sp *StakingProcessor) RegisterTasks()
  • func (sp *StakingProcessor) Start() error

Functions

func Logger

func Logger(name string) log.Logger

Logger returns logger singleton instance

Types

type BaseProcessor

type BaseProcessor struct {
	Logger log.Logger
	// contains filtered or unexported fields
}

func NewBaseProcessor

func NewBaseProcessor(cdc codec.Codec, queueConnector *queue.QueueConnector, httpClient *rpchttp.HTTP, txBroadcaster *broadcaster.TxBroadcaster, name string, impl Processor) *BaseProcessor

NewBaseProcessor creates a new BaseProcessor.

func (*BaseProcessor) Stop

func (bp *BaseProcessor) Stop()

Stop stops all necessary go routines

func (*BaseProcessor) String

func (bp *BaseProcessor) String() string

String implements Service by returning a string representation of the service.

type CheckpointContext

type CheckpointContext struct {
	ChainmanagerParams *chainmanagertypes.Params
	CheckpointParams   *checkpointtypes.Params
}

CheckpointContext represents checkpoint context

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) 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 ClerkContext

type ClerkContext struct {
	ChainmanagerParams *chainmanagertypes.Params
}

ClerkContext for bridge

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 MilestoneContext

type MilestoneContext struct {
	ChainmanagerParams *chainmanagerTypes.Params
}

MilestoneContext represents milestone context

type MilestoneProcessor

type MilestoneProcessor struct {
	BaseProcessor
	// contains filtered or unexported fields
}

MilestoneProcessor - process milestone related events

func (*MilestoneProcessor) RegisterTasks

func (mp *MilestoneProcessor) RegisterTasks()

RegisterTasks - nil

func (*MilestoneProcessor) Start

func (mp *MilestoneProcessor) Start() error

Start starts new block subscription

func (*MilestoneProcessor) Stop

func (mp *MilestoneProcessor) Stop()

Stop stops all necessary go routines

type Processor

type Processor interface {
	Start() error

	RegisterTasks()

	String() string

	Stop()
}

Processor defines a block header listener for Rootchain, Borchain, Heimdall

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 *rpchttp.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 SpanProcessor

type SpanProcessor struct {
	BaseProcessor
	// contains filtered or unexported fields
}

SpanProcessor - process span related events

func (*SpanProcessor) RegisterTasks

func (sp *SpanProcessor) RegisterTasks()

RegisterTasks - nil

func (*SpanProcessor) Start

func (sp *SpanProcessor) Start() error

Start starts new block subscription

func (*SpanProcessor) Stop

func (sp *SpanProcessor) Stop()

Stop stops all necessary go routines

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