runner

Documentation

Index

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

Types

type Config

type Config struct {
	Disable         bool
	QueryAskTimeout time.Duration
	MaxParallel     int
	RefreshInterval time.Duration
	RefreshOnStart  bool
}

Config contains parameters for index updating.

type Runner

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

Runner contains cached information about markets.

func New

func New(ds datastore.TxnDatastore, clientBuilder lotus.ClientBuilder, config Config) (*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 ask.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.