(header *SignedRequestHeader, cols []string, types []string, rows []ResponseRow)
| 168 | } |
| 169 | |
| 170 | func buildResponse(header *SignedRequestHeader, cols []string, types []string, rows []ResponseRow) (r *Response) { |
| 171 | var ( |
| 172 | id proto.NodeID |
| 173 | err error |
| 174 | ) |
| 175 | if id, err = kms.GetLocalNodeID(); err != nil { |
| 176 | id = proto.NodeID("00000000000000000000000000000000") |
| 177 | } |
| 178 | r = &Response{ |
| 179 | Header: SignedResponseHeader{ |
| 180 | ResponseHeader: ResponseHeader{ |
| 181 | Request: header.RequestHeader, |
| 182 | RequestHash: header.Hash(), |
| 183 | NodeID: id, |
| 184 | Timestamp: time.Now().UTC(), |
| 185 | RowCount: 0, |
| 186 | LogOffset: 0, |
| 187 | LastInsertID: 0, |
| 188 | AffectedRows: 0, |
| 189 | }, |
| 190 | }, |
| 191 | Payload: ResponsePayload{ |
| 192 | Columns: cols, |
| 193 | DeclTypes: types, |
| 194 | Rows: rows, |
| 195 | }, |
| 196 | } |
| 197 | if err = r.BuildHash(); err != nil { |
| 198 | panic(err) |
| 199 | } |
| 200 | return |
| 201 | } |
| 202 | |
| 203 | func setup() { |
| 204 | rand.Seed(time.Now().UnixNano()) |
no test coverage detected