digest

Documentation

Overview

Package digest provides api features.

Index

• Variables
• func DigestBlock(ctx context.Context, st *currencydigest.Database, blk base.BlockMap, ...) error
• func NFT(st *currencydigest.Database, contract, idx string) (*types.NFT, error)
• func NFTCollection(st *currencydigest.Database, contract string) (*types.Design, error)
• func NFTCountByCollection(st *currencydigest.Database, contract string) (int64, error)
• func NFTOperators(st *currencydigest.Database, contract, account string) (*types.OperatorsBook, error)
• func NFTsByCollection(st *currencydigest.Database, contract, factHash, offset string, reverse bool, ...) error
• type BlockSession
  • func NewBlockSession(st *currencydigest.Database, blk mitumbase.BlockMap, ops []mitumbase.Operation, ...) (*BlockSession, error)
  • func (bs *BlockSession) Close() error
  • func (bs *BlockSession) Commit(ctx context.Context) error
  • func (bs *BlockSession) Prepare() error
• type BlockSessioner
• type Digester
  • func NewDigester(st *currencydigest.Database, root string, ...) *Digester
  • func (di *Digester) Digest(blocks []base.BlockMap)
• type Handlers
  • func NewHandlers(ctx context.Context, networkID base.NetworkID, encs *encoder.Encoders, ...) *Handlers
  • func (hd *Handlers) Cache() currencydigest.Cache
  • func (hd *Handlers) Handler() http.Handler
  • func (hd *Handlers) Initialize() error
  • func (hd *Handlers) Router() *mux.Router
  • func (hd *Handlers) SetLimiter(f func(string) int64) *Handlers
• type NFTBoxDoc
  • func NewNFTBoxDoc(st base.State, enc encoder.Encoder) (*NFTBoxDoc, error)
  • func (doc NFTBoxDoc) MarshalBSON() ([]byte, error)
• type NFTCollectionDoc
  • func NewNFTCollectionDoc(st base.State, enc encoder.Encoder) (NFTCollectionDoc, error)
  • func (doc NFTCollectionDoc) MarshalBSON() ([]byte, error)
• type NFTDoc
  • func NewNFTDoc(st base.State, enc encoder.Encoder) (*NFTDoc, error)
  • func (doc NFTDoc) MarshalBSON() ([]byte, error)
• type NFTLastIndexDoc
  • func NewNFTLastIndexDoc(st base.State, enc encoder.Encoder) (*NFTLastIndexDoc, error)
  • func (doc NFTLastIndexDoc) MarshalBSON() ([]byte, error)
• type NFTOperatorDoc
  • func NewNFTOperatorDoc(st base.State, enc encoder.Encoder) (*NFTOperatorDoc, error)
  • func (doc NFTOperatorDoc) MarshalBSON() ([]byte, error)

Variables

var (
	HandlerPathNFTOperators  = `/nft/{contract:.*}/account/{address:(?i)` + base.REStringAddressString + `}/operators` // revive:disable-line:line-length-limit
	HandlerPathNFTCollection = `/nft/{contract:.*}/collection`
	HandlerPathNFT           = `/nft/{contract:.*}/{id:.*}`
	HandlerPathNFTs          = `/nft/{contract:.*}/nfts`
	HandlerPathNFTCount      = `/nft/{contract:.*}/count`
)

Functions

func DigestBlock

func DigestBlock(
	ctx context.Context,
	st *currencydigest.Database,
	blk base.BlockMap,
	ops []base.Operation,
	opstree fixedtree.Tree,
	sts []base.State,
	proposal base.ProposalSignFact,
) error

func NFT

func NFT(st *currencydigest.Database, contract, idx string) (*types.NFT, error)

func NFTCollection

func NFTCollection(st *currencydigest.Database, contract string) (*types.Design, error)

func NFTCountByCollection

func NFTCountByCollection(
	st *currencydigest.Database,
	contract string,
) (int64, error)

func NFTOperators

func NFTOperators(
	st *currencydigest.Database,
	contract, account string,
) (*types.OperatorsBook, error)

func NFTsByCollection

func NFTsByCollection(
	st *currencydigest.Database,
	contract, factHash, offset string,
	reverse bool,
	limit int64,
	callback func(nft types.NFT, st mitumbase.State) (bool, error),
) error

