Documentation
¶
Index ¶
- type DVSReactor
- func (dvs *DVSReactor) OnQuery(key []byte) ([]byte, []byte, error)
- func (dvs *DVSReactor) OnRequest(request avsitypes.DVSRequest) (*avsitypes.DVSRequestResult, error)
- func (dvs *DVSReactor) SaveDVSRequestResult(res *avsitypes.DVSRequestResult, first bool) error
- func (dvs *DVSReactor) SignMessage(message []byte) (*bls.Signature, error)
- type DVSReqResponse
- type DVSReqStore
- type DVSState
- type PrivValidator
- type RequestPostRequest
- type RequestProcessRequest
- type ResponsePostRequest
- type ResponseProcessRequest
- type Store
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, ) (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
func (*DVSReactor) SignMessage ¶
func (dvs *DVSReactor) SignMessage(message []byte) (*bls.Signature, 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 PrivValidator ¶
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.