async

Documentation

Index

• type AsyncDispatcher
  • func NewAsyncDispatcher(conf *conf.RESTGatewayConf, processor tx.TxProcessor, ...) AsyncDispatcher

Types

type AsyncDispatcher

type AsyncDispatcher 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()
}

AsyncDispatcher 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

func NewAsyncDispatcher(conf *conf.RESTGatewayConf, processor tx.TxProcessor, receiptstore receipt.ReceiptStore) AsyncDispatcher