/** * Autogenerated by Thrift Compiler (0.12.0) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING * @generated */ #include "MilvusService.h" namespace milvus { namespace thrift { MilvusService_CreateTable_args::~MilvusService_CreateTable_args() throw() { } uint32_t MilvusService_CreateTable_args::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 2: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->param.read(iprot); this->__isset.param = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_CreateTable_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_CreateTable_args"); xfer += oprot->writeFieldBegin("param", ::apache::thrift::protocol::T_STRUCT, 2); xfer += this->param.write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_CreateTable_pargs::~MilvusService_CreateTable_pargs() throw() { } uint32_t MilvusService_CreateTable_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_CreateTable_pargs"); xfer += oprot->writeFieldBegin("param", ::apache::thrift::protocol::T_STRUCT, 2); xfer += (*(this->param)).write(oprot); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_CreateTable_result::~MilvusService_CreateTable_result() throw() { } uint32_t MilvusService_CreateTable_result::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_CreateTable_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("MilvusService_CreateTable_result"); if (this->__isset.e) { xfer += oprot->writeFieldBegin("e", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->e.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_CreateTable_presult::~MilvusService_CreateTable_presult() throw() { } uint32_t MilvusService_CreateTable_presult::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } MilvusService_HasTable_args::~MilvusService_HasTable_args() throw() { } uint32_t MilvusService_HasTable_args::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { xfer += iprot->readString(this->table_name); this->__isset.table_name = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_HasTable_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_HasTable_args"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString(this->table_name); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_HasTable_pargs::~MilvusService_HasTable_pargs() throw() { } uint32_t MilvusService_HasTable_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_HasTable_pargs"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString((*(this->table_name))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_HasTable_result::~MilvusService_HasTable_result() throw() { } uint32_t MilvusService_HasTable_result::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_BOOL) { xfer += iprot->readBool(this->success); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_HasTable_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("MilvusService_HasTable_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0); xfer += oprot->writeBool(this->success); xfer += oprot->writeFieldEnd(); } else if (this->__isset.e) { xfer += oprot->writeFieldBegin("e", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->e.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_HasTable_presult::~MilvusService_HasTable_presult() throw() { } uint32_t MilvusService_HasTable_presult::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_BOOL) { xfer += iprot->readBool((*(this->success))); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } MilvusService_DeleteTable_args::~MilvusService_DeleteTable_args() throw() { } uint32_t MilvusService_DeleteTable_args::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { xfer += iprot->readString(this->table_name); this->__isset.table_name = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_DeleteTable_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_DeleteTable_args"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString(this->table_name); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_DeleteTable_pargs::~MilvusService_DeleteTable_pargs() throw() { } uint32_t MilvusService_DeleteTable_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_DeleteTable_pargs"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString((*(this->table_name))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_DeleteTable_result::~MilvusService_DeleteTable_result() throw() { } uint32_t MilvusService_DeleteTable_result::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_DeleteTable_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("MilvusService_DeleteTable_result"); if (this->__isset.e) { xfer += oprot->writeFieldBegin("e", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->e.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_DeleteTable_presult::~MilvusService_DeleteTable_presult() throw() { } uint32_t MilvusService_DeleteTable_presult::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } MilvusService_BuildIndex_args::~MilvusService_BuildIndex_args() throw() { } uint32_t MilvusService_BuildIndex_args::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { xfer += iprot->readString(this->table_name); this->__isset.table_name = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_BuildIndex_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_BuildIndex_args"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString(this->table_name); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_BuildIndex_pargs::~MilvusService_BuildIndex_pargs() throw() { } uint32_t MilvusService_BuildIndex_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_BuildIndex_pargs"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString((*(this->table_name))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_BuildIndex_result::~MilvusService_BuildIndex_result() throw() { } uint32_t MilvusService_BuildIndex_result::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_BuildIndex_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("MilvusService_BuildIndex_result"); if (this->__isset.e) { xfer += oprot->writeFieldBegin("e", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->e.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_BuildIndex_presult::~MilvusService_BuildIndex_presult() throw() { } uint32_t MilvusService_BuildIndex_presult::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } MilvusService_AddVector_args::~MilvusService_AddVector_args() throw() { } uint32_t MilvusService_AddVector_args::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { xfer += iprot->readString(this->table_name); this->__isset.table_name = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->record_array.clear(); uint32_t _size21; ::apache::thrift::protocol::TType _etype24; xfer += iprot->readListBegin(_etype24, _size21); this->record_array.resize(_size21); uint32_t _i25; for (_i25 = 0; _i25 < _size21; ++_i25) { xfer += this->record_array[_i25].read(iprot); } xfer += iprot->readListEnd(); } this->__isset.record_array = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_AddVector_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_AddVector_args"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString(this->table_name); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("record_array", ::apache::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->record_array.size())); std::vector ::const_iterator _iter26; for (_iter26 = this->record_array.begin(); _iter26 != this->record_array.end(); ++_iter26) { xfer += (*_iter26).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_AddVector_pargs::~MilvusService_AddVector_pargs() throw() { } uint32_t MilvusService_AddVector_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_AddVector_pargs"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString((*(this->table_name))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("record_array", ::apache::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast((*(this->record_array)).size())); std::vector ::const_iterator _iter27; for (_iter27 = (*(this->record_array)).begin(); _iter27 != (*(this->record_array)).end(); ++_iter27) { xfer += (*_iter27).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_AddVector_result::~MilvusService_AddVector_result() throw() { } uint32_t MilvusService_AddVector_result::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); uint32_t _size28; ::apache::thrift::protocol::TType _etype31; xfer += iprot->readListBegin(_etype31, _size28); this->success.resize(_size28); uint32_t _i32; for (_i32 = 0; _i32 < _size28; ++_i32) { xfer += iprot->readI64(this->success[_i32]); } xfer += iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_AddVector_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("MilvusService_AddVector_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_I64, static_cast(this->success.size())); std::vector ::const_iterator _iter33; for (_iter33 = this->success.begin(); _iter33 != this->success.end(); ++_iter33) { xfer += oprot->writeI64((*_iter33)); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); } else if (this->__isset.e) { xfer += oprot->writeFieldBegin("e", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->e.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_AddVector_presult::~MilvusService_AddVector_presult() throw() { } uint32_t MilvusService_AddVector_presult::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); uint32_t _size34; ::apache::thrift::protocol::TType _etype37; xfer += iprot->readListBegin(_etype37, _size34); (*(this->success)).resize(_size34); uint32_t _i38; for (_i38 = 0; _i38 < _size34; ++_i38) { xfer += iprot->readI64((*(this->success))[_i38]); } xfer += iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } MilvusService_SearchVector_args::~MilvusService_SearchVector_args() throw() { } uint32_t MilvusService_SearchVector_args::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { xfer += iprot->readString(this->table_name); this->__isset.table_name = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->query_record_array.clear(); uint32_t _size39; ::apache::thrift::protocol::TType _etype42; xfer += iprot->readListBegin(_etype42, _size39); this->query_record_array.resize(_size39); uint32_t _i43; for (_i43 = 0; _i43 < _size39; ++_i43) { xfer += this->query_record_array[_i43].read(iprot); } xfer += iprot->readListEnd(); } this->__isset.query_record_array = true; } else { xfer += iprot->skip(ftype); } break; case 4: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->query_range_array.clear(); uint32_t _size44; ::apache::thrift::protocol::TType _etype47; xfer += iprot->readListBegin(_etype47, _size44); this->query_range_array.resize(_size44); uint32_t _i48; for (_i48 = 0; _i48 < _size44; ++_i48) { xfer += this->query_range_array[_i48].read(iprot); } xfer += iprot->readListEnd(); } this->__isset.query_range_array = true; } else { xfer += iprot->skip(ftype); } break; case 5: if (ftype == ::apache::thrift::protocol::T_I64) { xfer += iprot->readI64(this->topk); this->__isset.topk = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_SearchVector_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_SearchVector_args"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString(this->table_name); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("query_record_array", ::apache::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->query_record_array.size())); std::vector ::const_iterator _iter49; for (_iter49 = this->query_record_array.begin(); _iter49 != this->query_record_array.end(); ++_iter49) { xfer += (*_iter49).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("query_range_array", ::apache::thrift::protocol::T_LIST, 4); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->query_range_array.size())); std::vector ::const_iterator _iter50; for (_iter50 = this->query_range_array.begin(); _iter50 != this->query_range_array.end(); ++_iter50) { xfer += (*_iter50).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("topk", ::apache::thrift::protocol::T_I64, 5); xfer += oprot->writeI64(this->topk); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_SearchVector_pargs::~MilvusService_SearchVector_pargs() throw() { } uint32_t MilvusService_SearchVector_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_SearchVector_pargs"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString((*(this->table_name))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("query_record_array", ::apache::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast((*(this->query_record_array)).size())); std::vector ::const_iterator _iter51; for (_iter51 = (*(this->query_record_array)).begin(); _iter51 != (*(this->query_record_array)).end(); ++_iter51) { xfer += (*_iter51).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("query_range_array", ::apache::thrift::protocol::T_LIST, 4); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast((*(this->query_range_array)).size())); std::vector ::const_iterator _iter52; for (_iter52 = (*(this->query_range_array)).begin(); _iter52 != (*(this->query_range_array)).end(); ++_iter52) { xfer += (*_iter52).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("topk", ::apache::thrift::protocol::T_I64, 5); xfer += oprot->writeI64((*(this->topk))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_SearchVector_result::~MilvusService_SearchVector_result() throw() { } uint32_t MilvusService_SearchVector_result::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); uint32_t _size53; ::apache::thrift::protocol::TType _etype56; xfer += iprot->readListBegin(_etype56, _size53); this->success.resize(_size53); uint32_t _i57; for (_i57 = 0; _i57 < _size53; ++_i57) { xfer += this->success[_i57].read(iprot); } xfer += iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_SearchVector_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("MilvusService_SearchVector_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->success.size())); std::vector ::const_iterator _iter58; for (_iter58 = this->success.begin(); _iter58 != this->success.end(); ++_iter58) { xfer += (*_iter58).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); } else if (this->__isset.e) { xfer += oprot->writeFieldBegin("e", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->e.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_SearchVector_presult::~MilvusService_SearchVector_presult() throw() { } uint32_t MilvusService_SearchVector_presult::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); uint32_t _size59; ::apache::thrift::protocol::TType _etype62; xfer += iprot->readListBegin(_etype62, _size59); (*(this->success)).resize(_size59); uint32_t _i63; for (_i63 = 0; _i63 < _size59; ++_i63) { xfer += (*(this->success))[_i63].read(iprot); } xfer += iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } MilvusService_SearchVector2_args::~MilvusService_SearchVector2_args() throw() { } uint32_t MilvusService_SearchVector2_args::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { xfer += iprot->readString(this->table_name); this->__isset.table_name = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->query_record_array.clear(); uint32_t _size64; ::apache::thrift::protocol::TType _etype67; xfer += iprot->readListBegin(_etype67, _size64); this->query_record_array.resize(_size64); uint32_t _i68; for (_i68 = 0; _i68 < _size64; ++_i68) { xfer += this->query_record_array[_i68].read(iprot); } xfer += iprot->readListEnd(); } this->__isset.query_record_array = true; } else { xfer += iprot->skip(ftype); } break; case 4: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->query_range_array.clear(); uint32_t _size69; ::apache::thrift::protocol::TType _etype72; xfer += iprot->readListBegin(_etype72, _size69); this->query_range_array.resize(_size69); uint32_t _i73; for (_i73 = 0; _i73 < _size69; ++_i73) { xfer += this->query_range_array[_i73].read(iprot); } xfer += iprot->readListEnd(); } this->__isset.query_range_array = true; } else { xfer += iprot->skip(ftype); } break; case 5: if (ftype == ::apache::thrift::protocol::T_I64) { xfer += iprot->readI64(this->topk); this->__isset.topk = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_SearchVector2_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_SearchVector2_args"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString(this->table_name); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("query_record_array", ::apache::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->query_record_array.size())); std::vector ::const_iterator _iter74; for (_iter74 = this->query_record_array.begin(); _iter74 != this->query_record_array.end(); ++_iter74) { xfer += (*_iter74).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("query_range_array", ::apache::thrift::protocol::T_LIST, 4); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->query_range_array.size())); std::vector ::const_iterator _iter75; for (_iter75 = this->query_range_array.begin(); _iter75 != this->query_range_array.end(); ++_iter75) { xfer += (*_iter75).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("topk", ::apache::thrift::protocol::T_I64, 5); xfer += oprot->writeI64(this->topk); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_SearchVector2_pargs::~MilvusService_SearchVector2_pargs() throw() { } uint32_t MilvusService_SearchVector2_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_SearchVector2_pargs"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString((*(this->table_name))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("query_record_array", ::apache::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast((*(this->query_record_array)).size())); std::vector ::const_iterator _iter76; for (_iter76 = (*(this->query_record_array)).begin(); _iter76 != (*(this->query_record_array)).end(); ++_iter76) { xfer += (*_iter76).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("query_range_array", ::apache::thrift::protocol::T_LIST, 4); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast((*(this->query_range_array)).size())); std::vector ::const_iterator _iter77; for (_iter77 = (*(this->query_range_array)).begin(); _iter77 != (*(this->query_range_array)).end(); ++_iter77) { xfer += (*_iter77).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("topk", ::apache::thrift::protocol::T_I64, 5); xfer += oprot->writeI64((*(this->topk))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_SearchVector2_result::~MilvusService_SearchVector2_result() throw() { } uint32_t MilvusService_SearchVector2_result::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); uint32_t _size78; ::apache::thrift::protocol::TType _etype81; xfer += iprot->readListBegin(_etype81, _size78); this->success.resize(_size78); uint32_t _i82; for (_i82 = 0; _i82 < _size78; ++_i82) { xfer += this->success[_i82].read(iprot); } xfer += iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_SearchVector2_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("MilvusService_SearchVector2_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->success.size())); std::vector ::const_iterator _iter83; for (_iter83 = this->success.begin(); _iter83 != this->success.end(); ++_iter83) { xfer += (*_iter83).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); } else if (this->__isset.e) { xfer += oprot->writeFieldBegin("e", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->e.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_SearchVector2_presult::~MilvusService_SearchVector2_presult() throw() { } uint32_t MilvusService_SearchVector2_presult::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); uint32_t _size84; ::apache::thrift::protocol::TType _etype87; xfer += iprot->readListBegin(_etype87, _size84); (*(this->success)).resize(_size84); uint32_t _i88; for (_i88 = 0; _i88 < _size84; ++_i88) { xfer += (*(this->success))[_i88].read(iprot); } xfer += iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } MilvusService_SearchVectorInFiles_args::~MilvusService_SearchVectorInFiles_args() throw() { } uint32_t MilvusService_SearchVectorInFiles_args::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { xfer += iprot->readString(this->table_name); this->__isset.table_name = true; } else { xfer += iprot->skip(ftype); } break; case 3: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->file_id_array.clear(); uint32_t _size89; ::apache::thrift::protocol::TType _etype92; xfer += iprot->readListBegin(_etype92, _size89); this->file_id_array.resize(_size89); uint32_t _i93; for (_i93 = 0; _i93 < _size89; ++_i93) { xfer += iprot->readString(this->file_id_array[_i93]); } xfer += iprot->readListEnd(); } this->__isset.file_id_array = true; } else { xfer += iprot->skip(ftype); } break; case 4: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->query_record_array.clear(); uint32_t _size94; ::apache::thrift::protocol::TType _etype97; xfer += iprot->readListBegin(_etype97, _size94); this->query_record_array.resize(_size94); uint32_t _i98; for (_i98 = 0; _i98 < _size94; ++_i98) { xfer += this->query_record_array[_i98].read(iprot); } xfer += iprot->readListEnd(); } this->__isset.query_record_array = true; } else { xfer += iprot->skip(ftype); } break; case 5: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->query_range_array.clear(); uint32_t _size99; ::apache::thrift::protocol::TType _etype102; xfer += iprot->readListBegin(_etype102, _size99); this->query_range_array.resize(_size99); uint32_t _i103; for (_i103 = 0; _i103 < _size99; ++_i103) { xfer += this->query_range_array[_i103].read(iprot); } xfer += iprot->readListEnd(); } this->__isset.query_range_array = true; } else { xfer += iprot->skip(ftype); } break; case 6: if (ftype == ::apache::thrift::protocol::T_I64) { xfer += iprot->readI64(this->topk); this->__isset.topk = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_SearchVectorInFiles_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_SearchVectorInFiles_args"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString(this->table_name); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("file_id_array", ::apache::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->file_id_array.size())); std::vector ::const_iterator _iter104; for (_iter104 = this->file_id_array.begin(); _iter104 != this->file_id_array.end(); ++_iter104) { xfer += oprot->writeString((*_iter104)); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("query_record_array", ::apache::thrift::protocol::T_LIST, 4); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->query_record_array.size())); std::vector ::const_iterator _iter105; for (_iter105 = this->query_record_array.begin(); _iter105 != this->query_record_array.end(); ++_iter105) { xfer += (*_iter105).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("query_range_array", ::apache::thrift::protocol::T_LIST, 5); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->query_range_array.size())); std::vector ::const_iterator _iter106; for (_iter106 = this->query_range_array.begin(); _iter106 != this->query_range_array.end(); ++_iter106) { xfer += (*_iter106).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("topk", ::apache::thrift::protocol::T_I64, 6); xfer += oprot->writeI64(this->topk); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_SearchVectorInFiles_pargs::~MilvusService_SearchVectorInFiles_pargs() throw() { } uint32_t MilvusService_SearchVectorInFiles_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_SearchVectorInFiles_pargs"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString((*(this->table_name))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("file_id_array", ::apache::thrift::protocol::T_LIST, 3); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast((*(this->file_id_array)).size())); std::vector ::const_iterator _iter107; for (_iter107 = (*(this->file_id_array)).begin(); _iter107 != (*(this->file_id_array)).end(); ++_iter107) { xfer += oprot->writeString((*_iter107)); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("query_record_array", ::apache::thrift::protocol::T_LIST, 4); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast((*(this->query_record_array)).size())); std::vector ::const_iterator _iter108; for (_iter108 = (*(this->query_record_array)).begin(); _iter108 != (*(this->query_record_array)).end(); ++_iter108) { xfer += (*_iter108).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("query_range_array", ::apache::thrift::protocol::T_LIST, 5); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast((*(this->query_range_array)).size())); std::vector ::const_iterator _iter109; for (_iter109 = (*(this->query_range_array)).begin(); _iter109 != (*(this->query_range_array)).end(); ++_iter109) { xfer += (*_iter109).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldBegin("topk", ::apache::thrift::protocol::T_I64, 6); xfer += oprot->writeI64((*(this->topk))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_SearchVectorInFiles_result::~MilvusService_SearchVectorInFiles_result() throw() { } uint32_t MilvusService_SearchVectorInFiles_result::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); uint32_t _size110; ::apache::thrift::protocol::TType _etype113; xfer += iprot->readListBegin(_etype113, _size110); this->success.resize(_size110); uint32_t _i114; for (_i114 = 0; _i114 < _size110; ++_i114) { xfer += this->success[_i114].read(iprot); } xfer += iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_SearchVectorInFiles_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("MilvusService_SearchVectorInFiles_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRUCT, static_cast(this->success.size())); std::vector ::const_iterator _iter115; for (_iter115 = this->success.begin(); _iter115 != this->success.end(); ++_iter115) { xfer += (*_iter115).write(oprot); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); } else if (this->__isset.e) { xfer += oprot->writeFieldBegin("e", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->e.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_SearchVectorInFiles_presult::~MilvusService_SearchVectorInFiles_presult() throw() { } uint32_t MilvusService_SearchVectorInFiles_presult::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); uint32_t _size116; ::apache::thrift::protocol::TType _etype119; xfer += iprot->readListBegin(_etype119, _size116); (*(this->success)).resize(_size116); uint32_t _i120; for (_i120 = 0; _i120 < _size116; ++_i120) { xfer += (*(this->success))[_i120].read(iprot); } xfer += iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } MilvusService_DescribeTable_args::~MilvusService_DescribeTable_args() throw() { } uint32_t MilvusService_DescribeTable_args::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { xfer += iprot->readString(this->table_name); this->__isset.table_name = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_DescribeTable_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_DescribeTable_args"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString(this->table_name); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_DescribeTable_pargs::~MilvusService_DescribeTable_pargs() throw() { } uint32_t MilvusService_DescribeTable_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_DescribeTable_pargs"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString((*(this->table_name))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_DescribeTable_result::~MilvusService_DescribeTable_result() throw() { } uint32_t MilvusService_DescribeTable_result::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->success.read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_DescribeTable_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("MilvusService_DescribeTable_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0); xfer += this->success.write(oprot); xfer += oprot->writeFieldEnd(); } else if (this->__isset.e) { xfer += oprot->writeFieldBegin("e", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->e.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_DescribeTable_presult::~MilvusService_DescribeTable_presult() throw() { } uint32_t MilvusService_DescribeTable_presult::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += (*(this->success)).read(iprot); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } MilvusService_GetTableRowCount_args::~MilvusService_GetTableRowCount_args() throw() { } uint32_t MilvusService_GetTableRowCount_args::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { xfer += iprot->readString(this->table_name); this->__isset.table_name = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_GetTableRowCount_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_GetTableRowCount_args"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString(this->table_name); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_GetTableRowCount_pargs::~MilvusService_GetTableRowCount_pargs() throw() { } uint32_t MilvusService_GetTableRowCount_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_GetTableRowCount_pargs"); xfer += oprot->writeFieldBegin("table_name", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString((*(this->table_name))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_GetTableRowCount_result::~MilvusService_GetTableRowCount_result() throw() { } uint32_t MilvusService_GetTableRowCount_result::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_I64) { xfer += iprot->readI64(this->success); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_GetTableRowCount_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("MilvusService_GetTableRowCount_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_I64, 0); xfer += oprot->writeI64(this->success); xfer += oprot->writeFieldEnd(); } else if (this->__isset.e) { xfer += oprot->writeFieldBegin("e", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->e.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_GetTableRowCount_presult::~MilvusService_GetTableRowCount_presult() throw() { } uint32_t MilvusService_GetTableRowCount_presult::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_I64) { xfer += iprot->readI64((*(this->success))); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } MilvusService_ShowTables_args::~MilvusService_ShowTables_args() throw() { } uint32_t MilvusService_ShowTables_args::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } xfer += iprot->skip(ftype); xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_ShowTables_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_ShowTables_args"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_ShowTables_pargs::~MilvusService_ShowTables_pargs() throw() { } uint32_t MilvusService_ShowTables_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_ShowTables_pargs"); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_ShowTables_result::~MilvusService_ShowTables_result() throw() { } uint32_t MilvusService_ShowTables_result::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_LIST) { { this->success.clear(); uint32_t _size121; ::apache::thrift::protocol::TType _etype124; xfer += iprot->readListBegin(_etype124, _size121); this->success.resize(_size121); uint32_t _i125; for (_i125 = 0; _i125 < _size121; ++_i125) { xfer += iprot->readString(this->success[_i125]); } xfer += iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_ShowTables_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("MilvusService_ShowTables_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_LIST, 0); { xfer += oprot->writeListBegin(::apache::thrift::protocol::T_STRING, static_cast(this->success.size())); std::vector ::const_iterator _iter126; for (_iter126 = this->success.begin(); _iter126 != this->success.end(); ++_iter126) { xfer += oprot->writeString((*_iter126)); } xfer += oprot->writeListEnd(); } xfer += oprot->writeFieldEnd(); } else if (this->__isset.e) { xfer += oprot->writeFieldBegin("e", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->e.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_ShowTables_presult::~MilvusService_ShowTables_presult() throw() { } uint32_t MilvusService_ShowTables_presult::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_LIST) { { (*(this->success)).clear(); uint32_t _size127; ::apache::thrift::protocol::TType _etype130; xfer += iprot->readListBegin(_etype130, _size127); (*(this->success)).resize(_size127); uint32_t _i131; for (_i131 = 0; _i131 < _size127; ++_i131) { xfer += iprot->readString((*(this->success))[_i131]); } xfer += iprot->readListEnd(); } this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } MilvusService_Ping_args::~MilvusService_Ping_args() throw() { } uint32_t MilvusService_Ping_args::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 2: if (ftype == ::apache::thrift::protocol::T_STRING) { xfer += iprot->readString(this->cmd); this->__isset.cmd = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_Ping_args::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_Ping_args"); xfer += oprot->writeFieldBegin("cmd", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString(this->cmd); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_Ping_pargs::~MilvusService_Ping_pargs() throw() { } uint32_t MilvusService_Ping_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; ::apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot); xfer += oprot->writeStructBegin("MilvusService_Ping_pargs"); xfer += oprot->writeFieldBegin("cmd", ::apache::thrift::protocol::T_STRING, 2); xfer += oprot->writeString((*(this->cmd))); xfer += oprot->writeFieldEnd(); xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_Ping_result::~MilvusService_Ping_result() throw() { } uint32_t MilvusService_Ping_result::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_STRING) { xfer += iprot->readString(this->success); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } uint32_t MilvusService_Ping_result::write(::apache::thrift::protocol::TProtocol* oprot) const { uint32_t xfer = 0; xfer += oprot->writeStructBegin("MilvusService_Ping_result"); if (this->__isset.success) { xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0); xfer += oprot->writeString(this->success); xfer += oprot->writeFieldEnd(); } else if (this->__isset.e) { xfer += oprot->writeFieldBegin("e", ::apache::thrift::protocol::T_STRUCT, 1); xfer += this->e.write(oprot); xfer += oprot->writeFieldEnd(); } xfer += oprot->writeFieldStop(); xfer += oprot->writeStructEnd(); return xfer; } MilvusService_Ping_presult::~MilvusService_Ping_presult() throw() { } uint32_t MilvusService_Ping_presult::read(::apache::thrift::protocol::TProtocol* iprot) { ::apache::thrift::protocol::TInputRecursionTracker tracker(*iprot); uint32_t xfer = 0; std::string fname; ::apache::thrift::protocol::TType ftype; int16_t fid; xfer += iprot->readStructBegin(fname); using ::apache::thrift::protocol::TProtocolException; while (true) { xfer += iprot->readFieldBegin(fname, ftype, fid); if (ftype == ::apache::thrift::protocol::T_STOP) { break; } switch (fid) { case 0: if (ftype == ::apache::thrift::protocol::T_STRING) { xfer += iprot->readString((*(this->success))); this->__isset.success = true; } else { xfer += iprot->skip(ftype); } break; case 1: if (ftype == ::apache::thrift::protocol::T_STRUCT) { xfer += this->e.read(iprot); this->__isset.e = true; } else { xfer += iprot->skip(ftype); } break; default: xfer += iprot->skip(ftype); break; } xfer += iprot->readFieldEnd(); } xfer += iprot->readStructEnd(); return xfer; } void MilvusServiceClient::CreateTable(const TableSchema& param) { send_CreateTable(param); recv_CreateTable(); } void MilvusServiceClient::send_CreateTable(const TableSchema& param) { int32_t cseqid = 0; oprot_->writeMessageBegin("CreateTable", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_CreateTable_pargs args; args.param = ¶m; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); } void MilvusServiceClient::recv_CreateTable() { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("CreateTable") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } MilvusService_CreateTable_presult result; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.e) { throw result.e; } return; } bool MilvusServiceClient::HasTable(const std::string& table_name) { send_HasTable(table_name); return recv_HasTable(); } void MilvusServiceClient::send_HasTable(const std::string& table_name) { int32_t cseqid = 0; oprot_->writeMessageBegin("HasTable", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_HasTable_pargs args; args.table_name = &table_name; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); } bool MilvusServiceClient::recv_HasTable() { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("HasTable") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } bool _return; MilvusService_HasTable_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { return _return; } if (result.__isset.e) { throw result.e; } throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "HasTable failed: unknown result"); } void MilvusServiceClient::DeleteTable(const std::string& table_name) { send_DeleteTable(table_name); recv_DeleteTable(); } void MilvusServiceClient::send_DeleteTable(const std::string& table_name) { int32_t cseqid = 0; oprot_->writeMessageBegin("DeleteTable", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_DeleteTable_pargs args; args.table_name = &table_name; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); } void MilvusServiceClient::recv_DeleteTable() { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("DeleteTable") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } MilvusService_DeleteTable_presult result; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.e) { throw result.e; } return; } void MilvusServiceClient::BuildIndex(const std::string& table_name) { send_BuildIndex(table_name); recv_BuildIndex(); } void MilvusServiceClient::send_BuildIndex(const std::string& table_name) { int32_t cseqid = 0; oprot_->writeMessageBegin("BuildIndex", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_BuildIndex_pargs args; args.table_name = &table_name; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); } void MilvusServiceClient::recv_BuildIndex() { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("BuildIndex") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } MilvusService_BuildIndex_presult result; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.e) { throw result.e; } return; } void MilvusServiceClient::AddVector(std::vector & _return, const std::string& table_name, const std::vector & record_array) { send_AddVector(table_name, record_array); recv_AddVector(_return); } void MilvusServiceClient::send_AddVector(const std::string& table_name, const std::vector & record_array) { int32_t cseqid = 0; oprot_->writeMessageBegin("AddVector", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_AddVector_pargs args; args.table_name = &table_name; args.record_array = &record_array; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); } void MilvusServiceClient::recv_AddVector(std::vector & _return) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("AddVector") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } MilvusService_AddVector_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled return; } if (result.__isset.e) { throw result.e; } throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "AddVector failed: unknown result"); } void MilvusServiceClient::SearchVector(std::vector & _return, const std::string& table_name, const std::vector & query_record_array, const std::vector & query_range_array, const int64_t topk) { send_SearchVector(table_name, query_record_array, query_range_array, topk); recv_SearchVector(_return); } void MilvusServiceClient::send_SearchVector(const std::string& table_name, const std::vector & query_record_array, const std::vector & query_range_array, const int64_t topk) { int32_t cseqid = 0; oprot_->writeMessageBegin("SearchVector", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_SearchVector_pargs args; args.table_name = &table_name; args.query_record_array = &query_record_array; args.query_range_array = &query_range_array; args.topk = &topk; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); } void MilvusServiceClient::recv_SearchVector(std::vector & _return) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("SearchVector") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } MilvusService_SearchVector_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled return; } if (result.__isset.e) { throw result.e; } throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "SearchVector failed: unknown result"); } void MilvusServiceClient::SearchVector2(std::vector & _return, const std::string& table_name, const std::vector & query_record_array, const std::vector & query_range_array, const int64_t topk) { send_SearchVector2(table_name, query_record_array, query_range_array, topk); recv_SearchVector2(_return); } void MilvusServiceClient::send_SearchVector2(const std::string& table_name, const std::vector & query_record_array, const std::vector & query_range_array, const int64_t topk) { int32_t cseqid = 0; oprot_->writeMessageBegin("SearchVector2", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_SearchVector2_pargs args; args.table_name = &table_name; args.query_record_array = &query_record_array; args.query_range_array = &query_range_array; args.topk = &topk; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); } void MilvusServiceClient::recv_SearchVector2(std::vector & _return) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("SearchVector2") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } MilvusService_SearchVector2_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled return; } if (result.__isset.e) { throw result.e; } throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "SearchVector2 failed: unknown result"); } void MilvusServiceClient::SearchVectorInFiles(std::vector & _return, const std::string& table_name, const std::vector & file_id_array, const std::vector & query_record_array, const std::vector & query_range_array, const int64_t topk) { send_SearchVectorInFiles(table_name, file_id_array, query_record_array, query_range_array, topk); recv_SearchVectorInFiles(_return); } void MilvusServiceClient::send_SearchVectorInFiles(const std::string& table_name, const std::vector & file_id_array, const std::vector & query_record_array, const std::vector & query_range_array, const int64_t topk) { int32_t cseqid = 0; oprot_->writeMessageBegin("SearchVectorInFiles", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_SearchVectorInFiles_pargs args; args.table_name = &table_name; args.file_id_array = &file_id_array; args.query_record_array = &query_record_array; args.query_range_array = &query_range_array; args.topk = &topk; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); } void MilvusServiceClient::recv_SearchVectorInFiles(std::vector & _return) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("SearchVectorInFiles") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } MilvusService_SearchVectorInFiles_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled return; } if (result.__isset.e) { throw result.e; } throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "SearchVectorInFiles failed: unknown result"); } void MilvusServiceClient::DescribeTable(TableSchema& _return, const std::string& table_name) { send_DescribeTable(table_name); recv_DescribeTable(_return); } void MilvusServiceClient::send_DescribeTable(const std::string& table_name) { int32_t cseqid = 0; oprot_->writeMessageBegin("DescribeTable", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_DescribeTable_pargs args; args.table_name = &table_name; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); } void MilvusServiceClient::recv_DescribeTable(TableSchema& _return) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("DescribeTable") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } MilvusService_DescribeTable_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled return; } if (result.__isset.e) { throw result.e; } throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "DescribeTable failed: unknown result"); } int64_t MilvusServiceClient::GetTableRowCount(const std::string& table_name) { send_GetTableRowCount(table_name); return recv_GetTableRowCount(); } void MilvusServiceClient::send_GetTableRowCount(const std::string& table_name) { int32_t cseqid = 0; oprot_->writeMessageBegin("GetTableRowCount", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_GetTableRowCount_pargs args; args.table_name = &table_name; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); } int64_t MilvusServiceClient::recv_GetTableRowCount() { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("GetTableRowCount") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } int64_t _return; MilvusService_GetTableRowCount_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { return _return; } if (result.__isset.e) { throw result.e; } throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "GetTableRowCount failed: unknown result"); } void MilvusServiceClient::ShowTables(std::vector & _return) { send_ShowTables(); recv_ShowTables(_return); } void MilvusServiceClient::send_ShowTables() { int32_t cseqid = 0; oprot_->writeMessageBegin("ShowTables", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_ShowTables_pargs args; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); } void MilvusServiceClient::recv_ShowTables(std::vector & _return) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("ShowTables") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } MilvusService_ShowTables_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled return; } if (result.__isset.e) { throw result.e; } throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "ShowTables failed: unknown result"); } void MilvusServiceClient::Ping(std::string& _return, const std::string& cmd) { send_Ping(cmd); recv_Ping(_return); } void MilvusServiceClient::send_Ping(const std::string& cmd) { int32_t cseqid = 0; oprot_->writeMessageBegin("Ping", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_Ping_pargs args; args.cmd = &cmd; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); } void MilvusServiceClient::recv_Ping(std::string& _return) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; iprot_->readMessageBegin(fname, mtype, rseqid); if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("Ping") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } MilvusService_Ping_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled return; } if (result.__isset.e) { throw result.e; } throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "Ping failed: unknown result"); } bool MilvusServiceProcessor::dispatchCall(::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, const std::string& fname, int32_t seqid, void* callContext) { ProcessMap::iterator pfn; pfn = processMap_.find(fname); if (pfn == processMap_.end()) { iprot->skip(::apache::thrift::protocol::T_STRUCT); iprot->readMessageEnd(); iprot->getTransport()->readEnd(); ::apache::thrift::TApplicationException x(::apache::thrift::TApplicationException::UNKNOWN_METHOD, "Invalid method name: '"+fname+"'"); oprot->writeMessageBegin(fname, ::apache::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); return true; } (this->*(pfn->second))(seqid, iprot, oprot, callContext); return true; } void MilvusServiceProcessor::process_CreateTable(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = NULL; if (this->eventHandler_.get() != NULL) { ctx = this->eventHandler_->getContext("MilvusService.CreateTable", callContext); } ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "MilvusService.CreateTable"); if (this->eventHandler_.get() != NULL) { this->eventHandler_->preRead(ctx, "MilvusService.CreateTable"); } MilvusService_CreateTable_args args; args.read(iprot); iprot->readMessageEnd(); uint32_t bytes = iprot->getTransport()->readEnd(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postRead(ctx, "MilvusService.CreateTable", bytes); } MilvusService_CreateTable_result result; try { iface_->CreateTable(args.param); } catch (Exception &e) { result.e = e; result.__isset.e = true; } catch (const std::exception& e) { if (this->eventHandler_.get() != NULL) { this->eventHandler_->handlerError(ctx, "MilvusService.CreateTable"); } ::apache::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("CreateTable", ::apache::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); return; } if (this->eventHandler_.get() != NULL) { this->eventHandler_->preWrite(ctx, "MilvusService.CreateTable"); } oprot->writeMessageBegin("CreateTable", ::apache::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); bytes = oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postWrite(ctx, "MilvusService.CreateTable", bytes); } } void MilvusServiceProcessor::process_HasTable(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = NULL; if (this->eventHandler_.get() != NULL) { ctx = this->eventHandler_->getContext("MilvusService.HasTable", callContext); } ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "MilvusService.HasTable"); if (this->eventHandler_.get() != NULL) { this->eventHandler_->preRead(ctx, "MilvusService.HasTable"); } MilvusService_HasTable_args args; args.read(iprot); iprot->readMessageEnd(); uint32_t bytes = iprot->getTransport()->readEnd(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postRead(ctx, "MilvusService.HasTable", bytes); } MilvusService_HasTable_result result; try { result.success = iface_->HasTable(args.table_name); result.__isset.success = true; } catch (Exception &e) { result.e = e; result.__isset.e = true; } catch (const std::exception& e) { if (this->eventHandler_.get() != NULL) { this->eventHandler_->handlerError(ctx, "MilvusService.HasTable"); } ::apache::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("HasTable", ::apache::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); return; } if (this->eventHandler_.get() != NULL) { this->eventHandler_->preWrite(ctx, "MilvusService.HasTable"); } oprot->writeMessageBegin("HasTable", ::apache::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); bytes = oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postWrite(ctx, "MilvusService.HasTable", bytes); } } void MilvusServiceProcessor::process_DeleteTable(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = NULL; if (this->eventHandler_.get() != NULL) { ctx = this->eventHandler_->getContext("MilvusService.DeleteTable", callContext); } ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "MilvusService.DeleteTable"); if (this->eventHandler_.get() != NULL) { this->eventHandler_->preRead(ctx, "MilvusService.DeleteTable"); } MilvusService_DeleteTable_args args; args.read(iprot); iprot->readMessageEnd(); uint32_t bytes = iprot->getTransport()->readEnd(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postRead(ctx, "MilvusService.DeleteTable", bytes); } MilvusService_DeleteTable_result result; try { iface_->DeleteTable(args.table_name); } catch (Exception &e) { result.e = e; result.__isset.e = true; } catch (const std::exception& e) { if (this->eventHandler_.get() != NULL) { this->eventHandler_->handlerError(ctx, "MilvusService.DeleteTable"); } ::apache::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("DeleteTable", ::apache::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); return; } if (this->eventHandler_.get() != NULL) { this->eventHandler_->preWrite(ctx, "MilvusService.DeleteTable"); } oprot->writeMessageBegin("DeleteTable", ::apache::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); bytes = oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postWrite(ctx, "MilvusService.DeleteTable", bytes); } } void MilvusServiceProcessor::process_BuildIndex(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = NULL; if (this->eventHandler_.get() != NULL) { ctx = this->eventHandler_->getContext("MilvusService.BuildIndex", callContext); } ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "MilvusService.BuildIndex"); if (this->eventHandler_.get() != NULL) { this->eventHandler_->preRead(ctx, "MilvusService.BuildIndex"); } MilvusService_BuildIndex_args args; args.read(iprot); iprot->readMessageEnd(); uint32_t bytes = iprot->getTransport()->readEnd(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postRead(ctx, "MilvusService.BuildIndex", bytes); } MilvusService_BuildIndex_result result; try { iface_->BuildIndex(args.table_name); } catch (Exception &e) { result.e = e; result.__isset.e = true; } catch (const std::exception& e) { if (this->eventHandler_.get() != NULL) { this->eventHandler_->handlerError(ctx, "MilvusService.BuildIndex"); } ::apache::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("BuildIndex", ::apache::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); return; } if (this->eventHandler_.get() != NULL) { this->eventHandler_->preWrite(ctx, "MilvusService.BuildIndex"); } oprot->writeMessageBegin("BuildIndex", ::apache::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); bytes = oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postWrite(ctx, "MilvusService.BuildIndex", bytes); } } void MilvusServiceProcessor::process_AddVector(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = NULL; if (this->eventHandler_.get() != NULL) { ctx = this->eventHandler_->getContext("MilvusService.AddVector", callContext); } ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "MilvusService.AddVector"); if (this->eventHandler_.get() != NULL) { this->eventHandler_->preRead(ctx, "MilvusService.AddVector"); } MilvusService_AddVector_args args; args.read(iprot); iprot->readMessageEnd(); uint32_t bytes = iprot->getTransport()->readEnd(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postRead(ctx, "MilvusService.AddVector", bytes); } MilvusService_AddVector_result result; try { iface_->AddVector(result.success, args.table_name, args.record_array); result.__isset.success = true; } catch (Exception &e) { result.e = e; result.__isset.e = true; } catch (const std::exception& e) { if (this->eventHandler_.get() != NULL) { this->eventHandler_->handlerError(ctx, "MilvusService.AddVector"); } ::apache::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("AddVector", ::apache::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); return; } if (this->eventHandler_.get() != NULL) { this->eventHandler_->preWrite(ctx, "MilvusService.AddVector"); } oprot->writeMessageBegin("AddVector", ::apache::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); bytes = oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postWrite(ctx, "MilvusService.AddVector", bytes); } } void MilvusServiceProcessor::process_SearchVector(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = NULL; if (this->eventHandler_.get() != NULL) { ctx = this->eventHandler_->getContext("MilvusService.SearchVector", callContext); } ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "MilvusService.SearchVector"); if (this->eventHandler_.get() != NULL) { this->eventHandler_->preRead(ctx, "MilvusService.SearchVector"); } MilvusService_SearchVector_args args; args.read(iprot); iprot->readMessageEnd(); uint32_t bytes = iprot->getTransport()->readEnd(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postRead(ctx, "MilvusService.SearchVector", bytes); } MilvusService_SearchVector_result result; try { iface_->SearchVector(result.success, args.table_name, args.query_record_array, args.query_range_array, args.topk); result.__isset.success = true; } catch (Exception &e) { result.e = e; result.__isset.e = true; } catch (const std::exception& e) { if (this->eventHandler_.get() != NULL) { this->eventHandler_->handlerError(ctx, "MilvusService.SearchVector"); } ::apache::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("SearchVector", ::apache::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); return; } if (this->eventHandler_.get() != NULL) { this->eventHandler_->preWrite(ctx, "MilvusService.SearchVector"); } oprot->writeMessageBegin("SearchVector", ::apache::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); bytes = oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postWrite(ctx, "MilvusService.SearchVector", bytes); } } void MilvusServiceProcessor::process_SearchVector2(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = NULL; if (this->eventHandler_.get() != NULL) { ctx = this->eventHandler_->getContext("MilvusService.SearchVector2", callContext); } ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "MilvusService.SearchVector2"); if (this->eventHandler_.get() != NULL) { this->eventHandler_->preRead(ctx, "MilvusService.SearchVector2"); } MilvusService_SearchVector2_args args; args.read(iprot); iprot->readMessageEnd(); uint32_t bytes = iprot->getTransport()->readEnd(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postRead(ctx, "MilvusService.SearchVector2", bytes); } MilvusService_SearchVector2_result result; try { iface_->SearchVector2(result.success, args.table_name, args.query_record_array, args.query_range_array, args.topk); result.__isset.success = true; } catch (Exception &e) { result.e = e; result.__isset.e = true; } catch (const std::exception& e) { if (this->eventHandler_.get() != NULL) { this->eventHandler_->handlerError(ctx, "MilvusService.SearchVector2"); } ::apache::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("SearchVector2", ::apache::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); return; } if (this->eventHandler_.get() != NULL) { this->eventHandler_->preWrite(ctx, "MilvusService.SearchVector2"); } oprot->writeMessageBegin("SearchVector2", ::apache::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); bytes = oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postWrite(ctx, "MilvusService.SearchVector2", bytes); } } void MilvusServiceProcessor::process_SearchVectorInFiles(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = NULL; if (this->eventHandler_.get() != NULL) { ctx = this->eventHandler_->getContext("MilvusService.SearchVectorInFiles", callContext); } ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "MilvusService.SearchVectorInFiles"); if (this->eventHandler_.get() != NULL) { this->eventHandler_->preRead(ctx, "MilvusService.SearchVectorInFiles"); } MilvusService_SearchVectorInFiles_args args; args.read(iprot); iprot->readMessageEnd(); uint32_t bytes = iprot->getTransport()->readEnd(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postRead(ctx, "MilvusService.SearchVectorInFiles", bytes); } MilvusService_SearchVectorInFiles_result result; try { iface_->SearchVectorInFiles(result.success, args.table_name, args.file_id_array, args.query_record_array, args.query_range_array, args.topk); result.__isset.success = true; } catch (Exception &e) { result.e = e; result.__isset.e = true; } catch (const std::exception& e) { if (this->eventHandler_.get() != NULL) { this->eventHandler_->handlerError(ctx, "MilvusService.SearchVectorInFiles"); } ::apache::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("SearchVectorInFiles", ::apache::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); return; } if (this->eventHandler_.get() != NULL) { this->eventHandler_->preWrite(ctx, "MilvusService.SearchVectorInFiles"); } oprot->writeMessageBegin("SearchVectorInFiles", ::apache::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); bytes = oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postWrite(ctx, "MilvusService.SearchVectorInFiles", bytes); } } void MilvusServiceProcessor::process_DescribeTable(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = NULL; if (this->eventHandler_.get() != NULL) { ctx = this->eventHandler_->getContext("MilvusService.DescribeTable", callContext); } ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "MilvusService.DescribeTable"); if (this->eventHandler_.get() != NULL) { this->eventHandler_->preRead(ctx, "MilvusService.DescribeTable"); } MilvusService_DescribeTable_args args; args.read(iprot); iprot->readMessageEnd(); uint32_t bytes = iprot->getTransport()->readEnd(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postRead(ctx, "MilvusService.DescribeTable", bytes); } MilvusService_DescribeTable_result result; try { iface_->DescribeTable(result.success, args.table_name); result.__isset.success = true; } catch (Exception &e) { result.e = e; result.__isset.e = true; } catch (const std::exception& e) { if (this->eventHandler_.get() != NULL) { this->eventHandler_->handlerError(ctx, "MilvusService.DescribeTable"); } ::apache::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("DescribeTable", ::apache::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); return; } if (this->eventHandler_.get() != NULL) { this->eventHandler_->preWrite(ctx, "MilvusService.DescribeTable"); } oprot->writeMessageBegin("DescribeTable", ::apache::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); bytes = oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postWrite(ctx, "MilvusService.DescribeTable", bytes); } } void MilvusServiceProcessor::process_GetTableRowCount(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = NULL; if (this->eventHandler_.get() != NULL) { ctx = this->eventHandler_->getContext("MilvusService.GetTableRowCount", callContext); } ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "MilvusService.GetTableRowCount"); if (this->eventHandler_.get() != NULL) { this->eventHandler_->preRead(ctx, "MilvusService.GetTableRowCount"); } MilvusService_GetTableRowCount_args args; args.read(iprot); iprot->readMessageEnd(); uint32_t bytes = iprot->getTransport()->readEnd(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postRead(ctx, "MilvusService.GetTableRowCount", bytes); } MilvusService_GetTableRowCount_result result; try { result.success = iface_->GetTableRowCount(args.table_name); result.__isset.success = true; } catch (Exception &e) { result.e = e; result.__isset.e = true; } catch (const std::exception& e) { if (this->eventHandler_.get() != NULL) { this->eventHandler_->handlerError(ctx, "MilvusService.GetTableRowCount"); } ::apache::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("GetTableRowCount", ::apache::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); return; } if (this->eventHandler_.get() != NULL) { this->eventHandler_->preWrite(ctx, "MilvusService.GetTableRowCount"); } oprot->writeMessageBegin("GetTableRowCount", ::apache::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); bytes = oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postWrite(ctx, "MilvusService.GetTableRowCount", bytes); } } void MilvusServiceProcessor::process_ShowTables(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = NULL; if (this->eventHandler_.get() != NULL) { ctx = this->eventHandler_->getContext("MilvusService.ShowTables", callContext); } ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "MilvusService.ShowTables"); if (this->eventHandler_.get() != NULL) { this->eventHandler_->preRead(ctx, "MilvusService.ShowTables"); } MilvusService_ShowTables_args args; args.read(iprot); iprot->readMessageEnd(); uint32_t bytes = iprot->getTransport()->readEnd(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postRead(ctx, "MilvusService.ShowTables", bytes); } MilvusService_ShowTables_result result; try { iface_->ShowTables(result.success); result.__isset.success = true; } catch (Exception &e) { result.e = e; result.__isset.e = true; } catch (const std::exception& e) { if (this->eventHandler_.get() != NULL) { this->eventHandler_->handlerError(ctx, "MilvusService.ShowTables"); } ::apache::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("ShowTables", ::apache::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); return; } if (this->eventHandler_.get() != NULL) { this->eventHandler_->preWrite(ctx, "MilvusService.ShowTables"); } oprot->writeMessageBegin("ShowTables", ::apache::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); bytes = oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postWrite(ctx, "MilvusService.ShowTables", bytes); } } void MilvusServiceProcessor::process_Ping(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext) { void* ctx = NULL; if (this->eventHandler_.get() != NULL) { ctx = this->eventHandler_->getContext("MilvusService.Ping", callContext); } ::apache::thrift::TProcessorContextFreer freer(this->eventHandler_.get(), ctx, "MilvusService.Ping"); if (this->eventHandler_.get() != NULL) { this->eventHandler_->preRead(ctx, "MilvusService.Ping"); } MilvusService_Ping_args args; args.read(iprot); iprot->readMessageEnd(); uint32_t bytes = iprot->getTransport()->readEnd(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postRead(ctx, "MilvusService.Ping", bytes); } MilvusService_Ping_result result; try { iface_->Ping(result.success, args.cmd); result.__isset.success = true; } catch (Exception &e) { result.e = e; result.__isset.e = true; } catch (const std::exception& e) { if (this->eventHandler_.get() != NULL) { this->eventHandler_->handlerError(ctx, "MilvusService.Ping"); } ::apache::thrift::TApplicationException x(e.what()); oprot->writeMessageBegin("Ping", ::apache::thrift::protocol::T_EXCEPTION, seqid); x.write(oprot); oprot->writeMessageEnd(); oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); return; } if (this->eventHandler_.get() != NULL) { this->eventHandler_->preWrite(ctx, "MilvusService.Ping"); } oprot->writeMessageBegin("Ping", ::apache::thrift::protocol::T_REPLY, seqid); result.write(oprot); oprot->writeMessageEnd(); bytes = oprot->getTransport()->writeEnd(); oprot->getTransport()->flush(); if (this->eventHandler_.get() != NULL) { this->eventHandler_->postWrite(ctx, "MilvusService.Ping", bytes); } } ::apache::thrift::stdcxx::shared_ptr< ::apache::thrift::TProcessor > MilvusServiceProcessorFactory::getProcessor(const ::apache::thrift::TConnectionInfo& connInfo) { ::apache::thrift::ReleaseHandler< MilvusServiceIfFactory > cleanup(handlerFactory_); ::apache::thrift::stdcxx::shared_ptr< MilvusServiceIf > handler(handlerFactory_->getHandler(connInfo), cleanup); ::apache::thrift::stdcxx::shared_ptr< ::apache::thrift::TProcessor > processor(new MilvusServiceProcessor(handler)); return processor; } void MilvusServiceConcurrentClient::CreateTable(const TableSchema& param) { int32_t seqid = send_CreateTable(param); recv_CreateTable(seqid); } int32_t MilvusServiceConcurrentClient::send_CreateTable(const TableSchema& param) { int32_t cseqid = this->sync_.generateSeqId(); ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); oprot_->writeMessageBegin("CreateTable", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_CreateTable_pargs args; args.param = ¶m; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); sentry.commit(); return cseqid; } void MilvusServiceConcurrentClient::recv_CreateTable(const int32_t seqid) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; // the read mutex gets dropped and reacquired as part of waitForWork() // The destructor of this sentry wakes up other clients ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); while(true) { if(!this->sync_.getPending(fname, mtype, rseqid)) { iprot_->readMessageBegin(fname, mtype, rseqid); } if(seqid == rseqid) { if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); sentry.commit(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("CreateTable") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); // in a bad state, don't commit using ::apache::thrift::protocol::TProtocolException; throw TProtocolException(TProtocolException::INVALID_DATA); } MilvusService_CreateTable_presult result; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.e) { sentry.commit(); throw result.e; } sentry.commit(); return; } // seqid != rseqid this->sync_.updatePending(fname, mtype, rseqid); // this will temporarily unlock the readMutex, and let other clients get work done this->sync_.waitForWork(seqid); } // end while(true) } bool MilvusServiceConcurrentClient::HasTable(const std::string& table_name) { int32_t seqid = send_HasTable(table_name); return recv_HasTable(seqid); } int32_t MilvusServiceConcurrentClient::send_HasTable(const std::string& table_name) { int32_t cseqid = this->sync_.generateSeqId(); ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); oprot_->writeMessageBegin("HasTable", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_HasTable_pargs args; args.table_name = &table_name; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); sentry.commit(); return cseqid; } bool MilvusServiceConcurrentClient::recv_HasTable(const int32_t seqid) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; // the read mutex gets dropped and reacquired as part of waitForWork() // The destructor of this sentry wakes up other clients ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); while(true) { if(!this->sync_.getPending(fname, mtype, rseqid)) { iprot_->readMessageBegin(fname, mtype, rseqid); } if(seqid == rseqid) { if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); sentry.commit(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("HasTable") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); // in a bad state, don't commit using ::apache::thrift::protocol::TProtocolException; throw TProtocolException(TProtocolException::INVALID_DATA); } bool _return; MilvusService_HasTable_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { sentry.commit(); return _return; } if (result.__isset.e) { sentry.commit(); throw result.e; } // in a bad state, don't commit throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "HasTable failed: unknown result"); } // seqid != rseqid this->sync_.updatePending(fname, mtype, rseqid); // this will temporarily unlock the readMutex, and let other clients get work done this->sync_.waitForWork(seqid); } // end while(true) } void MilvusServiceConcurrentClient::DeleteTable(const std::string& table_name) { int32_t seqid = send_DeleteTable(table_name); recv_DeleteTable(seqid); } int32_t MilvusServiceConcurrentClient::send_DeleteTable(const std::string& table_name) { int32_t cseqid = this->sync_.generateSeqId(); ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); oprot_->writeMessageBegin("DeleteTable", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_DeleteTable_pargs args; args.table_name = &table_name; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); sentry.commit(); return cseqid; } void MilvusServiceConcurrentClient::recv_DeleteTable(const int32_t seqid) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; // the read mutex gets dropped and reacquired as part of waitForWork() // The destructor of this sentry wakes up other clients ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); while(true) { if(!this->sync_.getPending(fname, mtype, rseqid)) { iprot_->readMessageBegin(fname, mtype, rseqid); } if(seqid == rseqid) { if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); sentry.commit(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("DeleteTable") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); // in a bad state, don't commit using ::apache::thrift::protocol::TProtocolException; throw TProtocolException(TProtocolException::INVALID_DATA); } MilvusService_DeleteTable_presult result; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.e) { sentry.commit(); throw result.e; } sentry.commit(); return; } // seqid != rseqid this->sync_.updatePending(fname, mtype, rseqid); // this will temporarily unlock the readMutex, and let other clients get work done this->sync_.waitForWork(seqid); } // end while(true) } void MilvusServiceConcurrentClient::BuildIndex(const std::string& table_name) { int32_t seqid = send_BuildIndex(table_name); recv_BuildIndex(seqid); } int32_t MilvusServiceConcurrentClient::send_BuildIndex(const std::string& table_name) { int32_t cseqid = this->sync_.generateSeqId(); ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); oprot_->writeMessageBegin("BuildIndex", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_BuildIndex_pargs args; args.table_name = &table_name; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); sentry.commit(); return cseqid; } void MilvusServiceConcurrentClient::recv_BuildIndex(const int32_t seqid) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; // the read mutex gets dropped and reacquired as part of waitForWork() // The destructor of this sentry wakes up other clients ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); while(true) { if(!this->sync_.getPending(fname, mtype, rseqid)) { iprot_->readMessageBegin(fname, mtype, rseqid); } if(seqid == rseqid) { if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); sentry.commit(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("BuildIndex") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); // in a bad state, don't commit using ::apache::thrift::protocol::TProtocolException; throw TProtocolException(TProtocolException::INVALID_DATA); } MilvusService_BuildIndex_presult result; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.e) { sentry.commit(); throw result.e; } sentry.commit(); return; } // seqid != rseqid this->sync_.updatePending(fname, mtype, rseqid); // this will temporarily unlock the readMutex, and let other clients get work done this->sync_.waitForWork(seqid); } // end while(true) } void MilvusServiceConcurrentClient::AddVector(std::vector & _return, const std::string& table_name, const std::vector & record_array) { int32_t seqid = send_AddVector(table_name, record_array); recv_AddVector(_return, seqid); } int32_t MilvusServiceConcurrentClient::send_AddVector(const std::string& table_name, const std::vector & record_array) { int32_t cseqid = this->sync_.generateSeqId(); ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); oprot_->writeMessageBegin("AddVector", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_AddVector_pargs args; args.table_name = &table_name; args.record_array = &record_array; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); sentry.commit(); return cseqid; } void MilvusServiceConcurrentClient::recv_AddVector(std::vector & _return, const int32_t seqid) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; // the read mutex gets dropped and reacquired as part of waitForWork() // The destructor of this sentry wakes up other clients ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); while(true) { if(!this->sync_.getPending(fname, mtype, rseqid)) { iprot_->readMessageBegin(fname, mtype, rseqid); } if(seqid == rseqid) { if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); sentry.commit(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("AddVector") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); // in a bad state, don't commit using ::apache::thrift::protocol::TProtocolException; throw TProtocolException(TProtocolException::INVALID_DATA); } MilvusService_AddVector_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled sentry.commit(); return; } if (result.__isset.e) { sentry.commit(); throw result.e; } // in a bad state, don't commit throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "AddVector failed: unknown result"); } // seqid != rseqid this->sync_.updatePending(fname, mtype, rseqid); // this will temporarily unlock the readMutex, and let other clients get work done this->sync_.waitForWork(seqid); } // end while(true) } void MilvusServiceConcurrentClient::SearchVector(std::vector & _return, const std::string& table_name, const std::vector & query_record_array, const std::vector & query_range_array, const int64_t topk) { int32_t seqid = send_SearchVector(table_name, query_record_array, query_range_array, topk); recv_SearchVector(_return, seqid); } int32_t MilvusServiceConcurrentClient::send_SearchVector(const std::string& table_name, const std::vector & query_record_array, const std::vector & query_range_array, const int64_t topk) { int32_t cseqid = this->sync_.generateSeqId(); ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); oprot_->writeMessageBegin("SearchVector", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_SearchVector_pargs args; args.table_name = &table_name; args.query_record_array = &query_record_array; args.query_range_array = &query_range_array; args.topk = &topk; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); sentry.commit(); return cseqid; } void MilvusServiceConcurrentClient::recv_SearchVector(std::vector & _return, const int32_t seqid) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; // the read mutex gets dropped and reacquired as part of waitForWork() // The destructor of this sentry wakes up other clients ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); while(true) { if(!this->sync_.getPending(fname, mtype, rseqid)) { iprot_->readMessageBegin(fname, mtype, rseqid); } if(seqid == rseqid) { if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); sentry.commit(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("SearchVector") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); // in a bad state, don't commit using ::apache::thrift::protocol::TProtocolException; throw TProtocolException(TProtocolException::INVALID_DATA); } MilvusService_SearchVector_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled sentry.commit(); return; } if (result.__isset.e) { sentry.commit(); throw result.e; } // in a bad state, don't commit throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "SearchVector failed: unknown result"); } // seqid != rseqid this->sync_.updatePending(fname, mtype, rseqid); // this will temporarily unlock the readMutex, and let other clients get work done this->sync_.waitForWork(seqid); } // end while(true) } void MilvusServiceConcurrentClient::SearchVector2(std::vector & _return, const std::string& table_name, const std::vector & query_record_array, const std::vector & query_range_array, const int64_t topk) { int32_t seqid = send_SearchVector2(table_name, query_record_array, query_range_array, topk); recv_SearchVector2(_return, seqid); } int32_t MilvusServiceConcurrentClient::send_SearchVector2(const std::string& table_name, const std::vector & query_record_array, const std::vector & query_range_array, const int64_t topk) { int32_t cseqid = this->sync_.generateSeqId(); ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); oprot_->writeMessageBegin("SearchVector2", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_SearchVector2_pargs args; args.table_name = &table_name; args.query_record_array = &query_record_array; args.query_range_array = &query_range_array; args.topk = &topk; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); sentry.commit(); return cseqid; } void MilvusServiceConcurrentClient::recv_SearchVector2(std::vector & _return, const int32_t seqid) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; // the read mutex gets dropped and reacquired as part of waitForWork() // The destructor of this sentry wakes up other clients ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); while(true) { if(!this->sync_.getPending(fname, mtype, rseqid)) { iprot_->readMessageBegin(fname, mtype, rseqid); } if(seqid == rseqid) { if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); sentry.commit(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("SearchVector2") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); // in a bad state, don't commit using ::apache::thrift::protocol::TProtocolException; throw TProtocolException(TProtocolException::INVALID_DATA); } MilvusService_SearchVector2_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled sentry.commit(); return; } if (result.__isset.e) { sentry.commit(); throw result.e; } // in a bad state, don't commit throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "SearchVector2 failed: unknown result"); } // seqid != rseqid this->sync_.updatePending(fname, mtype, rseqid); // this will temporarily unlock the readMutex, and let other clients get work done this->sync_.waitForWork(seqid); } // end while(true) } void MilvusServiceConcurrentClient::SearchVectorInFiles(std::vector & _return, const std::string& table_name, const std::vector & file_id_array, const std::vector & query_record_array, const std::vector & query_range_array, const int64_t topk) { int32_t seqid = send_SearchVectorInFiles(table_name, file_id_array, query_record_array, query_range_array, topk); recv_SearchVectorInFiles(_return, seqid); } int32_t MilvusServiceConcurrentClient::send_SearchVectorInFiles(const std::string& table_name, const std::vector & file_id_array, const std::vector & query_record_array, const std::vector & query_range_array, const int64_t topk) { int32_t cseqid = this->sync_.generateSeqId(); ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); oprot_->writeMessageBegin("SearchVectorInFiles", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_SearchVectorInFiles_pargs args; args.table_name = &table_name; args.file_id_array = &file_id_array; args.query_record_array = &query_record_array; args.query_range_array = &query_range_array; args.topk = &topk; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); sentry.commit(); return cseqid; } void MilvusServiceConcurrentClient::recv_SearchVectorInFiles(std::vector & _return, const int32_t seqid) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; // the read mutex gets dropped and reacquired as part of waitForWork() // The destructor of this sentry wakes up other clients ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); while(true) { if(!this->sync_.getPending(fname, mtype, rseqid)) { iprot_->readMessageBegin(fname, mtype, rseqid); } if(seqid == rseqid) { if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); sentry.commit(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("SearchVectorInFiles") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); // in a bad state, don't commit using ::apache::thrift::protocol::TProtocolException; throw TProtocolException(TProtocolException::INVALID_DATA); } MilvusService_SearchVectorInFiles_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled sentry.commit(); return; } if (result.__isset.e) { sentry.commit(); throw result.e; } // in a bad state, don't commit throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "SearchVectorInFiles failed: unknown result"); } // seqid != rseqid this->sync_.updatePending(fname, mtype, rseqid); // this will temporarily unlock the readMutex, and let other clients get work done this->sync_.waitForWork(seqid); } // end while(true) } void MilvusServiceConcurrentClient::DescribeTable(TableSchema& _return, const std::string& table_name) { int32_t seqid = send_DescribeTable(table_name); recv_DescribeTable(_return, seqid); } int32_t MilvusServiceConcurrentClient::send_DescribeTable(const std::string& table_name) { int32_t cseqid = this->sync_.generateSeqId(); ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); oprot_->writeMessageBegin("DescribeTable", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_DescribeTable_pargs args; args.table_name = &table_name; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); sentry.commit(); return cseqid; } void MilvusServiceConcurrentClient::recv_DescribeTable(TableSchema& _return, const int32_t seqid) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; // the read mutex gets dropped and reacquired as part of waitForWork() // The destructor of this sentry wakes up other clients ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); while(true) { if(!this->sync_.getPending(fname, mtype, rseqid)) { iprot_->readMessageBegin(fname, mtype, rseqid); } if(seqid == rseqid) { if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); sentry.commit(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("DescribeTable") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); // in a bad state, don't commit using ::apache::thrift::protocol::TProtocolException; throw TProtocolException(TProtocolException::INVALID_DATA); } MilvusService_DescribeTable_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled sentry.commit(); return; } if (result.__isset.e) { sentry.commit(); throw result.e; } // in a bad state, don't commit throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "DescribeTable failed: unknown result"); } // seqid != rseqid this->sync_.updatePending(fname, mtype, rseqid); // this will temporarily unlock the readMutex, and let other clients get work done this->sync_.waitForWork(seqid); } // end while(true) } int64_t MilvusServiceConcurrentClient::GetTableRowCount(const std::string& table_name) { int32_t seqid = send_GetTableRowCount(table_name); return recv_GetTableRowCount(seqid); } int32_t MilvusServiceConcurrentClient::send_GetTableRowCount(const std::string& table_name) { int32_t cseqid = this->sync_.generateSeqId(); ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); oprot_->writeMessageBegin("GetTableRowCount", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_GetTableRowCount_pargs args; args.table_name = &table_name; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); sentry.commit(); return cseqid; } int64_t MilvusServiceConcurrentClient::recv_GetTableRowCount(const int32_t seqid) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; // the read mutex gets dropped and reacquired as part of waitForWork() // The destructor of this sentry wakes up other clients ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); while(true) { if(!this->sync_.getPending(fname, mtype, rseqid)) { iprot_->readMessageBegin(fname, mtype, rseqid); } if(seqid == rseqid) { if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); sentry.commit(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("GetTableRowCount") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); // in a bad state, don't commit using ::apache::thrift::protocol::TProtocolException; throw TProtocolException(TProtocolException::INVALID_DATA); } int64_t _return; MilvusService_GetTableRowCount_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { sentry.commit(); return _return; } if (result.__isset.e) { sentry.commit(); throw result.e; } // in a bad state, don't commit throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "GetTableRowCount failed: unknown result"); } // seqid != rseqid this->sync_.updatePending(fname, mtype, rseqid); // this will temporarily unlock the readMutex, and let other clients get work done this->sync_.waitForWork(seqid); } // end while(true) } void MilvusServiceConcurrentClient::ShowTables(std::vector & _return) { int32_t seqid = send_ShowTables(); recv_ShowTables(_return, seqid); } int32_t MilvusServiceConcurrentClient::send_ShowTables() { int32_t cseqid = this->sync_.generateSeqId(); ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); oprot_->writeMessageBegin("ShowTables", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_ShowTables_pargs args; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); sentry.commit(); return cseqid; } void MilvusServiceConcurrentClient::recv_ShowTables(std::vector & _return, const int32_t seqid) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; // the read mutex gets dropped and reacquired as part of waitForWork() // The destructor of this sentry wakes up other clients ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); while(true) { if(!this->sync_.getPending(fname, mtype, rseqid)) { iprot_->readMessageBegin(fname, mtype, rseqid); } if(seqid == rseqid) { if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); sentry.commit(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("ShowTables") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); // in a bad state, don't commit using ::apache::thrift::protocol::TProtocolException; throw TProtocolException(TProtocolException::INVALID_DATA); } MilvusService_ShowTables_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled sentry.commit(); return; } if (result.__isset.e) { sentry.commit(); throw result.e; } // in a bad state, don't commit throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "ShowTables failed: unknown result"); } // seqid != rseqid this->sync_.updatePending(fname, mtype, rseqid); // this will temporarily unlock the readMutex, and let other clients get work done this->sync_.waitForWork(seqid); } // end while(true) } void MilvusServiceConcurrentClient::Ping(std::string& _return, const std::string& cmd) { int32_t seqid = send_Ping(cmd); recv_Ping(_return, seqid); } int32_t MilvusServiceConcurrentClient::send_Ping(const std::string& cmd) { int32_t cseqid = this->sync_.generateSeqId(); ::apache::thrift::async::TConcurrentSendSentry sentry(&this->sync_); oprot_->writeMessageBegin("Ping", ::apache::thrift::protocol::T_CALL, cseqid); MilvusService_Ping_pargs args; args.cmd = &cmd; args.write(oprot_); oprot_->writeMessageEnd(); oprot_->getTransport()->writeEnd(); oprot_->getTransport()->flush(); sentry.commit(); return cseqid; } void MilvusServiceConcurrentClient::recv_Ping(std::string& _return, const int32_t seqid) { int32_t rseqid = 0; std::string fname; ::apache::thrift::protocol::TMessageType mtype; // the read mutex gets dropped and reacquired as part of waitForWork() // The destructor of this sentry wakes up other clients ::apache::thrift::async::TConcurrentRecvSentry sentry(&this->sync_, seqid); while(true) { if(!this->sync_.getPending(fname, mtype, rseqid)) { iprot_->readMessageBegin(fname, mtype, rseqid); } if(seqid == rseqid) { if (mtype == ::apache::thrift::protocol::T_EXCEPTION) { ::apache::thrift::TApplicationException x; x.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); sentry.commit(); throw x; } if (mtype != ::apache::thrift::protocol::T_REPLY) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); } if (fname.compare("Ping") != 0) { iprot_->skip(::apache::thrift::protocol::T_STRUCT); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); // in a bad state, don't commit using ::apache::thrift::protocol::TProtocolException; throw TProtocolException(TProtocolException::INVALID_DATA); } MilvusService_Ping_presult result; result.success = &_return; result.read(iprot_); iprot_->readMessageEnd(); iprot_->getTransport()->readEnd(); if (result.__isset.success) { // _return pointer has now been filled sentry.commit(); return; } if (result.__isset.e) { sentry.commit(); throw result.e; } // in a bad state, don't commit throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "Ping failed: unknown result"); } // seqid != rseqid this->sync_.updatePending(fname, mtype, rseqid); // this will temporarily unlock the readMutex, and let other clients get work done this->sync_.waitForWork(seqid); } // end while(true) } }} // namespace