(cli *nodeProfile)
| 118 | } |
| 119 | |
| 120 | func createRandomQueryRequest(cli *nodeProfile) (r *types.SignedRequestHeader, err error) { |
| 121 | req := &types.Request{ |
| 122 | Header: types.SignedRequestHeader{ |
| 123 | RequestHeader: types.RequestHeader{ |
| 124 | QueryType: types.QueryType(rand.Intn(2)), |
| 125 | NodeID: cli.NodeID, |
| 126 | ConnectionID: uint64(rand.Int63()), |
| 127 | SeqNo: uint64(rand.Int63()), |
| 128 | Timestamp: time.Now().UTC(), |
| 129 | // BatchCount and QueriesHash will be set by req.Sign() |
| 130 | }, |
| 131 | }, |
| 132 | Payload: types.RequestPayload{ |
| 133 | Queries: createRandomStorageQueries(10, 10, 10, 10), |
| 134 | }, |
| 135 | } |
| 136 | |
| 137 | createRandomString(10, 10, (*string)(&req.Header.DatabaseID)) |
| 138 | |
| 139 | if err = req.Sign(cli.PrivateKey); err != nil { |
| 140 | return |
| 141 | } |
| 142 | |
| 143 | r = &req.Header |
| 144 | return |
| 145 | } |
| 146 | |
| 147 | func createRandomQueryResponse(cli, worker *nodeProfile) ( |
| 148 | r *types.SignedResponseHeader, err error, |
no test coverage detected