tools

Documentation

Index

• func WrapWithTimeout(lotusFunc LotusRPCWrapper, timeout time.Duration) error
• type Cache
  • func (m *Cache) GetActorCode(address address.Address) (cid.Cid, error)
  • func (m *Cache) GetActorPubKey(address address.Address, reverse bool) (string, error)
  • func (m *Cache) NewImpl(node *api.FullNode)
• type Database
• type LotusRPCWrapper

Functions

func WrapWithTimeout

func WrapWithTimeout(lotusFunc LotusRPCWrapper, timeout time.Duration) error

WrapWithTimeout executes lotusFunc but return an error after the `timeout`

Types

type Cache

type Cache struct {
	Node *api.FullNode
	// contains filtered or unexported fields
}

In-memory database

func (*Cache) GetActorCode

func (m *Cache) GetActorCode(address address.Address) (cid.Cid, error)

func (*Cache) GetActorPubKey

func (m *Cache) GetActorPubKey(address address.Address, reverse bool) (string, error)

func (*Cache) NewImpl

func (m *Cache) NewImpl(node *api.FullNode)

type Database

type Database interface {
	NewImpl(*api.FullNode)
	// Address-ActorCID Map
	GetActorCode(address address.Address) (cid.Cid, error)

	// Address-ActorPubkey Map
	GetActorPubKey(address address.Address, reverse bool) (string, error)
	// contains filtered or unexported methods
}

var ActorsDB Database

type LotusRPCWrapper

type LotusRPCWrapper func()