async

type Dispatcher ¶ added in v0.9.18

type Dispatcher interface {
	ValidateConf() error
	Run() error
	IsInitialized() bool
	DispatchMsgAsync(ctx context.Context, msg *messages.SendTransaction, ack bool) (*messages.AsyncSentMsg, error)
	HandleReceipts(res http.ResponseWriter, req *http.Request, params httprouter.Params)
	Close()
}

Dispatcher is passed in to process messages over a streaming system with a receipt store. Only used for POST methods, when fly-sync is not set to true

func NewAsyncDispatcher(conf *conf.RESTGatewayConf, processor tx.Processor, receiptstore receipt.Store) Dispatcher