Versions in this module Expand all Collapse all v1 v1.0.0 Oct 23, 2023 Changes in this version + type ApprovalOpMsg struct + OperationID string + OperationType string + TransactionHash string + func (m ApprovalOpMsg) Message() Message + type BlockRangeMessage struct + End int64 + Start int64 + func (br BlockRangeMessage) Message() Message + type CollectionCreatedMessage struct + Index string + func (m CollectionCreatedMessage) Message() Message + type CollectionDataCreatedMessage struct + Chain string + CollectionIndex string + func (m CollectionDataCreatedMessage) Message() Message + type CollectionDataRemovedMessage struct + Chain string + CollectionIndex string + func (m CollectionDataRemovedMessage) Message() Message + type CollectionDataUpdatedMessage struct + Chain string + CollectionIndex string + func (m CollectionDataUpdatedMessage) Message() Message + type CollectionRemovedMessage struct + Index string + func (m CollectionRemovedMessage) Message() Message + type ConfirmationOpMsg struct + ConfirmationID string + TransactionHash string + func (m ConfirmationOpMsg) Message() Message + type Consumer struct + func NewConsumer(log *logan.Entry, cfg ConsumerConfig, handler Handler) *Consumer + func (c *Consumer) Run(ctx context.Context) + type ConsumerConfig struct + MaxRetryPeriod time.Duration + MinRetryPeriod time.Duration + Name string + PollDuration time.Duration + PrefetchLimit int64 + Queue string + RedisClient *redis.Client + RetryConsumeAttempts uint64 + type Consumerer interface + Consumer func() ConsumerConfig + func NewConsumerer(getter kv.Getter, name string, opts ConsumererOpts) Consumerer + type ConsumererOpts struct + RedisClient *redis.Client + type Handler interface + Handle func(ctx context.Context, msgs []Message) error + type ItemCreatedMessage struct + Index string + func (m ItemCreatedMessage) Message() Message + type ItemOnChainDataCreatedMessage struct + Chain string + ItemIndex string + func (m ItemOnChainDataCreatedMessage) Message() Message + type ItemOnChainDataRemovedMessage struct + Chain string + ItemIndex string + func (m ItemOnChainDataRemovedMessage) Message() Message + type ItemRemovedMessage struct + Index string + func (m ItemRemovedMessage) Message() Message + type Message struct + func (m *Message) MustApprovalOpMessage() (msg ApprovalOpMsg) + func (m *Message) MustBlockRangeMessage() (msg BlockRangeMessage) + func (m *Message) MustCollectionCreatedMessage() (msg CollectionCreatedMessage) + func (m *Message) MustCollectionDataCreatedMessage() (msg CollectionDataCreatedMessage) + func (m *Message) MustCollectionDataRemovedMessage() (msg CollectionDataRemovedMessage) + func (m *Message) MustCollectionDataUpdatedMessage() (msg CollectionDataUpdatedMessage) + func (m *Message) MustCollectionRemovedMessage() (msg CollectionRemovedMessage) + func (m *Message) MustConfirmationOpMessage() (msg ConfirmationOpMsg) + func (m *Message) MustItemCreatedMessage() (msg ItemCreatedMessage) + func (m *Message) MustItemOnChainDataCreatedMessage() (msg ItemOnChainDataCreatedMessage) + func (m *Message) MustItemOnChainDataRemovedMessage() (msg ItemOnChainDataRemovedMessage) + func (m *Message) MustItemRemovedMessage() (msg ItemRemovedMessage) + func (m *Message) MustRejectionOpMessage() (msg RejectionOpMsg) + func (m *Message) MustSeedCreatedMessage() (msg SeedCreatedMessage) + func (m *Message) MustSeedRemovedMessage() (msg SeedRemovedMessage) + func (m *Message) MustTransferOpMessage() (msg TransferOpMsg) + func (m *Message) MustVoteOpMessage() (msg VoteOpMsg) + func (m *Message) Type() MessageType + func (m Message) String() string + type MessageType string + const MessageTypeApprovalOp + const MessageTypeBlockRange + const MessageTypeCollectionCreated + const MessageTypeCollectionDataCreated + const MessageTypeCollectionDataRemoved + const MessageTypeCollectionDataUpdated + const MessageTypeCollectionRemoved + const MessageTypeConfirmationOp + const MessageTypeItemCreated + const MessageTypeItemOnChainDataCreated + const MessageTypeItemOnChainDataRemoved + const MessageTypeItemRemoved + const MessageTypeRejectionOp + const MessageTypeSeedCreated + const MessageTypeSeedRemoved + const MessageTypeTransferOp + const MessageTypeVoteOp + type MultiPublisher struct + func (m *MultiPublisher) PublishMsgs(ctx context.Context, msgs ...Message) error + type Publisher struct + func NewPublisher(log *logan.Entry, redisClient *redis.Client, tag, queueName string) (*Publisher, error) + func (p *Publisher) PublishMsgs(ctx context.Context, msgs ...Message) error + type RejectionOpMsg struct + OperationID string + OperationType string + TransactionHash string + func (m RejectionOpMsg) Message() Message + type SeedCreatedMessage struct + ItemIndex string + Seed string + TxHash string + func (m SeedCreatedMessage) Message() Message + type SeedRemovedMessage struct + ItemIndex string + Seed string + TxHash string + func (m SeedRemovedMessage) Message() Message + type TransferOpMsg struct + TransactionHash string + TransferID string + func (m TransferOpMsg) Message() Message + type VoteOpMsg struct + OperationID string + OperationType string + TransactionHash string + VotingChoice string + func (m VoteOpMsg) Message() Message
Go to main page