handler

Documentation

Index

• func CalculateLostBond(ctx *svc.ServiceContext)
• func HandlePendingBlock(ctx *svc.ServiceContext, block schema.SyncBlock) error
• func HandlePendingEvent(ctx *svc.ServiceContext, event schema.SyncEvent) error
• func HandleRollbackBlock(ctx *svc.ServiceContext, block schema.SyncBlock) error
• func HandleRollbackEvent(ctx *svc.ServiceContext, event schema.SyncEvent) error
• func LatestBlackNumber(ctx *svc.ServiceContext)
• func LogFilter(ctx *svc.ServiceContext, block schema.SyncBlock, addresses []common.Address, ...) ([]*schema.SyncEvent, error)
• func LogsToEvents(ctx *svc.ServiceContext, logs []types.Log, syncBlockID int64) ([]*schema.SyncEvent, error)
• func Run(ctx *svc.ServiceContext)
• func SyncBlock(ctx *svc.ServiceContext)
• func SyncClaimDataLen(ctx *svc.ServiceContext)
• func SyncCredit(ctx *svc.ServiceContext)
• func SyncDispute(ctx *svc.ServiceContext)
• func SyncEvent(ctx *svc.ServiceContext)
• type RetryDisputeGameClient
  • func NewRetryDisputeGameClient(db *gorm.DB, address common.Address, rpc *ethclient.Client, limit rate.Limit, ...) (*RetryDisputeGameClient, error)
  • func (r *RetryDisputeGameClient) GetAllAddress(disputeGame *common.Address) (map[string]bool, error)
  • func (r *RetryDisputeGameClient) GetCredit(ctx context.Context, address common.Address) (*big.Int, error)
  • func (r *RetryDisputeGameClient) ProcessDisputeGameCreated(ctx context.Context, evt schema.SyncEvent) error
  • func (r *RetryDisputeGameClient) ProcessDisputeGameCredit(ctx context.Context) error
  • func (r *RetryDisputeGameClient) ProcessDisputeGameMove(ctx context.Context, evt schema.SyncEvent) error
  • func (r *RetryDisputeGameClient) ProcessDisputeGameResolve(evt schema.SyncEvent) error

Functions

func CalculateLostBond

func CalculateLostBond(ctx *svc.ServiceContext)

func HandlePendingBlock

func HandlePendingBlock(ctx *svc.ServiceContext, block schema.SyncBlock) error

func HandlePendingEvent

func HandlePendingEvent(ctx *svc.ServiceContext, event schema.SyncEvent) error

func HandleRollbackBlock

func HandleRollbackBlock(ctx *svc.ServiceContext, block schema.SyncBlock) error

func HandleRollbackEvent

func HandleRollbackEvent(ctx *svc.ServiceContext, event schema.SyncEvent) error

func LatestBlackNumber

func LatestBlackNumber(ctx *svc.ServiceContext)

func LogFilter

func LogFilter(ctx *svc.ServiceContext, block schema.SyncBlock, addresses []common.Address, topics [][]common.Hash) ([]*schema.SyncEvent, error)

func LogsToEvents

func LogsToEvents(ctx *svc.ServiceContext, logs []types.Log, syncBlockID int64) ([]*schema.SyncEvent, error)

func Run

func Run(ctx *svc.ServiceContext)

func SyncBlock

func SyncBlock(ctx *svc.ServiceContext)

func SyncClaimDataLen

func SyncClaimDataLen(ctx *svc.ServiceContext)

SyncClaimDataLen Compensation processing historical data

func SyncCredit

func SyncCredit(ctx *svc.ServiceContext)

func SyncDispute

func SyncDispute(ctx *svc.ServiceContext)

func SyncEvent

func SyncEvent(ctx *svc.ServiceContext)

Types

type RetryDisputeGameClient

type RetryDisputeGameClient struct {
	Client             *contract.RateAndRetryDisputeGameClient
	DB                 *gorm.DB
	DisputeGameAddress common.Address
}

func NewRetryDisputeGameClient

func NewRetryDisputeGameClient(db *gorm.DB, address common.Address, rpc *ethclient.Client, limit rate.Limit,
	burst int,
) (*RetryDisputeGameClient, error)

func (*RetryDisputeGameClient) GetAllAddress

func (r *RetryDisputeGameClient) GetAllAddress(disputeGame *common.Address) (map[string]bool, error)

func (*RetryDisputeGameClient) GetCredit

func (r *RetryDisputeGameClient) GetCredit(ctx context.Context, address common.Address) (*big.Int, error)

func (*RetryDisputeGameClient) ProcessDisputeGameCreated

func (r *RetryDisputeGameClient) ProcessDisputeGameCreated(ctx context.Context, evt schema.SyncEvent) error

func (*RetryDisputeGameClient) ProcessDisputeGameCredit

func (r *RetryDisputeGameClient) ProcessDisputeGameCredit(ctx context.Context) error

func (*RetryDisputeGameClient) ProcessDisputeGameMove

func (r *RetryDisputeGameClient) ProcessDisputeGameMove(ctx context.Context, evt schema.SyncEvent) error

func (*RetryDisputeGameClient) ProcessDisputeGameResolve

func (r *RetryDisputeGameClient) ProcessDisputeGameResolve(evt schema.SyncEvent) error