mock

Documentation

Index

• Variables
• type EventRepository
  • func NewEventRepository() *EventRepository
  • func (r *EventRepository) Delete(ctx context.Context, id int) error
  • func (r *EventRepository) FindByEventTypeAndBlockID(ctx context.Context, eventType string, blockID int64) (*eventindexer.Event, error)
  • func (r *EventRepository) FindUniqueProposers(ctx context.Context) ([]eventindexer.UniqueProposersResponse, error)
  • func (r *EventRepository) FindUniqueProvers(ctx context.Context) ([]eventindexer.UniqueProversResponse, error)
  • func (r *EventRepository) FirstByAddressAndEventName(ctx context.Context, address string, event string) (*eventindexer.Event, error)
  • func (r *EventRepository) GetAssignedBlocksByProverAddress(ctx context.Context, req *http.Request, address string) (paginate.Page, error)
  • func (r *EventRepository) GetByAddressAndEventName(ctx context.Context, req *http.Request, address string, event string) (paginate.Page, error)
  • func (r *EventRepository) GetCountByAddressAndEventName(ctx context.Context, address string, event string) (int, error)
  • func (r *EventRepository) GetTotalSlashedTokens(ctx context.Context) (*big.Int, error)
  • func (r *EventRepository) Save(ctx context.Context, opts eventindexer.SaveEventOpts) (*eventindexer.Event, error)
• type NFTBalanceRepository
  • func NewNFTBalanceRepository() *NFTBalanceRepository
  • func (r *NFTBalanceRepository) FindByAddress(ctx context.Context, req *http.Request, address string, chainID string) (paginate.Page, error)
  • func (r *NFTBalanceRepository) IncreaseBalance(ctx context.Context, opts eventindexer.UpdateNFTBalanceOpts) (*eventindexer.NFTBalance, error)
  • func (r *NFTBalanceRepository) SubtractBalance(ctx context.Context, opts eventindexer.UpdateNFTBalanceOpts) (*eventindexer.NFTBalance, error)
• type ProcessedBlockRepository
  • func (r *ProcessedBlockRepository) GetLatestBlockProcessedForEvent(chainID *big.Int) (*eventindexer.ProcessedBlock, error)
  • func (r *ProcessedBlockRepository) Save(opts eventindexer.SaveProcessedBlockOpts) error
• type StatRepository
  • func NewStatRepository() *StatRepository
  • func (r *StatRepository) Find(ctx context.Context, statType string, feeTokenAddress *string) (*eventindexer.Stat, error)
  • func (r *StatRepository) FindAll(ctx context.Context) ([]*eventindexer.Stat, error)
  • func (r *StatRepository) Save(ctx context.Context, opts eventindexer.SaveStatOpts) (*eventindexer.Stat, error)

Variables

var (
	MockChainID       = big.NewInt(167001)
	LatestBlockNumber = big.NewInt(10)
)

var (
	LatestBlock = &eventindexer.ProcessedBlock{
		Height:  100,
		Hash:    "0x",
		ChainID: MockChainID.Int64(),
	}
)

Types

type EventRepository

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

func NewEventRepository

func NewEventRepository() *EventRepository

func (*EventRepository) Delete

func (r *EventRepository) Delete(
	ctx context.Context,
	id int,
) error

func (*EventRepository) FindByEventTypeAndBlockID

func (r *EventRepository) FindByEventTypeAndBlockID(
	ctx context.Context,
	eventType string,
	blockID int64) (*eventindexer.Event, error)

func (*EventRepository) FindUniqueProposers

func (r *EventRepository) FindUniqueProposers(
	ctx context.Context,
) ([]eventindexer.UniqueProposersResponse, error)

func (*EventRepository) FindUniqueProvers

func (r *EventRepository) FindUniqueProvers(
	ctx context.Context,
) ([]eventindexer.UniqueProversResponse, error)

func (*EventRepository) FirstByAddressAndEventName

func (r *EventRepository) FirstByAddressAndEventName(
	ctx context.Context,
	address string,
	event string,
) (*eventindexer.Event, error)

func (*EventRepository) GetAssignedBlocksByProverAddress

func (r *EventRepository) GetAssignedBlocksByProverAddress(
	ctx context.Context,
	req *http.Request,
	address string,
) (paginate.Page, error)

func (*EventRepository) GetByAddressAndEventName

func (r *EventRepository) GetByAddressAndEventName(
	ctx context.Context,
	req *http.Request,
	address string,
	event string,
) (paginate.Page, error)

func (*EventRepository) GetCountByAddressAndEventName

func (r *EventRepository) GetCountByAddressAndEventName(
	ctx context.Context,
	address string,
	event string,
) (int, error)

func (*EventRepository) GetTotalSlashedTokens

func (r *EventRepository) GetTotalSlashedTokens(
	ctx context.Context,
) (*big.Int, error)

func (*EventRepository) Save

func (r *EventRepository) Save(ctx context.Context, opts eventindexer.SaveEventOpts) (*eventindexer.Event, error)

type NFTBalanceRepository

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

func NewNFTBalanceRepository

func NewNFTBalanceRepository() *NFTBalanceRepository

func (*NFTBalanceRepository) FindByAddress

func (r *NFTBalanceRepository) FindByAddress(ctx context.Context,
	req *http.Request,
	address string,
	chainID string,
) (paginate.Page, error)

func (*NFTBalanceRepository) IncreaseBalance

func (r *NFTBalanceRepository) IncreaseBalance(
	ctx context.Context,
	opts eventindexer.UpdateNFTBalanceOpts,
) (*eventindexer.NFTBalance, error)

func (*NFTBalanceRepository) SubtractBalance

func (r *NFTBalanceRepository) SubtractBalance(
	ctx context.Context,
	opts eventindexer.UpdateNFTBalanceOpts,
) (*eventindexer.NFTBalance, error)

type ProcessedBlockRepository

type ProcessedBlockRepository struct {
}

func (*ProcessedBlockRepository) GetLatestBlockProcessedForEvent

func (r *ProcessedBlockRepository) GetLatestBlockProcessedForEvent(
	chainID *big.Int,
) (*eventindexer.ProcessedBlock, error)

func (*ProcessedBlockRepository) Save

func (r *ProcessedBlockRepository) Save(opts eventindexer.SaveProcessedBlockOpts) error

type StatRepository

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

func NewStatRepository

func NewStatRepository() *StatRepository

func (*StatRepository) Find

func (r *StatRepository) Find(
	ctx context.Context,
	statType string,
	feeTokenAddress *string,
) (*eventindexer.Stat, error)

func (*StatRepository) FindAll

func (r *StatRepository) FindAll(
	ctx context.Context,
) ([]*eventindexer.Stat, error)

FindAll finds each type of unique stat and merges them together

func (*StatRepository) Save

func (r *StatRepository) Save(ctx context.Context, opts eventindexer.SaveStatOpts) (*eventindexer.Stat, error)