mempooltx

Documentation

Index

• type MempoolTransactionCreateUseCase
  • func NewMempoolTransactionCreateUseCase(config *config.Configuration, logger *slog.Logger, ...) MempoolTransactionCreateUseCase
• type MempoolTransactionDeleteByIDUseCase
  • func NewMempoolTransactionDeleteByIDUseCase(config *config.Configuration, logger *slog.Logger, ...) MempoolTransactionDeleteByIDUseCase
• type MempoolTransactionInsertionDetectorUseCase
  • func NewMempoolTransactionInsertionDetectorUseCase(config *config.Configuration, logger *slog.Logger, ...) MempoolTransactionInsertionDetectorUseCase
• type MempoolTransactionListByChainIDUseCase
  • func NewMempoolTransactionListByChainIDUseCase(config *config.Configuration, logger *slog.Logger, ...) MempoolTransactionListByChainIDUseCase

Types

type MempoolTransactionCreateUseCase

type MempoolTransactionCreateUseCase interface {
	Execute(ctx context.Context, mempoolTx *domain.MempoolTransaction) error
}

func NewMempoolTransactionCreateUseCase

func NewMempoolTransactionCreateUseCase(config *config.Configuration, logger *slog.Logger, repo domain.MempoolTransactionRepository) MempoolTransactionCreateUseCase

type MempoolTransactionDeleteByIDUseCase

type MempoolTransactionDeleteByIDUseCase interface {
	Execute(ctx context.Context, id primitive.ObjectID) error
}

func NewMempoolTransactionDeleteByIDUseCase

func NewMempoolTransactionDeleteByIDUseCase(config *config.Configuration, logger *slog.Logger, repo domain.MempoolTransactionRepository) MempoolTransactionDeleteByIDUseCase

type MempoolTransactionInsertionDetectorUseCase

type MempoolTransactionInsertionDetectorUseCase interface {
	Execute(ctx context.Context) (*domain.MempoolTransaction, error)
	Terminate()
}

func NewMempoolTransactionInsertionDetectorUseCase

func NewMempoolTransactionInsertionDetectorUseCase(config *config.Configuration, logger *slog.Logger, repo domain.MempoolTransactionRepository) MempoolTransactionInsertionDetectorUseCase

type MempoolTransactionListByChainIDUseCase

type MempoolTransactionListByChainIDUseCase interface {
	Execute(ctx context.Context, chainID uint16) ([]*domain.MempoolTransaction, error)
}

func NewMempoolTransactionListByChainIDUseCase

func NewMempoolTransactionListByChainIDUseCase(config *config.Configuration, logger *slog.Logger, repo domain.MempoolTransactionRepository) MempoolTransactionListByChainIDUseCase