回复成功并包含数据
(requestId int64, message string, dataJSON []byte)
| 498 | |
| 499 | // 回复成功并包含数据 |
| 500 | func (this *APIStream) replyOkData(requestId int64, message string, dataJSON []byte) { |
| 501 | _ = this.stream.Send(&pb.NodeStreamMessage{RequestId: requestId, IsOk: true, Message: message, DataJSON: dataJSON}) |
| 502 | } |
| 503 | |
| 504 | // 获取缓存存取对象 |
| 505 | func (this *APIStream) cacheStorage(message *pb.NodeStreamMessage, cachePolicyJSON []byte) (storage caches.StorageInterface, shouldStop bool, err error) { |