collector

Documentation

Index

• type CellCollectionIterator
• type CellIterator
  • func NewLiveCellIterator(client rpc.Client, key *indexer.SearchKey) CellIterator
  • func NewLiveCellIteratorByLightClient(client lightclient.Client, key *indexer.SearchKey) CellIterator
  • func NewLiveCellIteratorByLightClientFromAddress(client lightclient.Client, addr string) (CellIterator, error)
  • func NewLiveCellIteratorFromAddress(client rpc.Client, addr string) (CellIterator, error)
• type ChangeOutputIndex
• type CkbLiveCellGetter
  • func (c *CkbLiveCellGetter) GetCells(searchKey *indexer.SearchKey, order indexer.SearchOrder, limit uint64, ...) (*indexer.LiveCells, error)
• type LightClientLiveCellGetter
  • func (c *LightClientLiveCellGetter) GetCells(searchKey *indexer.SearchKey, order indexer.SearchOrder, limit uint64, ...) (*indexer.LiveCells, error)
• 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
• type LiveCellIterator
  • func (r *LiveCellIterator) HasNext() bool
  • func (r *LiveCellIterator) Next() *types.TransactionInput
• type LiveCellsGetter
• type OffChainInputCollector
  • func NewOffChainInputCollector(Client rpc.Client) *OffChainInputCollector
  • func (c *OffChainInputCollector) ApplyOffChainTransaction(tipBlockNumber uint64, transaction types.Transaction)
• type OffChainInputIterator
  • func NewOffChainInputIterator(iterator CellIterator, collector *OffChainInputCollector, ...) *OffChainInputIterator
  • func NewOffChainInputIteratorFromAddress(client rpc.Client, addr string, collector *OffChainInputCollector, ...) (*OffChainInputIterator, error)
  • func (r *OffChainInputIterator) GetLiveCells(searchKey *indexer.SearchKey, order indexer.SearchOrder, limit uint64, ...) (*indexer.LiveCells, error)
  • func (r *OffChainInputIterator) HasNext() bool
  • func (r *OffChainInputIterator) Next() *types.TransactionInput
• type OutPointWithBlockNumber
• type ScriptHandler
• type TransactionBuilder
• type TransactionInputWithBlockNumber

Types

type CellCollectionIterator

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

type CellIterator

type CellIterator interface {
	HasNext() bool
	Next() *types.TransactionInput
}

func NewLiveCellIterator

func NewLiveCellIterator(client rpc.Client, key *indexer.SearchKey) CellIterator

func NewLiveCellIteratorByLightClient

func NewLiveCellIteratorByLightClient(client lightclient.Client, key *indexer.SearchKey) CellIterator

func NewLiveCellIteratorByLightClientFromAddress

func NewLiveCellIteratorByLightClientFromAddress(client lightclient.Client, addr string) (CellIterator, error)

func NewLiveCellIteratorFromAddress

func NewLiveCellIteratorFromAddress(client rpc.Client, addr string) (CellIterator, error)

type ChangeOutputIndex

type ChangeOutputIndex struct {
	Value int
}

type CkbLiveCellGetter

type CkbLiveCellGetter struct {
	Client  rpc.Client
	Context context.Context
}

func (*CkbLiveCellGetter) GetCells

func (c *CkbLiveCellGetter) GetCells(searchKey *indexer.SearchKey, order indexer.SearchOrder, limit uint64, afterCursor string) (*indexer.LiveCells, error)

type LightClientLiveCellGetter

type LightClientLiveCellGetter struct {
	Client  lightclient.Client
	Context context.Context
}

func (*LightClientLiveCellGetter) GetCells

func (c *LightClientLiveCellGetter) GetCells(searchKey *indexer.SearchKey, order indexer.SearchOrder, limit uint64, afterCursor string) (*indexer.LiveCells, error)

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
	TypeScript  *types.Script
	// contains filtered or unexported fields
}

func NewLiveCellCollector

func NewLiveCellCollector(client rpc.Client, searchKey *indexer.SearchKey, searchOrder indexer.SearchOrder, limit uint64, afterCursor string) *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

type LiveCellIterator

type LiveCellIterator struct {
	LiveCellGetter LiveCellsGetter
	SearchKey      *indexer.SearchKey
	SearchOrder    indexer.SearchOrder
	Limit          uint64
	// contains filtered or unexported fields
}

func (*LiveCellIterator) HasNext

func (r *LiveCellIterator) HasNext() bool

func (*LiveCellIterator) Next

func (r *LiveCellIterator) Next() *types.TransactionInput

type LiveCellsGetter

type LiveCellsGetter interface {
	GetCells(searchKey *indexer.SearchKey, order indexer.SearchOrder, limit uint64, afterCursor string) (*indexer.LiveCells, error)
}

type OffChainInputCollector

type OffChainInputCollector struct {
	Client rpc.Client
	// contains filtered or unexported fields
}

func NewOffChainInputCollector

func NewOffChainInputCollector(Client rpc.Client) *OffChainInputCollector

func (*OffChainInputCollector) ApplyOffChainTransaction

func (c *OffChainInputCollector) ApplyOffChainTransaction(tipBlockNumber uint64, transaction types.Transaction)

type OffChainInputIterator

type OffChainInputIterator struct {
	Iterator                    *LiveCellIterator
	Collector                   *OffChainInputCollector
	ConsumeOffChainCellsFirstly bool
	// contains filtered or unexported fields
}

func NewOffChainInputIterator

func NewOffChainInputIterator(iterator CellIterator, collector *OffChainInputCollector, consumeOffChainCellsFirstly bool) *OffChainInputIterator

func NewOffChainInputIteratorFromAddress

func NewOffChainInputIteratorFromAddress(client rpc.Client, addr string, collector *OffChainInputCollector, consumeOffChainCellsFirstly bool) (*OffChainInputIterator, error)

func (*OffChainInputIterator) GetLiveCells

func (r *OffChainInputIterator) GetLiveCells(searchKey *indexer.SearchKey, order indexer.SearchOrder, limit uint64, afterCursor string) (*indexer.LiveCells, error)

func (*OffChainInputIterator) HasNext

func (r *OffChainInputIterator) HasNext() bool

func (*OffChainInputIterator) Next

func (r *OffChainInputIterator) Next() *types.TransactionInput

type OutPointWithBlockNumber

type OutPointWithBlockNumber struct {
	*types.OutPoint
	// contains filtered or unexported fields
}

type ScriptHandler

type ScriptHandler interface {
	BuildTransaction(builder TransactionBuilder, group *transaction.ScriptGroup, context interface{}) (bool, error)
}

type TransactionBuilder

type TransactionBuilder interface {
	SetVersion(version uint32)
	AddHeaderDep(headerDep types.Hash) int
	AddCellDep(cellDep *types.CellDep) int
	AddInput(input *types.CellInput) int
	SetSince(index uint, since uint64) error
	AddOutput(output *types.CellOutput, data []byte) int
	SetOutputData(index uint, data []byte) error
	SetWitness(index uint, witnessType types.WitnessType, data []byte) error
	AddScriptGroup(group *transaction.ScriptGroup) int
	Build(contexts ...interface{}) (*transaction.TransactionWithScriptGroups, error)
}

type TransactionInputWithBlockNumber

type TransactionInputWithBlockNumber struct {
	types.TransactionInput
	// contains filtered or unexported fields
}