Files
2026-07-13 13:24:55 +08:00

5001 lines
129 KiB
Go

/*
* 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 "<UNSET>"
}
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 "<UNSET>"
}
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 "<UNSET>"
}
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 "<UNSET>"
}
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 "<UNSET>"
}
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 "<UNSET>"
}
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 "<UNSET>"
}
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 "<UNSET>"
}
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 "<UNSET>"
}
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 "<UNSET>"
}
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 "<UNSET>"
}
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 "<UNSET>"
}
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 "<nil>"
}
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 "<nil>"
}
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 "<nil>"
}
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 "<nil>"
}
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 "<nil>"
}
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 "<nil>"
}
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 "<nil>"
}
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 "<nil>"
}
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 "<nil>"
}
return fmt.Sprintf("Dataset(%+v)", *p)
}