Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TransferProcessor ¶
type TransferProcessor struct { *processorCommon.BaseProcessor *cosmos.CosmosClient // contains filtered or unexported fields }
func NewTransferProcessor ¶
func NewTransferProcessor(cfg TransferProcessorConfig, cosmosClient *cosmos.CosmosClient, db *store.Store, log logger.Logger, ) (*TransferProcessor, error)
func (*TransferProcessor) Process ¶
func (p *TransferProcessor) Process(_ context.Context, receipt *sdk.TxResponse) error
func (*TransferProcessor) Queue ¶
func (p *TransferProcessor) Queue(msg interface{})
func (*TransferProcessor) Start ¶
func (p *TransferProcessor) Start(ctx context.Context)
type TransferProcessorConfig ¶
type TransferProcessorConfig struct {
common.BaseConfig
}
func DefaultConfig ¶
func DefaultConfig() TransferProcessorConfig
func (TransferProcessorConfig) IsValid ¶
func (cfg TransferProcessorConfig) IsValid() (bool, error)
Click to show internal directories.
Click to hide internal directories.