Types

type BlockSession

type BlockSession struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewBlockSession

func NewBlockSession(
	st *currencydigest.Database,
	blk mitumbase.BlockMap,
	ops []mitumbase.Operation,
	opstree fixedtree.Tree,
	sts []mitumbase.State,
	proposal mitumbase.ProposalSignFact,
) (*BlockSession, error)

func (*BlockSession) Close

func (bs *BlockSession) Close() error

func (*BlockSession) Commit

func (bs *BlockSession) Commit(ctx context.Context) error

func (*BlockSession) Prepare

func (bs *BlockSession) Prepare() error

type BlockSessioner

type BlockSessioner interface {
	Prepare() error
	Commit(context.Context) error
	Close() error
}

type Digester

type Digester struct {
	sync.RWMutex
	*util.ContextDaemon
	*logging.Logging
	// contains filtered or unexported fields
}

func NewDigester

func NewDigester(
	st *currencydigest.Database,
	root string,
	sourceReaders *isaac.BlockItemReaders,
	fromRemotes isaac.RemotesBlockItemReadFunc,
	networkID base.NetworkID,
	errChan chan error,
) *Digester

func (*Digester) Digest

func (di *Digester) Digest(blocks []base.BlockMap)

type Handlers

type Handlers struct {
	*zerolog.Logger
	// contains filtered or unexported fields
}

func NewHandlers

func NewHandlers(
	ctx context.Context,
	networkID base.NetworkID,
	encs *encoder.Encoders,
	enc encoder.Encoder,
	st *currencydigest.Database,
	cache currencydigest.Cache,
	router *mux.Router,
	routes map[string]*mux.Route,
) *Handlers

func (*Handlers) Cache

func (hd *Handlers) Cache() currencydigest.Cache

func (*Handlers) Handler

func (hd *Handlers) Handler() http.Handler

func (*Handlers) Initialize

func (hd *Handlers) Initialize() error

func (*Handlers) Router

func (hd *Handlers) Router() *mux.Router

func (*Handlers) SetLimiter

func (hd *Handlers) SetLimiter(f func(string) int64) *Handlers

type NFTBoxDoc

type NFTBoxDoc struct {
	mongodbstorage.BaseDoc
	// contains filtered or unexported fields
}

func NewNFTBoxDoc

func NewNFTBoxDoc(st base.State, enc encoder.Encoder) (*NFTBoxDoc, error)

func (NFTBoxDoc) MarshalBSON

func (doc NFTBoxDoc) MarshalBSON() ([]byte, error)

type NFTCollectionDoc

type NFTCollectionDoc struct {
	mongodbstorage.BaseDoc
	// contains filtered or unexported fields
}

func NewNFTCollectionDoc

func NewNFTCollectionDoc(st base.State, enc encoder.Encoder) (NFTCollectionDoc, error)

func (NFTCollectionDoc) MarshalBSON

func (doc NFTCollectionDoc) MarshalBSON() ([]byte, error)

type NFTDoc

type NFTDoc struct {
	mongodbstorage.BaseDoc
	// contains filtered or unexported fields
}

func NewNFTDoc

func NewNFTDoc(st base.State, enc encoder.Encoder) (*NFTDoc, error)

func (NFTDoc) MarshalBSON

func (doc NFTDoc) MarshalBSON() ([]byte, error)

type NFTLastIndexDoc

type NFTLastIndexDoc struct {
	mongodbstorage.BaseDoc
	// contains filtered or unexported fields
}

func NewNFTLastIndexDoc

func NewNFTLastIndexDoc(st base.State, enc encoder.Encoder) (*NFTLastIndexDoc, error)

func (NFTLastIndexDoc) MarshalBSON

func (doc NFTLastIndexDoc) MarshalBSON() ([]byte, error)

type NFTOperatorDoc

type NFTOperatorDoc struct {
	mongodbstorage.BaseDoc
	// contains filtered or unexported fields
}

func NewNFTOperatorDoc

func NewNFTOperatorDoc(st base.State, enc encoder.Encoder) (*NFTOperatorDoc, error)

func (NFTOperatorDoc) MarshalBSON

func (doc NFTOperatorDoc) MarshalBSON() ([]byte, error)