subscriber

Documentation

Index

• type BlockCache
  • func NewBlockCache(size int) *BlockCache
  • func (c BlockCache) GetOldestBlock(timetsamp uint64) (string, int64)
  • func (c BlockCache) PutBlockData(hash string, number int64, timestamp uint64)
• type BlockData
• type EthereumSubscriber
  • func NewEthereumSubscriber(chainId string, rpcUrl string, logger log.Logger) (*EthereumSubscriber, error)
  • func (sub *EthereumSubscriber) GetOldestBlock(timestamp uint64) (oracletypes.BlockData, error)
  • func (sub *EthereumSubscriber) Id() string
  • func (sub *EthereumSubscriber) OwnerOf(_ context.Context, nftAddressHex string, tokenIdHex string, blockHash string) (string, error)
  • func (sub *EthereumSubscriber) Start(ctx context.Context)
  • func (sub *EthereumSubscriber) Stop()
• type Subscriber
  • func InitSubscribers(config *config.Config, logger log.Logger) (subscribers []Subscriber, err error)
  • func NewSubscriber(config config.ChainConfig, logger log.Logger) (Subscriber, error)

Types

type BlockCache

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

func NewBlockCache

func NewBlockCache(size int) *BlockCache

func (BlockCache) GetOldestBlock

func (c BlockCache) GetOldestBlock(timetsamp uint64) (string, int64)

func (BlockCache) PutBlockData

func (c BlockCache) PutBlockData(hash string, number int64, timestamp uint64)

type BlockData

type BlockData struct {
	Hash   string
	Number int64
}

type EthereumSubscriber

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

func NewEthereumSubscriber

func NewEthereumSubscriber(chainId string, rpcUrl string, logger log.Logger) (*EthereumSubscriber, error)

func (*EthereumSubscriber) GetOldestBlock

func (sub *EthereumSubscriber) GetOldestBlock(timestamp uint64) (oracletypes.BlockData, error)

GetOldestBlock returns the latest block data

func (*EthereumSubscriber) Id

func (sub *EthereumSubscriber) Id() string

func (*EthereumSubscriber) OwnerOf

func (sub *EthereumSubscriber) OwnerOf(_ context.Context, nftAddressHex string, tokenIdHex string, blockHash string) (string, error)

OwnerOf returns the owner of the given NFT

func (*EthereumSubscriber) Start

func (sub *EthereumSubscriber) Start(ctx context.Context)

func (*EthereumSubscriber) Stop

func (sub *EthereumSubscriber) Stop()

type Subscriber

type Subscriber interface {
	Id() string
	Start(ctx context.Context)
	Stop()
	GetOldestBlock(timestamp uint64) (oracletypes.BlockData, error)
	OwnerOf(ctx context.Context, nftAddressHex string, tokenIdHex string, blockHash string) (string, error)
}

func InitSubscribers

func InitSubscribers(config *config.Config, logger log.Logger) (subscribers []Subscriber, err error)

func NewSubscriber

func NewSubscriber(config config.ChainConfig, logger log.Logger) (Subscriber, error)