go-client/idl/admin/bulk

// Autogenerated by Thrift Compiler (0.13.0) // DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING package admin import ( "bytes" "context" "database/sql/driver" "errors" "fmt" "github.com/apache/incubator-pegasus/go-client/idl/base" "github.com/apache/incubator-pegasus/go-client/idl/replication" "github.com/apache/thrift/lib/go/thrift" "reflect" ) // (needed to ensure safety because of naive import list construction.) var _ = thrift.ZERO var _ = fmt.Printf var _ = context.Background var _ = reflect.DeepEqual var _ = bytes.Equal var _ = base.GoUnusedProtection__ var _ = replication.GoUnusedProtection__ type BulkLoadStatus int64 const ( BulkLoadStatus_BLS_INVALID BulkLoadStatus = 0 BulkLoadStatus_BLS_DOWNLOADING BulkLoadStatus = 1 BulkLoadStatus_BLS_DOWNLOADED BulkLoadStatus = 2 BulkLoadStatus_BLS_INGESTING BulkLoadStatus = 3 BulkLoadStatus_BLS_SUCCEED BulkLoadStatus = 4 BulkLoadStatus_BLS_FAILED BulkLoadStatus = 5 BulkLoadStatus_BLS_PAUSING BulkLoadStatus = 6 BulkLoadStatus_BLS_PAUSED BulkLoadStatus = 7 BulkLoadStatus_BLS_CANCELED BulkLoadStatus = 8 ) func (p BulkLoadStatus) String() string { switch p { case BulkLoadStatus_BLS_INVALID: return "BLS_INVALID" case BulkLoadStatus_BLS_DOWNLOADING: return "BLS_DOWNLOADING" case BulkLoadStatus_BLS_DOWNLOADED: return "BLS_DOWNLOADED" case BulkLoadStatus_BLS_INGESTING: return "BLS_INGESTING" case BulkLoadStatus_BLS_SUCCEED: return "BLS_SUCCEED" case BulkLoadStatus_BLS_FAILED: return "BLS_FAILED" case BulkLoadStatus_BLS_PAUSING: return "BLS_PAUSING" case BulkLoadStatus_BLS_PAUSED: return "BLS_PAUSED" case BulkLoadStatus_BLS_CANCELED: return "BLS_CANCELED" } return "<UNSET>" } func BulkLoadStatusFromString(s string) (BulkLoadStatus, error) { switch s { case "BLS_INVALID": return BulkLoadStatus_BLS_INVALID, nil case "BLS_DOWNLOADING": return BulkLoadStatus_BLS_DOWNLOADING, nil case "BLS_DOWNLOADED": return BulkLoadStatus_BLS_DOWNLOADED, nil case "BLS_INGESTING": return BulkLoadStatus_BLS_INGESTING, nil case "BLS_SUCCEED": return BulkLoadStatus_BLS_SUCCEED, nil case "BLS_FAILED": return BulkLoadStatus_BLS_FAILED, nil case "BLS_PAUSING": return BulkLoadStatus_BLS_PAUSING, nil case "BLS_PAUSED": return BulkLoadStatus_BLS_PAUSED, nil case "BLS_CANCELED": return BulkLoadStatus_BLS_CANCELED, nil } return BulkLoadStatus(0), fmt.Errorf("not a valid BulkLoadStatus string") } func BulkLoadStatusPtr(v BulkLoadStatus) *BulkLoadStatus { return &v } func (p BulkLoadStatus) MarshalText() ([]byte, error) { return []byte(p.String()), nil } func (p *BulkLoadStatus) UnmarshalText(text []byte) error { q, err := BulkLoadStatusFromString(string(text)) if err != nil { return err } *p = q return nil } func (p *BulkLoadStatus) Scan(value interface{}) error { v, ok := value.(int64) if !ok { return errors.New("Scan value is not int64") } *p = BulkLoadStatus(v) return nil } func (p *BulkLoadStatus) Value() (driver.Value, error) { if p == nil { return nil, nil } return int64(*p), nil } type IngestionStatus int64 const ( IngestionStatus_IS_INVALID IngestionStatus = 0 IngestionStatus_IS_RUNNING IngestionStatus = 1 IngestionStatus_IS_SUCCEED IngestionStatus = 2 IngestionStatus_IS_FAILED IngestionStatus = 3 ) func (p IngestionStatus) String() string { switch p { case IngestionStatus_IS_INVALID: return "IS_INVALID" case IngestionStatus_IS_RUNNING: return "IS_RUNNING" case IngestionStatus_IS_SUCCEED: return "IS_SUCCEED" case IngestionStatus_IS_FAILED: return "IS_FAILED" } return "<UNSET>" } func IngestionStatusFromString(s string) (IngestionStatus, error) { switch s { case "IS_INVALID": return IngestionStatus_IS_INVALID, nil case "IS_RUNNING": return IngestionStatus_IS_RUNNING, nil case "IS_SUCCEED": return IngestionStatus_IS_SUCCEED, nil case "IS_FAILED": return IngestionStatus_IS_FAILED, nil } return IngestionStatus(0), fmt.Errorf("not a valid IngestionStatus string") } func IngestionStatusPtr(v IngestionStatus) *IngestionStatus { return &v } func (p IngestionStatus) MarshalText() ([]byte, error) { return []byte(p.String()), nil } func (p *IngestionStatus) UnmarshalText(text []byte) error { q, err := IngestionStatusFromString(string(text)) if err != nil { return err } *p = q return nil } func (p *IngestionStatus) Scan(value interface{}) error { v, ok := value.(int64) if !ok { return errors.New("Scan value is not int64") } *p = IngestionStatus(v) return nil } func (p *IngestionStatus) Value() (driver.Value, error) { if p == nil { return nil, nil } return int64(*p), nil } type BulkLoadControlType int64 const ( BulkLoadControlType_BLC_PAUSE BulkLoadControlType = 0 BulkLoadControlType_BLC_RESTART BulkLoadControlType = 1 BulkLoadControlType_BLC_CANCEL BulkLoadControlType = 2 BulkLoadControlType_BLC_FORCE_CANCEL BulkLoadControlType = 3 ) func (p BulkLoadControlType) String() string { switch p { case BulkLoadControlType_BLC_PAUSE: return "BLC_PAUSE" case BulkLoadControlType_BLC_RESTART: return "BLC_RESTART" case BulkLoadControlType_BLC_CANCEL: return "BLC_CANCEL" case BulkLoadControlType_BLC_FORCE_CANCEL: return "BLC_FORCE_CANCEL" } return "<UNSET>" } func BulkLoadControlTypeFromString(s string) (BulkLoadControlType, error) { switch s { case "BLC_PAUSE": return BulkLoadControlType_BLC_PAUSE, nil case "BLC_RESTART": return BulkLoadControlType_BLC_RESTART, nil case "BLC_CANCEL": return BulkLoadControlType_BLC_CANCEL, nil case "BLC_FORCE_CANCEL": return BulkLoadControlType_BLC_FORCE_CANCEL, nil } return BulkLoadControlType(0), fmt.Errorf("not a valid BulkLoadControlType string") } func BulkLoadControlTypePtr(v BulkLoadControlType) *BulkLoadControlType { return &v } func (p BulkLoadControlType) MarshalText() ([]byte, error) { return []byte(p.String()), nil } func (p *BulkLoadControlType) UnmarshalText(text []byte) error { q, err := BulkLoadControlTypeFromString(string(text)) if err != nil { return err } *p = q return nil } func (p *BulkLoadControlType) Scan(value interface{}) error { v, ok := value.(int64) if !ok { return errors.New("Scan value is not int64") } *p = BulkLoadControlType(v) return nil } func (p *BulkLoadControlType) Value() (driver.Value, error) { if p == nil { return nil, nil } return int64(*p), nil } // Attributes: // - Files // - FileTotalSize type BulkLoadMetadata struct { Files []*FileMeta `thrift:"files,1" db:"files" json:"files"` FileTotalSize int64 `thrift:"file_total_size,2" db:"file_total_size" json:"file_total_size"` } func NewBulkLoadMetadata() *BulkLoadMetadata { return &BulkLoadMetadata{} } func (p *BulkLoadMetadata) GetFiles() []*FileMeta { return p.Files } func (p *BulkLoadMetadata) GetFileTotalSize() int64 { return p.FileTotalSize } func (p *BulkLoadMetadata) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) } for { _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() if err != nil { return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.LIST { if err := p.ReadField1(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 2: if fieldTypeId == thrift.I64 { if err := p.ReadField2(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } default: if err := iprot.Skip(fieldTypeId); err != nil { return err } } if err := iprot.ReadFieldEnd(); err != nil { return err } } if err := iprot.ReadStructEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } return nil } func (p *BulkLoadMetadata) ReadField1(iprot thrift.TProtocol) error { _, size, err := iprot.ReadListBegin() if err != nil { return thrift.PrependError("error reading list begin: ", err) } tSlice := make([]*FileMeta, 0, size) p.Files = tSlice for i := 0; i < size; i++ { _elem0 := &FileMeta{} if err := _elem0.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem0), err) } p.Files = append(p.Files, _elem0) } if err := iprot.ReadListEnd(); err != nil { return thrift.PrependError("error reading list end: ", err) } return nil } func (p *BulkLoadMetadata) ReadField2(iprot thrift.TProtocol) error { if v, err := iprot.ReadI64(); err != nil { return thrift.PrependError("error reading field 2: ", err) } else { p.FileTotalSize = v } return nil } func (p *BulkLoadMetadata) Write(oprot thrift.TProtocol) error { if err := oprot.WriteStructBegin("bulk_load_metadata"); err != nil { return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } if p != nil { if err := p.writeField1(oprot); err != nil { return err } if err := p.writeField2(oprot); err != nil { return err } } if err := oprot.WriteFieldStop(); err != nil { return thrift.PrependError("write field stop error: ", err) } if err := oprot.WriteStructEnd(); err != nil { return thrift.PrependError("write struct stop error: ", err) } return nil } func (p *BulkLoadMetadata) writeField1(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("files", thrift.LIST, 1); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:files: ", p), err) } if err := oprot.WriteListBegin(thrift.STRUCT, len(p.Files)); err != nil { return thrift.PrependError("error writing list begin: ", err) } for _, v := range p.Files { if err := v.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", v), err) } } if err := oprot.WriteListEnd(); err != nil { return thrift.PrependError("error writing list end: ", err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 1:files: ", p), err) } return err } func (p *BulkLoadMetadata) writeField2(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("file_total_size", thrift.I64, 2); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:file_total_size: ", p), err) } if err := oprot.WriteI64(int64(p.FileTotalSize)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.file_total_size (2) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 2:file_total_size: ", p), err) } return err } func (p *BulkLoadMetadata) String() string { if p == nil { return "<nil>" } return fmt.Sprintf("BulkLoadMetadata(%+v)", *p) } // Attributes: // - AppName // - ClusterName // - FileProviderType // - RemoteRootPath // - IngestBehind type StartBulkLoadRequest struct { AppName string `thrift:"app_name,1" db:"app_name" json:"app_name"` ClusterName string `thrift:"cluster_name,2" db:"cluster_name" json:"cluster_name"` FileProviderType string `thrift:"file_provider_type,3" db:"file_provider_type" json:"file_provider_type"` RemoteRootPath string `thrift:"remote_root_path,4" db:"remote_root_path" json:"remote_root_path"` IngestBehind bool `thrift:"ingest_behind,5" db:"ingest_behind" json:"ingest_behind"` } func NewStartBulkLoadRequest() *StartBulkLoadRequest { return &StartBulkLoadRequest{} } func (p *StartBulkLoadRequest) GetAppName() string { return p.AppName } func (p *StartBulkLoadRequest) GetClusterName() string { return p.ClusterName } func (p *StartBulkLoadRequest) GetFileProviderType() string { return p.FileProviderType } func (p *StartBulkLoadRequest) GetRemoteRootPath() string { return p.RemoteRootPath } func (p *StartBulkLoadRequest) GetIngestBehind() bool { return p.IngestBehind } func (p *StartBulkLoadRequest) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) } for { _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() if err != nil { return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.STRING { if err := p.ReadField1(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 2: if fieldTypeId == thrift.STRING { if err := p.ReadField2(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 3: if fieldTypeId == thrift.STRING { if err := p.ReadField3(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 4: if fieldTypeId == thrift.STRING { if err := p.ReadField4(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 5: if fieldTypeId == thrift.BOOL { if err := p.ReadField5(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } default: if err := iprot.Skip(fieldTypeId); err != nil { return err } } if err := iprot.ReadFieldEnd(); err != nil { return err } } if err := iprot.ReadStructEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } return nil } func (p *StartBulkLoadRequest) ReadField1(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 1: ", err) } else { p.AppName = v } return nil } func (p *StartBulkLoadRequest) ReadField2(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 2: ", err) } else { p.ClusterName = v } return nil } func (p *StartBulkLoadRequest) ReadField3(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 3: ", err) } else { p.FileProviderType = v } return nil } func (p *StartBulkLoadRequest) ReadField4(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 4: ", err) } else { p.RemoteRootPath = v } return nil } func (p *StartBulkLoadRequest) ReadField5(iprot thrift.TProtocol) error { if v, err := iprot.ReadBool(); err != nil { return thrift.PrependError("error reading field 5: ", err) } else { p.IngestBehind = v } return nil } func (p *StartBulkLoadRequest) Write(oprot thrift.TProtocol) error { if err := oprot.WriteStructBegin("start_bulk_load_request"); err != nil { return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } if p != nil { if err := p.writeField1(oprot); err != nil { return err } if err := p.writeField2(oprot); err != nil { return err } if err := p.writeField3(oprot); err != nil { return err } if err := p.writeField4(oprot); err != nil { return err } if err := p.writeField5(oprot); err != nil { return err } } if err := oprot.WriteFieldStop(); err != nil { return thrift.PrependError("write field stop error: ", err) } if err := oprot.WriteStructEnd(); err != nil { return thrift.PrependError("write struct stop error: ", err) } return nil } func (p *StartBulkLoadRequest) writeField1(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("app_name", thrift.STRING, 1); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:app_name: ", p), err) } if err := oprot.WriteString(string(p.AppName)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.app_name (1) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 1:app_name: ", p), err) } return err } func (p *StartBulkLoadRequest) writeField2(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("cluster_name", thrift.STRING, 2); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:cluster_name: ", p), err) } if err := oprot.WriteString(string(p.ClusterName)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.cluster_name (2) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 2:cluster_name: ", p), err) } return err } func (p *StartBulkLoadRequest) writeField3(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("file_provider_type", thrift.STRING, 3); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 3:file_provider_type: ", p), err) } if err := oprot.WriteString(string(p.FileProviderType)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.file_provider_type (3) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 3:file_provider_type: ", p), err) } return err } func (p *StartBulkLoadRequest) writeField4(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("remote_root_path", thrift.STRING, 4); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 4:remote_root_path: ", p), err) } if err := oprot.WriteString(string(p.RemoteRootPath)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.remote_root_path (4) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 4:remote_root_path: ", p), err) } return err } func (p *StartBulkLoadRequest) writeField5(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("ingest_behind", thrift.BOOL, 5); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 5:ingest_behind: ", p), err) } if err := oprot.WriteBool(bool(p.IngestBehind)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.ingest_behind (5) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 5:ingest_behind: ", p), err) } return err } func (p *StartBulkLoadRequest) String() string { if p == nil { return "<nil>" } return fmt.Sprintf("StartBulkLoadRequest(%+v)", *p) } // Attributes: // - Err // - HintMsg type StartBulkLoadResponse struct { Err *base.ErrorCode `thrift:"err,1" db:"err" json:"err"` HintMsg string `thrift:"hint_msg,2" db:"hint_msg" json:"hint_msg"` } func NewStartBulkLoadResponse() *StartBulkLoadResponse { return &StartBulkLoadResponse{} } var StartBulkLoadResponse_Err_DEFAULT *base.ErrorCode func (p *StartBulkLoadResponse) GetErr() *base.ErrorCode { if !p.IsSetErr() { return StartBulkLoadResponse_Err_DEFAULT } return p.Err } func (p *StartBulkLoadResponse) GetHintMsg() string { return p.HintMsg } func (p *StartBulkLoadResponse) IsSetErr() bool { return p.Err != nil } func (p *StartBulkLoadResponse) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) } for { _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() if err != nil { return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.STRUCT { if err := p.ReadField1(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 2: if fieldTypeId == thrift.STRING { if err := p.ReadField2(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } default: if err := iprot.Skip(fieldTypeId); err != nil { return err } } if err := iprot.ReadFieldEnd(); err != nil { return err } } if err := iprot.ReadStructEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } return nil } func (p *StartBulkLoadResponse) ReadField1(iprot thrift.TProtocol) error { p.Err = &base.ErrorCode{} if err := p.Err.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Err), err) } return nil } func (p *StartBulkLoadResponse) ReadField2(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 2: ", err) } else { p.HintMsg = v } return nil } func (p *StartBulkLoadResponse) Write(oprot thrift.TProtocol) error { if err := oprot.WriteStructBegin("start_bulk_load_response"); err != nil { return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } if p != nil { if err := p.writeField1(oprot); err != nil { return err } if err := p.writeField2(oprot); err != nil { return err } } if err := oprot.WriteFieldStop(); err != nil { return thrift.PrependError("write field stop error: ", err) } if err := oprot.WriteStructEnd(); err != nil { return thrift.PrependError("write struct stop error: ", err) } return nil } func (p *StartBulkLoadResponse) writeField1(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("err", thrift.STRUCT, 1); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:err: ", p), err) } if err := p.Err.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Err), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 1:err: ", p), err) } return err } func (p *StartBulkLoadResponse) writeField2(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("hint_msg", thrift.STRING, 2); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:hint_msg: ", p), err) } if err := oprot.WriteString(string(p.HintMsg)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.hint_msg (2) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 2:hint_msg: ", p), err) } return err } func (p *StartBulkLoadResponse) String() string { if p == nil { return "<nil>" } return fmt.Sprintf("StartBulkLoadResponse(%+v)", *p) } // Attributes: // - DownloadProgress // - DownloadStatus // - IngestStatus // - IsCleanedUp // - IsPaused type PartitionBulkLoadState struct { DownloadProgress int32 `thrift:"download_progress,1" db:"download_progress" json:"download_progress"` DownloadStatus *base.ErrorCode `thrift:"download_status,2" db:"download_status" json:"download_status,omitempty"` IngestStatus IngestionStatus `thrift:"ingest_status,3" db:"ingest_status" json:"ingest_status"` IsCleanedUp bool `thrift:"is_cleaned_up,4" db:"is_cleaned_up" json:"is_cleaned_up"` IsPaused bool `thrift:"is_paused,5" db:"is_paused" json:"is_paused"` } func NewPartitionBulkLoadState() *PartitionBulkLoadState { return &PartitionBulkLoadState{ IngestStatus: 0, } } var PartitionBulkLoadState_DownloadProgress_DEFAULT int32 = 0 func (p *PartitionBulkLoadState) GetDownloadProgress() int32 { return p.DownloadProgress } var PartitionBulkLoadState_DownloadStatus_DEFAULT *base.ErrorCode func (p *PartitionBulkLoadState) GetDownloadStatus() *base.ErrorCode { if !p.IsSetDownloadStatus() { return PartitionBulkLoadState_DownloadStatus_DEFAULT } return p.DownloadStatus } var PartitionBulkLoadState_IngestStatus_DEFAULT IngestionStatus = 0 func (p *PartitionBulkLoadState) GetIngestStatus() IngestionStatus { return p.IngestStatus } var PartitionBulkLoadState_IsCleanedUp_DEFAULT bool = false func (p *PartitionBulkLoadState) GetIsCleanedUp() bool { return p.IsCleanedUp } var PartitionBulkLoadState_IsPaused_DEFAULT bool = false func (p *PartitionBulkLoadState) GetIsPaused() bool { return p.IsPaused } func (p *PartitionBulkLoadState) IsSetDownloadProgress() bool { return p.DownloadProgress != PartitionBulkLoadState_DownloadProgress_DEFAULT } func (p *PartitionBulkLoadState) IsSetDownloadStatus() bool { return p.DownloadStatus != nil } func (p *PartitionBulkLoadState) IsSetIngestStatus() bool { return p.IngestStatus != PartitionBulkLoadState_IngestStatus_DEFAULT } func (p *PartitionBulkLoadState) IsSetIsCleanedUp() bool { return p.IsCleanedUp != PartitionBulkLoadState_IsCleanedUp_DEFAULT } func (p *PartitionBulkLoadState) IsSetIsPaused() bool { return p.IsPaused != PartitionBulkLoadState_IsPaused_DEFAULT } func (p *PartitionBulkLoadState) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) } for { _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() if err != nil { return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.I32 { if err := p.ReadField1(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 2: if fieldTypeId == thrift.STRUCT { if err := p.ReadField2(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 3: if fieldTypeId == thrift.I32 { if err := p.ReadField3(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 4: if fieldTypeId == thrift.BOOL { if err := p.ReadField4(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 5: if fieldTypeId == thrift.BOOL { if err := p.ReadField5(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } default: if err := iprot.Skip(fieldTypeId); err != nil { return err } } if err := iprot.ReadFieldEnd(); err != nil { return err } } if err := iprot.ReadStructEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } return nil } func (p *PartitionBulkLoadState) ReadField1(iprot thrift.TProtocol) error { if v, err := iprot.ReadI32(); err != nil { return thrift.PrependError("error reading field 1: ", err) } else { p.DownloadProgress = v } return nil } func (p *PartitionBulkLoadState) ReadField2(iprot thrift.TProtocol) error { p.DownloadStatus = &base.ErrorCode{} if err := p.DownloadStatus.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.DownloadStatus), err) } return nil } func (p *PartitionBulkLoadState) ReadField3(iprot thrift.TProtocol) error { if v, err := iprot.ReadI32(); err != nil { return thrift.PrependError("error reading field 3: ", err) } else { temp := IngestionStatus(v) p.IngestStatus = temp } return nil } func (p *PartitionBulkLoadState) ReadField4(iprot thrift.TProtocol) error { if v, err := iprot.ReadBool(); err != nil { return thrift.PrependError("error reading field 4: ", err) } else { p.IsCleanedUp = v } return nil } func (p *PartitionBulkLoadState) ReadField5(iprot thrift.TProtocol) error { if v, err := iprot.ReadBool(); err != nil { return thrift.PrependError("error reading field 5: ", err) } else { p.IsPaused = v } return nil } func (p *PartitionBulkLoadState) Write(oprot thrift.TProtocol) error { if err := oprot.WriteStructBegin("partition_bulk_load_state"); err != nil { return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } if p != nil { if err := p.writeField1(oprot); err != nil { return err } if err := p.writeField2(oprot); err != nil { return err } if err := p.writeField3(oprot); err != nil { return err } if err := p.writeField4(oprot); err != nil { return err } if err := p.writeField5(oprot); err != nil { return err } } if err := oprot.WriteFieldStop(); err != nil { return thrift.PrependError("write field stop error: ", err) } if err := oprot.WriteStructEnd(); err != nil { return thrift.PrependError("write struct stop error: ", err) } return nil } func (p *PartitionBulkLoadState) writeField1(oprot thrift.TProtocol) (err error) { if p.IsSetDownloadProgress() { if err := oprot.WriteFieldBegin("download_progress", thrift.I32, 1); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:download_progress: ", p), err) } if err := oprot.WriteI32(int32(p.DownloadProgress)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.download_progress (1) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 1:download_progress: ", p), err) } } return err } func (p *PartitionBulkLoadState) writeField2(oprot thrift.TProtocol) (err error) { if p.IsSetDownloadStatus() { if err := oprot.WriteFieldBegin("download_status", thrift.STRUCT, 2); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:download_status: ", p), err) } if err := p.DownloadStatus.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.DownloadStatus), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 2:download_status: ", p), err) } } return err } func (p *PartitionBulkLoadState) writeField3(oprot thrift.TProtocol) (err error) { if p.IsSetIngestStatus() { if err := oprot.WriteFieldBegin("ingest_status", thrift.I32, 3); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 3:ingest_status: ", p), err) } if err := oprot.WriteI32(int32(p.IngestStatus)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.ingest_status (3) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 3:ingest_status: ", p), err) } } return err } func (p *PartitionBulkLoadState) writeField4(oprot thrift.TProtocol) (err error) { if p.IsSetIsCleanedUp() { if err := oprot.WriteFieldBegin("is_cleaned_up", thrift.BOOL, 4); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 4:is_cleaned_up: ", p), err) } if err := oprot.WriteBool(bool(p.IsCleanedUp)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.is_cleaned_up (4) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 4:is_cleaned_up: ", p), err) } } return err } func (p *PartitionBulkLoadState) writeField5(oprot thrift.TProtocol) (err error) { if p.IsSetIsPaused() { if err := oprot.WriteFieldBegin("is_paused", thrift.BOOL, 5); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 5:is_paused: ", p), err) } if err := oprot.WriteBool(bool(p.IsPaused)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.is_paused (5) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 5:is_paused: ", p), err) } } return err } func (p *PartitionBulkLoadState) String() string { if p == nil { return "<nil>" } return fmt.Sprintf("PartitionBulkLoadState(%+v)", *p) } // Attributes: // - Pid // - AppName // - Primary // - RemoteProviderName // - ClusterName // - Ballot // - MetaBulkLoadStatus // - QueryBulkLoadMetadata // - RemoteRootPath // - HpPrimary type BulkLoadRequest struct { Pid *base.Gpid `thrift:"pid,1" db:"pid" json:"pid"` AppName string `thrift:"app_name,2" db:"app_name" json:"app_name"` Primary *base.RPCAddress `thrift:"primary,3" db:"primary" json:"primary"` RemoteProviderName string `thrift:"remote_provider_name,4" db:"remote_provider_name" json:"remote_provider_name"` ClusterName string `thrift:"cluster_name,5" db:"cluster_name" json:"cluster_name"` Ballot int64 `thrift:"ballot,6" db:"ballot" json:"ballot"` MetaBulkLoadStatus BulkLoadStatus `thrift:"meta_bulk_load_status,7" db:"meta_bulk_load_status" json:"meta_bulk_load_status"` QueryBulkLoadMetadata bool `thrift:"query_bulk_load_metadata,8" db:"query_bulk_load_metadata" json:"query_bulk_load_metadata"` RemoteRootPath string `thrift:"remote_root_path,9" db:"remote_root_path" json:"remote_root_path"` HpPrimary *base.HostPort `thrift:"hp_primary,10" db:"hp_primary" json:"hp_primary,omitempty"` } func NewBulkLoadRequest() *BulkLoadRequest { return &BulkLoadRequest{} } var BulkLoadRequest_Pid_DEFAULT *base.Gpid func (p *BulkLoadRequest) GetPid() *base.Gpid { if !p.IsSetPid() { return BulkLoadRequest_Pid_DEFAULT } return p.Pid } func (p *BulkLoadRequest) GetAppName() string { return p.AppName } var BulkLoadRequest_Primary_DEFAULT *base.RPCAddress func (p *BulkLoadRequest) GetPrimary() *base.RPCAddress { if !p.IsSetPrimary() { return BulkLoadRequest_Primary_DEFAULT } return p.Primary } func (p *BulkLoadRequest) GetRemoteProviderName() string { return p.RemoteProviderName } func (p *BulkLoadRequest) GetClusterName() string { return p.ClusterName } func (p *BulkLoadRequest) GetBallot() int64 { return p.Ballot } func (p *BulkLoadRequest) GetMetaBulkLoadStatus() BulkLoadStatus { return p.MetaBulkLoadStatus } func (p *BulkLoadRequest) GetQueryBulkLoadMetadata() bool { return p.QueryBulkLoadMetadata } func (p *BulkLoadRequest) GetRemoteRootPath() string { return p.RemoteRootPath } var BulkLoadRequest_HpPrimary_DEFAULT *base.HostPort func (p *BulkLoadRequest) GetHpPrimary() *base.HostPort { if !p.IsSetHpPrimary() { return BulkLoadRequest_HpPrimary_DEFAULT } return p.HpPrimary } func (p *BulkLoadRequest) IsSetPid() bool { return p.Pid != nil } func (p *BulkLoadRequest) IsSetPrimary() bool { return p.Primary != nil } func (p *BulkLoadRequest) IsSetHpPrimary() bool { return p.HpPrimary != nil } func (p *BulkLoadRequest) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) } for { _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() if err != nil { return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.STRUCT { if err := p.ReadField1(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 2: if fieldTypeId == thrift.STRING { if err := p.ReadField2(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 3: if fieldTypeId == thrift.STRUCT { if err := p.ReadField3(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 4: if fieldTypeId == thrift.STRING { if err := p.ReadField4(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 5: if fieldTypeId == thrift.STRING { if err := p.ReadField5(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 6: if fieldTypeId == thrift.I64 { if err := p.ReadField6(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 7: if fieldTypeId == thrift.I32 { if err := p.ReadField7(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 8: if fieldTypeId == thrift.BOOL { if err := p.ReadField8(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 9: if fieldTypeId == thrift.STRING { if err := p.ReadField9(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 10: if fieldTypeId == thrift.STRUCT { if err := p.ReadField10(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } default: if err := iprot.Skip(fieldTypeId); err != nil { return err } } if err := iprot.ReadFieldEnd(); err != nil { return err } } if err := iprot.ReadStructEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } return nil } func (p *BulkLoadRequest) ReadField1(iprot thrift.TProtocol) error { p.Pid = &base.Gpid{} if err := p.Pid.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Pid), err) } return nil } func (p *BulkLoadRequest) ReadField2(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 2: ", err) } else { p.AppName = v } return nil } func (p *BulkLoadRequest) ReadField3(iprot thrift.TProtocol) error { p.Primary = &base.RPCAddress{} if err := p.Primary.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Primary), err) } return nil } func (p *BulkLoadRequest) ReadField4(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 4: ", err) } else { p.RemoteProviderName = v } return nil } func (p *BulkLoadRequest) ReadField5(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 5: ", err) } else { p.ClusterName = v } return nil } func (p *BulkLoadRequest) ReadField6(iprot thrift.TProtocol) error { if v, err := iprot.ReadI64(); err != nil { return thrift.PrependError("error reading field 6: ", err) } else { p.Ballot = v } return nil } func (p *BulkLoadRequest) ReadField7(iprot thrift.TProtocol) error { if v, err := iprot.ReadI32(); err != nil { return thrift.PrependError("error reading field 7: ", err) } else { temp := BulkLoadStatus(v) p.MetaBulkLoadStatus = temp } return nil } func (p *BulkLoadRequest) ReadField8(iprot thrift.TProtocol) error { if v, err := iprot.ReadBool(); err != nil { return thrift.PrependError("error reading field 8: ", err) } else { p.QueryBulkLoadMetadata = v } return nil } func (p *BulkLoadRequest) ReadField9(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 9: ", err) } else { p.RemoteRootPath = v } return nil } func (p *BulkLoadRequest) ReadField10(iprot thrift.TProtocol) error { p.HpPrimary = &base.HostPort{} if err := p.HpPrimary.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.HpPrimary), err) } return nil } func (p *BulkLoadRequest) Write(oprot thrift.TProtocol) error { if err := oprot.WriteStructBegin("bulk_load_request"); err != nil { return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } if p != nil { if err := p.writeField1(oprot); err != nil { return err } if err := p.writeField2(oprot); err != nil { return err } if err := p.writeField3(oprot); err != nil { return err } if err := p.writeField4(oprot); err != nil { return err } if err := p.writeField5(oprot); err != nil { return err } if err := p.writeField6(oprot); err != nil { return err } if err := p.writeField7(oprot); err != nil { return err } if err := p.writeField8(oprot); err != nil { return err } if err := p.writeField9(oprot); err != nil { return err } if err := p.writeField10(oprot); err != nil { return err } } if err := oprot.WriteFieldStop(); err != nil { return thrift.PrependError("write field stop error: ", err) } if err := oprot.WriteStructEnd(); err != nil { return thrift.PrependError("write struct stop error: ", err) } return nil } func (p *BulkLoadRequest) writeField1(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("pid", thrift.STRUCT, 1); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:pid: ", p), err) } if err := p.Pid.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Pid), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 1:pid: ", p), err) } return err } func (p *BulkLoadRequest) writeField2(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("app_name", thrift.STRING, 2); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:app_name: ", p), err) } if err := oprot.WriteString(string(p.AppName)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.app_name (2) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 2:app_name: ", p), err) } return err } func (p *BulkLoadRequest) writeField3(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("primary", thrift.STRUCT, 3); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 3:primary: ", p), err) } if err := p.Primary.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Primary), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 3:primary: ", p), err) } return err } func (p *BulkLoadRequest) writeField4(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("remote_provider_name", thrift.STRING, 4); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 4:remote_provider_name: ", p), err) } if err := oprot.WriteString(string(p.RemoteProviderName)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.remote_provider_name (4) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 4:remote_provider_name: ", p), err) } return err } func (p *BulkLoadRequest) writeField5(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("cluster_name", thrift.STRING, 5); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 5:cluster_name: ", p), err) } if err := oprot.WriteString(string(p.ClusterName)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.cluster_name (5) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 5:cluster_name: ", p), err) } return err } func (p *BulkLoadRequest) writeField6(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("ballot", thrift.I64, 6); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 6:ballot: ", p), err) } if err := oprot.WriteI64(int64(p.Ballot)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.ballot (6) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 6:ballot: ", p), err) } return err } func (p *BulkLoadRequest) writeField7(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("meta_bulk_load_status", thrift.I32, 7); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 7:meta_bulk_load_status: ", p), err) } if err := oprot.WriteI32(int32(p.MetaBulkLoadStatus)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.meta_bulk_load_status (7) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 7:meta_bulk_load_status: ", p), err) } return err } func (p *BulkLoadRequest) writeField8(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("query_bulk_load_metadata", thrift.BOOL, 8); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 8:query_bulk_load_metadata: ", p), err) } if err := oprot.WriteBool(bool(p.QueryBulkLoadMetadata)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.query_bulk_load_metadata (8) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 8:query_bulk_load_metadata: ", p), err) } return err } func (p *BulkLoadRequest) writeField9(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("remote_root_path", thrift.STRING, 9); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 9:remote_root_path: ", p), err) } if err := oprot.WriteString(string(p.RemoteRootPath)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.remote_root_path (9) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 9:remote_root_path: ", p), err) } return err } func (p *BulkLoadRequest) writeField10(oprot thrift.TProtocol) (err error) { if p.IsSetHpPrimary() { if err := oprot.WriteFieldBegin("hp_primary", thrift.STRUCT, 10); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 10:hp_primary: ", p), err) } if err := p.HpPrimary.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.HpPrimary), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 10:hp_primary: ", p), err) } } return err } func (p *BulkLoadRequest) String() string { if p == nil { return "<nil>" } return fmt.Sprintf("BulkLoadRequest(%+v)", *p) } // Attributes: // - Err // - Pid // - AppName // - PrimaryBulkLoadStatus // - GroupBulkLoadState // - Metadata // - TotalDownloadProgress // - IsGroupIngestionFinished // - IsGroupBulkLoadContextCleanedUp // - IsGroupBulkLoadPaused // - HpGroupBulkLoadState type BulkLoadResponse struct { Err *base.ErrorCode `thrift:"err,1" db:"err" json:"err"` Pid *base.Gpid `thrift:"pid,2" db:"pid" json:"pid"` AppName string `thrift:"app_name,3" db:"app_name" json:"app_name"` PrimaryBulkLoadStatus BulkLoadStatus `thrift:"primary_bulk_load_status,4" db:"primary_bulk_load_status" json:"primary_bulk_load_status"` GroupBulkLoadState map[*base.RPCAddress]*PartitionBulkLoadState `thrift:"group_bulk_load_state,5" db:"group_bulk_load_state" json:"group_bulk_load_state"` Metadata *BulkLoadMetadata `thrift:"metadata,6" db:"metadata" json:"metadata,omitempty"` TotalDownloadProgress *int32 `thrift:"total_download_progress,7" db:"total_download_progress" json:"total_download_progress,omitempty"` IsGroupIngestionFinished *bool `thrift:"is_group_ingestion_finished,8" db:"is_group_ingestion_finished" json:"is_group_ingestion_finished,omitempty"` IsGroupBulkLoadContextCleanedUp *bool `thrift:"is_group_bulk_load_context_cleaned_up,9" db:"is_group_bulk_load_context_cleaned_up" json:"is_group_bulk_load_context_cleaned_up,omitempty"` IsGroupBulkLoadPaused *bool `thrift:"is_group_bulk_load_paused,10" db:"is_group_bulk_load_paused" json:"is_group_bulk_load_paused,omitempty"` HpGroupBulkLoadState map[*base.HostPort]*PartitionBulkLoadState `thrift:"hp_group_bulk_load_state,11" db:"hp_group_bulk_load_state" json:"hp_group_bulk_load_state,omitempty"` } func NewBulkLoadResponse() *BulkLoadResponse { return &BulkLoadResponse{} } var BulkLoadResponse_Err_DEFAULT *base.ErrorCode func (p *BulkLoadResponse) GetErr() *base.ErrorCode { if !p.IsSetErr() { return BulkLoadResponse_Err_DEFAULT } return p.Err } var BulkLoadResponse_Pid_DEFAULT *base.Gpid func (p *BulkLoadResponse) GetPid() *base.Gpid { if !p.IsSetPid() { return BulkLoadResponse_Pid_DEFAULT } return p.Pid } func (p *BulkLoadResponse) GetAppName() string { return p.AppName } func (p *BulkLoadResponse) GetPrimaryBulkLoadStatus() BulkLoadStatus { return p.PrimaryBulkLoadStatus } func (p *BulkLoadResponse) GetGroupBulkLoadState() map[*base.RPCAddress]*PartitionBulkLoadState { return p.GroupBulkLoadState } var BulkLoadResponse_Metadata_DEFAULT *BulkLoadMetadata func (p *BulkLoadResponse) GetMetadata() *BulkLoadMetadata { if !p.IsSetMetadata() { return BulkLoadResponse_Metadata_DEFAULT } return p.Metadata } var BulkLoadResponse_TotalDownloadProgress_DEFAULT int32 func (p *BulkLoadResponse) GetTotalDownloadProgress() int32 { if !p.IsSetTotalDownloadProgress() { return BulkLoadResponse_TotalDownloadProgress_DEFAULT } return *p.TotalDownloadProgress } var BulkLoadResponse_IsGroupIngestionFinished_DEFAULT bool func (p *BulkLoadResponse) GetIsGroupIngestionFinished() bool { if !p.IsSetIsGroupIngestionFinished() { return BulkLoadResponse_IsGroupIngestionFinished_DEFAULT } return *p.IsGroupIngestionFinished } var BulkLoadResponse_IsGroupBulkLoadContextCleanedUp_DEFAULT bool func (p *BulkLoadResponse) GetIsGroupBulkLoadContextCleanedUp() bool { if !p.IsSetIsGroupBulkLoadContextCleanedUp() { return BulkLoadResponse_IsGroupBulkLoadContextCleanedUp_DEFAULT } return *p.IsGroupBulkLoadContextCleanedUp } var BulkLoadResponse_IsGroupBulkLoadPaused_DEFAULT bool func (p *BulkLoadResponse) GetIsGroupBulkLoadPaused() bool { if !p.IsSetIsGroupBulkLoadPaused() { return BulkLoadResponse_IsGroupBulkLoadPaused_DEFAULT } return *p.IsGroupBulkLoadPaused } var BulkLoadResponse_HpGroupBulkLoadState_DEFAULT map[*base.HostPort]*PartitionBulkLoadState func (p *BulkLoadResponse) GetHpGroupBulkLoadState() map[*base.HostPort]*PartitionBulkLoadState { return p.HpGroupBulkLoadState } func (p *BulkLoadResponse) IsSetErr() bool { return p.Err != nil } func (p *BulkLoadResponse) IsSetPid() bool { return p.Pid != nil } func (p *BulkLoadResponse) IsSetMetadata() bool { return p.Metadata != nil } func (p *BulkLoadResponse) IsSetTotalDownloadProgress() bool { return p.TotalDownloadProgress != nil } func (p *BulkLoadResponse) IsSetIsGroupIngestionFinished() bool { return p.IsGroupIngestionFinished != nil } func (p *BulkLoadResponse) IsSetIsGroupBulkLoadContextCleanedUp() bool { return p.IsGroupBulkLoadContextCleanedUp != nil } func (p *BulkLoadResponse) IsSetIsGroupBulkLoadPaused() bool { return p.IsGroupBulkLoadPaused != nil } func (p *BulkLoadResponse) IsSetHpGroupBulkLoadState() bool { return p.HpGroupBulkLoadState != nil } func (p *BulkLoadResponse) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) } for { _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() if err != nil { return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.STRUCT { if err := p.ReadField1(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 2: if fieldTypeId == thrift.STRUCT { if err := p.ReadField2(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 3: if fieldTypeId == thrift.STRING { if err := p.ReadField3(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 4: if fieldTypeId == thrift.I32 { if err := p.ReadField4(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 5: if fieldTypeId == thrift.MAP { if err := p.ReadField5(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 6: if fieldTypeId == thrift.STRUCT { if err := p.ReadField6(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 7: if fieldTypeId == thrift.I32 { if err := p.ReadField7(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 8: if fieldTypeId == thrift.BOOL { if err := p.ReadField8(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 9: if fieldTypeId == thrift.BOOL { if err := p.ReadField9(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 10: if fieldTypeId == thrift.BOOL { if err := p.ReadField10(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 11: if fieldTypeId == thrift.MAP { if err := p.ReadField11(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } default: if err := iprot.Skip(fieldTypeId); err != nil { return err } } if err := iprot.ReadFieldEnd(); err != nil { return err } } if err := iprot.ReadStructEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } return nil } func (p *BulkLoadResponse) ReadField1(iprot thrift.TProtocol) error { p.Err = &base.ErrorCode{} if err := p.Err.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Err), err) } return nil } func (p *BulkLoadResponse) ReadField2(iprot thrift.TProtocol) error { p.Pid = &base.Gpid{} if err := p.Pid.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Pid), err) } return nil } func (p *BulkLoadResponse) ReadField3(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 3: ", err) } else { p.AppName = v } return nil } func (p *BulkLoadResponse) ReadField4(iprot thrift.TProtocol) error { if v, err := iprot.ReadI32(); err != nil { return thrift.PrependError("error reading field 4: ", err) } else { temp := BulkLoadStatus(v) p.PrimaryBulkLoadStatus = temp } return nil } func (p *BulkLoadResponse) ReadField5(iprot thrift.TProtocol) error { _, _, size, err := iprot.ReadMapBegin() if err != nil { return thrift.PrependError("error reading map begin: ", err) } tMap := make(map[*base.RPCAddress]*PartitionBulkLoadState, size) p.GroupBulkLoadState = tMap for i := 0; i < size; i++ { _key1 := &base.RPCAddress{} if err := _key1.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _key1), err) } _val2 := &PartitionBulkLoadState{ IngestStatus: 0, } if err := _val2.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _val2), err) } p.GroupBulkLoadState[_key1] = _val2 } if err := iprot.ReadMapEnd(); err != nil { return thrift.PrependError("error reading map end: ", err) } return nil } func (p *BulkLoadResponse) ReadField6(iprot thrift.TProtocol) error { p.Metadata = &BulkLoadMetadata{} if err := p.Metadata.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Metadata), err) } return nil } func (p *BulkLoadResponse) ReadField7(iprot thrift.TProtocol) error { if v, err := iprot.ReadI32(); err != nil { return thrift.PrependError("error reading field 7: ", err) } else { p.TotalDownloadProgress = &v } return nil } func (p *BulkLoadResponse) ReadField8(iprot thrift.TProtocol) error { if v, err := iprot.ReadBool(); err != nil { return thrift.PrependError("error reading field 8: ", err) } else { p.IsGroupIngestionFinished = &v } return nil } func (p *BulkLoadResponse) ReadField9(iprot thrift.TProtocol) error { if v, err := iprot.ReadBool(); err != nil { return thrift.PrependError("error reading field 9: ", err) } else { p.IsGroupBulkLoadContextCleanedUp = &v } return nil } func (p *BulkLoadResponse) ReadField10(iprot thrift.TProtocol) error { if v, err := iprot.ReadBool(); err != nil { return thrift.PrependError("error reading field 10: ", err) } else { p.IsGroupBulkLoadPaused = &v } return nil } func (p *BulkLoadResponse) ReadField11(iprot thrift.TProtocol) error { _, _, size, err := iprot.ReadMapBegin() if err != nil { return thrift.PrependError("error reading map begin: ", err) } tMap := make(map[*base.HostPort]*PartitionBulkLoadState, size) p.HpGroupBulkLoadState = tMap for i := 0; i < size; i++ { _key3 := &base.HostPort{} if err := _key3.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _key3), err) } _val4 := &PartitionBulkLoadState{ IngestStatus: 0, } if err := _val4.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _val4), err) } p.HpGroupBulkLoadState[_key3] = _val4 } if err := iprot.ReadMapEnd(); err != nil { return thrift.PrependError("error reading map end: ", err) } return nil } func (p *BulkLoadResponse) Write(oprot thrift.TProtocol) error { if err := oprot.WriteStructBegin("bulk_load_response"); err != nil { return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } if p != nil { if err := p.writeField1(oprot); err != nil { return err } if err := p.writeField2(oprot); err != nil { return err } if err := p.writeField3(oprot); err != nil { return err } if err := p.writeField4(oprot); err != nil { return err } if err := p.writeField5(oprot); err != nil { return err } if err := p.writeField6(oprot); err != nil { return err } if err := p.writeField7(oprot); err != nil { return err } if err := p.writeField8(oprot); err != nil { return err } if err := p.writeField9(oprot); err != nil { return err } if err := p.writeField10(oprot); err != nil { return err } if err := p.writeField11(oprot); err != nil { return err } } if err := oprot.WriteFieldStop(); err != nil { return thrift.PrependError("write field stop error: ", err) } if err := oprot.WriteStructEnd(); err != nil { return thrift.PrependError("write struct stop error: ", err) } return nil } func (p *BulkLoadResponse) writeField1(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("err", thrift.STRUCT, 1); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:err: ", p), err) } if err := p.Err.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Err), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 1:err: ", p), err) } return err } func (p *BulkLoadResponse) writeField2(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("pid", thrift.STRUCT, 2); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:pid: ", p), err) } if err := p.Pid.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Pid), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 2:pid: ", p), err) } return err } func (p *BulkLoadResponse) writeField3(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("app_name", thrift.STRING, 3); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 3:app_name: ", p), err) } if err := oprot.WriteString(string(p.AppName)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.app_name (3) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 3:app_name: ", p), err) } return err } func (p *BulkLoadResponse) writeField4(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("primary_bulk_load_status", thrift.I32, 4); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 4:primary_bulk_load_status: ", p), err) } if err := oprot.WriteI32(int32(p.PrimaryBulkLoadStatus)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.primary_bulk_load_status (4) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 4:primary_bulk_load_status: ", p), err) } return err } func (p *BulkLoadResponse) writeField5(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("group_bulk_load_state", thrift.MAP, 5); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 5:group_bulk_load_state: ", p), err) } if err := oprot.WriteMapBegin(thrift.STRUCT, thrift.STRUCT, len(p.GroupBulkLoadState)); err != nil { return thrift.PrependError("error writing map begin: ", err) } for k, v := range p.GroupBulkLoadState { if err := k.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", k), err) } if err := v.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", v), err) } } if err := oprot.WriteMapEnd(); err != nil { return thrift.PrependError("error writing map end: ", err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 5:group_bulk_load_state: ", p), err) } return err } func (p *BulkLoadResponse) writeField6(oprot thrift.TProtocol) (err error) { if p.IsSetMetadata() { if err := oprot.WriteFieldBegin("metadata", thrift.STRUCT, 6); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 6:metadata: ", p), err) } if err := p.Metadata.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Metadata), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 6:metadata: ", p), err) } } return err } func (p *BulkLoadResponse) writeField7(oprot thrift.TProtocol) (err error) { if p.IsSetTotalDownloadProgress() { if err := oprot.WriteFieldBegin("total_download_progress", thrift.I32, 7); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 7:total_download_progress: ", p), err) } if err := oprot.WriteI32(int32(*p.TotalDownloadProgress)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.total_download_progress (7) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 7:total_download_progress: ", p), err) } } return err } func (p *BulkLoadResponse) writeField8(oprot thrift.TProtocol) (err error) { if p.IsSetIsGroupIngestionFinished() { if err := oprot.WriteFieldBegin("is_group_ingestion_finished", thrift.BOOL, 8); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 8:is_group_ingestion_finished: ", p), err) } if err := oprot.WriteBool(bool(*p.IsGroupIngestionFinished)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.is_group_ingestion_finished (8) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 8:is_group_ingestion_finished: ", p), err) } } return err } func (p *BulkLoadResponse) writeField9(oprot thrift.TProtocol) (err error) { if p.IsSetIsGroupBulkLoadContextCleanedUp() { if err := oprot.WriteFieldBegin("is_group_bulk_load_context_cleaned_up", thrift.BOOL, 9); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 9:is_group_bulk_load_context_cleaned_up: ", p), err) } if err := oprot.WriteBool(bool(*p.IsGroupBulkLoadContextCleanedUp)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.is_group_bulk_load_context_cleaned_up (9) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 9:is_group_bulk_load_context_cleaned_up: ", p), err) } } return err } func (p *BulkLoadResponse) writeField10(oprot thrift.TProtocol) (err error) { if p.IsSetIsGroupBulkLoadPaused() { if err := oprot.WriteFieldBegin("is_group_bulk_load_paused", thrift.BOOL, 10); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 10:is_group_bulk_load_paused: ", p), err) } if err := oprot.WriteBool(bool(*p.IsGroupBulkLoadPaused)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.is_group_bulk_load_paused (10) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 10:is_group_bulk_load_paused: ", p), err) } } return err } func (p *BulkLoadResponse) writeField11(oprot thrift.TProtocol) (err error) { if p.IsSetHpGroupBulkLoadState() { if err := oprot.WriteFieldBegin("hp_group_bulk_load_state", thrift.MAP, 11); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 11:hp_group_bulk_load_state: ", p), err) } if err := oprot.WriteMapBegin(thrift.STRUCT, thrift.STRUCT, len(p.HpGroupBulkLoadState)); err != nil { return thrift.PrependError("error writing map begin: ", err) } for k, v := range p.HpGroupBulkLoadState { if err := k.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", k), err) } if err := v.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", v), err) } } if err := oprot.WriteMapEnd(); err != nil { return thrift.PrependError("error writing map end: ", err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 11:hp_group_bulk_load_state: ", p), err) } } return err } func (p *BulkLoadResponse) String() string { if p == nil { return "<nil>" } return fmt.Sprintf("BulkLoadResponse(%+v)", *p) } // Attributes: // - AppName // - Target // - Config // - ProviderName // - ClusterName // - MetaBulkLoadStatus // - RemoteRootPath // - HpTarget type GroupBulkLoadRequest struct { AppName string `thrift:"app_name,1" db:"app_name" json:"app_name"` Target *base.RPCAddress `thrift:"target,2" db:"target" json:"target"` Config *ReplicaConfiguration `thrift:"config,3" db:"config" json:"config"` ProviderName string `thrift:"provider_name,4" db:"provider_name" json:"provider_name"` ClusterName string `thrift:"cluster_name,5" db:"cluster_name" json:"cluster_name"` MetaBulkLoadStatus BulkLoadStatus `thrift:"meta_bulk_load_status,6" db:"meta_bulk_load_status" json:"meta_bulk_load_status"` RemoteRootPath string `thrift:"remote_root_path,7" db:"remote_root_path" json:"remote_root_path"` HpTarget *base.HostPort `thrift:"hp_target,8" db:"hp_target" json:"hp_target,omitempty"` } func NewGroupBulkLoadRequest() *GroupBulkLoadRequest { return &GroupBulkLoadRequest{} } func (p *GroupBulkLoadRequest) GetAppName() string { return p.AppName } var GroupBulkLoadRequest_Target_DEFAULT *base.RPCAddress func (p *GroupBulkLoadRequest) GetTarget() *base.RPCAddress { if !p.IsSetTarget() { return GroupBulkLoadRequest_Target_DEFAULT } return p.Target } var GroupBulkLoadRequest_Config_DEFAULT *ReplicaConfiguration func (p *GroupBulkLoadRequest) GetConfig() *ReplicaConfiguration { if !p.IsSetConfig() { return GroupBulkLoadRequest_Config_DEFAULT } return p.Config } func (p *GroupBulkLoadRequest) GetProviderName() string { return p.ProviderName } func (p *GroupBulkLoadRequest) GetClusterName() string { return p.ClusterName } func (p *GroupBulkLoadRequest) GetMetaBulkLoadStatus() BulkLoadStatus { return p.MetaBulkLoadStatus } func (p *GroupBulkLoadRequest) GetRemoteRootPath() string { return p.RemoteRootPath } var GroupBulkLoadRequest_HpTarget_DEFAULT *base.HostPort func (p *GroupBulkLoadRequest) GetHpTarget() *base.HostPort { if !p.IsSetHpTarget() { return GroupBulkLoadRequest_HpTarget_DEFAULT } return p.HpTarget } func (p *GroupBulkLoadRequest) IsSetTarget() bool { return p.Target != nil } func (p *GroupBulkLoadRequest) IsSetConfig() bool { return p.Config != nil } func (p *GroupBulkLoadRequest) IsSetHpTarget() bool { return p.HpTarget != nil } func (p *GroupBulkLoadRequest) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) } for { _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() if err != nil { return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.STRING { if err := p.ReadField1(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 2: if fieldTypeId == thrift.STRUCT { if err := p.ReadField2(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 3: if fieldTypeId == thrift.STRUCT { if err := p.ReadField3(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 4: if fieldTypeId == thrift.STRING { if err := p.ReadField4(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 5: if fieldTypeId == thrift.STRING { if err := p.ReadField5(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 6: if fieldTypeId == thrift.I32 { if err := p.ReadField6(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 7: if fieldTypeId == thrift.STRING { if err := p.ReadField7(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 8: if fieldTypeId == thrift.STRUCT { if err := p.ReadField8(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } default: if err := iprot.Skip(fieldTypeId); err != nil { return err } } if err := iprot.ReadFieldEnd(); err != nil { return err } } if err := iprot.ReadStructEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } return nil } func (p *GroupBulkLoadRequest) ReadField1(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 1: ", err) } else { p.AppName = v } return nil } func (p *GroupBulkLoadRequest) ReadField2(iprot thrift.TProtocol) error { p.Target = &base.RPCAddress{} if err := p.Target.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Target), err) } return nil } func (p *GroupBulkLoadRequest) ReadField3(iprot thrift.TProtocol) error { p.Config = &ReplicaConfiguration{ Status: 0, } if err := p.Config.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Config), err) } return nil } func (p *GroupBulkLoadRequest) ReadField4(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 4: ", err) } else { p.ProviderName = v } return nil } func (p *GroupBulkLoadRequest) ReadField5(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 5: ", err) } else { p.ClusterName = v } return nil } func (p *GroupBulkLoadRequest) ReadField6(iprot thrift.TProtocol) error { if v, err := iprot.ReadI32(); err != nil { return thrift.PrependError("error reading field 6: ", err) } else { temp := BulkLoadStatus(v) p.MetaBulkLoadStatus = temp } return nil } func (p *GroupBulkLoadRequest) ReadField7(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 7: ", err) } else { p.RemoteRootPath = v } return nil } func (p *GroupBulkLoadRequest) ReadField8(iprot thrift.TProtocol) error { p.HpTarget = &base.HostPort{} if err := p.HpTarget.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.HpTarget), err) } return nil } func (p *GroupBulkLoadRequest) Write(oprot thrift.TProtocol) error { if err := oprot.WriteStructBegin("group_bulk_load_request"); err != nil { return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } if p != nil { if err := p.writeField1(oprot); err != nil { return err } if err := p.writeField2(oprot); err != nil { return err } if err := p.writeField3(oprot); err != nil { return err } if err := p.writeField4(oprot); err != nil { return err } if err := p.writeField5(oprot); err != nil { return err } if err := p.writeField6(oprot); err != nil { return err } if err := p.writeField7(oprot); err != nil { return err } if err := p.writeField8(oprot); err != nil { return err } } if err := oprot.WriteFieldStop(); err != nil { return thrift.PrependError("write field stop error: ", err) } if err := oprot.WriteStructEnd(); err != nil { return thrift.PrependError("write struct stop error: ", err) } return nil } func (p *GroupBulkLoadRequest) writeField1(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("app_name", thrift.STRING, 1); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:app_name: ", p), err) } if err := oprot.WriteString(string(p.AppName)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.app_name (1) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 1:app_name: ", p), err) } return err } func (p *GroupBulkLoadRequest) writeField2(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("target", thrift.STRUCT, 2); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:target: ", p), err) } if err := p.Target.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Target), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 2:target: ", p), err) } return err } func (p *GroupBulkLoadRequest) writeField3(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("config", thrift.STRUCT, 3); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 3:config: ", p), err) } if err := p.Config.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Config), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 3:config: ", p), err) } return err } func (p *GroupBulkLoadRequest) writeField4(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("provider_name", thrift.STRING, 4); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 4:provider_name: ", p), err) } if err := oprot.WriteString(string(p.ProviderName)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.provider_name (4) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 4:provider_name: ", p), err) } return err } func (p *GroupBulkLoadRequest) writeField5(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("cluster_name", thrift.STRING, 5); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 5:cluster_name: ", p), err) } if err := oprot.WriteString(string(p.ClusterName)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.cluster_name (5) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 5:cluster_name: ", p), err) } return err } func (p *GroupBulkLoadRequest) writeField6(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("meta_bulk_load_status", thrift.I32, 6); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 6:meta_bulk_load_status: ", p), err) } if err := oprot.WriteI32(int32(p.MetaBulkLoadStatus)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.meta_bulk_load_status (6) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 6:meta_bulk_load_status: ", p), err) } return err } func (p *GroupBulkLoadRequest) writeField7(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("remote_root_path", thrift.STRING, 7); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 7:remote_root_path: ", p), err) } if err := oprot.WriteString(string(p.RemoteRootPath)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.remote_root_path (7) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 7:remote_root_path: ", p), err) } return err } func (p *GroupBulkLoadRequest) writeField8(oprot thrift.TProtocol) (err error) { if p.IsSetHpTarget() { if err := oprot.WriteFieldBegin("hp_target", thrift.STRUCT, 8); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 8:hp_target: ", p), err) } if err := p.HpTarget.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.HpTarget), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 8:hp_target: ", p), err) } } return err } func (p *GroupBulkLoadRequest) String() string { if p == nil { return "<nil>" } return fmt.Sprintf("GroupBulkLoadRequest(%+v)", *p) } // Attributes: // - Err // - Status // - BulkLoadState type GroupBulkLoadResponse struct { Err *base.ErrorCode `thrift:"err,1" db:"err" json:"err"` Status BulkLoadStatus `thrift:"status,2" db:"status" json:"status"` BulkLoadState *PartitionBulkLoadState `thrift:"bulk_load_state,3" db:"bulk_load_state" json:"bulk_load_state"` } func NewGroupBulkLoadResponse() *GroupBulkLoadResponse { return &GroupBulkLoadResponse{} } var GroupBulkLoadResponse_Err_DEFAULT *base.ErrorCode func (p *GroupBulkLoadResponse) GetErr() *base.ErrorCode { if !p.IsSetErr() { return GroupBulkLoadResponse_Err_DEFAULT } return p.Err } func (p *GroupBulkLoadResponse) GetStatus() BulkLoadStatus { return p.Status } var GroupBulkLoadResponse_BulkLoadState_DEFAULT *PartitionBulkLoadState func (p *GroupBulkLoadResponse) GetBulkLoadState() *PartitionBulkLoadState { if !p.IsSetBulkLoadState() { return GroupBulkLoadResponse_BulkLoadState_DEFAULT } return p.BulkLoadState } func (p *GroupBulkLoadResponse) IsSetErr() bool { return p.Err != nil } func (p *GroupBulkLoadResponse) IsSetBulkLoadState() bool { return p.BulkLoadState != nil } func (p *GroupBulkLoadResponse) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) } for { _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() if err != nil { return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.STRUCT { if err := p.ReadField1(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 2: if fieldTypeId == thrift.I32 { if err := p.ReadField2(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 3: if fieldTypeId == thrift.STRUCT { if err := p.ReadField3(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } default: if err := iprot.Skip(fieldTypeId); err != nil { return err } } if err := iprot.ReadFieldEnd(); err != nil { return err } } if err := iprot.ReadStructEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } return nil } func (p *GroupBulkLoadResponse) ReadField1(iprot thrift.TProtocol) error { p.Err = &base.ErrorCode{} if err := p.Err.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Err), err) } return nil } func (p *GroupBulkLoadResponse) ReadField2(iprot thrift.TProtocol) error { if v, err := iprot.ReadI32(); err != nil { return thrift.PrependError("error reading field 2: ", err) } else { temp := BulkLoadStatus(v) p.Status = temp } return nil } func (p *GroupBulkLoadResponse) ReadField3(iprot thrift.TProtocol) error { p.BulkLoadState = &PartitionBulkLoadState{ IngestStatus: 0, } if err := p.BulkLoadState.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.BulkLoadState), err) } return nil } func (p *GroupBulkLoadResponse) Write(oprot thrift.TProtocol) error { if err := oprot.WriteStructBegin("group_bulk_load_response"); err != nil { return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } if p != nil { if err := p.writeField1(oprot); err != nil { return err } if err := p.writeField2(oprot); err != nil { return err } if err := p.writeField3(oprot); err != nil { return err } } if err := oprot.WriteFieldStop(); err != nil { return thrift.PrependError("write field stop error: ", err) } if err := oprot.WriteStructEnd(); err != nil { return thrift.PrependError("write struct stop error: ", err) } return nil } func (p *GroupBulkLoadResponse) writeField1(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("err", thrift.STRUCT, 1); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:err: ", p), err) } if err := p.Err.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Err), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 1:err: ", p), err) } return err } func (p *GroupBulkLoadResponse) writeField2(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("status", thrift.I32, 2); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:status: ", p), err) } if err := oprot.WriteI32(int32(p.Status)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.status (2) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 2:status: ", p), err) } return err } func (p *GroupBulkLoadResponse) writeField3(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("bulk_load_state", thrift.STRUCT, 3); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 3:bulk_load_state: ", p), err) } if err := p.BulkLoadState.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.BulkLoadState), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 3:bulk_load_state: ", p), err) } return err } func (p *GroupBulkLoadResponse) String() string { if p == nil { return "<nil>" } return fmt.Sprintf("GroupBulkLoadResponse(%+v)", *p) } // Attributes: // - AppName // - Metadata // - IngestBehind // - Ballot // - VerifyBeforeIngest type IngestionRequest struct { AppName string `thrift:"app_name,1" db:"app_name" json:"app_name"` Metadata *BulkLoadMetadata `thrift:"metadata,2" db:"metadata" json:"metadata"` IngestBehind bool `thrift:"ingest_behind,3" db:"ingest_behind" json:"ingest_behind"` Ballot int64 `thrift:"ballot,4" db:"ballot" json:"ballot"` VerifyBeforeIngest bool `thrift:"verify_before_ingest,5" db:"verify_before_ingest" json:"verify_before_ingest"` } func NewIngestionRequest() *IngestionRequest { return &IngestionRequest{} } func (p *IngestionRequest) GetAppName() string { return p.AppName } var IngestionRequest_Metadata_DEFAULT *BulkLoadMetadata func (p *IngestionRequest) GetMetadata() *BulkLoadMetadata { if !p.IsSetMetadata() { return IngestionRequest_Metadata_DEFAULT } return p.Metadata } func (p *IngestionRequest) GetIngestBehind() bool { return p.IngestBehind } func (p *IngestionRequest) GetBallot() int64 { return p.Ballot } func (p *IngestionRequest) GetVerifyBeforeIngest() bool { return p.VerifyBeforeIngest } func (p *IngestionRequest) IsSetMetadata() bool { return p.Metadata != nil } func (p *IngestionRequest) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) } for { _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() if err != nil { return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.STRING { if err := p.ReadField1(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 2: if fieldTypeId == thrift.STRUCT { if err := p.ReadField2(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 3: if fieldTypeId == thrift.BOOL { if err := p.ReadField3(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 4: if fieldTypeId == thrift.I64 { if err := p.ReadField4(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 5: if fieldTypeId == thrift.BOOL { if err := p.ReadField5(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } default: if err := iprot.Skip(fieldTypeId); err != nil { return err } } if err := iprot.ReadFieldEnd(); err != nil { return err } } if err := iprot.ReadStructEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } return nil } func (p *IngestionRequest) ReadField1(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 1: ", err) } else { p.AppName = v } return nil } func (p *IngestionRequest) ReadField2(iprot thrift.TProtocol) error { p.Metadata = &BulkLoadMetadata{} if err := p.Metadata.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Metadata), err) } return nil } func (p *IngestionRequest) ReadField3(iprot thrift.TProtocol) error { if v, err := iprot.ReadBool(); err != nil { return thrift.PrependError("error reading field 3: ", err) } else { p.IngestBehind = v } return nil } func (p *IngestionRequest) ReadField4(iprot thrift.TProtocol) error { if v, err := iprot.ReadI64(); err != nil { return thrift.PrependError("error reading field 4: ", err) } else { p.Ballot = v } return nil } func (p *IngestionRequest) ReadField5(iprot thrift.TProtocol) error { if v, err := iprot.ReadBool(); err != nil { return thrift.PrependError("error reading field 5: ", err) } else { p.VerifyBeforeIngest = v } return nil } func (p *IngestionRequest) Write(oprot thrift.TProtocol) error { if err := oprot.WriteStructBegin("ingestion_request"); err != nil { return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } if p != nil { if err := p.writeField1(oprot); err != nil { return err } if err := p.writeField2(oprot); err != nil { return err } if err := p.writeField3(oprot); err != nil { return err } if err := p.writeField4(oprot); err != nil { return err } if err := p.writeField5(oprot); err != nil { return err } } if err := oprot.WriteFieldStop(); err != nil { return thrift.PrependError("write field stop error: ", err) } if err := oprot.WriteStructEnd(); err != nil { return thrift.PrependError("write struct stop error: ", err) } return nil } func (p *IngestionRequest) writeField1(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("app_name", thrift.STRING, 1); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:app_name: ", p), err) } if err := oprot.WriteString(string(p.AppName)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.app_name (1) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 1:app_name: ", p), err) } return err } func (p *IngestionRequest) writeField2(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("metadata", thrift.STRUCT, 2); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:metadata: ", p), err) } if err := p.Metadata.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Metadata), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 2:metadata: ", p), err) } return err } func (p *IngestionRequest) writeField3(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("ingest_behind", thrift.BOOL, 3); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 3:ingest_behind: ", p), err) } if err := oprot.WriteBool(bool(p.IngestBehind)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.ingest_behind (3) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 3:ingest_behind: ", p), err) } return err } func (p *IngestionRequest) writeField4(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("ballot", thrift.I64, 4); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 4:ballot: ", p), err) } if err := oprot.WriteI64(int64(p.Ballot)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.ballot (4) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 4:ballot: ", p), err) } return err } func (p *IngestionRequest) writeField5(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("verify_before_ingest", thrift.BOOL, 5); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 5:verify_before_ingest: ", p), err) } if err := oprot.WriteBool(bool(p.VerifyBeforeIngest)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.verify_before_ingest (5) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 5:verify_before_ingest: ", p), err) } return err } func (p *IngestionRequest) String() string { if p == nil { return "<nil>" } return fmt.Sprintf("IngestionRequest(%+v)", *p) } // Attributes: // - Err // - RocksdbError type IngestionResponse struct { Err *base.ErrorCode `thrift:"err,1" db:"err" json:"err"` RocksdbError int32 `thrift:"rocksdb_error,2" db:"rocksdb_error" json:"rocksdb_error"` } func NewIngestionResponse() *IngestionResponse { return &IngestionResponse{} } var IngestionResponse_Err_DEFAULT *base.ErrorCode func (p *IngestionResponse) GetErr() *base.ErrorCode { if !p.IsSetErr() { return IngestionResponse_Err_DEFAULT } return p.Err } func (p *IngestionResponse) GetRocksdbError() int32 { return p.RocksdbError } func (p *IngestionResponse) IsSetErr() bool { return p.Err != nil } func (p *IngestionResponse) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) } for { _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() if err != nil { return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.STRUCT { if err := p.ReadField1(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 2: if fieldTypeId == thrift.I32 { if err := p.ReadField2(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } default: if err := iprot.Skip(fieldTypeId); err != nil { return err } } if err := iprot.ReadFieldEnd(); err != nil { return err } } if err := iprot.ReadStructEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } return nil } func (p *IngestionResponse) ReadField1(iprot thrift.TProtocol) error { p.Err = &base.ErrorCode{} if err := p.Err.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Err), err) } return nil } func (p *IngestionResponse) ReadField2(iprot thrift.TProtocol) error { if v, err := iprot.ReadI32(); err != nil { return thrift.PrependError("error reading field 2: ", err) } else { p.RocksdbError = v } return nil } func (p *IngestionResponse) Write(oprot thrift.TProtocol) error { if err := oprot.WriteStructBegin("ingestion_response"); err != nil { return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } if p != nil { if err := p.writeField1(oprot); err != nil { return err } if err := p.writeField2(oprot); err != nil { return err } } if err := oprot.WriteFieldStop(); err != nil { return thrift.PrependError("write field stop error: ", err) } if err := oprot.WriteStructEnd(); err != nil { return thrift.PrependError("write struct stop error: ", err) } return nil } func (p *IngestionResponse) writeField1(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("err", thrift.STRUCT, 1); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:err: ", p), err) } if err := p.Err.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Err), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 1:err: ", p), err) } return err } func (p *IngestionResponse) writeField2(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("rocksdb_error", thrift.I32, 2); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:rocksdb_error: ", p), err) } if err := oprot.WriteI32(int32(p.RocksdbError)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.rocksdb_error (2) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 2:rocksdb_error: ", p), err) } return err } func (p *IngestionResponse) String() string { if p == nil { return "<nil>" } return fmt.Sprintf("IngestionResponse(%+v)", *p) } // Attributes: // - AppName // - Type type ControlBulkLoadRequest struct { AppName string `thrift:"app_name,1" db:"app_name" json:"app_name"` Type BulkLoadControlType `thrift:"type,2" db:"type" json:"type"` } func NewControlBulkLoadRequest() *ControlBulkLoadRequest { return &ControlBulkLoadRequest{} } func (p *ControlBulkLoadRequest) GetAppName() string { return p.AppName } func (p *ControlBulkLoadRequest) GetType() BulkLoadControlType { return p.Type } func (p *ControlBulkLoadRequest) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) } for { _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() if err != nil { return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.STRING { if err := p.ReadField1(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 2: if fieldTypeId == thrift.I32 { if err := p.ReadField2(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } default: if err := iprot.Skip(fieldTypeId); err != nil { return err } } if err := iprot.ReadFieldEnd(); err != nil { return err } } if err := iprot.ReadStructEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } return nil } func (p *ControlBulkLoadRequest) ReadField1(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 1: ", err) } else { p.AppName = v } return nil } func (p *ControlBulkLoadRequest) ReadField2(iprot thrift.TProtocol) error { if v, err := iprot.ReadI32(); err != nil { return thrift.PrependError("error reading field 2: ", err) } else { temp := BulkLoadControlType(v) p.Type = temp } return nil } func (p *ControlBulkLoadRequest) Write(oprot thrift.TProtocol) error { if err := oprot.WriteStructBegin("control_bulk_load_request"); err != nil { return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } if p != nil { if err := p.writeField1(oprot); err != nil { return err } if err := p.writeField2(oprot); err != nil { return err } } if err := oprot.WriteFieldStop(); err != nil { return thrift.PrependError("write field stop error: ", err) } if err := oprot.WriteStructEnd(); err != nil { return thrift.PrependError("write struct stop error: ", err) } return nil } func (p *ControlBulkLoadRequest) writeField1(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("app_name", thrift.STRING, 1); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:app_name: ", p), err) } if err := oprot.WriteString(string(p.AppName)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.app_name (1) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 1:app_name: ", p), err) } return err } func (p *ControlBulkLoadRequest) writeField2(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("type", thrift.I32, 2); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:type: ", p), err) } if err := oprot.WriteI32(int32(p.Type)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.type (2) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 2:type: ", p), err) } return err } func (p *ControlBulkLoadRequest) String() string { if p == nil { return "<nil>" } return fmt.Sprintf("ControlBulkLoadRequest(%+v)", *p) } // Attributes: // - Err // - HintMsg type ControlBulkLoadResponse struct { Err *base.ErrorCode `thrift:"err,1" db:"err" json:"err"` HintMsg *string `thrift:"hint_msg,2" db:"hint_msg" json:"hint_msg,omitempty"` } func NewControlBulkLoadResponse() *ControlBulkLoadResponse { return &ControlBulkLoadResponse{} } var ControlBulkLoadResponse_Err_DEFAULT *base.ErrorCode func (p *ControlBulkLoadResponse) GetErr() *base.ErrorCode { if !p.IsSetErr() { return ControlBulkLoadResponse_Err_DEFAULT } return p.Err } var ControlBulkLoadResponse_HintMsg_DEFAULT string func (p *ControlBulkLoadResponse) GetHintMsg() string { if !p.IsSetHintMsg() { return ControlBulkLoadResponse_HintMsg_DEFAULT } return *p.HintMsg } func (p *ControlBulkLoadResponse) IsSetErr() bool { return p.Err != nil } func (p *ControlBulkLoadResponse) IsSetHintMsg() bool { return p.HintMsg != nil } func (p *ControlBulkLoadResponse) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) } for { _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() if err != nil { return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.STRUCT { if err := p.ReadField1(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 2: if fieldTypeId == thrift.STRING { if err := p.ReadField2(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } default: if err := iprot.Skip(fieldTypeId); err != nil { return err } } if err := iprot.ReadFieldEnd(); err != nil { return err } } if err := iprot.ReadStructEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } return nil } func (p *ControlBulkLoadResponse) ReadField1(iprot thrift.TProtocol) error { p.Err = &base.ErrorCode{} if err := p.Err.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Err), err) } return nil } func (p *ControlBulkLoadResponse) ReadField2(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 2: ", err) } else { p.HintMsg = &v } return nil } func (p *ControlBulkLoadResponse) Write(oprot thrift.TProtocol) error { if err := oprot.WriteStructBegin("control_bulk_load_response"); err != nil { return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } if p != nil { if err := p.writeField1(oprot); err != nil { return err } if err := p.writeField2(oprot); err != nil { return err } } if err := oprot.WriteFieldStop(); err != nil { return thrift.PrependError("write field stop error: ", err) } if err := oprot.WriteStructEnd(); err != nil { return thrift.PrependError("write struct stop error: ", err) } return nil } func (p *ControlBulkLoadResponse) writeField1(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("err", thrift.STRUCT, 1); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:err: ", p), err) } if err := p.Err.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Err), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 1:err: ", p), err) } return err } func (p *ControlBulkLoadResponse) writeField2(oprot thrift.TProtocol) (err error) { if p.IsSetHintMsg() { if err := oprot.WriteFieldBegin("hint_msg", thrift.STRING, 2); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:hint_msg: ", p), err) } if err := oprot.WriteString(string(*p.HintMsg)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.hint_msg (2) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 2:hint_msg: ", p), err) } } return err } func (p *ControlBulkLoadResponse) String() string { if p == nil { return "<nil>" } return fmt.Sprintf("ControlBulkLoadResponse(%+v)", *p) } // Attributes: // - AppName type QueryBulkLoadRequest struct { AppName string `thrift:"app_name,1" db:"app_name" json:"app_name"` } func NewQueryBulkLoadRequest() *QueryBulkLoadRequest { return &QueryBulkLoadRequest{} } func (p *QueryBulkLoadRequest) GetAppName() string { return p.AppName } func (p *QueryBulkLoadRequest) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) } for { _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() if err != nil { return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.STRING { if err := p.ReadField1(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } default: if err := iprot.Skip(fieldTypeId); err != nil { return err } } if err := iprot.ReadFieldEnd(); err != nil { return err } } if err := iprot.ReadStructEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } return nil } func (p *QueryBulkLoadRequest) ReadField1(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 1: ", err) } else { p.AppName = v } return nil } func (p *QueryBulkLoadRequest) Write(oprot thrift.TProtocol) error { if err := oprot.WriteStructBegin("query_bulk_load_request"); err != nil { return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } if p != nil { if err := p.writeField1(oprot); err != nil { return err } } if err := oprot.WriteFieldStop(); err != nil { return thrift.PrependError("write field stop error: ", err) } if err := oprot.WriteStructEnd(); err != nil { return thrift.PrependError("write struct stop error: ", err) } return nil } func (p *QueryBulkLoadRequest) writeField1(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("app_name", thrift.STRING, 1); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:app_name: ", p), err) } if err := oprot.WriteString(string(p.AppName)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.app_name (1) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 1:app_name: ", p), err) } return err } func (p *QueryBulkLoadRequest) String() string { if p == nil { return "<nil>" } return fmt.Sprintf("QueryBulkLoadRequest(%+v)", *p) } // Attributes: // - Err // - AppName // - AppStatus // - PartitionsStatus // - MaxReplicaCount // - BulkLoadStates // - HintMsg // - IsBulkLoading // - HpBulkLoadStates type QueryBulkLoadResponse struct { Err *base.ErrorCode `thrift:"err,1" db:"err" json:"err"` AppName string `thrift:"app_name,2" db:"app_name" json:"app_name"` AppStatus BulkLoadStatus `thrift:"app_status,3" db:"app_status" json:"app_status"` PartitionsStatus []BulkLoadStatus `thrift:"partitions_status,4" db:"partitions_status" json:"partitions_status"` MaxReplicaCount int32 `thrift:"max_replica_count,5" db:"max_replica_count" json:"max_replica_count"` BulkLoadStates []map[*base.RPCAddress]*PartitionBulkLoadState `thrift:"bulk_load_states,6" db:"bulk_load_states" json:"bulk_load_states"` HintMsg *string `thrift:"hint_msg,7" db:"hint_msg" json:"hint_msg,omitempty"` IsBulkLoading *bool `thrift:"is_bulk_loading,8" db:"is_bulk_loading" json:"is_bulk_loading,omitempty"` HpBulkLoadStates []map[*base.HostPort]*PartitionBulkLoadState `thrift:"hp_bulk_load_states,9" db:"hp_bulk_load_states" json:"hp_bulk_load_states,omitempty"` } func NewQueryBulkLoadResponse() *QueryBulkLoadResponse { return &QueryBulkLoadResponse{} } var QueryBulkLoadResponse_Err_DEFAULT *base.ErrorCode func (p *QueryBulkLoadResponse) GetErr() *base.ErrorCode { if !p.IsSetErr() { return QueryBulkLoadResponse_Err_DEFAULT } return p.Err } func (p *QueryBulkLoadResponse) GetAppName() string { return p.AppName } func (p *QueryBulkLoadResponse) GetAppStatus() BulkLoadStatus { return p.AppStatus } func (p *QueryBulkLoadResponse) GetPartitionsStatus() []BulkLoadStatus { return p.PartitionsStatus } func (p *QueryBulkLoadResponse) GetMaxReplicaCount() int32 { return p.MaxReplicaCount } func (p *QueryBulkLoadResponse) GetBulkLoadStates() []map[*base.RPCAddress]*PartitionBulkLoadState { return p.BulkLoadStates } var QueryBulkLoadResponse_HintMsg_DEFAULT string func (p *QueryBulkLoadResponse) GetHintMsg() string { if !p.IsSetHintMsg() { return QueryBulkLoadResponse_HintMsg_DEFAULT } return *p.HintMsg } var QueryBulkLoadResponse_IsBulkLoading_DEFAULT bool func (p *QueryBulkLoadResponse) GetIsBulkLoading() bool { if !p.IsSetIsBulkLoading() { return QueryBulkLoadResponse_IsBulkLoading_DEFAULT } return *p.IsBulkLoading } var QueryBulkLoadResponse_HpBulkLoadStates_DEFAULT []map[*base.HostPort]*PartitionBulkLoadState func (p *QueryBulkLoadResponse) GetHpBulkLoadStates() []map[*base.HostPort]*PartitionBulkLoadState { return p.HpBulkLoadStates } func (p *QueryBulkLoadResponse) IsSetErr() bool { return p.Err != nil } func (p *QueryBulkLoadResponse) IsSetHintMsg() bool { return p.HintMsg != nil } func (p *QueryBulkLoadResponse) IsSetIsBulkLoading() bool { return p.IsBulkLoading != nil } func (p *QueryBulkLoadResponse) IsSetHpBulkLoadStates() bool { return p.HpBulkLoadStates != nil } func (p *QueryBulkLoadResponse) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) } for { _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() if err != nil { return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.STRUCT { if err := p.ReadField1(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 2: if fieldTypeId == thrift.STRING { if err := p.ReadField2(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 3: if fieldTypeId == thrift.I32 { if err := p.ReadField3(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 4: if fieldTypeId == thrift.LIST { if err := p.ReadField4(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 5: if fieldTypeId == thrift.I32 { if err := p.ReadField5(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 6: if fieldTypeId == thrift.LIST { if err := p.ReadField6(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 7: if fieldTypeId == thrift.STRING { if err := p.ReadField7(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 8: if fieldTypeId == thrift.BOOL { if err := p.ReadField8(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 9: if fieldTypeId == thrift.LIST { if err := p.ReadField9(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } default: if err := iprot.Skip(fieldTypeId); err != nil { return err } } if err := iprot.ReadFieldEnd(); err != nil { return err } } if err := iprot.ReadStructEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } return nil } func (p *QueryBulkLoadResponse) ReadField1(iprot thrift.TProtocol) error { p.Err = &base.ErrorCode{} if err := p.Err.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Err), err) } return nil } func (p *QueryBulkLoadResponse) ReadField2(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 2: ", err) } else { p.AppName = v } return nil } func (p *QueryBulkLoadResponse) ReadField3(iprot thrift.TProtocol) error { if v, err := iprot.ReadI32(); err != nil { return thrift.PrependError("error reading field 3: ", err) } else { temp := BulkLoadStatus(v) p.AppStatus = temp } return nil } func (p *QueryBulkLoadResponse) ReadField4(iprot thrift.TProtocol) error { _, size, err := iprot.ReadListBegin() if err != nil { return thrift.PrependError("error reading list begin: ", err) } tSlice := make([]BulkLoadStatus, 0, size) p.PartitionsStatus = tSlice for i := 0; i < size; i++ { var _elem5 BulkLoadStatus if v, err := iprot.ReadI32(); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { temp := BulkLoadStatus(v) _elem5 = temp } p.PartitionsStatus = append(p.PartitionsStatus, _elem5) } if err := iprot.ReadListEnd(); err != nil { return thrift.PrependError("error reading list end: ", err) } return nil } func (p *QueryBulkLoadResponse) ReadField5(iprot thrift.TProtocol) error { if v, err := iprot.ReadI32(); err != nil { return thrift.PrependError("error reading field 5: ", err) } else { p.MaxReplicaCount = v } return nil } func (p *QueryBulkLoadResponse) ReadField6(iprot thrift.TProtocol) error { _, size, err := iprot.ReadListBegin() if err != nil { return thrift.PrependError("error reading list begin: ", err) } tSlice := make([]map[*base.RPCAddress]*PartitionBulkLoadState, 0, size) p.BulkLoadStates = tSlice for i := 0; i < size; i++ { _, _, size, err := iprot.ReadMapBegin() if err != nil { return thrift.PrependError("error reading map begin: ", err) } tMap := make(map[*base.RPCAddress]*PartitionBulkLoadState, size) _elem6 := tMap for i := 0; i < size; i++ { _key7 := &base.RPCAddress{} if err := _key7.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _key7), err) } _val8 := &PartitionBulkLoadState{ IngestStatus: 0, } if err := _val8.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _val8), err) } _elem6[_key7] = _val8 } if err := iprot.ReadMapEnd(); err != nil { return thrift.PrependError("error reading map end: ", err) } p.BulkLoadStates = append(p.BulkLoadStates, _elem6) } if err := iprot.ReadListEnd(); err != nil { return thrift.PrependError("error reading list end: ", err) } return nil } func (p *QueryBulkLoadResponse) ReadField7(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 7: ", err) } else { p.HintMsg = &v } return nil } func (p *QueryBulkLoadResponse) ReadField8(iprot thrift.TProtocol) error { if v, err := iprot.ReadBool(); err != nil { return thrift.PrependError("error reading field 8: ", err) } else { p.IsBulkLoading = &v } return nil } func (p *QueryBulkLoadResponse) ReadField9(iprot thrift.TProtocol) error { _, size, err := iprot.ReadListBegin() if err != nil { return thrift.PrependError("error reading list begin: ", err) } tSlice := make([]map[*base.HostPort]*PartitionBulkLoadState, 0, size) p.HpBulkLoadStates = tSlice for i := 0; i < size; i++ { _, _, size, err := iprot.ReadMapBegin() if err != nil { return thrift.PrependError("error reading map begin: ", err) } tMap := make(map[*base.HostPort]*PartitionBulkLoadState, size) _elem9 := tMap for i := 0; i < size; i++ { _key10 := &base.HostPort{} if err := _key10.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _key10), err) } _val11 := &PartitionBulkLoadState{ IngestStatus: 0, } if err := _val11.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _val11), err) } _elem9[_key10] = _val11 } if err := iprot.ReadMapEnd(); err != nil { return thrift.PrependError("error reading map end: ", err) } p.HpBulkLoadStates = append(p.HpBulkLoadStates, _elem9) } if err := iprot.ReadListEnd(); err != nil { return thrift.PrependError("error reading list end: ", err) } return nil } func (p *QueryBulkLoadResponse) Write(oprot thrift.TProtocol) error { if err := oprot.WriteStructBegin("query_bulk_load_response"); err != nil { return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } if p != nil { if err := p.writeField1(oprot); err != nil { return err } if err := p.writeField2(oprot); err != nil { return err } if err := p.writeField3(oprot); err != nil { return err } if err := p.writeField4(oprot); err != nil { return err } if err := p.writeField5(oprot); err != nil { return err } if err := p.writeField6(oprot); err != nil { return err } if err := p.writeField7(oprot); err != nil { return err } if err := p.writeField8(oprot); err != nil { return err } if err := p.writeField9(oprot); err != nil { return err } } if err := oprot.WriteFieldStop(); err != nil { return thrift.PrependError("write field stop error: ", err) } if err := oprot.WriteStructEnd(); err != nil { return thrift.PrependError("write struct stop error: ", err) } return nil } func (p *QueryBulkLoadResponse) writeField1(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("err", thrift.STRUCT, 1); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:err: ", p), err) } if err := p.Err.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Err), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 1:err: ", p), err) } return err } func (p *QueryBulkLoadResponse) writeField2(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("app_name", thrift.STRING, 2); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:app_name: ", p), err) } if err := oprot.WriteString(string(p.AppName)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.app_name (2) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 2:app_name: ", p), err) } return err } func (p *QueryBulkLoadResponse) writeField3(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("app_status", thrift.I32, 3); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 3:app_status: ", p), err) } if err := oprot.WriteI32(int32(p.AppStatus)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.app_status (3) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 3:app_status: ", p), err) } return err } func (p *QueryBulkLoadResponse) writeField4(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("partitions_status", thrift.LIST, 4); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 4:partitions_status: ", p), err) } if err := oprot.WriteListBegin(thrift.I32, len(p.PartitionsStatus)); err != nil { return thrift.PrependError("error writing list begin: ", err) } for _, v := range p.PartitionsStatus { if err := oprot.WriteI32(int32(v)); err != nil { return thrift.PrependError(fmt.Sprintf("%T. (0) field write error: ", p), err) } } if err := oprot.WriteListEnd(); err != nil { return thrift.PrependError("error writing list end: ", err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 4:partitions_status: ", p), err) } return err } func (p *QueryBulkLoadResponse) writeField5(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("max_replica_count", thrift.I32, 5); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 5:max_replica_count: ", p), err) } if err := oprot.WriteI32(int32(p.MaxReplicaCount)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.max_replica_count (5) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 5:max_replica_count: ", p), err) } return err } func (p *QueryBulkLoadResponse) writeField6(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("bulk_load_states", thrift.LIST, 6); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 6:bulk_load_states: ", p), err) } if err := oprot.WriteListBegin(thrift.MAP, len(p.BulkLoadStates)); err != nil { return thrift.PrependError("error writing list begin: ", err) } for _, v := range p.BulkLoadStates { if err := oprot.WriteMapBegin(thrift.STRUCT, thrift.STRUCT, len(v)); err != nil { return thrift.PrependError("error writing map begin: ", err) } for k, v := range v { if err := k.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", k), err) } if err := v.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", v), err) } } if err := oprot.WriteMapEnd(); err != nil { return thrift.PrependError("error writing map end: ", err) } } if err := oprot.WriteListEnd(); err != nil { return thrift.PrependError("error writing list end: ", err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 6:bulk_load_states: ", p), err) } return err } func (p *QueryBulkLoadResponse) writeField7(oprot thrift.TProtocol) (err error) { if p.IsSetHintMsg() { if err := oprot.WriteFieldBegin("hint_msg", thrift.STRING, 7); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 7:hint_msg: ", p), err) } if err := oprot.WriteString(string(*p.HintMsg)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.hint_msg (7) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 7:hint_msg: ", p), err) } } return err } func (p *QueryBulkLoadResponse) writeField8(oprot thrift.TProtocol) (err error) { if p.IsSetIsBulkLoading() { if err := oprot.WriteFieldBegin("is_bulk_loading", thrift.BOOL, 8); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 8:is_bulk_loading: ", p), err) } if err := oprot.WriteBool(bool(*p.IsBulkLoading)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.is_bulk_loading (8) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 8:is_bulk_loading: ", p), err) } } return err } func (p *QueryBulkLoadResponse) writeField9(oprot thrift.TProtocol) (err error) { if p.IsSetHpBulkLoadStates() { if err := oprot.WriteFieldBegin("hp_bulk_load_states", thrift.LIST, 9); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 9:hp_bulk_load_states: ", p), err) } if err := oprot.WriteListBegin(thrift.MAP, len(p.HpBulkLoadStates)); err != nil { return thrift.PrependError("error writing list begin: ", err) } for _, v := range p.HpBulkLoadStates { if err := oprot.WriteMapBegin(thrift.STRUCT, thrift.STRUCT, len(v)); err != nil { return thrift.PrependError("error writing map begin: ", err) } for k, v := range v { if err := k.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", k), err) } if err := v.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", v), err) } } if err := oprot.WriteMapEnd(); err != nil { return thrift.PrependError("error writing map end: ", err) } } if err := oprot.WriteListEnd(); err != nil { return thrift.PrependError("error writing list end: ", err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 9:hp_bulk_load_states: ", p), err) } } return err } func (p *QueryBulkLoadResponse) String() string { if p == nil { return "<nil>" } return fmt.Sprintf("QueryBulkLoadResponse(%+v)", *p) } // Attributes: // - AppName type ClearBulkLoadStateRequest struct { AppName string `thrift:"app_name,1" db:"app_name" json:"app_name"` } func NewClearBulkLoadStateRequest() *ClearBulkLoadStateRequest { return &ClearBulkLoadStateRequest{} } func (p *ClearBulkLoadStateRequest) GetAppName() string { return p.AppName } func (p *ClearBulkLoadStateRequest) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) } for { _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() if err != nil { return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.STRING { if err := p.ReadField1(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } default: if err := iprot.Skip(fieldTypeId); err != nil { return err } } if err := iprot.ReadFieldEnd(); err != nil { return err } } if err := iprot.ReadStructEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } return nil } func (p *ClearBulkLoadStateRequest) ReadField1(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 1: ", err) } else { p.AppName = v } return nil } func (p *ClearBulkLoadStateRequest) Write(oprot thrift.TProtocol) error { if err := oprot.WriteStructBegin("clear_bulk_load_state_request"); err != nil { return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } if p != nil { if err := p.writeField1(oprot); err != nil { return err } } if err := oprot.WriteFieldStop(); err != nil { return thrift.PrependError("write field stop error: ", err) } if err := oprot.WriteStructEnd(); err != nil { return thrift.PrependError("write struct stop error: ", err) } return nil } func (p *ClearBulkLoadStateRequest) writeField1(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("app_name", thrift.STRING, 1); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:app_name: ", p), err) } if err := oprot.WriteString(string(p.AppName)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.app_name (1) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 1:app_name: ", p), err) } return err } func (p *ClearBulkLoadStateRequest) String() string { if p == nil { return "<nil>" } return fmt.Sprintf("ClearBulkLoadStateRequest(%+v)", *p) } // Attributes: // - Err // - HintMsg type ClearBulkLoadStateResponse struct { Err *base.ErrorCode `thrift:"err,1" db:"err" json:"err"` HintMsg string `thrift:"hint_msg,2" db:"hint_msg" json:"hint_msg"` } func NewClearBulkLoadStateResponse() *ClearBulkLoadStateResponse { return &ClearBulkLoadStateResponse{} } var ClearBulkLoadStateResponse_Err_DEFAULT *base.ErrorCode func (p *ClearBulkLoadStateResponse) GetErr() *base.ErrorCode { if !p.IsSetErr() { return ClearBulkLoadStateResponse_Err_DEFAULT } return p.Err } func (p *ClearBulkLoadStateResponse) GetHintMsg() string { return p.HintMsg } func (p *ClearBulkLoadStateResponse) IsSetErr() bool { return p.Err != nil } func (p *ClearBulkLoadStateResponse) Read(iprot thrift.TProtocol) error { if _, err := iprot.ReadStructBegin(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) } for { _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin() if err != nil { return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) } if fieldTypeId == thrift.STOP { break } switch fieldId { case 1: if fieldTypeId == thrift.STRUCT { if err := p.ReadField1(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } case 2: if fieldTypeId == thrift.STRING { if err := p.ReadField2(iprot); err != nil { return err } } else { if err := iprot.Skip(fieldTypeId); err != nil { return err } } default: if err := iprot.Skip(fieldTypeId); err != nil { return err } } if err := iprot.ReadFieldEnd(); err != nil { return err } } if err := iprot.ReadStructEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) } return nil } func (p *ClearBulkLoadStateResponse) ReadField1(iprot thrift.TProtocol) error { p.Err = &base.ErrorCode{} if err := p.Err.Read(iprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Err), err) } return nil } func (p *ClearBulkLoadStateResponse) ReadField2(iprot thrift.TProtocol) error { if v, err := iprot.ReadString(); err != nil { return thrift.PrependError("error reading field 2: ", err) } else { p.HintMsg = v } return nil } func (p *ClearBulkLoadStateResponse) Write(oprot thrift.TProtocol) error { if err := oprot.WriteStructBegin("clear_bulk_load_state_response"); err != nil { return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } if p != nil { if err := p.writeField1(oprot); err != nil { return err } if err := p.writeField2(oprot); err != nil { return err } } if err := oprot.WriteFieldStop(); err != nil { return thrift.PrependError("write field stop error: ", err) } if err := oprot.WriteStructEnd(); err != nil { return thrift.PrependError("write struct stop error: ", err) } return nil } func (p *ClearBulkLoadStateResponse) writeField1(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("err", thrift.STRUCT, 1); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:err: ", p), err) } if err := p.Err.Write(oprot); err != nil { return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Err), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 1:err: ", p), err) } return err } func (p *ClearBulkLoadStateResponse) writeField2(oprot thrift.TProtocol) (err error) { if err := oprot.WriteFieldBegin("hint_msg", thrift.STRING, 2); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:hint_msg: ", p), err) } if err := oprot.WriteString(string(p.HintMsg)); err != nil { return thrift.PrependError(fmt.Sprintf("%T.hint_msg (2) field write error: ", p), err) } if err := oprot.WriteFieldEnd(); err != nil { return thrift.PrependError(fmt.Sprintf("%T write field end error 2:hint_msg: ", p), err) } return err } func (p *ClearBulkLoadStateResponse) String() string { if p == nil { return "<nil>" } return fmt.Sprintf("ClearBulkLoadStateResponse(%+v)", *p) }

go-client/idl/admin/bulk_load.go (4,064 lines of code) (raw):