subscriber

package

v0.2.0 Latest Latest Go to latest Published: Apr 16, 2024 License: LGPL-3.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/settlus/chain

Links

Open Source Insights

Documentation ¶

Index ¶

type EthereumSubscriber
- func NewEthereumSubscriber(chainId string, rpcUrl string, logger log.Logger, repo repository.Repository) (*EthereumSubscriber, error)
type Subscriber
- func InitSubscribers(config *config.Config, logger log.Logger) (subscribers []Subscriber, err error)
- func NewSubscriber(config config.ChainConfig, logger log.Logger, repo repository.Repository) (Subscriber, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type EthereumSubscriber ¶

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

func NewEthereumSubscriber ¶

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

func (*EthereumSubscriber) GetOldestBlock ¶ added in v0.0.6

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, repo repository.Repository) (Subscriber, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL