shared

Documentation

Index

• Constants
• func FetchIPLD(db *sqlx.DB, mhKey string, blockNumber uint64) ([]byte, error)
• func FetchIPLDByMhKeyAndBlockNumber(tx *sqlx.Tx, mhKey string, blockNumber uint64) ([]byte, error)
• func HandleZeroAddr(to common.Address) string
• func HandleZeroAddrPointer(to *common.Address) string
• func IPLDsContainBytes(iplds []models.IPLDModel, b []byte) bool
• func MultihashKeyFromCID(c cid.Cid) string
• func MultihashKeyFromCIDString(c string) (string, error)
• func NewDB(connectString string, config postgres.Config) (*sqlx.DB, error)
• func Rollback(tx *sqlx.Tx)
• func SetupDB() *sqlx.DB
• func SetupTestStateDiffIndexer(ctx context.Context, chainConfig *params.ChainConfig, genHash common.Hash) interfaces.StateDiffIndexer
• func TearDownDB(db *sqlx.DB)
• type GroupCacheConfig
• type GroupConfig
• type PoolConfig

Constants

const (
	DefaultMaxBatchSize     uint64        = 100
	DefaultMaxBatchNumber   int64         = 50
	DefaultStateDiffTimeout time.Duration = 240 * time.Second

	GcachePoolEnabled             = "GCACHE_POOL_ENABLED"
	GcachePoolHttpPath            = "GCACHE_POOL_HTTP_PATH"
	GcachePoolHttpPeers           = "GCACHE_POOL_HTTP_PEERS"
	GcacheStatedbCacheSize        = "GCACHE_STATEDB_CACHE_SIZE"
	GcacheStatedbCacheExpiry      = "GCACHE_STATEDB_CACHE_EXPIRY"
	GcacheStatedbLogStatsInterval = "GCACHE_STATEDB_LOG_STATS_INTERVAL"
)

Functions

func FetchIPLD

func FetchIPLD(db *sqlx.DB, mhKey string, blockNumber uint64) ([]byte, error)

FetchIPLD is used to retrieve an IPLD from Postgres mhkey and blockNumber

func FetchIPLDByMhKeyAndBlockNumber

func FetchIPLDByMhKeyAndBlockNumber(tx *sqlx.Tx, mhKey string, blockNumber uint64) ([]byte, error)

FetchIPLDByMhKeyAndBlockNumber is used to retrieve an ipld from Postgres blockstore with the provided tx, mhkey string and blockNumber

func HandleZeroAddr

func HandleZeroAddr(to common.Address) string

HandleZeroAddr will return an empty string for a 0 value address

func HandleZeroAddrPointer

func HandleZeroAddrPointer(to *common.Address) string

HandleZeroAddrPointer will return an emtpy string for a nil address pointer

func IPLDsContainBytes

func IPLDsContainBytes(iplds []models.IPLDModel, b []byte) bool

IPLDsContainBytes used to check if a list of strings contains a particular string

func MultihashKeyFromCID

func MultihashKeyFromCID(c cid.Cid) string

MultihashKeyFromCID converts a cid into a blockstore-prefixed multihash db key string

func MultihashKeyFromCIDString

func MultihashKeyFromCIDString(c string) (string, error)

MultihashKeyFromCIDString converts a cid string into a blockstore-prefixed multihash db key string

func NewDB

func NewDB(connectString string, config postgres.Config) (*sqlx.DB, error)

NewDB creates a new db connection and initializes the connection pool

func Rollback

func Rollback(tx *sqlx.Tx)

Rollback sql transaction and log any error

func SetupDB

func SetupDB() *sqlx.DB

SetupDB is use to setup a db for watcher tests

func SetupTestStateDiffIndexer

func SetupTestStateDiffIndexer(ctx context.Context, chainConfig *params.ChainConfig, genHash common.Hash) interfaces.StateDiffIndexer

func TearDownDB

func TearDownDB(db *sqlx.DB)

TearDownDB is used to tear down the watcher dbs after tests

Types

type GroupCacheConfig

type GroupCacheConfig struct {
	Pool    PoolConfig
	StateDB GroupConfig
}

type GroupConfig

type GroupConfig struct {
	CacheSizeInMB          int
	CacheExpiryInMins      int
	LogStatsIntervalInSecs int

	// Used in tests to override the cache name, to work around
	// the "duplicate registration of group" error from groupcache
	Name string
}

type PoolConfig

type PoolConfig struct {
	Enabled           bool
	HttpEndpoint      string
	PeerHttpEndpoints []string
}