common

Documentation

Index

• func FormatTxURL(txHash string) string
• func MustGetEvmTxSender(tx *types.Transaction) string
• type BaseProcessor
  • func (p *BaseProcessor) IsTxProcessed(txHashStr string) bool
  • func (p *BaseProcessor) ParseAccountDetail(addr string) string
  • func (p *BaseProcessor) SetWebHookManager(manager webhook.WebHookManager)
• type MsgFormatter
  • func (f *MsgFormatter) FormatKeyValueMsg(key string, value interface{}) *MsgFormatter
  • func (f *MsgFormatter) FormatMsg(msg string) *MsgFormatter
  • func (f *MsgFormatter) FormatTitle(title string) *MsgFormatter
  • func (f *MsgFormatter) String() string
• type Processor
• type TxMsg

Functions

func FormatTxURL

func FormatTxURL(txHash string) string

func MustGetEvmTxSender

func MustGetEvmTxSender(tx *types.Transaction) string

Types

type BaseProcessor

type BaseProcessor struct {
	Db  *store.Store
	Whm webhook.WebHookManager
	Log logger.Logger
	Mtx *sync.Mutex
}

func (*BaseProcessor) IsTxProcessed

func (p *BaseProcessor) IsTxProcessed(txHashStr string) bool

func (*BaseProcessor) ParseAccountDetail

func (p *BaseProcessor) ParseAccountDetail(addr string) string

func (*BaseProcessor) SetWebHookManager

func (p *BaseProcessor) SetWebHookManager(manager webhook.WebHookManager)

type MsgFormatter

type MsgFormatter struct {
	// contains filtered or unexported fields
}

func (*MsgFormatter) FormatKeyValueMsg

func (f *MsgFormatter) FormatKeyValueMsg(key string, value interface{}) *MsgFormatter

func (*MsgFormatter) FormatMsg

func (f *MsgFormatter) FormatMsg(msg string) *MsgFormatter

func (*MsgFormatter) FormatTitle

func (f *MsgFormatter) FormatTitle(title string) *MsgFormatter

func (*MsgFormatter) String

func (f *MsgFormatter) String() string

type Processor

type Processor interface {
	Queue(interface{})
	Start(context.Context)
	SetWebHookManager(manager webhook.WebHookManager)
}

type TxMsg

type TxMsg struct {
	From      string
	To        string
	Amount    string
	Token     string
	TokenName string
	TxHash    string
}