Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CosmosChainProcessor ¶
type CosmosChainProcessor struct {
// contains filtered or unexported fields
}
func NewCosmosChainProcessor ¶
func NewCosmosChainProcessor(log *zap.Logger, provider *cosmos.CosmosProvider) *CosmosChainProcessor
func (*CosmosChainProcessor) Provider ¶
func (ccp *CosmosChainProcessor) Provider() provider.ChainProvider
Provider returns the ChainProvider, which provides the methods for querying, assembling IBC messages, and sending transactions.
func (*CosmosChainProcessor) Run ¶
func (ccp *CosmosChainProcessor) Run(ctx context.Context, initialBlockHistory uint64) error
Run starts the query loop for the chain which will gather applicable ibc messages and push events out to the relevant PathProcessors. The initialBlockHistory parameter determines how many historical blocks should be fetched and processed before continuing with current blocks. ChainProcessors should obey the context and return upon context cancellation.
func (*CosmosChainProcessor) SetPathProcessors ¶
func (ccp *CosmosChainProcessor) SetPathProcessors(pathProcessors processor.PathProcessors)
Set the PathProcessors that this ChainProcessor should publish relevant IBC events to. ChainProcessors need reference to their PathProcessors and vice-versa, handled by EventProcessorBuilder.Build().
Source Files
Click to show internal directories.
Click to hide internal directories.