/* * Copyright 2025 coze-dev Authors * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ // Code generated by thriftgo (0.4.1). DO NOT EDIT. package knowledge import ( "database/sql" "database/sql/driver" "fmt" "github.com/apache/thrift/lib/go/thrift" ) // type type FormatType int64 const ( // Text FormatType_Text FormatType = 0 // table FormatType_Table FormatType = 1 // image FormatType_Image FormatType = 2 // database FormatType_Database FormatType = 3 ) func (p FormatType) String() string { switch p { case FormatType_Text: return "Text" case FormatType_Table: return "Table" case FormatType_Image: return "Image" case FormatType_Database: return "Database" } return "" } func FormatTypeFromString(s string) (FormatType, error) { switch s { case "Text": return FormatType_Text, nil case "Table": return FormatType_Table, nil case "Image": return FormatType_Image, nil case "Database": return FormatType_Database, nil } return FormatType(0), fmt.Errorf("not a valid FormatType string") } func FormatTypePtr(v FormatType) *FormatType { return &v } func (p *FormatType) Scan(value interface{}) (err error) { var result sql.NullInt64 err = result.Scan(value) *p = FormatType(result.Int64) return } func (p *FormatType) Value() (driver.Value, error) { if p == nil { return nil, nil } return int64(*p), nil } type ChunkType int64 const ( ChunkType_DefaultChunk ChunkType = 0 ChunkType_CustomChunk ChunkType = 1 ChunkType_LevelChunk ChunkType = 2 ) func (p ChunkType) String() string { switch p { case ChunkType_DefaultChunk: return "DefaultChunk" case ChunkType_CustomChunk: return "CustomChunk" case ChunkType_LevelChunk: return "LevelChunk" } return "" } func ChunkTypeFromString(s string) (ChunkType, error) { switch s { case "DefaultChunk": return ChunkType_DefaultChunk, nil case "CustomChunk": return ChunkType_CustomChunk, nil case "LevelChunk": return ChunkType_LevelChunk, nil } return ChunkType(0), fmt.Errorf("not a valid ChunkType string") } func ChunkTypePtr(v ChunkType) *ChunkType { return &v } func (p *ChunkType) Scan(value interface{}) (err error) { var result sql.NullInt64 err = result.Scan(value) *p = ChunkType(result.Int64) return } func (p *ChunkType) Value() (driver.Value, error) { if p == nil { return nil, nil } return int64(*p), nil } type ContentSchema int64 const ( ContentSchema_DefaultSchema ContentSchema = 0 ContentSchema_LinkReaderSchema ContentSchema = 1 ) func (p ContentSchema) String() string { switch p { case ContentSchema_DefaultSchema: return "DefaultSchema" case ContentSchema_LinkReaderSchema: return "LinkReaderSchema" } return "" } func ContentSchemaFromString(s string) (ContentSchema, error) { switch s { case "DefaultSchema": return ContentSchema_DefaultSchema, nil case "LinkReaderSchema": return ContentSchema_LinkReaderSchema, nil } return ContentSchema(0), fmt.Errorf("not a valid ContentSchema string") } func ContentSchemaPtr(v ContentSchema) *ContentSchema { return &v } func (p *ContentSchema) Scan(value interface{}) (err error) { var result sql.NullInt64 err = result.Scan(value) *p = ContentSchema(result.Int64) return } func (p *ContentSchema) Value() (driver.Value, error) { if p == nil { return nil, nil } return int64(*p), nil } type CaptionType int64 const ( // intelligent annotation CaptionType_Auto CaptionType = 0 // manual annotation CaptionType_Manual CaptionType = 1 ) func (p CaptionType) String() string { switch p { case CaptionType_Auto: return "Auto" case CaptionType_Manual: return "Manual" } return "" } func CaptionTypeFromString(s string) (CaptionType, error) { switch s { case "Auto": return CaptionType_Auto, nil case "Manual": return CaptionType_Manual, nil } return CaptionType(0), fmt.Errorf("not a valid CaptionType string") } func CaptionTypePtr(v CaptionType) *CaptionType { return &v } func (p *CaptionType) Scan(value interface{}) (err error) { var result sql.NullInt64 err = result.Scan(value) *p = CaptionType(result.Int64) return } func (p *CaptionType) Value() (driver.Value, error) { if p == nil { return nil, nil } return int64(*p), nil } type DocumentStatus int64 const ( // Uploading DocumentStatus_Processing DocumentStatus = 0 // take effect DocumentStatus_Enable DocumentStatus = 1 // failure DocumentStatus_Disable DocumentStatus = 2 // delete DocumentStatus_Deleted DocumentStatus = 3 // In rescaling, the caller is not aware of the state DocumentStatus_Resegment DocumentStatus = 4 // Refreshing (will be deleted after successful refresh) DocumentStatus_Refreshing DocumentStatus = 5 // fail DocumentStatus_Failed DocumentStatus = 9 ) func (p DocumentStatus) String() string { switch p { case DocumentStatus_Processing: return "Processing" case DocumentStatus_Enable: return "Enable" case DocumentStatus_Disable: return "Disable" case DocumentStatus_Deleted: return "Deleted" case DocumentStatus_Resegment: return "Resegment" case DocumentStatus_Refreshing: return "Refreshing" case DocumentStatus_Failed: return "Failed" } return "" } func DocumentStatusFromString(s string) (DocumentStatus, error) { switch s { case "Processing": return DocumentStatus_Processing, nil case "Enable": return DocumentStatus_Enable, nil case "Disable": return DocumentStatus_Disable, nil case "Deleted": return DocumentStatus_Deleted, nil case "Resegment": return DocumentStatus_Resegment, nil case "Refreshing": return DocumentStatus_Refreshing, nil case "Failed": return DocumentStatus_Failed, nil } return DocumentStatus(0), fmt.Errorf("not a valid DocumentStatus string") } func DocumentStatusPtr(v DocumentStatus) *DocumentStatus { return &v } func (p *DocumentStatus) Scan(value interface{}) (err error) { var result sql.NullInt64 err = result.Scan(value) *p = DocumentStatus(result.Int64) return } func (p *DocumentStatus) Value() (driver.Value, error) { if p == nil { return nil, nil } return int64(*p), nil } type DocumentSource int64 const ( // local file upload DocumentSource_Document DocumentSource = 0 // custom type DocumentSource_Custom DocumentSource = 2 ) func (p DocumentSource) String() string { switch p { case DocumentSource_Document: return "Document" case DocumentSource_Custom: return "Custom" } return "" } func DocumentSourceFromString(s string) (DocumentSource, error) { switch s { case "Document": return DocumentSource_Document, nil case "Custom": return DocumentSource_Custom, nil } return DocumentSource(0), fmt.Errorf("not a valid DocumentSource string") } func DocumentSourcePtr(v DocumentSource) *DocumentSource { return &v } func (p *DocumentSource) Scan(value interface{}) (err error) { var result sql.NullInt64 err = result.Scan(value) *p = DocumentSource(result.Int64) return } func (p *DocumentSource) Value() (driver.Value, error) { if p == nil { return nil, nil } return int64(*p), nil } type ParsingType int64 const ( //fast parse ParsingType_FastParsing ParsingType = 0 //accurate analysis ParsingType_AccurateParsing ParsingType = 1 ) func (p ParsingType) String() string { switch p { case ParsingType_FastParsing: return "FastParsing" case ParsingType_AccurateParsing: return "AccurateParsing" } return "" } func ParsingTypeFromString(s string) (ParsingType, error) { switch s { case "FastParsing": return ParsingType_FastParsing, nil case "AccurateParsing": return ParsingType_AccurateParsing, nil } return ParsingType(0), fmt.Errorf("not a valid ParsingType string") } func ParsingTypePtr(v ParsingType) *ParsingType { return &v } func (p *ParsingType) Scan(value interface{}) (err error) { var result sql.NullInt64 err = result.Scan(value) *p = ParsingType(result.Int64) return } func (p *ParsingType) Value() (driver.Value, error) { if p == nil { return nil, nil } return int64(*p), nil } // sort field type OrderField int64 const ( OrderField_CreateTime OrderField = 1 OrderField_UpdateTime OrderField = 2 ) func (p OrderField) String() string { switch p { case OrderField_CreateTime: return "CreateTime" case OrderField_UpdateTime: return "UpdateTime" } return "" } func OrderFieldFromString(s string) (OrderField, error) { switch s { case "CreateTime": return OrderField_CreateTime, nil case "UpdateTime": return OrderField_UpdateTime, nil } return OrderField(0), fmt.Errorf("not a valid OrderField string") } func OrderFieldPtr(v OrderField) *OrderField { return &v } func (p *OrderField) Scan(value interface{}) (err error) { var result sql.NullInt64 err = result.Scan(value) *p = OrderField(result.Int64) return } func (p *OrderField) Value() (driver.Value, error) { if p == nil { return nil, nil } return int64(*p), nil } // OrderType type OrderType int64 const ( OrderType_Desc OrderType = 1 OrderType_Asc OrderType = 2 ) func (p OrderType) String() string { switch p { case OrderType_Desc: return "Desc" case OrderType_Asc: return "Asc" } return "" } func OrderTypeFromString(s string) (OrderType, error) { switch s { case "Desc": return OrderType_Desc, nil case "Asc": return OrderType_Asc, nil } return OrderType(0), fmt.Errorf("not a valid OrderType string") } func OrderTypePtr(v OrderType) *OrderType { return &v } func (p *OrderType) Scan(value interface{}) (err error) { var result sql.NullInt64 err = result.Scan(value) *p = OrderType(result.Int64) return } func (p *OrderType) Value() (driver.Value, error) { if p == nil { return nil, nil } return int64(*p), nil } type ReviewStatus int64 const ( // Processing ReviewStatus_Processing ReviewStatus = 0 // Completed. ReviewStatus_Enable ReviewStatus = 1 // fail ReviewStatus_Failed ReviewStatus = 2 // fail ReviewStatus_ForceStop ReviewStatus = 3 ) func (p ReviewStatus) String() string { switch p { case ReviewStatus_Processing: return "Processing" case ReviewStatus_Enable: return "Enable" case ReviewStatus_Failed: return "Failed" case ReviewStatus_ForceStop: return "ForceStop" } return "" } func ReviewStatusFromString(s string) (ReviewStatus, error) { switch s { case "Processing": return ReviewStatus_Processing, nil case "Enable": return ReviewStatus_Enable, nil case "Failed": return ReviewStatus_Failed, nil case "ForceStop": return ReviewStatus_ForceStop, nil } return ReviewStatus(0), fmt.Errorf("not a valid ReviewStatus string") } func ReviewStatusPtr(v ReviewStatus) *ReviewStatus { return &v } func (p *ReviewStatus) Scan(value interface{}) (err error) { var result sql.NullInt64 err = result.Scan(value) *p = ReviewStatus(result.Int64) return } func (p *ReviewStatus) Value() (driver.Value, error) { if p == nil { return nil, nil } return int64(*p), nil } type ColumnType int64 const ( ColumnType_Unknown ColumnType = 0 // Text ColumnType_Text ColumnType = 1 // number ColumnType_Number ColumnType = 2 // time ColumnType_Date ColumnType = 3 // float ColumnType_Float ColumnType = 4 // bool ColumnType_Boolean ColumnType = 5 // picture ColumnType_Image ColumnType = 6 ) func (p ColumnType) String() string { switch p { case ColumnType_Unknown: return "Unknown" case ColumnType_Text: return "Text" case ColumnType_Number: return "Number" case ColumnType_Date: return "Date" case ColumnType_Float: return "Float" case ColumnType_Boolean: return "Boolean" case ColumnType_Image: return "Image" } return "" } func ColumnTypeFromString(s string) (ColumnType, error) { switch s { case "Unknown": return ColumnType_Unknown, nil case "Text": return ColumnType_Text, nil case "Number": return ColumnType_Number, nil case "Date": return ColumnType_Date, nil case "Float": return ColumnType_Float, nil case "Boolean": return ColumnType_Boolean, nil case "Image": return ColumnType_Image, nil } return ColumnType(0), fmt.Errorf("not a valid ColumnType string") } func ColumnTypePtr(v ColumnType) *ColumnType { return &v } func (p *ColumnType) Scan(value interface{}) (err error) { var result sql.NullInt64 err = result.Scan(value) *p = ColumnType(result.Int64) return } func (p *ColumnType) Value() (driver.Value, error) { if p == nil { return nil, nil } return int64(*p), nil } type DatasetStatus int64 const ( DatasetStatus_DatasetProcessing DatasetStatus = 0 DatasetStatus_DatasetReady DatasetStatus = 1 // soft delete DatasetStatus_DatasetDeleted DatasetStatus = 2 // Do not enable DatasetStatus_DatasetForbid DatasetStatus = 3 DatasetStatus_DatasetFailed DatasetStatus = 9 ) func (p DatasetStatus) String() string { switch p { case DatasetStatus_DatasetProcessing: return "DatasetProcessing" case DatasetStatus_DatasetReady: return "DatasetReady" case DatasetStatus_DatasetDeleted: return "DatasetDeleted" case DatasetStatus_DatasetForbid: return "DatasetForbid" case DatasetStatus_DatasetFailed: return "DatasetFailed" } return "" } func DatasetStatusFromString(s string) (DatasetStatus, error) { switch s { case "DatasetProcessing": return DatasetStatus_DatasetProcessing, nil case "DatasetReady": return DatasetStatus_DatasetReady, nil case "DatasetDeleted": return DatasetStatus_DatasetDeleted, nil case "DatasetForbid": return DatasetStatus_DatasetForbid, nil case "DatasetFailed": return DatasetStatus_DatasetFailed, nil } return DatasetStatus(0), fmt.Errorf("not a valid DatasetStatus string") } func DatasetStatusPtr(v DatasetStatus) *DatasetStatus { return &v } func (p *DatasetStatus) Scan(value interface{}) (err error) { var result sql.NullInt64 err = result.Scan(value) *p = DatasetStatus(result.Int64) return } func (p *DatasetStatus) Value() (driver.Value, error) { if p == nil { return nil, nil } return int64(*p), nil } type ChunkStrategy struct { // A separator, such as a period Separator string `thrift:"separator,1" form:"separator" json:"separator" query:"separator"` // Maximum number of tokens for sharding MaxTokens int64 `thrift:"max_tokens,2" form:"max_tokens" json:"max_tokens" query:"max_tokens"` // Replace consecutive spaces, newlines, and tabs RemoveExtraSpaces bool `thrift:"remove_extra_spaces,3" form:"remove_extra_spaces" json:"remove_extra_spaces" query:"remove_extra_spaces"` // Remove URL and email RemoveUrlsEmails bool `thrift:"remove_urls_emails,4" form:"remove_urls_emails" json:"remove_urls_emails" query:"remove_urls_emails"` // If 0, the configuration of the above fields is not used ChunkType ChunkType `thrift:"chunk_type,5" form:"chunk_type" json:"chunk_type" query:"chunk_type"` // Image type, image description text annotation method CaptionType *CaptionType `thrift:"caption_type,7,optional" form:"caption_type" json:"caption_type,omitempty" query:"caption_type"` //segmented overlap Overlap *int64 `thrift:"overlap,8,optional" form:"overlap" json:"overlap,omitempty" query:"overlap"` //Maximum number of levels (effective when segmented by level) MaxLevel *int64 `thrift:"max_level,9,optional" form:"max_level" json:"max_level,omitempty" query:"max_level"` //Slice preserves level headers (effective when segmented by level) SaveTitle *bool `thrift:"save_title,10,optional" form:"save_title" json:"save_title,omitempty" query:"save_title"` } func NewChunkStrategy() *ChunkStrategy { return &ChunkStrategy{} } func (p *ChunkStrategy) InitDefault() { } func (p *ChunkStrategy) GetSeparator() (v string) { return p.Separator } func (p *ChunkStrategy) GetMaxTokens() (v int64) { return p.MaxTokens } func (p *ChunkStrategy) GetRemoveExtraSpaces() (v bool) { return p.RemoveExtraSpaces } func (p *ChunkStrategy) GetRemoveUrlsEmails() (v bool) { return p.RemoveUrlsEmails } func (p *ChunkStrategy) GetChunkType() (v ChunkType) { return p.ChunkType } var ChunkStrategy_CaptionType_DEFAULT CaptionType func (p *ChunkStrategy) GetCaptionType() (v CaptionType) { if !p.IsSetCaptionType() { return ChunkStrategy_CaptionType_DEFAULT } return *p.CaptionType } var ChunkStrategy_Overlap_DEFAULT int64 func (p *ChunkStrategy) GetOverlap() (v int64) { if !p.IsSetOverlap() { return ChunkStrategy_Overlap_DEFAULT } return *p.Overlap } var ChunkStrategy_MaxLevel_DEFAULT int64 func (p *ChunkStrategy) GetMaxLevel() (v int64) { if !p.IsSetMaxLevel() { return ChunkStrategy_MaxLevel_DEFAULT } return *p.MaxLevel } var ChunkStrategy_SaveTitle_DEFAULT bool func (p *ChunkStrategy) GetSaveTitle() (v bool) { if !p.IsSetSaveTitle() { return ChunkStrategy_SaveTitle_DEFAULT } return *p.SaveTitle } var fieldIDToName_ChunkStrategy = map[int16]string{ 1: "separator", 2: "max_tokens", 3: "remove_extra_spaces", 4: "remove_urls_emails", 5: "chunk_type", 7: "caption_type", 8: "overlap", 9: "max_level", 10: "save_title", } func (p *ChunkStrategy) IsSetCaptionType() bool { return p.CaptionType != nil } func (p *ChunkStrategy) IsSetOverlap() bool { return p.Overlap != nil } func (p *ChunkStrategy) IsSetMaxLevel() bool { return p.MaxLevel != nil } func (p *ChunkStrategy) IsSetSaveTitle() bool { return p.SaveTitle != nil } func (p *ChunkStrategy) Read(iprot thrift.TProtocol) (err error) { var fieldTypeId thrift.TType var fieldId int16 if _, err = iprot.ReadStructBegin(); err != nil { goto ReadStructBeginError } for { _, fieldTypeId, fieldId, err = iprot.ReadFieldBegin() if err != nil { goto ReadFieldBeginError } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.STRING { if err = p.ReadField1(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 2: if fieldTypeId == thrift.I64 { if err = p.ReadField2(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 3: if fieldTypeId == thrift.BOOL { if err = p.ReadField3(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 4: if fieldTypeId == thrift.BOOL { if err = p.ReadField4(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 5: if fieldTypeId == thrift.I32 { if err = p.ReadField5(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 7: if fieldTypeId == thrift.I32 { if err = p.ReadField7(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 8: if fieldTypeId == thrift.I64 { if err = p.ReadField8(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 9: if fieldTypeId == thrift.I64 { if err = p.ReadField9(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 10: if fieldTypeId == thrift.BOOL { if err = p.ReadField10(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } default: if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } } if err = iprot.ReadFieldEnd(); err != nil { goto ReadFieldEndError } } if err = iprot.ReadStructEnd(); err != nil { goto ReadStructEndError } return nil ReadStructBeginError: return thrift.PrependError(fmt.Sprintf("%T read struct begin error: ", p), err) ReadFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T read field %d begin error: ", p, fieldId), err) ReadFieldError: return thrift.PrependError(fmt.Sprintf("%T read field %d '%s' error: ", p, fieldId, fieldIDToName_ChunkStrategy[fieldId]), err) SkipFieldError: return thrift.PrependError(fmt.Sprintf("%T field %d skip type %d error: ", p, fieldId, fieldTypeId), err) ReadFieldEndError: return thrift.PrependError(fmt.Sprintf("%T read field end error", p), err) ReadStructEndError: return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } func (p *ChunkStrategy) ReadField1(iprot thrift.TProtocol) error { var _field string if v, err := iprot.ReadString(); err != nil { return err } else { _field = v } p.Separator = _field return nil } func (p *ChunkStrategy) ReadField2(iprot thrift.TProtocol) error { var _field int64 if v, err := iprot.ReadI64(); err != nil { return err } else { _field = v } p.MaxTokens = _field return nil } func (p *ChunkStrategy) ReadField3(iprot thrift.TProtocol) error { var _field bool if v, err := iprot.ReadBool(); err != nil { return err } else { _field = v } p.RemoveExtraSpaces = _field return nil } func (p *ChunkStrategy) ReadField4(iprot thrift.TProtocol) error { var _field bool if v, err := iprot.ReadBool(); err != nil { return err } else { _field = v } p.RemoveUrlsEmails = _field return nil } func (p *ChunkStrategy) ReadField5(iprot thrift.TProtocol) error { var _field ChunkType if v, err := iprot.ReadI32(); err != nil { return err } else { _field = ChunkType(v) } p.ChunkType = _field return nil } func (p *ChunkStrategy) ReadField7(iprot thrift.TProtocol) error { var _field *CaptionType if v, err := iprot.ReadI32(); err != nil { return err } else { tmp := CaptionType(v) _field = &tmp } p.CaptionType = _field return nil } func (p *ChunkStrategy) ReadField8(iprot thrift.TProtocol) error { var _field *int64 if v, err := iprot.ReadI64(); err != nil { return err } else { _field = &v } p.Overlap = _field return nil } func (p *ChunkStrategy) ReadField9(iprot thrift.TProtocol) error { var _field *int64 if v, err := iprot.ReadI64(); err != nil { return err } else { _field = &v } p.MaxLevel = _field return nil } func (p *ChunkStrategy) ReadField10(iprot thrift.TProtocol) error { var _field *bool if v, err := iprot.ReadBool(); err != nil { return err } else { _field = &v } p.SaveTitle = _field return nil } func (p *ChunkStrategy) Write(oprot thrift.TProtocol) (err error) { var fieldId int16 if err = oprot.WriteStructBegin("ChunkStrategy"); err != nil { goto WriteStructBeginError } if p != nil { if err = p.writeField1(oprot); err != nil { fieldId = 1 goto WriteFieldError } if err = p.writeField2(oprot); err != nil { fieldId = 2 goto WriteFieldError } if err = p.writeField3(oprot); err != nil { fieldId = 3 goto WriteFieldError } if err = p.writeField4(oprot); err != nil { fieldId = 4 goto WriteFieldError } if err = p.writeField5(oprot); err != nil { fieldId = 5 goto WriteFieldError } if err = p.writeField7(oprot); err != nil { fieldId = 7 goto WriteFieldError } if err = p.writeField8(oprot); err != nil { fieldId = 8 goto WriteFieldError } if err = p.writeField9(oprot); err != nil { fieldId = 9 goto WriteFieldError } if err = p.writeField10(oprot); err != nil { fieldId = 10 goto WriteFieldError } } if err = oprot.WriteFieldStop(); err != nil { goto WriteFieldStopError } if err = oprot.WriteStructEnd(); err != nil { goto WriteStructEndError } return nil WriteStructBeginError: return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) WriteFieldError: return thrift.PrependError(fmt.Sprintf("%T write field %d error: ", p, fieldId), err) WriteFieldStopError: return thrift.PrependError(fmt.Sprintf("%T write field stop error: ", p), err) WriteStructEndError: return thrift.PrependError(fmt.Sprintf("%T write struct end error: ", p), err) } func (p *ChunkStrategy) writeField1(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("separator", thrift.STRING, 1); err != nil { goto WriteFieldBeginError } if err := oprot.WriteString(p.Separator); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 1 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 1 end error: ", p), err) } func (p *ChunkStrategy) writeField2(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("max_tokens", thrift.I64, 2); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI64(p.MaxTokens); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 2 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 2 end error: ", p), err) } func (p *ChunkStrategy) writeField3(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("remove_extra_spaces", thrift.BOOL, 3); err != nil { goto WriteFieldBeginError } if err := oprot.WriteBool(p.RemoveExtraSpaces); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 3 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 3 end error: ", p), err) } func (p *ChunkStrategy) writeField4(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("remove_urls_emails", thrift.BOOL, 4); err != nil { goto WriteFieldBeginError } if err := oprot.WriteBool(p.RemoveUrlsEmails); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 4 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 4 end error: ", p), err) } func (p *ChunkStrategy) writeField5(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("chunk_type", thrift.I32, 5); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(int32(p.ChunkType)); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 5 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 5 end error: ", p), err) } func (p *ChunkStrategy) writeField7(oprot thrift.TProtocol) (err error) { if p.IsSetCaptionType() { if err = oprot.WriteFieldBegin("caption_type", thrift.I32, 7); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(int32(*p.CaptionType)); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 7 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 7 end error: ", p), err) } func (p *ChunkStrategy) writeField8(oprot thrift.TProtocol) (err error) { if p.IsSetOverlap() { if err = oprot.WriteFieldBegin("overlap", thrift.I64, 8); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI64(*p.Overlap); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 8 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 8 end error: ", p), err) } func (p *ChunkStrategy) writeField9(oprot thrift.TProtocol) (err error) { if p.IsSetMaxLevel() { if err = oprot.WriteFieldBegin("max_level", thrift.I64, 9); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI64(*p.MaxLevel); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 9 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 9 end error: ", p), err) } func (p *ChunkStrategy) writeField10(oprot thrift.TProtocol) (err error) { if p.IsSetSaveTitle() { if err = oprot.WriteFieldBegin("save_title", thrift.BOOL, 10); err != nil { goto WriteFieldBeginError } if err := oprot.WriteBool(*p.SaveTitle); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 10 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 10 end error: ", p), err) } func (p *ChunkStrategy) String() string { if p == nil { return "" } return fmt.Sprintf("ChunkStrategy(%+v)", *p) } type ParsingStrategy struct { //parse type ParsingType *ParsingType `thrift:"parsing_type,1,optional" form:"parsing_type" json:"parsing_type,omitempty" query:"parsing_type"` //Whether to enable image element extraction (effective when accurately parsing) ImageExtraction *bool `thrift:"image_extraction,2,optional" form:"image_extraction" json:"image_extraction,omitempty" query:"image_extraction"` //Whether to enable table element extraction (effective when accurately parsing) TableExtraction *bool `thrift:"table_extraction,3,optional" form:"table_extraction" json:"table_extraction,omitempty" query:"table_extraction"` //Whether to turn on picture OCR (effective when accurate analysis) ImageOcr *bool `thrift:"image_ocr,4,optional" form:"image_ocr" json:"image_ocr,omitempty" query:"image_ocr"` } func NewParsingStrategy() *ParsingStrategy { return &ParsingStrategy{} } func (p *ParsingStrategy) InitDefault() { } var ParsingStrategy_ParsingType_DEFAULT ParsingType func (p *ParsingStrategy) GetParsingType() (v ParsingType) { if !p.IsSetParsingType() { return ParsingStrategy_ParsingType_DEFAULT } return *p.ParsingType } var ParsingStrategy_ImageExtraction_DEFAULT bool func (p *ParsingStrategy) GetImageExtraction() (v bool) { if !p.IsSetImageExtraction() { return ParsingStrategy_ImageExtraction_DEFAULT } return *p.ImageExtraction } var ParsingStrategy_TableExtraction_DEFAULT bool func (p *ParsingStrategy) GetTableExtraction() (v bool) { if !p.IsSetTableExtraction() { return ParsingStrategy_TableExtraction_DEFAULT } return *p.TableExtraction } var ParsingStrategy_ImageOcr_DEFAULT bool func (p *ParsingStrategy) GetImageOcr() (v bool) { if !p.IsSetImageOcr() { return ParsingStrategy_ImageOcr_DEFAULT } return *p.ImageOcr } var fieldIDToName_ParsingStrategy = map[int16]string{ 1: "parsing_type", 2: "image_extraction", 3: "table_extraction", 4: "image_ocr", } func (p *ParsingStrategy) IsSetParsingType() bool { return p.ParsingType != nil } func (p *ParsingStrategy) IsSetImageExtraction() bool { return p.ImageExtraction != nil } func (p *ParsingStrategy) IsSetTableExtraction() bool { return p.TableExtraction != nil } func (p *ParsingStrategy) IsSetImageOcr() bool { return p.ImageOcr != nil } func (p *ParsingStrategy) Read(iprot thrift.TProtocol) (err error) { var fieldTypeId thrift.TType var fieldId int16 if _, err = iprot.ReadStructBegin(); err != nil { goto ReadStructBeginError } for { _, fieldTypeId, fieldId, err = iprot.ReadFieldBegin() if err != nil { goto ReadFieldBeginError } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.I32 { if err = p.ReadField1(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 2: if fieldTypeId == thrift.BOOL { if err = p.ReadField2(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 3: if fieldTypeId == thrift.BOOL { if err = p.ReadField3(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 4: if fieldTypeId == thrift.BOOL { if err = p.ReadField4(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } default: if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } } if err = iprot.ReadFieldEnd(); err != nil { goto ReadFieldEndError } } if err = iprot.ReadStructEnd(); err != nil { goto ReadStructEndError } return nil ReadStructBeginError: return thrift.PrependError(fmt.Sprintf("%T read struct begin error: ", p), err) ReadFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T read field %d begin error: ", p, fieldId), err) ReadFieldError: return thrift.PrependError(fmt.Sprintf("%T read field %d '%s' error: ", p, fieldId, fieldIDToName_ParsingStrategy[fieldId]), err) SkipFieldError: return thrift.PrependError(fmt.Sprintf("%T field %d skip type %d error: ", p, fieldId, fieldTypeId), err) ReadFieldEndError: return thrift.PrependError(fmt.Sprintf("%T read field end error", p), err) ReadStructEndError: return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } func (p *ParsingStrategy) ReadField1(iprot thrift.TProtocol) error { var _field *ParsingType if v, err := iprot.ReadI32(); err != nil { return err } else { tmp := ParsingType(v) _field = &tmp } p.ParsingType = _field return nil } func (p *ParsingStrategy) ReadField2(iprot thrift.TProtocol) error { var _field *bool if v, err := iprot.ReadBool(); err != nil { return err } else { _field = &v } p.ImageExtraction = _field return nil } func (p *ParsingStrategy) ReadField3(iprot thrift.TProtocol) error { var _field *bool if v, err := iprot.ReadBool(); err != nil { return err } else { _field = &v } p.TableExtraction = _field return nil } func (p *ParsingStrategy) ReadField4(iprot thrift.TProtocol) error { var _field *bool if v, err := iprot.ReadBool(); err != nil { return err } else { _field = &v } p.ImageOcr = _field return nil } func (p *ParsingStrategy) Write(oprot thrift.TProtocol) (err error) { var fieldId int16 if err = oprot.WriteStructBegin("ParsingStrategy"); err != nil { goto WriteStructBeginError } if p != nil { if err = p.writeField1(oprot); err != nil { fieldId = 1 goto WriteFieldError } if err = p.writeField2(oprot); err != nil { fieldId = 2 goto WriteFieldError } if err = p.writeField3(oprot); err != nil { fieldId = 3 goto WriteFieldError } if err = p.writeField4(oprot); err != nil { fieldId = 4 goto WriteFieldError } } if err = oprot.WriteFieldStop(); err != nil { goto WriteFieldStopError } if err = oprot.WriteStructEnd(); err != nil { goto WriteStructEndError } return nil WriteStructBeginError: return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) WriteFieldError: return thrift.PrependError(fmt.Sprintf("%T write field %d error: ", p, fieldId), err) WriteFieldStopError: return thrift.PrependError(fmt.Sprintf("%T write field stop error: ", p), err) WriteStructEndError: return thrift.PrependError(fmt.Sprintf("%T write struct end error: ", p), err) } func (p *ParsingStrategy) writeField1(oprot thrift.TProtocol) (err error) { if p.IsSetParsingType() { if err = oprot.WriteFieldBegin("parsing_type", thrift.I32, 1); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(int32(*p.ParsingType)); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 1 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 1 end error: ", p), err) } func (p *ParsingStrategy) writeField2(oprot thrift.TProtocol) (err error) { if p.IsSetImageExtraction() { if err = oprot.WriteFieldBegin("image_extraction", thrift.BOOL, 2); err != nil { goto WriteFieldBeginError } if err := oprot.WriteBool(*p.ImageExtraction); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 2 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 2 end error: ", p), err) } func (p *ParsingStrategy) writeField3(oprot thrift.TProtocol) (err error) { if p.IsSetTableExtraction() { if err = oprot.WriteFieldBegin("table_extraction", thrift.BOOL, 3); err != nil { goto WriteFieldBeginError } if err := oprot.WriteBool(*p.TableExtraction); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 3 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 3 end error: ", p), err) } func (p *ParsingStrategy) writeField4(oprot thrift.TProtocol) (err error) { if p.IsSetImageOcr() { if err = oprot.WriteFieldBegin("image_ocr", thrift.BOOL, 4); err != nil { goto WriteFieldBeginError } if err := oprot.WriteBool(*p.ImageOcr); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 4 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 4 end error: ", p), err) } func (p *ParsingStrategy) String() string { if p == nil { return "" } return fmt.Sprintf("ParsingStrategy(%+v)", *p) } type IndexStrategy struct { //Whether to enable vector indexing (default is true) VectorIndexing *bool `thrift:"vector_indexing,1,optional" form:"vector_indexing" json:"vector_indexing,omitempty" query:"vector_indexing"` //Whether to enable keyword indexing (default is true) KeywordIndexing *bool `thrift:"keyword_indexing,2,optional" form:"keyword_indexing" json:"keyword_indexing,omitempty" query:"keyword_indexing"` //Whether to enable hierarchical indexing HierarchicalIndexing *bool `thrift:"hierarchical_indexing,3,optional" form:"hierarchical_indexing" json:"hierarchical_indexing,omitempty" query:"hierarchical_indexing"` //vector model Model *string `thrift:"model,4,optional" form:"model" json:"model,omitempty" query:"model"` } func NewIndexStrategy() *IndexStrategy { return &IndexStrategy{} } func (p *IndexStrategy) InitDefault() { } var IndexStrategy_VectorIndexing_DEFAULT bool func (p *IndexStrategy) GetVectorIndexing() (v bool) { if !p.IsSetVectorIndexing() { return IndexStrategy_VectorIndexing_DEFAULT } return *p.VectorIndexing } var IndexStrategy_KeywordIndexing_DEFAULT bool func (p *IndexStrategy) GetKeywordIndexing() (v bool) { if !p.IsSetKeywordIndexing() { return IndexStrategy_KeywordIndexing_DEFAULT } return *p.KeywordIndexing } var IndexStrategy_HierarchicalIndexing_DEFAULT bool func (p *IndexStrategy) GetHierarchicalIndexing() (v bool) { if !p.IsSetHierarchicalIndexing() { return IndexStrategy_HierarchicalIndexing_DEFAULT } return *p.HierarchicalIndexing } var IndexStrategy_Model_DEFAULT string func (p *IndexStrategy) GetModel() (v string) { if !p.IsSetModel() { return IndexStrategy_Model_DEFAULT } return *p.Model } var fieldIDToName_IndexStrategy = map[int16]string{ 1: "vector_indexing", 2: "keyword_indexing", 3: "hierarchical_indexing", 4: "model", } func (p *IndexStrategy) IsSetVectorIndexing() bool { return p.VectorIndexing != nil } func (p *IndexStrategy) IsSetKeywordIndexing() bool { return p.KeywordIndexing != nil } func (p *IndexStrategy) IsSetHierarchicalIndexing() bool { return p.HierarchicalIndexing != nil } func (p *IndexStrategy) IsSetModel() bool { return p.Model != nil } func (p *IndexStrategy) Read(iprot thrift.TProtocol) (err error) { var fieldTypeId thrift.TType var fieldId int16 if _, err = iprot.ReadStructBegin(); err != nil { goto ReadStructBeginError } for { _, fieldTypeId, fieldId, err = iprot.ReadFieldBegin() if err != nil { goto ReadFieldBeginError } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.BOOL { if err = p.ReadField1(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 2: if fieldTypeId == thrift.BOOL { if err = p.ReadField2(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 3: if fieldTypeId == thrift.BOOL { if err = p.ReadField3(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 4: if fieldTypeId == thrift.STRING { if err = p.ReadField4(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } default: if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } } if err = iprot.ReadFieldEnd(); err != nil { goto ReadFieldEndError } } if err = iprot.ReadStructEnd(); err != nil { goto ReadStructEndError } return nil ReadStructBeginError: return thrift.PrependError(fmt.Sprintf("%T read struct begin error: ", p), err) ReadFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T read field %d begin error: ", p, fieldId), err) ReadFieldError: return thrift.PrependError(fmt.Sprintf("%T read field %d '%s' error: ", p, fieldId, fieldIDToName_IndexStrategy[fieldId]), err) SkipFieldError: return thrift.PrependError(fmt.Sprintf("%T field %d skip type %d error: ", p, fieldId, fieldTypeId), err) ReadFieldEndError: return thrift.PrependError(fmt.Sprintf("%T read field end error", p), err) ReadStructEndError: return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } func (p *IndexStrategy) ReadField1(iprot thrift.TProtocol) error { var _field *bool if v, err := iprot.ReadBool(); err != nil { return err } else { _field = &v } p.VectorIndexing = _field return nil } func (p *IndexStrategy) ReadField2(iprot thrift.TProtocol) error { var _field *bool if v, err := iprot.ReadBool(); err != nil { return err } else { _field = &v } p.KeywordIndexing = _field return nil } func (p *IndexStrategy) ReadField3(iprot thrift.TProtocol) error { var _field *bool if v, err := iprot.ReadBool(); err != nil { return err } else { _field = &v } p.HierarchicalIndexing = _field return nil } func (p *IndexStrategy) ReadField4(iprot thrift.TProtocol) error { var _field *string if v, err := iprot.ReadString(); err != nil { return err } else { _field = &v } p.Model = _field return nil } func (p *IndexStrategy) Write(oprot thrift.TProtocol) (err error) { var fieldId int16 if err = oprot.WriteStructBegin("IndexStrategy"); err != nil { goto WriteStructBeginError } if p != nil { if err = p.writeField1(oprot); err != nil { fieldId = 1 goto WriteFieldError } if err = p.writeField2(oprot); err != nil { fieldId = 2 goto WriteFieldError } if err = p.writeField3(oprot); err != nil { fieldId = 3 goto WriteFieldError } if err = p.writeField4(oprot); err != nil { fieldId = 4 goto WriteFieldError } } if err = oprot.WriteFieldStop(); err != nil { goto WriteFieldStopError } if err = oprot.WriteStructEnd(); err != nil { goto WriteStructEndError } return nil WriteStructBeginError: return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) WriteFieldError: return thrift.PrependError(fmt.Sprintf("%T write field %d error: ", p, fieldId), err) WriteFieldStopError: return thrift.PrependError(fmt.Sprintf("%T write field stop error: ", p), err) WriteStructEndError: return thrift.PrependError(fmt.Sprintf("%T write struct end error: ", p), err) } func (p *IndexStrategy) writeField1(oprot thrift.TProtocol) (err error) { if p.IsSetVectorIndexing() { if err = oprot.WriteFieldBegin("vector_indexing", thrift.BOOL, 1); err != nil { goto WriteFieldBeginError } if err := oprot.WriteBool(*p.VectorIndexing); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 1 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 1 end error: ", p), err) } func (p *IndexStrategy) writeField2(oprot thrift.TProtocol) (err error) { if p.IsSetKeywordIndexing() { if err = oprot.WriteFieldBegin("keyword_indexing", thrift.BOOL, 2); err != nil { goto WriteFieldBeginError } if err := oprot.WriteBool(*p.KeywordIndexing); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 2 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 2 end error: ", p), err) } func (p *IndexStrategy) writeField3(oprot thrift.TProtocol) (err error) { if p.IsSetHierarchicalIndexing() { if err = oprot.WriteFieldBegin("hierarchical_indexing", thrift.BOOL, 3); err != nil { goto WriteFieldBeginError } if err := oprot.WriteBool(*p.HierarchicalIndexing); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 3 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 3 end error: ", p), err) } func (p *IndexStrategy) writeField4(oprot thrift.TProtocol) (err error) { if p.IsSetModel() { if err = oprot.WriteFieldBegin("model", thrift.STRING, 4); err != nil { goto WriteFieldBeginError } if err := oprot.WriteString(*p.Model); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 4 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 4 end error: ", p), err) } func (p *IndexStrategy) String() string { if p == nil { return "" } return fmt.Sprintf("IndexStrategy(%+v)", *p) } type FilterStrategy struct { //filter pages FilterPage []int32 `thrift:"filter_page,1,optional" form:"filter_page" json:"filter_page,omitempty" query:"filter_page"` } func NewFilterStrategy() *FilterStrategy { return &FilterStrategy{} } func (p *FilterStrategy) InitDefault() { } var FilterStrategy_FilterPage_DEFAULT []int32 func (p *FilterStrategy) GetFilterPage() (v []int32) { if !p.IsSetFilterPage() { return FilterStrategy_FilterPage_DEFAULT } return p.FilterPage } var fieldIDToName_FilterStrategy = map[int16]string{ 1: "filter_page", } func (p *FilterStrategy) IsSetFilterPage() bool { return p.FilterPage != nil } func (p *FilterStrategy) Read(iprot thrift.TProtocol) (err error) { var fieldTypeId thrift.TType var fieldId int16 if _, err = iprot.ReadStructBegin(); err != nil { goto ReadStructBeginError } for { _, fieldTypeId, fieldId, err = iprot.ReadFieldBegin() if err != nil { goto ReadFieldBeginError } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.LIST { if err = p.ReadField1(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } default: if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } } if err = iprot.ReadFieldEnd(); err != nil { goto ReadFieldEndError } } if err = iprot.ReadStructEnd(); err != nil { goto ReadStructEndError } return nil ReadStructBeginError: return thrift.PrependError(fmt.Sprintf("%T read struct begin error: ", p), err) ReadFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T read field %d begin error: ", p, fieldId), err) ReadFieldError: return thrift.PrependError(fmt.Sprintf("%T read field %d '%s' error: ", p, fieldId, fieldIDToName_FilterStrategy[fieldId]), err) SkipFieldError: return thrift.PrependError(fmt.Sprintf("%T field %d skip type %d error: ", p, fieldId, fieldTypeId), err) ReadFieldEndError: return thrift.PrependError(fmt.Sprintf("%T read field end error", p), err) ReadStructEndError: return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } func (p *FilterStrategy) ReadField1(iprot thrift.TProtocol) error { _, size, err := iprot.ReadListBegin() if err != nil { return err } _field := make([]int32, 0, size) for i := 0; i < size; i++ { var _elem int32 if v, err := iprot.ReadI32(); err != nil { return err } else { _elem = v } _field = append(_field, _elem) } if err := iprot.ReadListEnd(); err != nil { return err } p.FilterPage = _field return nil } func (p *FilterStrategy) Write(oprot thrift.TProtocol) (err error) { var fieldId int16 if err = oprot.WriteStructBegin("FilterStrategy"); err != nil { goto WriteStructBeginError } if p != nil { if err = p.writeField1(oprot); err != nil { fieldId = 1 goto WriteFieldError } } if err = oprot.WriteFieldStop(); err != nil { goto WriteFieldStopError } if err = oprot.WriteStructEnd(); err != nil { goto WriteStructEndError } return nil WriteStructBeginError: return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) WriteFieldError: return thrift.PrependError(fmt.Sprintf("%T write field %d error: ", p, fieldId), err) WriteFieldStopError: return thrift.PrependError(fmt.Sprintf("%T write field stop error: ", p), err) WriteStructEndError: return thrift.PrependError(fmt.Sprintf("%T write struct end error: ", p), err) } func (p *FilterStrategy) writeField1(oprot thrift.TProtocol) (err error) { if p.IsSetFilterPage() { if err = oprot.WriteFieldBegin("filter_page", thrift.LIST, 1); err != nil { goto WriteFieldBeginError } if err := oprot.WriteListBegin(thrift.I32, len(p.FilterPage)); err != nil { return err } for _, v := range p.FilterPage { if err := oprot.WriteI32(v); err != nil { return err } } if err := oprot.WriteListEnd(); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 1 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 1 end error: ", p), err) } func (p *FilterStrategy) String() string { if p == nil { return "" } return fmt.Sprintf("FilterStrategy(%+v)", *p) } type SinkStrategy struct { // Check whether the index was successful CheckIndex bool `thrift:"check_index,1" form:"check_index" json:"check_index" query:"check_index"` } func NewSinkStrategy() *SinkStrategy { return &SinkStrategy{} } func (p *SinkStrategy) InitDefault() { } func (p *SinkStrategy) GetCheckIndex() (v bool) { return p.CheckIndex } var fieldIDToName_SinkStrategy = map[int16]string{ 1: "check_index", } func (p *SinkStrategy) Read(iprot thrift.TProtocol) (err error) { var fieldTypeId thrift.TType var fieldId int16 if _, err = iprot.ReadStructBegin(); err != nil { goto ReadStructBeginError } for { _, fieldTypeId, fieldId, err = iprot.ReadFieldBegin() if err != nil { goto ReadFieldBeginError } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.BOOL { if err = p.ReadField1(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } default: if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } } if err = iprot.ReadFieldEnd(); err != nil { goto ReadFieldEndError } } if err = iprot.ReadStructEnd(); err != nil { goto ReadStructEndError } return nil ReadStructBeginError: return thrift.PrependError(fmt.Sprintf("%T read struct begin error: ", p), err) ReadFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T read field %d begin error: ", p, fieldId), err) ReadFieldError: return thrift.PrependError(fmt.Sprintf("%T read field %d '%s' error: ", p, fieldId, fieldIDToName_SinkStrategy[fieldId]), err) SkipFieldError: return thrift.PrependError(fmt.Sprintf("%T field %d skip type %d error: ", p, fieldId, fieldTypeId), err) ReadFieldEndError: return thrift.PrependError(fmt.Sprintf("%T read field end error", p), err) ReadStructEndError: return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } func (p *SinkStrategy) ReadField1(iprot thrift.TProtocol) error { var _field bool if v, err := iprot.ReadBool(); err != nil { return err } else { _field = v } p.CheckIndex = _field return nil } func (p *SinkStrategy) Write(oprot thrift.TProtocol) (err error) { var fieldId int16 if err = oprot.WriteStructBegin("SinkStrategy"); err != nil { goto WriteStructBeginError } if p != nil { if err = p.writeField1(oprot); err != nil { fieldId = 1 goto WriteFieldError } } if err = oprot.WriteFieldStop(); err != nil { goto WriteFieldStopError } if err = oprot.WriteStructEnd(); err != nil { goto WriteStructEndError } return nil WriteStructBeginError: return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) WriteFieldError: return thrift.PrependError(fmt.Sprintf("%T write field %d error: ", p, fieldId), err) WriteFieldStopError: return thrift.PrependError(fmt.Sprintf("%T write field stop error: ", p), err) WriteStructEndError: return thrift.PrependError(fmt.Sprintf("%T write struct end error: ", p), err) } func (p *SinkStrategy) writeField1(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("check_index", thrift.BOOL, 1); err != nil { goto WriteFieldBeginError } if err := oprot.WriteBool(p.CheckIndex); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 1 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 1 end error: ", p), err) } func (p *SinkStrategy) String() string { if p == nil { return "" } return fmt.Sprintf("SinkStrategy(%+v)", *p) } // Table column information type DocTableColumn struct { // Column ID ID int64 `thrift:"id,1" form:"id" json:"id,string"` // column_name ColumnName string `thrift:"column_name,2" form:"column_name" json:"column_name" query:"column_name"` // Is it a semantically matched column? IsSemantic bool `thrift:"is_semantic,3" form:"is_semantic" json:"is_semantic" query:"is_semantic"` // List the serial number originally in excel Sequence int64 `thrift:"sequence,4" form:"sequence" json:"sequence,string"` // column type ColumnType *ColumnType `thrift:"column_type,5,optional" form:"column_type" json:"column_type,omitempty" query:"column_type"` ContainsEmptyValue *bool `thrift:"contains_empty_value,6,optional" form:"contains_empty_value" json:"contains_empty_value,omitempty" query:"contains_empty_value"` // describe Desc *string `thrift:"desc,7,optional" form:"desc" json:"desc,omitempty" query:"desc"` } func NewDocTableColumn() *DocTableColumn { return &DocTableColumn{} } func (p *DocTableColumn) InitDefault() { } func (p *DocTableColumn) GetID() (v int64) { return p.ID } func (p *DocTableColumn) GetColumnName() (v string) { return p.ColumnName } func (p *DocTableColumn) GetIsSemantic() (v bool) { return p.IsSemantic } func (p *DocTableColumn) GetSequence() (v int64) { return p.Sequence } var DocTableColumn_ColumnType_DEFAULT ColumnType func (p *DocTableColumn) GetColumnType() (v ColumnType) { if !p.IsSetColumnType() { return DocTableColumn_ColumnType_DEFAULT } return *p.ColumnType } var DocTableColumn_ContainsEmptyValue_DEFAULT bool func (p *DocTableColumn) GetContainsEmptyValue() (v bool) { if !p.IsSetContainsEmptyValue() { return DocTableColumn_ContainsEmptyValue_DEFAULT } return *p.ContainsEmptyValue } var DocTableColumn_Desc_DEFAULT string func (p *DocTableColumn) GetDesc() (v string) { if !p.IsSetDesc() { return DocTableColumn_Desc_DEFAULT } return *p.Desc } var fieldIDToName_DocTableColumn = map[int16]string{ 1: "id", 2: "column_name", 3: "is_semantic", 4: "sequence", 5: "column_type", 6: "contains_empty_value", 7: "desc", } func (p *DocTableColumn) IsSetColumnType() bool { return p.ColumnType != nil } func (p *DocTableColumn) IsSetContainsEmptyValue() bool { return p.ContainsEmptyValue != nil } func (p *DocTableColumn) IsSetDesc() bool { return p.Desc != nil } func (p *DocTableColumn) Read(iprot thrift.TProtocol) (err error) { var fieldTypeId thrift.TType var fieldId int16 if _, err = iprot.ReadStructBegin(); err != nil { goto ReadStructBeginError } for { _, fieldTypeId, fieldId, err = iprot.ReadFieldBegin() if err != nil { goto ReadFieldBeginError } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.I64 { if err = p.ReadField1(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 2: if fieldTypeId == thrift.STRING { if err = p.ReadField2(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 3: if fieldTypeId == thrift.BOOL { if err = p.ReadField3(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 4: if fieldTypeId == thrift.I64 { if err = p.ReadField4(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 5: if fieldTypeId == thrift.I32 { if err = p.ReadField5(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 6: if fieldTypeId == thrift.BOOL { if err = p.ReadField6(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 7: if fieldTypeId == thrift.STRING { if err = p.ReadField7(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } default: if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } } if err = iprot.ReadFieldEnd(); err != nil { goto ReadFieldEndError } } if err = iprot.ReadStructEnd(); err != nil { goto ReadStructEndError } return nil ReadStructBeginError: return thrift.PrependError(fmt.Sprintf("%T read struct begin error: ", p), err) ReadFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T read field %d begin error: ", p, fieldId), err) ReadFieldError: return thrift.PrependError(fmt.Sprintf("%T read field %d '%s' error: ", p, fieldId, fieldIDToName_DocTableColumn[fieldId]), err) SkipFieldError: return thrift.PrependError(fmt.Sprintf("%T field %d skip type %d error: ", p, fieldId, fieldTypeId), err) ReadFieldEndError: return thrift.PrependError(fmt.Sprintf("%T read field end error", p), err) ReadStructEndError: return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } func (p *DocTableColumn) ReadField1(iprot thrift.TProtocol) error { var _field int64 if v, err := iprot.ReadI64(); err != nil { return err } else { _field = v } p.ID = _field return nil } func (p *DocTableColumn) ReadField2(iprot thrift.TProtocol) error { var _field string if v, err := iprot.ReadString(); err != nil { return err } else { _field = v } p.ColumnName = _field return nil } func (p *DocTableColumn) ReadField3(iprot thrift.TProtocol) error { var _field bool if v, err := iprot.ReadBool(); err != nil { return err } else { _field = v } p.IsSemantic = _field return nil } func (p *DocTableColumn) ReadField4(iprot thrift.TProtocol) error { var _field int64 if v, err := iprot.ReadI64(); err != nil { return err } else { _field = v } p.Sequence = _field return nil } func (p *DocTableColumn) ReadField5(iprot thrift.TProtocol) error { var _field *ColumnType if v, err := iprot.ReadI32(); err != nil { return err } else { tmp := ColumnType(v) _field = &tmp } p.ColumnType = _field return nil } func (p *DocTableColumn) ReadField6(iprot thrift.TProtocol) error { var _field *bool if v, err := iprot.ReadBool(); err != nil { return err } else { _field = &v } p.ContainsEmptyValue = _field return nil } func (p *DocTableColumn) ReadField7(iprot thrift.TProtocol) error { var _field *string if v, err := iprot.ReadString(); err != nil { return err } else { _field = &v } p.Desc = _field return nil } func (p *DocTableColumn) Write(oprot thrift.TProtocol) (err error) { var fieldId int16 if err = oprot.WriteStructBegin("DocTableColumn"); err != nil { goto WriteStructBeginError } if p != nil { if err = p.writeField1(oprot); err != nil { fieldId = 1 goto WriteFieldError } if err = p.writeField2(oprot); err != nil { fieldId = 2 goto WriteFieldError } if err = p.writeField3(oprot); err != nil { fieldId = 3 goto WriteFieldError } if err = p.writeField4(oprot); err != nil { fieldId = 4 goto WriteFieldError } if err = p.writeField5(oprot); err != nil { fieldId = 5 goto WriteFieldError } if err = p.writeField6(oprot); err != nil { fieldId = 6 goto WriteFieldError } if err = p.writeField7(oprot); err != nil { fieldId = 7 goto WriteFieldError } } if err = oprot.WriteFieldStop(); err != nil { goto WriteFieldStopError } if err = oprot.WriteStructEnd(); err != nil { goto WriteStructEndError } return nil WriteStructBeginError: return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) WriteFieldError: return thrift.PrependError(fmt.Sprintf("%T write field %d error: ", p, fieldId), err) WriteFieldStopError: return thrift.PrependError(fmt.Sprintf("%T write field stop error: ", p), err) WriteStructEndError: return thrift.PrependError(fmt.Sprintf("%T write struct end error: ", p), err) } func (p *DocTableColumn) writeField1(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("id", thrift.I64, 1); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI64(p.ID); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 1 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 1 end error: ", p), err) } func (p *DocTableColumn) writeField2(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("column_name", thrift.STRING, 2); err != nil { goto WriteFieldBeginError } if err := oprot.WriteString(p.ColumnName); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 2 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 2 end error: ", p), err) } func (p *DocTableColumn) writeField3(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("is_semantic", thrift.BOOL, 3); err != nil { goto WriteFieldBeginError } if err := oprot.WriteBool(p.IsSemantic); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 3 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 3 end error: ", p), err) } func (p *DocTableColumn) writeField4(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("sequence", thrift.I64, 4); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI64(p.Sequence); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 4 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 4 end error: ", p), err) } func (p *DocTableColumn) writeField5(oprot thrift.TProtocol) (err error) { if p.IsSetColumnType() { if err = oprot.WriteFieldBegin("column_type", thrift.I32, 5); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(int32(*p.ColumnType)); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 5 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 5 end error: ", p), err) } func (p *DocTableColumn) writeField6(oprot thrift.TProtocol) (err error) { if p.IsSetContainsEmptyValue() { if err = oprot.WriteFieldBegin("contains_empty_value", thrift.BOOL, 6); err != nil { goto WriteFieldBeginError } if err := oprot.WriteBool(*p.ContainsEmptyValue); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 6 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 6 end error: ", p), err) } func (p *DocTableColumn) writeField7(oprot thrift.TProtocol) (err error) { if p.IsSetDesc() { if err = oprot.WriteFieldBegin("desc", thrift.STRING, 7); err != nil { goto WriteFieldBeginError } if err := oprot.WriteString(*p.Desc); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 7 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 7 end error: ", p), err) } func (p *DocTableColumn) String() string { if p == nil { return "" } return fmt.Sprintf("DocTableColumn(%+v)", *p) } type PhotoInfo struct { // Picture Knowledge Base One picture corresponds to one document Name string `thrift:"name,1" form:"name" json:"name" query:"name"` // Document ID DocumentID int64 `thrift:"document_id,2" form:"document_id" json:"document_id,string" query:"document_id"` // image link URL string `thrift:"url,3" form:"url" json:"url" query:"url"` // picture description information Caption string `thrift:"caption,4" form:"caption" json:"caption" query:"caption"` // create_time CreateTime int32 `thrift:"create_time,5" form:"create_time" json:"create_time" query:"create_time"` // update time UpdateTime int32 `thrift:"update_time,6" form:"update_time" json:"update_time" query:"update_time"` // creator_id CreatorID int64 `thrift:"creator_id,7" form:"creator_id" json:"creator_id,string"` // Image suffix jpg, png, etc Type string `thrift:"type,8" form:"type" json:"type" query:"type"` // image size Size int32 `thrift:"size,9" form:"size" json:"size" query:"size"` // status Status DocumentStatus `thrift:"status,10" form:"status" json:"status" query:"status"` // source SourceType DocumentSource `thrift:"source_type,11" form:"source_type" json:"source_type" query:"source_type"` } func NewPhotoInfo() *PhotoInfo { return &PhotoInfo{} } func (p *PhotoInfo) InitDefault() { } func (p *PhotoInfo) GetName() (v string) { return p.Name } func (p *PhotoInfo) GetDocumentID() (v int64) { return p.DocumentID } func (p *PhotoInfo) GetURL() (v string) { return p.URL } func (p *PhotoInfo) GetCaption() (v string) { return p.Caption } func (p *PhotoInfo) GetCreateTime() (v int32) { return p.CreateTime } func (p *PhotoInfo) GetUpdateTime() (v int32) { return p.UpdateTime } func (p *PhotoInfo) GetCreatorID() (v int64) { return p.CreatorID } func (p *PhotoInfo) GetType() (v string) { return p.Type } func (p *PhotoInfo) GetSize() (v int32) { return p.Size } func (p *PhotoInfo) GetStatus() (v DocumentStatus) { return p.Status } func (p *PhotoInfo) GetSourceType() (v DocumentSource) { return p.SourceType } var fieldIDToName_PhotoInfo = map[int16]string{ 1: "name", 2: "document_id", 3: "url", 4: "caption", 5: "create_time", 6: "update_time", 7: "creator_id", 8: "type", 9: "size", 10: "status", 11: "source_type", } func (p *PhotoInfo) Read(iprot thrift.TProtocol) (err error) { var fieldTypeId thrift.TType var fieldId int16 if _, err = iprot.ReadStructBegin(); err != nil { goto ReadStructBeginError } for { _, fieldTypeId, fieldId, err = iprot.ReadFieldBegin() if err != nil { goto ReadFieldBeginError } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.STRING { if err = p.ReadField1(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 2: if fieldTypeId == thrift.I64 { if err = p.ReadField2(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 3: if fieldTypeId == thrift.STRING { if err = p.ReadField3(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 4: if fieldTypeId == thrift.STRING { if err = p.ReadField4(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 5: if fieldTypeId == thrift.I32 { if err = p.ReadField5(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 6: if fieldTypeId == thrift.I32 { if err = p.ReadField6(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 7: if fieldTypeId == thrift.I64 { if err = p.ReadField7(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 8: if fieldTypeId == thrift.STRING { if err = p.ReadField8(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 9: if fieldTypeId == thrift.I32 { if err = p.ReadField9(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 10: if fieldTypeId == thrift.I32 { if err = p.ReadField10(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 11: if fieldTypeId == thrift.I32 { if err = p.ReadField11(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } default: if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } } if err = iprot.ReadFieldEnd(); err != nil { goto ReadFieldEndError } } if err = iprot.ReadStructEnd(); err != nil { goto ReadStructEndError } return nil ReadStructBeginError: return thrift.PrependError(fmt.Sprintf("%T read struct begin error: ", p), err) ReadFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T read field %d begin error: ", p, fieldId), err) ReadFieldError: return thrift.PrependError(fmt.Sprintf("%T read field %d '%s' error: ", p, fieldId, fieldIDToName_PhotoInfo[fieldId]), err) SkipFieldError: return thrift.PrependError(fmt.Sprintf("%T field %d skip type %d error: ", p, fieldId, fieldTypeId), err) ReadFieldEndError: return thrift.PrependError(fmt.Sprintf("%T read field end error", p), err) ReadStructEndError: return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } func (p *PhotoInfo) ReadField1(iprot thrift.TProtocol) error { var _field string if v, err := iprot.ReadString(); err != nil { return err } else { _field = v } p.Name = _field return nil } func (p *PhotoInfo) ReadField2(iprot thrift.TProtocol) error { var _field int64 if v, err := iprot.ReadI64(); err != nil { return err } else { _field = v } p.DocumentID = _field return nil } func (p *PhotoInfo) ReadField3(iprot thrift.TProtocol) error { var _field string if v, err := iprot.ReadString(); err != nil { return err } else { _field = v } p.URL = _field return nil } func (p *PhotoInfo) ReadField4(iprot thrift.TProtocol) error { var _field string if v, err := iprot.ReadString(); err != nil { return err } else { _field = v } p.Caption = _field return nil } func (p *PhotoInfo) ReadField5(iprot thrift.TProtocol) error { var _field int32 if v, err := iprot.ReadI32(); err != nil { return err } else { _field = v } p.CreateTime = _field return nil } func (p *PhotoInfo) ReadField6(iprot thrift.TProtocol) error { var _field int32 if v, err := iprot.ReadI32(); err != nil { return err } else { _field = v } p.UpdateTime = _field return nil } func (p *PhotoInfo) ReadField7(iprot thrift.TProtocol) error { var _field int64 if v, err := iprot.ReadI64(); err != nil { return err } else { _field = v } p.CreatorID = _field return nil } func (p *PhotoInfo) ReadField8(iprot thrift.TProtocol) error { var _field string if v, err := iprot.ReadString(); err != nil { return err } else { _field = v } p.Type = _field return nil } func (p *PhotoInfo) ReadField9(iprot thrift.TProtocol) error { var _field int32 if v, err := iprot.ReadI32(); err != nil { return err } else { _field = v } p.Size = _field return nil } func (p *PhotoInfo) ReadField10(iprot thrift.TProtocol) error { var _field DocumentStatus if v, err := iprot.ReadI32(); err != nil { return err } else { _field = DocumentStatus(v) } p.Status = _field return nil } func (p *PhotoInfo) ReadField11(iprot thrift.TProtocol) error { var _field DocumentSource if v, err := iprot.ReadI32(); err != nil { return err } else { _field = DocumentSource(v) } p.SourceType = _field return nil } func (p *PhotoInfo) Write(oprot thrift.TProtocol) (err error) { var fieldId int16 if err = oprot.WriteStructBegin("PhotoInfo"); err != nil { goto WriteStructBeginError } if p != nil { if err = p.writeField1(oprot); err != nil { fieldId = 1 goto WriteFieldError } if err = p.writeField2(oprot); err != nil { fieldId = 2 goto WriteFieldError } if err = p.writeField3(oprot); err != nil { fieldId = 3 goto WriteFieldError } if err = p.writeField4(oprot); err != nil { fieldId = 4 goto WriteFieldError } if err = p.writeField5(oprot); err != nil { fieldId = 5 goto WriteFieldError } if err = p.writeField6(oprot); err != nil { fieldId = 6 goto WriteFieldError } if err = p.writeField7(oprot); err != nil { fieldId = 7 goto WriteFieldError } if err = p.writeField8(oprot); err != nil { fieldId = 8 goto WriteFieldError } if err = p.writeField9(oprot); err != nil { fieldId = 9 goto WriteFieldError } if err = p.writeField10(oprot); err != nil { fieldId = 10 goto WriteFieldError } if err = p.writeField11(oprot); err != nil { fieldId = 11 goto WriteFieldError } } if err = oprot.WriteFieldStop(); err != nil { goto WriteFieldStopError } if err = oprot.WriteStructEnd(); err != nil { goto WriteStructEndError } return nil WriteStructBeginError: return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) WriteFieldError: return thrift.PrependError(fmt.Sprintf("%T write field %d error: ", p, fieldId), err) WriteFieldStopError: return thrift.PrependError(fmt.Sprintf("%T write field stop error: ", p), err) WriteStructEndError: return thrift.PrependError(fmt.Sprintf("%T write struct end error: ", p), err) } func (p *PhotoInfo) writeField1(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("name", thrift.STRING, 1); err != nil { goto WriteFieldBeginError } if err := oprot.WriteString(p.Name); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 1 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 1 end error: ", p), err) } func (p *PhotoInfo) writeField2(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("document_id", thrift.I64, 2); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI64(p.DocumentID); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 2 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 2 end error: ", p), err) } func (p *PhotoInfo) writeField3(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("url", thrift.STRING, 3); err != nil { goto WriteFieldBeginError } if err := oprot.WriteString(p.URL); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 3 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 3 end error: ", p), err) } func (p *PhotoInfo) writeField4(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("caption", thrift.STRING, 4); err != nil { goto WriteFieldBeginError } if err := oprot.WriteString(p.Caption); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 4 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 4 end error: ", p), err) } func (p *PhotoInfo) writeField5(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("create_time", thrift.I32, 5); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(p.CreateTime); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 5 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 5 end error: ", p), err) } func (p *PhotoInfo) writeField6(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("update_time", thrift.I32, 6); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(p.UpdateTime); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 6 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 6 end error: ", p), err) } func (p *PhotoInfo) writeField7(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("creator_id", thrift.I64, 7); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI64(p.CreatorID); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 7 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 7 end error: ", p), err) } func (p *PhotoInfo) writeField8(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("type", thrift.STRING, 8); err != nil { goto WriteFieldBeginError } if err := oprot.WriteString(p.Type); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 8 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 8 end error: ", p), err) } func (p *PhotoInfo) writeField9(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("size", thrift.I32, 9); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(p.Size); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 9 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 9 end error: ", p), err) } func (p *PhotoInfo) writeField10(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("status", thrift.I32, 10); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(int32(p.Status)); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 10 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 10 end error: ", p), err) } func (p *PhotoInfo) writeField11(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("source_type", thrift.I32, 11); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(int32(p.SourceType)); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 11 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 11 end error: ", p), err) } func (p *PhotoInfo) String() string { if p == nil { return "" } return fmt.Sprintf("PhotoInfo(%+v)", *p) } type DocumentProgress struct { DocumentID int64 `thrift:"document_id,1" form:"document_id" json:"document_id,string" query:"document_id"` // Knowledge Base Progress Percentage Progress int32 `thrift:"progress,2" form:"progress" json:"progress" query:"progress"` Status DocumentStatus `thrift:"status,3" form:"status" json:"status" query:"status"` // A detailed description of the status; if the slice fails, a failure message is returned StatusDescript *string `thrift:"status_descript,4,optional" form:"status_descript" json:"status_descript,omitempty" query:"status_descript"` DocumentName string `thrift:"document_name,5" form:"document_name" json:"document_name" query:"document_name"` // Remaining time in seconds RemainingTime *int64 `thrift:"remaining_time,6,optional" form:"remaining_time" json:"remaining_time,omitempty" query:"remaining_time"` Size *int64 `thrift:"size,7,optional" form:"size" json:"size,omitempty" query:"size"` Type *string `thrift:"type,8,optional" form:"type" json:"type,omitempty" query:"type"` URL *string `thrift:"url,9,optional" form:"url" json:"url,omitempty" query:"url"` } func NewDocumentProgress() *DocumentProgress { return &DocumentProgress{} } func (p *DocumentProgress) InitDefault() { } func (p *DocumentProgress) GetDocumentID() (v int64) { return p.DocumentID } func (p *DocumentProgress) GetProgress() (v int32) { return p.Progress } func (p *DocumentProgress) GetStatus() (v DocumentStatus) { return p.Status } var DocumentProgress_StatusDescript_DEFAULT string func (p *DocumentProgress) GetStatusDescript() (v string) { if !p.IsSetStatusDescript() { return DocumentProgress_StatusDescript_DEFAULT } return *p.StatusDescript } func (p *DocumentProgress) GetDocumentName() (v string) { return p.DocumentName } var DocumentProgress_RemainingTime_DEFAULT int64 func (p *DocumentProgress) GetRemainingTime() (v int64) { if !p.IsSetRemainingTime() { return DocumentProgress_RemainingTime_DEFAULT } return *p.RemainingTime } var DocumentProgress_Size_DEFAULT int64 func (p *DocumentProgress) GetSize() (v int64) { if !p.IsSetSize() { return DocumentProgress_Size_DEFAULT } return *p.Size } var DocumentProgress_Type_DEFAULT string func (p *DocumentProgress) GetType() (v string) { if !p.IsSetType() { return DocumentProgress_Type_DEFAULT } return *p.Type } var DocumentProgress_URL_DEFAULT string func (p *DocumentProgress) GetURL() (v string) { if !p.IsSetURL() { return DocumentProgress_URL_DEFAULT } return *p.URL } var fieldIDToName_DocumentProgress = map[int16]string{ 1: "document_id", 2: "progress", 3: "status", 4: "status_descript", 5: "document_name", 6: "remaining_time", 7: "size", 8: "type", 9: "url", } func (p *DocumentProgress) IsSetStatusDescript() bool { return p.StatusDescript != nil } func (p *DocumentProgress) IsSetRemainingTime() bool { return p.RemainingTime != nil } func (p *DocumentProgress) IsSetSize() bool { return p.Size != nil } func (p *DocumentProgress) IsSetType() bool { return p.Type != nil } func (p *DocumentProgress) IsSetURL() bool { return p.URL != nil } func (p *DocumentProgress) Read(iprot thrift.TProtocol) (err error) { var fieldTypeId thrift.TType var fieldId int16 if _, err = iprot.ReadStructBegin(); err != nil { goto ReadStructBeginError } for { _, fieldTypeId, fieldId, err = iprot.ReadFieldBegin() if err != nil { goto ReadFieldBeginError } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.I64 { if err = p.ReadField1(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 2: if fieldTypeId == thrift.I32 { if err = p.ReadField2(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 3: if fieldTypeId == thrift.I32 { if err = p.ReadField3(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 4: if fieldTypeId == thrift.STRING { if err = p.ReadField4(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 5: if fieldTypeId == thrift.STRING { if err = p.ReadField5(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 6: if fieldTypeId == thrift.I64 { if err = p.ReadField6(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 7: if fieldTypeId == thrift.I64 { if err = p.ReadField7(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 8: if fieldTypeId == thrift.STRING { if err = p.ReadField8(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 9: if fieldTypeId == thrift.STRING { if err = p.ReadField9(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } default: if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } } if err = iprot.ReadFieldEnd(); err != nil { goto ReadFieldEndError } } if err = iprot.ReadStructEnd(); err != nil { goto ReadStructEndError } return nil ReadStructBeginError: return thrift.PrependError(fmt.Sprintf("%T read struct begin error: ", p), err) ReadFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T read field %d begin error: ", p, fieldId), err) ReadFieldError: return thrift.PrependError(fmt.Sprintf("%T read field %d '%s' error: ", p, fieldId, fieldIDToName_DocumentProgress[fieldId]), err) SkipFieldError: return thrift.PrependError(fmt.Sprintf("%T field %d skip type %d error: ", p, fieldId, fieldTypeId), err) ReadFieldEndError: return thrift.PrependError(fmt.Sprintf("%T read field end error", p), err) ReadStructEndError: return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } func (p *DocumentProgress) ReadField1(iprot thrift.TProtocol) error { var _field int64 if v, err := iprot.ReadI64(); err != nil { return err } else { _field = v } p.DocumentID = _field return nil } func (p *DocumentProgress) ReadField2(iprot thrift.TProtocol) error { var _field int32 if v, err := iprot.ReadI32(); err != nil { return err } else { _field = v } p.Progress = _field return nil } func (p *DocumentProgress) ReadField3(iprot thrift.TProtocol) error { var _field DocumentStatus if v, err := iprot.ReadI32(); err != nil { return err } else { _field = DocumentStatus(v) } p.Status = _field return nil } func (p *DocumentProgress) ReadField4(iprot thrift.TProtocol) error { var _field *string if v, err := iprot.ReadString(); err != nil { return err } else { _field = &v } p.StatusDescript = _field return nil } func (p *DocumentProgress) ReadField5(iprot thrift.TProtocol) error { var _field string if v, err := iprot.ReadString(); err != nil { return err } else { _field = v } p.DocumentName = _field return nil } func (p *DocumentProgress) ReadField6(iprot thrift.TProtocol) error { var _field *int64 if v, err := iprot.ReadI64(); err != nil { return err } else { _field = &v } p.RemainingTime = _field return nil } func (p *DocumentProgress) ReadField7(iprot thrift.TProtocol) error { var _field *int64 if v, err := iprot.ReadI64(); err != nil { return err } else { _field = &v } p.Size = _field return nil } func (p *DocumentProgress) ReadField8(iprot thrift.TProtocol) error { var _field *string if v, err := iprot.ReadString(); err != nil { return err } else { _field = &v } p.Type = _field return nil } func (p *DocumentProgress) ReadField9(iprot thrift.TProtocol) error { var _field *string if v, err := iprot.ReadString(); err != nil { return err } else { _field = &v } p.URL = _field return nil } func (p *DocumentProgress) Write(oprot thrift.TProtocol) (err error) { var fieldId int16 if err = oprot.WriteStructBegin("DocumentProgress"); err != nil { goto WriteStructBeginError } if p != nil { if err = p.writeField1(oprot); err != nil { fieldId = 1 goto WriteFieldError } if err = p.writeField2(oprot); err != nil { fieldId = 2 goto WriteFieldError } if err = p.writeField3(oprot); err != nil { fieldId = 3 goto WriteFieldError } if err = p.writeField4(oprot); err != nil { fieldId = 4 goto WriteFieldError } if err = p.writeField5(oprot); err != nil { fieldId = 5 goto WriteFieldError } if err = p.writeField6(oprot); err != nil { fieldId = 6 goto WriteFieldError } if err = p.writeField7(oprot); err != nil { fieldId = 7 goto WriteFieldError } if err = p.writeField8(oprot); err != nil { fieldId = 8 goto WriteFieldError } if err = p.writeField9(oprot); err != nil { fieldId = 9 goto WriteFieldError } } if err = oprot.WriteFieldStop(); err != nil { goto WriteFieldStopError } if err = oprot.WriteStructEnd(); err != nil { goto WriteStructEndError } return nil WriteStructBeginError: return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) WriteFieldError: return thrift.PrependError(fmt.Sprintf("%T write field %d error: ", p, fieldId), err) WriteFieldStopError: return thrift.PrependError(fmt.Sprintf("%T write field stop error: ", p), err) WriteStructEndError: return thrift.PrependError(fmt.Sprintf("%T write struct end error: ", p), err) } func (p *DocumentProgress) writeField1(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("document_id", thrift.I64, 1); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI64(p.DocumentID); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 1 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 1 end error: ", p), err) } func (p *DocumentProgress) writeField2(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("progress", thrift.I32, 2); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(p.Progress); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 2 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 2 end error: ", p), err) } func (p *DocumentProgress) writeField3(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("status", thrift.I32, 3); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(int32(p.Status)); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 3 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 3 end error: ", p), err) } func (p *DocumentProgress) writeField4(oprot thrift.TProtocol) (err error) { if p.IsSetStatusDescript() { if err = oprot.WriteFieldBegin("status_descript", thrift.STRING, 4); err != nil { goto WriteFieldBeginError } if err := oprot.WriteString(*p.StatusDescript); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 4 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 4 end error: ", p), err) } func (p *DocumentProgress) writeField5(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("document_name", thrift.STRING, 5); err != nil { goto WriteFieldBeginError } if err := oprot.WriteString(p.DocumentName); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 5 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 5 end error: ", p), err) } func (p *DocumentProgress) writeField6(oprot thrift.TProtocol) (err error) { if p.IsSetRemainingTime() { if err = oprot.WriteFieldBegin("remaining_time", thrift.I64, 6); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI64(*p.RemainingTime); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 6 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 6 end error: ", p), err) } func (p *DocumentProgress) writeField7(oprot thrift.TProtocol) (err error) { if p.IsSetSize() { if err = oprot.WriteFieldBegin("size", thrift.I64, 7); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI64(*p.Size); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 7 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 7 end error: ", p), err) } func (p *DocumentProgress) writeField8(oprot thrift.TProtocol) (err error) { if p.IsSetType() { if err = oprot.WriteFieldBegin("type", thrift.STRING, 8); err != nil { goto WriteFieldBeginError } if err := oprot.WriteString(*p.Type); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 8 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 8 end error: ", p), err) } func (p *DocumentProgress) writeField9(oprot thrift.TProtocol) (err error) { if p.IsSetURL() { if err = oprot.WriteFieldBegin("url", thrift.STRING, 9); err != nil { goto WriteFieldBeginError } if err := oprot.WriteString(*p.URL); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 9 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 9 end error: ", p), err) } func (p *DocumentProgress) String() string { if p == nil { return "" } return fmt.Sprintf("DocumentProgress(%+v)", *p) } type Dataset struct { DatasetID int64 `thrift:"dataset_id,1" form:"dataset_id" json:"dataset_id,string" query:"dataset_id"` // Dataset name Name string `thrift:"name,2" form:"name" json:"name" query:"name"` // file list FileList []string `thrift:"file_list,3" form:"file_list" json:"file_list" query:"file_list"` // All file sizes AllFileSize int64 `thrift:"all_file_size,4" form:"all_file_size" json:"all_file_size,string" query:"all_file_size"` // Bot count BotUsedCount int32 `thrift:"bot_used_count,5" form:"bot_used_count" json:"bot_used_count" query:"bot_used_count"` Status DatasetStatus `thrift:"status,6" form:"status" json:"status" query:"status"` // List of file names in process, compatible with old logic ProcessingFileList []string `thrift:"processing_file_list,7" form:"processing_file_list" json:"processing_file_list" query:"processing_file_list"` // Update time, second timestamp UpdateTime int32 `thrift:"update_time,8" form:"update_time" json:"update_time" query:"update_time"` IconURL string `thrift:"icon_url,9" form:"icon_url" json:"icon_url" query:"icon_url"` Description string `thrift:"description,10" form:"description" json:"description" query:"description"` IconURI string `thrift:"icon_uri,11" form:"icon_uri" json:"icon_uri" query:"icon_uri"` // Can it be edited? CanEdit bool `thrift:"can_edit,12" form:"can_edit" json:"can_edit" query:"can_edit"` // create_time, second timestamp CreateTime int32 `thrift:"create_time,13" form:"create_time" json:"create_time" query:"create_time"` // creator ID CreatorID int64 `thrift:"creator_id,14" form:"creator_id" json:"creator_id,string" query:"creator_id"` // Space ID SpaceID int64 `thrift:"space_id,15" form:"space_id" json:"space_id,string" query:"space_id"` // Processing failed files FailedFileList []string `thrift:"failed_file_list,18" form:"failed_file_list" json:"failed_file_list" query:"failed_file_list"` FormatType FormatType `thrift:"format_type,19" form:"format_type" json:"format_type" query:"format_type"` // number of segments SliceCount int32 `thrift:"slice_count,20" form:"slice_count" json:"slice_count" query:"slice_count"` // hit count HitCount int32 `thrift:"hit_count,21" form:"hit_count" json:"hit_count" query:"hit_count"` // number of documents DocCount int32 `thrift:"doc_count,22" form:"doc_count" json:"doc_count" query:"doc_count"` // slicing rule ChunkStrategy *ChunkStrategy `thrift:"chunk_strategy,23" form:"chunk_strategy" json:"chunk_strategy" query:"chunk_strategy"` // List of file IDs in process ProcessingFileIDList []string `thrift:"processing_file_id_list,24" form:"processing_file_id_list" json:"processing_file_id_list" query:"processing_file_id_list"` //project ID ProjectID string `thrift:"project_id,25" form:"project_id" json:"project_id" query:"project_id"` } func NewDataset() *Dataset { return &Dataset{} } func (p *Dataset) InitDefault() { } func (p *Dataset) GetDatasetID() (v int64) { return p.DatasetID } func (p *Dataset) GetName() (v string) { return p.Name } func (p *Dataset) GetFileList() (v []string) { return p.FileList } func (p *Dataset) GetAllFileSize() (v int64) { return p.AllFileSize } func (p *Dataset) GetBotUsedCount() (v int32) { return p.BotUsedCount } func (p *Dataset) GetStatus() (v DatasetStatus) { return p.Status } func (p *Dataset) GetProcessingFileList() (v []string) { return p.ProcessingFileList } func (p *Dataset) GetUpdateTime() (v int32) { return p.UpdateTime } func (p *Dataset) GetIconURL() (v string) { return p.IconURL } func (p *Dataset) GetDescription() (v string) { return p.Description } func (p *Dataset) GetIconURI() (v string) { return p.IconURI } func (p *Dataset) GetCanEdit() (v bool) { return p.CanEdit } func (p *Dataset) GetCreateTime() (v int32) { return p.CreateTime } func (p *Dataset) GetCreatorID() (v int64) { return p.CreatorID } func (p *Dataset) GetSpaceID() (v int64) { return p.SpaceID } func (p *Dataset) GetFailedFileList() (v []string) { return p.FailedFileList } func (p *Dataset) GetFormatType() (v FormatType) { return p.FormatType } func (p *Dataset) GetSliceCount() (v int32) { return p.SliceCount } func (p *Dataset) GetHitCount() (v int32) { return p.HitCount } func (p *Dataset) GetDocCount() (v int32) { return p.DocCount } var Dataset_ChunkStrategy_DEFAULT *ChunkStrategy func (p *Dataset) GetChunkStrategy() (v *ChunkStrategy) { if !p.IsSetChunkStrategy() { return Dataset_ChunkStrategy_DEFAULT } return p.ChunkStrategy } func (p *Dataset) GetProcessingFileIDList() (v []string) { return p.ProcessingFileIDList } func (p *Dataset) GetProjectID() (v string) { return p.ProjectID } var fieldIDToName_Dataset = map[int16]string{ 1: "dataset_id", 2: "name", 3: "file_list", 4: "all_file_size", 5: "bot_used_count", 6: "status", 7: "processing_file_list", 8: "update_time", 9: "icon_url", 10: "description", 11: "icon_uri", 12: "can_edit", 13: "create_time", 14: "creator_id", 15: "space_id", 18: "failed_file_list", 19: "format_type", 20: "slice_count", 21: "hit_count", 22: "doc_count", 23: "chunk_strategy", 24: "processing_file_id_list", 25: "project_id", } func (p *Dataset) IsSetChunkStrategy() bool { return p.ChunkStrategy != nil } func (p *Dataset) Read(iprot thrift.TProtocol) (err error) { var fieldTypeId thrift.TType var fieldId int16 if _, err = iprot.ReadStructBegin(); err != nil { goto ReadStructBeginError } for { _, fieldTypeId, fieldId, err = iprot.ReadFieldBegin() if err != nil { goto ReadFieldBeginError } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.I64 { if err = p.ReadField1(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 2: if fieldTypeId == thrift.STRING { if err = p.ReadField2(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 3: if fieldTypeId == thrift.LIST { if err = p.ReadField3(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 4: if fieldTypeId == thrift.I64 { if err = p.ReadField4(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 5: if fieldTypeId == thrift.I32 { if err = p.ReadField5(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 6: if fieldTypeId == thrift.I32 { if err = p.ReadField6(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 7: if fieldTypeId == thrift.LIST { if err = p.ReadField7(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 8: if fieldTypeId == thrift.I32 { if err = p.ReadField8(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 9: if fieldTypeId == thrift.STRING { if err = p.ReadField9(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 10: if fieldTypeId == thrift.STRING { if err = p.ReadField10(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 11: if fieldTypeId == thrift.STRING { if err = p.ReadField11(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 12: if fieldTypeId == thrift.BOOL { if err = p.ReadField12(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 13: if fieldTypeId == thrift.I32 { if err = p.ReadField13(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 14: if fieldTypeId == thrift.I64 { if err = p.ReadField14(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 15: if fieldTypeId == thrift.I64 { if err = p.ReadField15(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 18: if fieldTypeId == thrift.LIST { if err = p.ReadField18(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 19: if fieldTypeId == thrift.I32 { if err = p.ReadField19(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 20: if fieldTypeId == thrift.I32 { if err = p.ReadField20(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 21: if fieldTypeId == thrift.I32 { if err = p.ReadField21(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 22: if fieldTypeId == thrift.I32 { if err = p.ReadField22(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 23: if fieldTypeId == thrift.STRUCT { if err = p.ReadField23(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 24: if fieldTypeId == thrift.LIST { if err = p.ReadField24(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } case 25: if fieldTypeId == thrift.STRING { if err = p.ReadField25(iprot); err != nil { goto ReadFieldError } } else if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } default: if err = iprot.Skip(fieldTypeId); err != nil { goto SkipFieldError } } if err = iprot.ReadFieldEnd(); err != nil { goto ReadFieldEndError } } if err = iprot.ReadStructEnd(); err != nil { goto ReadStructEndError } return nil ReadStructBeginError: return thrift.PrependError(fmt.Sprintf("%T read struct begin error: ", p), err) ReadFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T read field %d begin error: ", p, fieldId), err) ReadFieldError: return thrift.PrependError(fmt.Sprintf("%T read field %d '%s' error: ", p, fieldId, fieldIDToName_Dataset[fieldId]), err) SkipFieldError: return thrift.PrependError(fmt.Sprintf("%T field %d skip type %d error: ", p, fieldId, fieldTypeId), err) ReadFieldEndError: return thrift.PrependError(fmt.Sprintf("%T read field end error", p), err) ReadStructEndError: return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } func (p *Dataset) ReadField1(iprot thrift.TProtocol) error { var _field int64 if v, err := iprot.ReadI64(); err != nil { return err } else { _field = v } p.DatasetID = _field return nil } func (p *Dataset) ReadField2(iprot thrift.TProtocol) error { var _field string if v, err := iprot.ReadString(); err != nil { return err } else { _field = v } p.Name = _field return nil } func (p *Dataset) ReadField3(iprot thrift.TProtocol) error { _, size, err := iprot.ReadListBegin() if err != nil { return err } _field := make([]string, 0, size) for i := 0; i < size; i++ { var _elem string if v, err := iprot.ReadString(); err != nil { return err } else { _elem = v } _field = append(_field, _elem) } if err := iprot.ReadListEnd(); err != nil { return err } p.FileList = _field return nil } func (p *Dataset) ReadField4(iprot thrift.TProtocol) error { var _field int64 if v, err := iprot.ReadI64(); err != nil { return err } else { _field = v } p.AllFileSize = _field return nil } func (p *Dataset) ReadField5(iprot thrift.TProtocol) error { var _field int32 if v, err := iprot.ReadI32(); err != nil { return err } else { _field = v } p.BotUsedCount = _field return nil } func (p *Dataset) ReadField6(iprot thrift.TProtocol) error { var _field DatasetStatus if v, err := iprot.ReadI32(); err != nil { return err } else { _field = DatasetStatus(v) } p.Status = _field return nil } func (p *Dataset) ReadField7(iprot thrift.TProtocol) error { _, size, err := iprot.ReadListBegin() if err != nil { return err } _field := make([]string, 0, size) for i := 0; i < size; i++ { var _elem string if v, err := iprot.ReadString(); err != nil { return err } else { _elem = v } _field = append(_field, _elem) } if err := iprot.ReadListEnd(); err != nil { return err } p.ProcessingFileList = _field return nil } func (p *Dataset) ReadField8(iprot thrift.TProtocol) error { var _field int32 if v, err := iprot.ReadI32(); err != nil { return err } else { _field = v } p.UpdateTime = _field return nil } func (p *Dataset) ReadField9(iprot thrift.TProtocol) error { var _field string if v, err := iprot.ReadString(); err != nil { return err } else { _field = v } p.IconURL = _field return nil } func (p *Dataset) ReadField10(iprot thrift.TProtocol) error { var _field string if v, err := iprot.ReadString(); err != nil { return err } else { _field = v } p.Description = _field return nil } func (p *Dataset) ReadField11(iprot thrift.TProtocol) error { var _field string if v, err := iprot.ReadString(); err != nil { return err } else { _field = v } p.IconURI = _field return nil } func (p *Dataset) ReadField12(iprot thrift.TProtocol) error { var _field bool if v, err := iprot.ReadBool(); err != nil { return err } else { _field = v } p.CanEdit = _field return nil } func (p *Dataset) ReadField13(iprot thrift.TProtocol) error { var _field int32 if v, err := iprot.ReadI32(); err != nil { return err } else { _field = v } p.CreateTime = _field return nil } func (p *Dataset) ReadField14(iprot thrift.TProtocol) error { var _field int64 if v, err := iprot.ReadI64(); err != nil { return err } else { _field = v } p.CreatorID = _field return nil } func (p *Dataset) ReadField15(iprot thrift.TProtocol) error { var _field int64 if v, err := iprot.ReadI64(); err != nil { return err } else { _field = v } p.SpaceID = _field return nil } func (p *Dataset) ReadField18(iprot thrift.TProtocol) error { _, size, err := iprot.ReadListBegin() if err != nil { return err } _field := make([]string, 0, size) for i := 0; i < size; i++ { var _elem string if v, err := iprot.ReadString(); err != nil { return err } else { _elem = v } _field = append(_field, _elem) } if err := iprot.ReadListEnd(); err != nil { return err } p.FailedFileList = _field return nil } func (p *Dataset) ReadField19(iprot thrift.TProtocol) error { var _field FormatType if v, err := iprot.ReadI32(); err != nil { return err } else { _field = FormatType(v) } p.FormatType = _field return nil } func (p *Dataset) ReadField20(iprot thrift.TProtocol) error { var _field int32 if v, err := iprot.ReadI32(); err != nil { return err } else { _field = v } p.SliceCount = _field return nil } func (p *Dataset) ReadField21(iprot thrift.TProtocol) error { var _field int32 if v, err := iprot.ReadI32(); err != nil { return err } else { _field = v } p.HitCount = _field return nil } func (p *Dataset) ReadField22(iprot thrift.TProtocol) error { var _field int32 if v, err := iprot.ReadI32(); err != nil { return err } else { _field = v } p.DocCount = _field return nil } func (p *Dataset) ReadField23(iprot thrift.TProtocol) error { _field := NewChunkStrategy() if err := _field.Read(iprot); err != nil { return err } p.ChunkStrategy = _field return nil } func (p *Dataset) ReadField24(iprot thrift.TProtocol) error { _, size, err := iprot.ReadListBegin() if err != nil { return err } _field := make([]string, 0, size) for i := 0; i < size; i++ { var _elem string if v, err := iprot.ReadString(); err != nil { return err } else { _elem = v } _field = append(_field, _elem) } if err := iprot.ReadListEnd(); err != nil { return err } p.ProcessingFileIDList = _field return nil } func (p *Dataset) ReadField25(iprot thrift.TProtocol) error { var _field string if v, err := iprot.ReadString(); err != nil { return err } else { _field = v } p.ProjectID = _field return nil } func (p *Dataset) Write(oprot thrift.TProtocol) (err error) { var fieldId int16 if err = oprot.WriteStructBegin("Dataset"); err != nil { goto WriteStructBeginError } if p != nil { if err = p.writeField1(oprot); err != nil { fieldId = 1 goto WriteFieldError } if err = p.writeField2(oprot); err != nil { fieldId = 2 goto WriteFieldError } if err = p.writeField3(oprot); err != nil { fieldId = 3 goto WriteFieldError } if err = p.writeField4(oprot); err != nil { fieldId = 4 goto WriteFieldError } if err = p.writeField5(oprot); err != nil { fieldId = 5 goto WriteFieldError } if err = p.writeField6(oprot); err != nil { fieldId = 6 goto WriteFieldError } if err = p.writeField7(oprot); err != nil { fieldId = 7 goto WriteFieldError } if err = p.writeField8(oprot); err != nil { fieldId = 8 goto WriteFieldError } if err = p.writeField9(oprot); err != nil { fieldId = 9 goto WriteFieldError } if err = p.writeField10(oprot); err != nil { fieldId = 10 goto WriteFieldError } if err = p.writeField11(oprot); err != nil { fieldId = 11 goto WriteFieldError } if err = p.writeField12(oprot); err != nil { fieldId = 12 goto WriteFieldError } if err = p.writeField13(oprot); err != nil { fieldId = 13 goto WriteFieldError } if err = p.writeField14(oprot); err != nil { fieldId = 14 goto WriteFieldError } if err = p.writeField15(oprot); err != nil { fieldId = 15 goto WriteFieldError } if err = p.writeField18(oprot); err != nil { fieldId = 18 goto WriteFieldError } if err = p.writeField19(oprot); err != nil { fieldId = 19 goto WriteFieldError } if err = p.writeField20(oprot); err != nil { fieldId = 20 goto WriteFieldError } if err = p.writeField21(oprot); err != nil { fieldId = 21 goto WriteFieldError } if err = p.writeField22(oprot); err != nil { fieldId = 22 goto WriteFieldError } if err = p.writeField23(oprot); err != nil { fieldId = 23 goto WriteFieldError } if err = p.writeField24(oprot); err != nil { fieldId = 24 goto WriteFieldError } if err = p.writeField25(oprot); err != nil { fieldId = 25 goto WriteFieldError } } if err = oprot.WriteFieldStop(); err != nil { goto WriteFieldStopError } if err = oprot.WriteStructEnd(); err != nil { goto WriteStructEndError } return nil WriteStructBeginError: return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) WriteFieldError: return thrift.PrependError(fmt.Sprintf("%T write field %d error: ", p, fieldId), err) WriteFieldStopError: return thrift.PrependError(fmt.Sprintf("%T write field stop error: ", p), err) WriteStructEndError: return thrift.PrependError(fmt.Sprintf("%T write struct end error: ", p), err) } func (p *Dataset) writeField1(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("dataset_id", thrift.I64, 1); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI64(p.DatasetID); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 1 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 1 end error: ", p), err) } func (p *Dataset) writeField2(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("name", thrift.STRING, 2); err != nil { goto WriteFieldBeginError } if err := oprot.WriteString(p.Name); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 2 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 2 end error: ", p), err) } func (p *Dataset) writeField3(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("file_list", thrift.LIST, 3); err != nil { goto WriteFieldBeginError } if err := oprot.WriteListBegin(thrift.STRING, len(p.FileList)); err != nil { return err } for _, v := range p.FileList { if err := oprot.WriteString(v); err != nil { return err } } if err := oprot.WriteListEnd(); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 3 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 3 end error: ", p), err) } func (p *Dataset) writeField4(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("all_file_size", thrift.I64, 4); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI64(p.AllFileSize); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 4 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 4 end error: ", p), err) } func (p *Dataset) writeField5(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("bot_used_count", thrift.I32, 5); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(p.BotUsedCount); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 5 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 5 end error: ", p), err) } func (p *Dataset) writeField6(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("status", thrift.I32, 6); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(int32(p.Status)); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 6 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 6 end error: ", p), err) } func (p *Dataset) writeField7(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("processing_file_list", thrift.LIST, 7); err != nil { goto WriteFieldBeginError } if err := oprot.WriteListBegin(thrift.STRING, len(p.ProcessingFileList)); err != nil { return err } for _, v := range p.ProcessingFileList { if err := oprot.WriteString(v); err != nil { return err } } if err := oprot.WriteListEnd(); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 7 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 7 end error: ", p), err) } func (p *Dataset) writeField8(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("update_time", thrift.I32, 8); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(p.UpdateTime); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 8 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 8 end error: ", p), err) } func (p *Dataset) writeField9(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("icon_url", thrift.STRING, 9); err != nil { goto WriteFieldBeginError } if err := oprot.WriteString(p.IconURL); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 9 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 9 end error: ", p), err) } func (p *Dataset) writeField10(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("description", thrift.STRING, 10); err != nil { goto WriteFieldBeginError } if err := oprot.WriteString(p.Description); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 10 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 10 end error: ", p), err) } func (p *Dataset) writeField11(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("icon_uri", thrift.STRING, 11); err != nil { goto WriteFieldBeginError } if err := oprot.WriteString(p.IconURI); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 11 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 11 end error: ", p), err) } func (p *Dataset) writeField12(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("can_edit", thrift.BOOL, 12); err != nil { goto WriteFieldBeginError } if err := oprot.WriteBool(p.CanEdit); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 12 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 12 end error: ", p), err) } func (p *Dataset) writeField13(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("create_time", thrift.I32, 13); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(p.CreateTime); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 13 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 13 end error: ", p), err) } func (p *Dataset) writeField14(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("creator_id", thrift.I64, 14); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI64(p.CreatorID); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 14 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 14 end error: ", p), err) } func (p *Dataset) writeField15(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("space_id", thrift.I64, 15); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI64(p.SpaceID); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 15 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 15 end error: ", p), err) } func (p *Dataset) writeField18(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("failed_file_list", thrift.LIST, 18); err != nil { goto WriteFieldBeginError } if err := oprot.WriteListBegin(thrift.STRING, len(p.FailedFileList)); err != nil { return err } for _, v := range p.FailedFileList { if err := oprot.WriteString(v); err != nil { return err } } if err := oprot.WriteListEnd(); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 18 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 18 end error: ", p), err) } func (p *Dataset) writeField19(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("format_type", thrift.I32, 19); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(int32(p.FormatType)); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 19 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 19 end error: ", p), err) } func (p *Dataset) writeField20(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("slice_count", thrift.I32, 20); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(p.SliceCount); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 20 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 20 end error: ", p), err) } func (p *Dataset) writeField21(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("hit_count", thrift.I32, 21); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(p.HitCount); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 21 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 21 end error: ", p), err) } func (p *Dataset) writeField22(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("doc_count", thrift.I32, 22); err != nil { goto WriteFieldBeginError } if err := oprot.WriteI32(p.DocCount); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 22 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 22 end error: ", p), err) } func (p *Dataset) writeField23(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("chunk_strategy", thrift.STRUCT, 23); err != nil { goto WriteFieldBeginError } if err := p.ChunkStrategy.Write(oprot); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 23 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 23 end error: ", p), err) } func (p *Dataset) writeField24(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("processing_file_id_list", thrift.LIST, 24); err != nil { goto WriteFieldBeginError } if err := oprot.WriteListBegin(thrift.STRING, len(p.ProcessingFileIDList)); err != nil { return err } for _, v := range p.ProcessingFileIDList { if err := oprot.WriteString(v); err != nil { return err } } if err := oprot.WriteListEnd(); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 24 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 24 end error: ", p), err) } func (p *Dataset) writeField25(oprot thrift.TProtocol) (err error) { if err = oprot.WriteFieldBegin("project_id", thrift.STRING, 25); err != nil { goto WriteFieldBeginError } if err := oprot.WriteString(p.ProjectID); err != nil { return err } if err = oprot.WriteFieldEnd(); err != nil { goto WriteFieldEndError } return nil WriteFieldBeginError: return thrift.PrependError(fmt.Sprintf("%T write field 25 begin error: ", p), err) WriteFieldEndError: return thrift.PrependError(fmt.Sprintf("%T write field 25 end error: ", p), err) } func (p *Dataset) String() string { if p == nil { return "" } return fmt.Sprintf("Dataset(%+v)", *p) }