indexes

Documentation

Index

• Constants
• Variables
• func ForkMerge(ind *core.IpfsNode, chainId string, index *Index) (cid.Cid, error)
• type Index
  • func (i *Index) Decode(bs []byte) error
  • func (i *Index) Encode() []byte
• type IndexesServices
  • func CreateServices(ind *core.IpfsNode, chainId string, rcp bool) IndexesServices

Constants

const AIndexesKeyPathPrefix = "/aya/chain/indexes/"

const StaticSize = 74

Variables

var (
	ErrCreateFailed = errors.New("create index services failed")
	ErrSyncRollback = errors.New("sync to target cid has rollback")
)

Functions

func ForkMerge

func ForkMerge(ind *core.IpfsNode, chainId string, index *Index) (cid.Cid, error)

Types

type Index

type Index struct {
	BlockIndex uint64 `json:"Index"`

	Hash EComm.Hash `json:"Hash"`

	FullCID cid.Cid `json:"FullCID"`
}

func (*Index) Decode

func (i *Index) Decode(bs []byte) error

func (*Index) Encode

func (i *Index) Encode() []byte

type IndexesServices

type IndexesServices interface {
	GetLatest() (*Index, error)

	SyncToCID(fullCID cid.Cid) error

	PutIndex(index *Index) (cid.Cid, error)

	GetIndex(blockNumber uint64) (*Index, error)

	PutIndexBy(num uint64, bhash EComm.Hash, cid cid.Cid) (cid.Cid, error)

	Close() error
}

func CreateServices

func CreateServices(ind *core.IpfsNode, chainId string, rcp bool) IndexesServices