shared

Documentation

Index

• Constants
• func FetchIPLD(tx *sqlx.Tx, cid string) ([]byte, error)
• func FetchIPLDByMhKey(tx *sqlx.Tx, mhKey string) ([]byte, error)
• func HandleZeroAddr(to common.Address) string
• func HandleZeroAddrPointer(to *common.Address) string
• func IPLDsContainBytes(iplds []ipfs.BlockModel, b []byte) bool
• func MultihashKeyFromCID(c cid.Cid) string
• func MultihashKeyFromCIDString(c string) (string, error)
• func PublishIPLD(tx *sqlx.Tx, i node.Node) error
• func PublishRaw(tx *sqlx.Tx, codec, mh uint64, raw []byte) (string, error)
• func Rollback(tx *sqlx.Tx)

Constants

const (
	DefaultMaxBatchSize   uint64 = 100
	DefaultMaxBatchNumber int64  = 50
)

Functions

func FetchIPLD

func FetchIPLD(tx *sqlx.Tx, cid string) ([]byte, error)

FetchIPLD is used to retrieve an ipld from Postgres blockstore with the provided tx and cid string

func FetchIPLDByMhKey

func FetchIPLDByMhKey(tx *sqlx.Tx, mhKey string) ([]byte, error)

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

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 []ipfs.BlockModel, 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 PublishIPLD

func PublishIPLD(tx *sqlx.Tx, i node.Node) error

PublishIPLD is used to insert an ipld into Postgres blockstore with the provided tx

func PublishRaw

func PublishRaw(tx *sqlx.Tx, codec, mh uint64, raw []byte) (string, error)

PublishRaw derives a cid from raw bytes and provided codec and multihash type, and writes it to the db tx

func Rollback

func Rollback(tx *sqlx.Tx)

Rollback sql transaction and log any error