collector

Documentation

Index

• type CellCollectionIterator
• type ChangeOutputIndex
• type LiveCellCollectResult
• type LiveCellCollector
  • func NewLiveCellCollector(client rpc.Client, searchKey *indexer.SearchKey, ...) *LiveCellCollector
  • func (c *LiveCellCollector) CurrentItem() (*indexer.LiveCell, error)
  • func (c *LiveCellCollector) HasNext() bool
  • func (c *LiveCellCollector) Iterator() (CellCollectionIterator, error)
  • func (c *LiveCellCollector) Next() error

Types

type CellCollectionIterator

type CellCollectionIterator interface {
	HasNext() bool
	Next() error
	CurrentItem() (*indexer.LiveCell, error)
	Iterator() (CellCollectionIterator, error)
}

type ChangeOutputIndex

type ChangeOutputIndex struct {
	Value int
}

type LiveCellCollectResult

type LiveCellCollectResult struct {
	LiveCells []*indexer.LiveCell
	Capacity  uint64
	Options   map[string]interface{}
}

type LiveCellCollector

type LiveCellCollector struct {
	Client      rpc.Client
	SearchKey   *indexer.SearchKey
	SearchOrder indexer.SearchOrder
	Limit       uint64
	LastCursor  string
	EmptyData   bool
	// contains filtered or unexported fields
}

func NewLiveCellCollector

func NewLiveCellCollector(client rpc.Client, searchKey *indexer.SearchKey, searchOrder indexer.SearchOrder, limit uint64, afterCursor string, onlyNormalCell bool) *LiveCellCollector

func (*LiveCellCollector) CurrentItem

func (c *LiveCellCollector) CurrentItem() (*indexer.LiveCell, error)

func (*LiveCellCollector) HasNext

func (c *LiveCellCollector) HasNext() bool

func (*LiveCellCollector) Iterator

func (c *LiveCellCollector) Iterator() (CellCollectionIterator, error)

func (*LiveCellCollector) Next

func (c *LiveCellCollector) Next() error