task

Documentation

Index

• func AtPushProcessor(n *notify.Notify) func(context.Context, *asynq.Task) error
• func FailedMsgProcessor(n *notify.Notify) func(context.Context, *asynq.Task) error
• func PrepareMsgProcessor(n *notify.Notify) func(context.Context, *asynq.Task) error
• func SuccessReceivedMsgProcessor(n *notify.Notify) func(context.Context, *asynq.Task) error
• func SuccessSentMsgProcessor(n *notify.Notify) func(context.Context, *asynq.Task) error
• func TgPushProcessor(n *notify.Notify) func(context.Context, *asynq.Task) error

Functions

func AtPushProcessor

func AtPushProcessor(n *notify.Notify) func(context.Context, *asynq.Task) error

func FailedMsgProcessor

func FailedMsgProcessor(n *notify.Notify) func(context.Context, *asynq.Task) error

func PrepareMsgProcessor

func PrepareMsgProcessor(n *notify.Notify) func(context.Context, *asynq.Task) error

PrepareMsgProcessor will determine which kind of message should be prepared for sending. It also supports cross custodial - non-custodial transfer notifications. It handles 4 scenarios: 1. Failed transfer from a Custodial user -> Custodial/Non-custodial user. 2. Custodial -> Custodial transfer. 3. Non-custodial -> Custodial transfer. 4. Custodial -> Non-custodial transfer.

func SuccessReceivedMsgProcessor

func SuccessReceivedMsgProcessor(n *notify.Notify) func(context.Context, *asynq.Task) error

func SuccessSentMsgProcessor

func SuccessSentMsgProcessor(n *notify.Notify) func(context.Context, *asynq.Task) error

func TgPushProcessor

func TgPushProcessor(n *notify.Notify) func(context.Context, *asynq.Task) error