runner

Documentation

Index

• type Query
• type Runner
  • func New(ds datastore.TxnDatastore, api *apistruct.FullNodeStruct) (*Runner, error)
  • func (ai *Runner) Close() error
  • func (ai *Runner) Get() ask.Index
  • func (ai *Runner) Listen() <-chan struct{}
  • func (ai *Runner) Query(q Query) ([]ask.StorageAsk, error)
  • func (ai *Runner) Unregister(c chan struct{})

Types

type Query

type Query struct {
	MaxPrice  uint64
	PieceSize uint64
	Limit     int
	Offset    int
}

Query specifies filtering and paging data to retrieve active Asks

type Runner

type Runner struct {
	// contains filtered or unexported fields
}

Runner contains cached information about markets

func New

func New(ds datastore.TxnDatastore, api *apistruct.FullNodeStruct) (*Runner, error)

New returns a new ask index runner. It load a persisted ask index, and immediately starts building a new fresh one.

func (*Runner) Close

func (ai *Runner) Close() error

Close closes the AskIndex

func (*Runner) Get

func (ai *Runner) Get() ask.Index

Get returns a copy of the current index data

func (*Runner) Listen

func (ai *Runner) Listen() <-chan struct{}

Listen returns a new channel signaler that notifies when the index gets updated.

func (*Runner) Query

func (ai *Runner) Query(q Query) ([]ask.StorageAsk, error)

Query executes a query to retrieve active Asks

func (*Runner) Unregister

func (ai *Runner) Unregister(c chan struct{})

Unregister unregisters a channel signaler from the signaler hub