processedblocks

Documentation

Index

• type ProcessedBlock
• type Service
  • func New(st store.IStore) *Service
  • func (s *Service) Create(ctx context.Context, blockchain wconstants.BlockchainType, number int64, ...) error
  • func (s *Service) LastBlock(ctx context.Context, blockchain wconstants.BlockchainType) (*ProcessedBlock, error)
  • func (s *Service) LastBlockNumber(ctx context.Context, blockchain wconstants.BlockchainType) (int64, error)
  • func (s *Service) UpdateNumber(ctx context.Context, blockchain wconstants.BlockchainType, number int64, ...) error
  • func (s *Service) UpdateNumberWithHash(ctx context.Context, blockchain wconstants.BlockchainType, number int64, ...) error

Types

type ProcessedBlock

type ProcessedBlock struct {
	Blockchain string     `json:"blockchain"`
	Number     int64      `json:"number"`
	Hash       string     `json:"hash"`
	CreatedAt  time.Time  `json:"created_at"`
	UpdatedAt  *time.Time `json:"updated_at"`
}

type Service

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

func New

func New(
	st store.IStore,
) *Service

func (*Service) Create

func (s *Service) Create(ctx context.Context, blockchain wconstants.BlockchainType, number int64, hash string, opts ...repos.Option) error

Create

func (*Service) LastBlock

func (s *Service) LastBlock(ctx context.Context, blockchain wconstants.BlockchainType) (*ProcessedBlock, error)

LastBlock returns the last block info including hash

func (*Service) LastBlockNumber

func (s *Service) LastBlockNumber(ctx context.Context, blockchain wconstants.BlockchainType) (int64, error)

LastBlockNumber

func (*Service) UpdateNumber

func (s *Service) UpdateNumber(ctx context.Context, blockchain wconstants.BlockchainType, number int64, opts ...repos.Option) error

UpdateNumber

func (*Service) UpdateNumberWithHash

func (s *Service) UpdateNumberWithHash(ctx context.Context, blockchain wconstants.BlockchainType, number int64, hash string, opts ...repos.Option) error

UpdateNumberWithHash