Documentation
¶
Index ¶
- type QueueManager
- func (qc *QueueManager) PushExpiryEvent(ev *client.ExpiredStakingEvent) error
- func (qc *QueueManager) PushStakingEvent(ev *client.ActiveStakingEvent) error
- func (qc *QueueManager) PushUnbondingEvent(ev *client.UnbondingStakingEvent) error
- func (qc *QueueManager) PushWithdrawEvent(ev *client.WithdrawStakingEvent) error
- func (qc *QueueManager) ReQueueMessage(ctx context.Context, message client.QueueMessage, queueName string) error
- func (qc *QueueManager) Start() error
- func (qc *QueueManager) Stop() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type QueueManager ¶
type QueueManager struct {
StakingQueue client.QueueClient
UnbondingQueue client.QueueClient
WithdrawQueue client.QueueClient
ExpiryQueue client.QueueClient
// contains filtered or unexported fields
}
func NewQueueManager ¶
func NewQueueManager(cfg *config.QueueConfig, logger *zap.Logger) (*QueueManager, error)
func (*QueueManager) PushExpiryEvent ¶
func (qc *QueueManager) PushExpiryEvent(ev *client.ExpiredStakingEvent) error
func (*QueueManager) PushStakingEvent ¶
func (qc *QueueManager) PushStakingEvent(ev *client.ActiveStakingEvent) error
func (*QueueManager) PushUnbondingEvent ¶
func (qc *QueueManager) PushUnbondingEvent(ev *client.UnbondingStakingEvent) error
func (*QueueManager) PushWithdrawEvent ¶
func (qc *QueueManager) PushWithdrawEvent(ev *client.WithdrawStakingEvent) error
func (*QueueManager) ReQueueMessage ¶
func (qc *QueueManager) ReQueueMessage(ctx context.Context, message client.QueueMessage, queueName string) error
requeue message
func (*QueueManager) Start ¶
func (qc *QueueManager) Start() error
func (*QueueManager) Stop ¶
func (qc *QueueManager) Stop() error
Source Files
Click to show internal directories.
Click to hide internal directories.