worker

Documentation

Index

• Constants
• Variables
• func StringToBigInt(numberString string) (*big.Int, error)
• type AccountCreateArgs
  • func (AccountCreateArgs) Kind() string
• type AccountCreateWorker
  • func (w *AccountCreateWorker) Work(ctx context.Context, job *river.Job[AccountCreateArgs]) error
• type DispatchArgs
  • func (DispatchArgs) Kind() string
• type DispatchError
  • func (e *DispatchError) Error() string
  • func (e *DispatchError) Unwrap() error
• type DisptachWorker
  • func (w *DisptachWorker) Work(ctx context.Context, job *river.Job[DispatchArgs]) error
• type TokenTransferArgs
  • func (TokenTransferArgs) Kind() string
• type TokenTransferWorker
  • func (w *TokenTransferWorker) Work(ctx context.Context, job *river.Job[TokenTransferArgs]) error
• type WorkerContainer
  • func New(o WorkerOpts) (*WorkerContainer, error)
  • func (w *WorkerContainer) Start(ctx context.Context) error
  • func (w *WorkerContainer) Stop(ctx context.Context) error
• type WorkerOpts

Constants

const (
	Approve      = "approve"
	Check        = "check"
	GiveTo       = "giveTo"
	MintTo       = "mintTo"
	NextTime     = "nextTime"
	Register     = "register"
	Transfer     = "transfer"
	TransferFrom = "transferFrom"
)

const AccountCreateID = "ACCOUNT_CREATE"

const DispatchID = "DISPATCH"

Variables

var (
	ErrInsufficientGas          = errors.New("eth-custodial: insufficient gas")
	ErrGasPriceTooLow           = errors.New("eth-custodial: gas price too low")
	ErrNonceTooLow              = errors.New("eth-custodial: nonce too low")
	ErrReplacementTxUnderpriced = errors.New("eth-custodial: replacement tx underpriced")
	ErrNetwork                  = errors.New("eth-custodial: network related error")
)

var ErrInvalidNumberString = errors.New("invalid number string")

Functions

func StringToBigInt

func StringToBigInt(numberString string) (*big.Int, error)

Types

type AccountCreateArgs

type AccountCreateArgs struct {
	TrackingID string      `json:"trackingId"`
	KeyPair    keypair.Key `json:"keypair"`
}

func (AccountCreateArgs) Kind

func (AccountCreateArgs) Kind() string

type AccountCreateWorker

type AccountCreateWorker struct {
	river.WorkerDefaults[AccountCreateArgs]
	// contains filtered or unexported fields
}

func (*AccountCreateWorker) Work

func (w *AccountCreateWorker) Work(ctx context.Context, job *river.Job[AccountCreateArgs]) error

type DispatchArgs

type DispatchArgs struct {
	TrackingID string `json:"trackingId"`
	OTXID      uint64 `json:"otxId"`
	RawTx      string `json:"rawTx"`
}

func (DispatchArgs) Kind

func (DispatchArgs) Kind() string

type DispatchError

type DispatchError struct {
	Err         error
	OriginalErr error
}

func (*DispatchError) Error

func (e *DispatchError) Error() string

func (*DispatchError) Unwrap

func (e *DispatchError) Unwrap() error

type DisptachWorker

type DisptachWorker struct {
	river.WorkerDefaults[DispatchArgs]
	// contains filtered or unexported fields
}

func (*DisptachWorker) Work

func (w *DisptachWorker) Work(ctx context.Context, job *river.Job[DispatchArgs]) error

type TokenTransferArgs

type TokenTransferArgs struct {
	TrackingID   string `json:"trackingId"`
	From         string `json:"from"`
	To           string `json:"to"`
	TokenAddress string `json:"tokenAddress"`
	Amount       string `json:"amount"`
}

func (TokenTransferArgs) Kind

func (TokenTransferArgs) Kind() string

type TokenTransferWorker

type TokenTransferWorker struct {
	river.WorkerDefaults[TokenTransferArgs]
	// contains filtered or unexported fields
}

func (*TokenTransferWorker) Work

func (w *TokenTransferWorker) Work(ctx context.Context, job *river.Job[TokenTransferArgs]) error

type WorkerContainer

type WorkerContainer struct {
	GasOracle     gas.GasOracle
	Store         store.Store
	Logg          *slog.Logger
	ChainProvider *ethutils.Provider
	QueueClient   *river.Client[pgx.Tx]
}

func New

func New(o WorkerOpts) (*WorkerContainer, error)

func (*WorkerContainer) Start

func (w *WorkerContainer) Start(ctx context.Context) error

func (*WorkerContainer) Stop

func (w *WorkerContainer) Stop(ctx context.Context) error

type WorkerOpts

type WorkerOpts struct {
	MaxWorkers int
	ChainID    int64
	GasOracle  gas.GasOracle
	Store      store.Store
	Logg       *slog.Logger
}