Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DVSReactor ¶
func CreateDVSReactor ¶
func CreateDVSReactor( config config.PellConfig, proxyApp proxy.AppConns, aggregator aggtypes.Aggregator, storeDir string, dvsRequestIndexer requestindex.DvsRequestIndexer, db dbm.DB, logger log.Logger, privValidator types.PrivValidator, ) (DVSReactor, error)
func (*DVSReactor) OnRequest ¶
func (dvs *DVSReactor) OnRequest(request avsitypes.DVSRequest) (*avsitypes.DVSRequestResult, error)
func (*DVSReactor) SaveDVSRequestResult ¶
func (dvs *DVSReactor) SaveDVSRequestResult(res *avsitypes.DVSRequestResult, first bool) error
type DVSReqResponse ¶
type DVSReqResponse struct {
Request avsitypes.DVSRequest
Response *aggregator.ValidatedResponse
Receipt *ResponsePostRequest
}
type DVSReqStore ¶
type DVSReqStore interface {
SaveReq(req *DVSReqResponse) error
GetReq(id string) (*RequestProcessRequest, error)
}
type DVSState ¶
type DVSState struct {
// contains filtered or unexported fields
}
func NewDVSState ¶
func NewDVSState(cfg *config.PellConfig, dvsReqStore DVSReqStore, storeDir string) (*DVSState, error)
NewDVSState creates a new DVSState instance
func (*DVSState) SaveReq ¶
func (dvsState *DVSState) SaveReq(req *DVSReqResponse) error
type RequestPostRequest ¶
type RequestPostRequest struct {
Response aggregator.ValidatedResponse
}
type RequestProcessRequest ¶
type RequestProcessRequest struct {
Request avsitypes.DVSRequest
}
type ResponsePostRequest ¶
type ResponsePostRequest struct {
}
type ResponseProcessRequest ¶
Click to show internal directories.
Click to hide internal directories.