txfeeder

Documentation

Index

• type ApprovalHandlers
• type LogsHandler
• type SwapAndSyncHandlers
• type SwapHandlers
• type SyncHandlers
• type TransferHandlers
• type TxFeeder
  • func New(client *ethclient.Client) *TxFeeder
  • func (t *TxFeeder) AddApprovalLogsHandler(ctx context.Context, eventFilter ethereum.FilterQuery, ...) error
  • func (t *TxFeeder) AddLogsListenr(ctx context.Context, eventFilter ethereum.FilterQuery, handler LogsHandler) error
  • func (t *TxFeeder) AddSwapAndSyncLogsHandler(ctx context.Context, eventFilter ethereum.FilterQuery, ...) error
  • func (t *TxFeeder) AddSwapLogsHandler(ctx context.Context, eventFilter ethereum.FilterQuery, handler SwapHandlers) error
  • func (t *TxFeeder) AddSyncLogsHandler(ctx context.Context, eventFilter ethereum.FilterQuery, handler SyncHandlers) error
  • func (t *TxFeeder) AddTransferLogsHandler(ctx context.Context, eventFilter ethereum.FilterQuery, ...) error
  • func (t *TxFeeder) Close() error
  • func (t *TxFeeder) IsRunning() bool
  • func (t *TxFeeder) Run() error

Types

type ApprovalHandlers

type ApprovalHandlers func(*contract.TokenApproval) error

type LogsHandler

type LogsHandler func(types.Log) error

type SwapAndSyncHandlers

type SwapAndSyncHandlers struct {
	SwapHandler SwapHandlers
	SyncHandler SyncHandlers
}

type SwapHandlers

type SwapHandlers func(*contract.PairSwap) error

type SyncHandlers

type SyncHandlers func(*contract.PairSync) error

type TransferHandlers

type TransferHandlers func(*contract.TokenTransfer) error

type TxFeeder

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

func New

func New(client *ethclient.Client) *TxFeeder

func (*TxFeeder) AddApprovalLogsHandler

func (t *TxFeeder) AddApprovalLogsHandler(ctx context.Context, eventFilter ethereum.FilterQuery, handler ApprovalHandlers) error

func (*TxFeeder) AddLogsListenr

func (t *TxFeeder) AddLogsListenr(ctx context.Context, eventFilter ethereum.FilterQuery, handler LogsHandler) error

func (*TxFeeder) AddSwapAndSyncLogsHandler

func (t *TxFeeder) AddSwapAndSyncLogsHandler(ctx context.Context, eventFilter ethereum.FilterQuery, handlers *SwapAndSyncHandlers) error

func (*TxFeeder) AddSwapLogsHandler

func (t *TxFeeder) AddSwapLogsHandler(ctx context.Context, eventFilter ethereum.FilterQuery, handler SwapHandlers) error

func (*TxFeeder) AddSyncLogsHandler

func (t *TxFeeder) AddSyncLogsHandler(ctx context.Context, eventFilter ethereum.FilterQuery, handler SyncHandlers) error

func (*TxFeeder) AddTransferLogsHandler

func (t *TxFeeder) AddTransferLogsHandler(ctx context.Context, eventFilter ethereum.FilterQuery, handler TransferHandlers) error

func (*TxFeeder) Close

func (t *TxFeeder) Close() error

func (*TxFeeder) IsRunning

func (t *TxFeeder) IsRunning() bool

func (*TxFeeder) Run

func (t *TxFeeder) Run() error