The highest tagged major version is v5.

shared

package

v4.2.8-alpha Latest Latest Go to latest Published: Apr 1, 2023 License: AGPL-3.0 Imports: 18 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cerc-io/ipld-eth-server

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 ¶

View Source

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"
)

Variables ¶

This section is empty.

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
}

Source Files ¶

View all Source files

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