Help us shape the future of Go! Take the 2026 Go Developer Survey

storage

package
v0.20.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 30, 2026 License: Apache-2.0 Imports: 3 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
var MigrateStorageData_Message_DEFAULT string
View Source
var MigrateStorageReq_DryRun_DEFAULT bool
View Source
var MigrateStorageReq_TargetPath_DEFAULT string
View Source
var StorageBackendStatus_Detail_DEFAULT string
View Source
var StorageUsage_QuotaUsed_DEFAULT int64

Functions

This section is empty.

Types

type CleanPresignOrphansResp

type CleanPresignOrphansResp struct {
	Code    int32  `thrift:"code,1,required" form:"code,required" json:"code,required"`
	Message string `thrift:"message,2,required" form:"message,required" json:"message,required"`
	Removed int32  `thrift:"removed,3,required" form:"removed,required" json:"removed,required"`
}
var StorageServiceCleanPresignOrphansResult_Success_DEFAULT *CleanPresignOrphansResp

func NewCleanPresignOrphansResp

func NewCleanPresignOrphansResp() *CleanPresignOrphansResp

func (*CleanPresignOrphansResp) GetCode

func (p *CleanPresignOrphansResp) GetCode() (v int32)

func (*CleanPresignOrphansResp) GetMessage

func (p *CleanPresignOrphansResp) GetMessage() (v string)

func (*CleanPresignOrphansResp) GetRemoved

func (p *CleanPresignOrphansResp) GetRemoved() (v int32)

func (*CleanPresignOrphansResp) InitDefault

func (p *CleanPresignOrphansResp) InitDefault()

func (*CleanPresignOrphansResp) Read

func (p *CleanPresignOrphansResp) Read(iprot thrift.TProtocol) (err error)

func (*CleanPresignOrphansResp) ReadField1

func (p *CleanPresignOrphansResp) ReadField1(iprot thrift.TProtocol) error

func (*CleanPresignOrphansResp) ReadField2

func (p *CleanPresignOrphansResp) ReadField2(iprot thrift.TProtocol) error

func (*CleanPresignOrphansResp) ReadField3

func (p *CleanPresignOrphansResp) ReadField3(iprot thrift.TProtocol) error

func (*CleanPresignOrphansResp) String

func (p *CleanPresignOrphansResp) String() string

func (*CleanPresignOrphansResp) Write

func (p *CleanPresignOrphansResp) Write(oprot thrift.TProtocol) (err error)

type GetStorageInfoReq

type GetStorageInfoReq struct {
}

==================== 获取存储信息 ====================

var StorageServiceCleanPresignOrphansArgs_Req_DEFAULT *GetStorageInfoReq
var StorageServiceGetStorageInfoArgs_Req_DEFAULT *GetStorageInfoReq
var StorageServiceGetStorageInsightsArgs_Req_DEFAULT *GetStorageInfoReq

func NewGetStorageInfoReq

func NewGetStorageInfoReq() *GetStorageInfoReq

func (*GetStorageInfoReq) InitDefault

func (p *GetStorageInfoReq) InitDefault()

func (*GetStorageInfoReq) Read

func (p *GetStorageInfoReq) Read(iprot thrift.TProtocol) (err error)

func (*GetStorageInfoReq) String

func (p *GetStorageInfoReq) String() string

func (*GetStorageInfoReq) Write

func (p *GetStorageInfoReq) Write(oprot thrift.TProtocol) (err error)

type GetStorageInfoResp

type GetStorageInfoResp struct {
	Code    int32            `thrift:"code,1,required" form:"code,required" json:"code,required"`
	Message string           `thrift:"message,2,required" form:"message,required" json:"message,required"`
	Data    *StorageInfoData `thrift:"data,3,required" form:"data,required" json:"data,required"`
}
var StorageServiceGetStorageInfoResult_Success_DEFAULT *GetStorageInfoResp

func NewGetStorageInfoResp

func NewGetStorageInfoResp() *GetStorageInfoResp

func (*GetStorageInfoResp) GetCode

func (p *GetStorageInfoResp) GetCode() (v int32)

func (*GetStorageInfoResp) GetData

func (p *GetStorageInfoResp) GetData() (v *StorageInfoData)

func (*GetStorageInfoResp) GetMessage

func (p *GetStorageInfoResp) GetMessage() (v string)

func (*GetStorageInfoResp) InitDefault

func (p *GetStorageInfoResp) InitDefault()

func (*GetStorageInfoResp) IsSetData

func (p *GetStorageInfoResp) IsSetData() bool

func (*GetStorageInfoResp) Read

func (p *GetStorageInfoResp) Read(iprot thrift.TProtocol) (err error)

func (*GetStorageInfoResp) ReadField1

func (p *GetStorageInfoResp) ReadField1(iprot thrift.TProtocol) error

func (*GetStorageInfoResp) ReadField2

func (p *GetStorageInfoResp) ReadField2(iprot thrift.TProtocol) error

func (*GetStorageInfoResp) ReadField3

func (p *GetStorageInfoResp) ReadField3(iprot thrift.TProtocol) error

func (*GetStorageInfoResp) String

func (p *GetStorageInfoResp) String() string

func (*GetStorageInfoResp) Write

func (p *GetStorageInfoResp) Write(oprot thrift.TProtocol) (err error)

type GetStorageInsightsResp

type GetStorageInsightsResp struct {
	Code    int32                `thrift:"code,1,required" form:"code,required" json:"code,required"`
	Message string               `thrift:"message,2,required" form:"message,required" json:"message,required"`
	Data    *StorageInsightsData `thrift:"data,3,required" form:"data,required" json:"data,required"`
}
var StorageServiceGetStorageInsightsResult_Success_DEFAULT *GetStorageInsightsResp

func NewGetStorageInsightsResp

func NewGetStorageInsightsResp() *GetStorageInsightsResp

func (*GetStorageInsightsResp) GetCode

func (p *GetStorageInsightsResp) GetCode() (v int32)

func (*GetStorageInsightsResp) GetData

func (p *GetStorageInsightsResp) GetData() (v *StorageInsightsData)

func (*GetStorageInsightsResp) GetMessage

func (p *GetStorageInsightsResp) GetMessage() (v string)

func (*GetStorageInsightsResp) InitDefault

func (p *GetStorageInsightsResp) InitDefault()

func (*GetStorageInsightsResp) IsSetData

func (p *GetStorageInsightsResp) IsSetData() bool

func (*GetStorageInsightsResp) Read

func (p *GetStorageInsightsResp) Read(iprot thrift.TProtocol) (err error)

func (*GetStorageInsightsResp) ReadField1

func (p *GetStorageInsightsResp) ReadField1(iprot thrift.TProtocol) error

func (*GetStorageInsightsResp) ReadField2

func (p *GetStorageInsightsResp) ReadField2(iprot thrift.TProtocol) error

func (*GetStorageInsightsResp) ReadField3

func (p *GetStorageInsightsResp) ReadField3(iprot thrift.TProtocol) error

func (*GetStorageInsightsResp) String

func (p *GetStorageInsightsResp) String() string

func (*GetStorageInsightsResp) Write

func (p *GetStorageInsightsResp) Write(oprot thrift.TProtocol) (err error)

type MigrateStorageData added in v0.20.6

type MigrateStorageData struct {
	// 是否已切换到目标后端
	Switched bool `thrift:"switched,1,required" form:"switched,required" json:"switched,required"`
	// 本次复制成功的对象数
	Copied int64 `thrift:"copied,2,required" form:"copied,required" json:"copied,required"`
	// 目标已存在(续跑跳过)
	Skipped int64 `thrift:"skipped,3,required" form:"skipped,required" json:"skipped,required"`
	// 复制失败的对象数
	Failed int64 `thrift:"failed,4,required" form:"failed,required" json:"failed,required"`
	// 复制字节数
	Bytes int64 `thrift:"bytes,5,required" form:"bytes,required" json:"bytes,required"`
	// 计划涉及的对象总数
	Objects  int64  `thrift:"objects,6,required" form:"objects,required" json:"objects,required"`
	FromType string `thrift:"from_type,7,required" form:"from_type,required" json:"from_type,required"`
	ToType   string `thrift:"to_type,8,required" form:"to_type,required" json:"to_type,required"`
	// 失败摘要(failed>0 时)
	Message *string `thrift:"message,9,optional" form:"message" json:"message,omitempty"`
}

MigrateStorageData 迁移结果。

var MigrateStorageResp_Data_DEFAULT *MigrateStorageData

func NewMigrateStorageData added in v0.20.6

func NewMigrateStorageData() *MigrateStorageData

func (*MigrateStorageData) GetBytes added in v0.20.6

func (p *MigrateStorageData) GetBytes() (v int64)

func (*MigrateStorageData) GetCopied added in v0.20.6

func (p *MigrateStorageData) GetCopied() (v int64)

func (*MigrateStorageData) GetFailed added in v0.20.6

func (p *MigrateStorageData) GetFailed() (v int64)

func (*MigrateStorageData) GetFromType added in v0.20.6

func (p *MigrateStorageData) GetFromType() (v string)

func (*MigrateStorageData) GetMessage added in v0.20.6

func (p *MigrateStorageData) GetMessage() (v string)

func (*MigrateStorageData) GetObjects added in v0.20.6

func (p *MigrateStorageData) GetObjects() (v int64)

func (*MigrateStorageData) GetSkipped added in v0.20.6

func (p *MigrateStorageData) GetSkipped() (v int64)

func (*MigrateStorageData) GetSwitched added in v0.20.6

func (p *MigrateStorageData) GetSwitched() (v bool)

func (*MigrateStorageData) GetToType added in v0.20.6

func (p *MigrateStorageData) GetToType() (v string)

func (*MigrateStorageData) InitDefault added in v0.20.6

func (p *MigrateStorageData) InitDefault()

func (*MigrateStorageData) IsSetMessage added in v0.20.6

func (p *MigrateStorageData) IsSetMessage() bool

func (*MigrateStorageData) Read added in v0.20.6

func (p *MigrateStorageData) Read(iprot thrift.TProtocol) (err error)

func (*MigrateStorageData) ReadField1 added in v0.20.6

func (p *MigrateStorageData) ReadField1(iprot thrift.TProtocol) error

func (*MigrateStorageData) ReadField2 added in v0.20.6

func (p *MigrateStorageData) ReadField2(iprot thrift.TProtocol) error

func (*MigrateStorageData) ReadField3 added in v0.20.6

func (p *MigrateStorageData) ReadField3(iprot thrift.TProtocol) error

func (*MigrateStorageData) ReadField4 added in v0.20.6

func (p *MigrateStorageData) ReadField4(iprot thrift.TProtocol) error

func (*MigrateStorageData) ReadField5 added in v0.20.6

func (p *MigrateStorageData) ReadField5(iprot thrift.TProtocol) error

func (*MigrateStorageData) ReadField6 added in v0.20.6

func (p *MigrateStorageData) ReadField6(iprot thrift.TProtocol) error

func (*MigrateStorageData) ReadField7 added in v0.20.6

func (p *MigrateStorageData) ReadField7(iprot thrift.TProtocol) error

func (*MigrateStorageData) ReadField8 added in v0.20.6

func (p *MigrateStorageData) ReadField8(iprot thrift.TProtocol) error

func (*MigrateStorageData) ReadField9 added in v0.20.6

func (p *MigrateStorageData) ReadField9(iprot thrift.TProtocol) error

func (*MigrateStorageData) String added in v0.20.6

func (p *MigrateStorageData) String() string

func (*MigrateStorageData) Write added in v0.20.6

func (p *MigrateStorageData) Write(oprot thrift.TProtocol) (err error)

type MigrateStorageReq added in v0.20.6

type MigrateStorageReq struct {
	// 1: 目标后端类型(local / s3 / webdav / …;用管理台已配置的目标段凭据)
	TargetType string `thrift:"target_type,1,required" form:"target_type,required" json:"target_type,required"`
	// 2: 目标本地目录(仅 target_type=local 时有意义;缺省 = 沿用现配置的 storage_path)
	TargetPath *string `thrift:"target_path,2,optional" form:"target_path" json:"target_path,omitempty"`
	// 3: 只算计划不搬(先看再动:对象数/字节数/源→目标)
	DryRun *bool `thrift:"dry_run,3,optional" form:"dry_run" json:"dry_run,omitempty"`
}

==================== 存储迁移 ==================== MigrateStorageReq 存储迁移请求:把**存量对象**从当前后端搬到目标后端。

var StorageServiceMigrateStorageArgs_Req_DEFAULT *MigrateStorageReq

func NewMigrateStorageReq added in v0.20.6

func NewMigrateStorageReq() *MigrateStorageReq

func (*MigrateStorageReq) GetDryRun added in v0.20.6

func (p *MigrateStorageReq) GetDryRun() (v bool)

func (*MigrateStorageReq) GetTargetPath added in v0.20.6

func (p *MigrateStorageReq) GetTargetPath() (v string)

func (*MigrateStorageReq) GetTargetType added in v0.20.6

func (p *MigrateStorageReq) GetTargetType() (v string)

func (*MigrateStorageReq) InitDefault added in v0.20.6

func (p *MigrateStorageReq) InitDefault()

func (*MigrateStorageReq) IsSetDryRun added in v0.20.6

func (p *MigrateStorageReq) IsSetDryRun() bool

func (*MigrateStorageReq) IsSetTargetPath added in v0.20.6

func (p *MigrateStorageReq) IsSetTargetPath() bool

func (*MigrateStorageReq) Read added in v0.20.6

func (p *MigrateStorageReq) Read(iprot thrift.TProtocol) (err error)

func (*MigrateStorageReq) ReadField1 added in v0.20.6

func (p *MigrateStorageReq) ReadField1(iprot thrift.TProtocol) error

func (*MigrateStorageReq) ReadField2 added in v0.20.6

func (p *MigrateStorageReq) ReadField2(iprot thrift.TProtocol) error

func (*MigrateStorageReq) ReadField3 added in v0.20.6

func (p *MigrateStorageReq) ReadField3(iprot thrift.TProtocol) error

func (*MigrateStorageReq) String added in v0.20.6

func (p *MigrateStorageReq) String() string

func (*MigrateStorageReq) Write added in v0.20.6

func (p *MigrateStorageReq) Write(oprot thrift.TProtocol) (err error)

type MigrateStorageResp added in v0.20.6

type MigrateStorageResp struct {
	Code    int32               `thrift:"code,1,required" form:"code,required" json:"code,required"`
	Message string              `thrift:"message,2,required" form:"message,required" json:"message,required"`
	Data    *MigrateStorageData `thrift:"data,3,required" form:"data,required" json:"data,required"`
}
var StorageServiceMigrateStorageResult_Success_DEFAULT *MigrateStorageResp

func NewMigrateStorageResp added in v0.20.6

func NewMigrateStorageResp() *MigrateStorageResp

func (*MigrateStorageResp) GetCode added in v0.20.6

func (p *MigrateStorageResp) GetCode() (v int32)

func (*MigrateStorageResp) GetData added in v0.20.6

func (p *MigrateStorageResp) GetData() (v *MigrateStorageData)

func (*MigrateStorageResp) GetMessage added in v0.20.6

func (p *MigrateStorageResp) GetMessage() (v string)

func (*MigrateStorageResp) InitDefault added in v0.20.6

func (p *MigrateStorageResp) InitDefault()

func (*MigrateStorageResp) IsSetData added in v0.20.6

func (p *MigrateStorageResp) IsSetData() bool

func (*MigrateStorageResp) Read added in v0.20.6

func (p *MigrateStorageResp) Read(iprot thrift.TProtocol) (err error)

func (*MigrateStorageResp) ReadField1 added in v0.20.6

func (p *MigrateStorageResp) ReadField1(iprot thrift.TProtocol) error

func (*MigrateStorageResp) ReadField2 added in v0.20.6

func (p *MigrateStorageResp) ReadField2(iprot thrift.TProtocol) error

func (*MigrateStorageResp) ReadField3 added in v0.20.6

func (p *MigrateStorageResp) ReadField3(iprot thrift.TProtocol) error

func (*MigrateStorageResp) String added in v0.20.6

func (p *MigrateStorageResp) String() string

func (*MigrateStorageResp) Write added in v0.20.6

func (p *MigrateStorageResp) Write(oprot thrift.TProtocol) (err error)

type NFSConfig

type NFSConfig struct {
	Server     string `thrift:"server,1,required" form:"server,required" json:"server,required"`
	Path       string `thrift:"path,2,required" form:"path,required" json:"path,required"`
	MountPoint string `thrift:"mount_point,3,required" form:"mount_point,required" json:"mount_point,required"`
	Version    string `thrift:"version,4,required" form:"version,required" json:"version,required"`
	Options    string `thrift:"options,5,required" form:"options,required" json:"options,required"`
	Timeout    int32  `thrift:"timeout,6,required" form:"timeout,required" json:"timeout,required"`
	AutoMount  int32  `thrift:"auto_mount,7,required" form:"auto_mount,required" json:"auto_mount,required"`
	RetryCount int32  `thrift:"retry_count,8,required" form:"retry_count,required" json:"retry_count,required"`
	SubPath    string `thrift:"sub_path,9,required" form:"sub_path,required" json:"sub_path,required"`
}
var StorageConfig_Nfs_DEFAULT *NFSConfig

func NewNFSConfig

func NewNFSConfig() *NFSConfig

func (*NFSConfig) GetAutoMount

func (p *NFSConfig) GetAutoMount() (v int32)

func (*NFSConfig) GetMountPoint

func (p *NFSConfig) GetMountPoint() (v string)

func (*NFSConfig) GetOptions

func (p *NFSConfig) GetOptions() (v string)

func (*NFSConfig) GetPath

func (p *NFSConfig) GetPath() (v string)

func (*NFSConfig) GetRetryCount

func (p *NFSConfig) GetRetryCount() (v int32)

func (*NFSConfig) GetServer

func (p *NFSConfig) GetServer() (v string)

func (*NFSConfig) GetSubPath

func (p *NFSConfig) GetSubPath() (v string)

func (*NFSConfig) GetTimeout

func (p *NFSConfig) GetTimeout() (v int32)

func (*NFSConfig) GetVersion

func (p *NFSConfig) GetVersion() (v string)

func (*NFSConfig) InitDefault

func (p *NFSConfig) InitDefault()

func (*NFSConfig) Read

func (p *NFSConfig) Read(iprot thrift.TProtocol) (err error)

func (*NFSConfig) ReadField1

func (p *NFSConfig) ReadField1(iprot thrift.TProtocol) error

func (*NFSConfig) ReadField2

func (p *NFSConfig) ReadField2(iprot thrift.TProtocol) error

func (*NFSConfig) ReadField3

func (p *NFSConfig) ReadField3(iprot thrift.TProtocol) error

func (*NFSConfig) ReadField4

func (p *NFSConfig) ReadField4(iprot thrift.TProtocol) error

func (*NFSConfig) ReadField5

func (p *NFSConfig) ReadField5(iprot thrift.TProtocol) error

func (*NFSConfig) ReadField6

func (p *NFSConfig) ReadField6(iprot thrift.TProtocol) error

func (*NFSConfig) ReadField7

func (p *NFSConfig) ReadField7(iprot thrift.TProtocol) error

func (*NFSConfig) ReadField8

func (p *NFSConfig) ReadField8(iprot thrift.TProtocol) error

func (*NFSConfig) ReadField9

func (p *NFSConfig) ReadField9(iprot thrift.TProtocol) error

func (*NFSConfig) String

func (p *NFSConfig) String() string

func (*NFSConfig) Write

func (p *NFSConfig) Write(oprot thrift.TProtocol) (err error)

type S3Config

type S3Config struct {
	AccessKeyID     string `thrift:"access_key_id,1,required" form:"access_key_id,required" json:"access_key_id,required"`
	SecretAccessKey string `thrift:"secret_access_key,2,required" form:"secret_access_key,required" json:"secret_access_key,required"`
	BucketName      string `thrift:"bucket_name,3,required" form:"bucket_name,required" json:"bucket_name,required"`
	EndpointURL     string `thrift:"endpoint_url,4,required" form:"endpoint_url,required" json:"endpoint_url,required"`
	RegionName      string `thrift:"region_name,5,required" form:"region_name,required" json:"region_name,required"`
	Hostname        string `thrift:"hostname,6,required" form:"hostname,required" json:"hostname,required"`
	Proxy           string `thrift:"proxy,7,required" form:"proxy,required" json:"proxy,required"`
}
var StorageConfig_S3_DEFAULT *S3Config

func NewS3Config

func NewS3Config() *S3Config

func (*S3Config) GetAccessKeyID

func (p *S3Config) GetAccessKeyID() (v string)

func (*S3Config) GetBucketName

func (p *S3Config) GetBucketName() (v string)

func (*S3Config) GetEndpointURL

func (p *S3Config) GetEndpointURL() (v string)

func (*S3Config) GetHostname

func (p *S3Config) GetHostname() (v string)

func (*S3Config) GetProxy

func (p *S3Config) GetProxy() (v string)

func (*S3Config) GetRegionName

func (p *S3Config) GetRegionName() (v string)

func (*S3Config) GetSecretAccessKey

func (p *S3Config) GetSecretAccessKey() (v string)

func (*S3Config) InitDefault

func (p *S3Config) InitDefault()

func (*S3Config) Read

func (p *S3Config) Read(iprot thrift.TProtocol) (err error)

func (*S3Config) ReadField1

func (p *S3Config) ReadField1(iprot thrift.TProtocol) error

func (*S3Config) ReadField2

func (p *S3Config) ReadField2(iprot thrift.TProtocol) error

func (*S3Config) ReadField3

func (p *S3Config) ReadField3(iprot thrift.TProtocol) error

func (*S3Config) ReadField4

func (p *S3Config) ReadField4(iprot thrift.TProtocol) error

func (*S3Config) ReadField5

func (p *S3Config) ReadField5(iprot thrift.TProtocol) error

func (*S3Config) ReadField6

func (p *S3Config) ReadField6(iprot thrift.TProtocol) error

func (*S3Config) ReadField7

func (p *S3Config) ReadField7(iprot thrift.TProtocol) error

func (*S3Config) String

func (p *S3Config) String() string

func (*S3Config) Write

func (p *S3Config) Write(oprot thrift.TProtocol) (err error)

type StorageBackendStatus

type StorageBackendStatus struct {
	Type       string        `thrift:"type,1,required" form:"type,required" json:"type,required"`
	Configured bool          `thrift:"configured,2,required" form:"configured,required" json:"configured,required"`
	Active     bool          `thrift:"active,3,required" form:"active,required" json:"active,required"`
	Detail     *string       `thrift:"detail,4,optional" form:"detail" json:"detail,omitempty"`
	Usage      *StorageUsage `thrift:"usage,5,optional" form:"usage" json:"usage,omitempty"`
}

func NewStorageBackendStatus

func NewStorageBackendStatus() *StorageBackendStatus

func (*StorageBackendStatus) GetActive

func (p *StorageBackendStatus) GetActive() (v bool)

func (*StorageBackendStatus) GetConfigured

func (p *StorageBackendStatus) GetConfigured() (v bool)

func (*StorageBackendStatus) GetDetail

func (p *StorageBackendStatus) GetDetail() (v string)

func (*StorageBackendStatus) GetType

func (p *StorageBackendStatus) GetType() (v string)

func (*StorageBackendStatus) GetUsage

func (p *StorageBackendStatus) GetUsage() (v *StorageUsage)

func (*StorageBackendStatus) InitDefault

func (p *StorageBackendStatus) InitDefault()

func (*StorageBackendStatus) IsSetDetail

func (p *StorageBackendStatus) IsSetDetail() bool

func (*StorageBackendStatus) IsSetUsage

func (p *StorageBackendStatus) IsSetUsage() bool

func (*StorageBackendStatus) Read

func (p *StorageBackendStatus) Read(iprot thrift.TProtocol) (err error)

func (*StorageBackendStatus) ReadField1

func (p *StorageBackendStatus) ReadField1(iprot thrift.TProtocol) error

func (*StorageBackendStatus) ReadField2

func (p *StorageBackendStatus) ReadField2(iprot thrift.TProtocol) error

func (*StorageBackendStatus) ReadField3

func (p *StorageBackendStatus) ReadField3(iprot thrift.TProtocol) error

func (*StorageBackendStatus) ReadField4

func (p *StorageBackendStatus) ReadField4(iprot thrift.TProtocol) error

func (*StorageBackendStatus) ReadField5

func (p *StorageBackendStatus) ReadField5(iprot thrift.TProtocol) error

func (*StorageBackendStatus) String

func (p *StorageBackendStatus) String() string

func (*StorageBackendStatus) Write

func (p *StorageBackendStatus) Write(oprot thrift.TProtocol) (err error)

type StorageConfig

type StorageConfig struct {
	Type        string        `thrift:"type,1,required" form:"type,required" json:"type,required"`
	StoragePath string        `thrift:"storage_path,2,required" form:"storage_path,required" json:"storage_path,required"`
	Webdav      *WebDAVConfig `thrift:"webdav,3,required" form:"webdav,required" json:"webdav,required"`
	S3          *S3Config     `thrift:"s3,4,required" form:"s3,required" json:"s3,required"`
	Nfs         *NFSConfig    `thrift:"nfs,5,required" form:"nfs,required" json:"nfs,required"`
}
var StorageInfoData_StorageConfig_DEFAULT *StorageConfig

func NewStorageConfig

func NewStorageConfig() *StorageConfig

func (*StorageConfig) GetNfs

func (p *StorageConfig) GetNfs() (v *NFSConfig)

func (*StorageConfig) GetS3

func (p *StorageConfig) GetS3() (v *S3Config)

func (*StorageConfig) GetStoragePath

func (p *StorageConfig) GetStoragePath() (v string)

func (*StorageConfig) GetType

func (p *StorageConfig) GetType() (v string)

func (*StorageConfig) GetWebdav

func (p *StorageConfig) GetWebdav() (v *WebDAVConfig)

func (*StorageConfig) InitDefault

func (p *StorageConfig) InitDefault()

func (*StorageConfig) IsSetNfs

func (p *StorageConfig) IsSetNfs() bool

func (*StorageConfig) IsSetS3

func (p *StorageConfig) IsSetS3() bool

func (*StorageConfig) IsSetWebdav

func (p *StorageConfig) IsSetWebdav() bool

func (*StorageConfig) Read

func (p *StorageConfig) Read(iprot thrift.TProtocol) (err error)

func (*StorageConfig) ReadField1

func (p *StorageConfig) ReadField1(iprot thrift.TProtocol) error

func (*StorageConfig) ReadField2

func (p *StorageConfig) ReadField2(iprot thrift.TProtocol) error

func (*StorageConfig) ReadField3

func (p *StorageConfig) ReadField3(iprot thrift.TProtocol) error

func (*StorageConfig) ReadField4

func (p *StorageConfig) ReadField4(iprot thrift.TProtocol) error

func (*StorageConfig) ReadField5

func (p *StorageConfig) ReadField5(iprot thrift.TProtocol) error

func (*StorageConfig) String

func (p *StorageConfig) String() string

func (*StorageConfig) Write

func (p *StorageConfig) Write(oprot thrift.TProtocol) (err error)

type StorageDetail

type StorageDetail struct {
	Type         string `thrift:"type,1,required" form:"type,required" json:"type,required"`
	Available    bool   `thrift:"available,2,required" form:"available,required" json:"available,required"`
	StoragePath  string `thrift:"storage_path,3,required" form:"storage_path,required" json:"storage_path,required"`
	UsagePercent int32  `thrift:"usage_percent,4,required" form:"usage_percent,required" json:"usage_percent,required"`
	Error        string `thrift:"error,5,required" form:"error,required" json:"error,required"`
}

func NewStorageDetail

func NewStorageDetail() *StorageDetail

func (*StorageDetail) GetAvailable

func (p *StorageDetail) GetAvailable() (v bool)

func (*StorageDetail) GetError

func (p *StorageDetail) GetError() (v string)

func (*StorageDetail) GetStoragePath

func (p *StorageDetail) GetStoragePath() (v string)

func (*StorageDetail) GetType

func (p *StorageDetail) GetType() (v string)

func (*StorageDetail) GetUsagePercent

func (p *StorageDetail) GetUsagePercent() (v int32)

func (*StorageDetail) InitDefault

func (p *StorageDetail) InitDefault()

func (*StorageDetail) Read

func (p *StorageDetail) Read(iprot thrift.TProtocol) (err error)

func (*StorageDetail) ReadField1

func (p *StorageDetail) ReadField1(iprot thrift.TProtocol) error

func (*StorageDetail) ReadField2

func (p *StorageDetail) ReadField2(iprot thrift.TProtocol) error

func (*StorageDetail) ReadField3

func (p *StorageDetail) ReadField3(iprot thrift.TProtocol) error

func (*StorageDetail) ReadField4

func (p *StorageDetail) ReadField4(iprot thrift.TProtocol) error

func (*StorageDetail) ReadField5

func (p *StorageDetail) ReadField5(iprot thrift.TProtocol) error

func (*StorageDetail) String

func (p *StorageDetail) String() string

func (*StorageDetail) Write

func (p *StorageDetail) Write(oprot thrift.TProtocol) (err error)

type StorageInfoData

type StorageInfoData struct {
	// 当前存储类型
	Current string `thrift:"current,1,required" form:"current,required" json:"current,required"`
	// 可用存储类型列表
	Available []string `thrift:"available,2,required,list<string>" form:"available,required" json:"available,required"`
	// 各存储类型详细信息
	StorageDetails map[string]*StorageDetail `thrift:"storage_details,3,required" form:"storage_details,required" json:"storage_details,required"`
	// 存储配置
	StorageConfig *StorageConfig `thrift:"storage_config,4,required" form:"storage_config,required" json:"storage_config,required"`
}
var GetStorageInfoResp_Data_DEFAULT *StorageInfoData

func NewStorageInfoData

func NewStorageInfoData() *StorageInfoData

func (*StorageInfoData) GetAvailable

func (p *StorageInfoData) GetAvailable() (v []string)

func (*StorageInfoData) GetCurrent

func (p *StorageInfoData) GetCurrent() (v string)

func (*StorageInfoData) GetStorageConfig

func (p *StorageInfoData) GetStorageConfig() (v *StorageConfig)

func (*StorageInfoData) GetStorageDetails

func (p *StorageInfoData) GetStorageDetails() (v map[string]*StorageDetail)

func (*StorageInfoData) InitDefault

func (p *StorageInfoData) InitDefault()

func (*StorageInfoData) IsSetStorageConfig

func (p *StorageInfoData) IsSetStorageConfig() bool

func (*StorageInfoData) Read

func (p *StorageInfoData) Read(iprot thrift.TProtocol) (err error)

func (*StorageInfoData) ReadField1

func (p *StorageInfoData) ReadField1(iprot thrift.TProtocol) error

func (*StorageInfoData) ReadField2

func (p *StorageInfoData) ReadField2(iprot thrift.TProtocol) error

func (*StorageInfoData) ReadField3

func (p *StorageInfoData) ReadField3(iprot thrift.TProtocol) error

func (*StorageInfoData) ReadField4

func (p *StorageInfoData) ReadField4(iprot thrift.TProtocol) error

func (*StorageInfoData) String

func (p *StorageInfoData) String() string

func (*StorageInfoData) Write

func (p *StorageInfoData) Write(oprot thrift.TProtocol) (err error)

type StorageInsightsData

type StorageInsightsData struct {
	CurrentType    string            `thrift:"current_type,1,required" form:"current_type,required" json:"current_type,required"`
	EffectiveType  string            `thrift:"effective_type,2,required" form:"effective_type,required" json:"effective_type,required"`
	PresignPolicy  string            `thrift:"presign_policy,3,required" form:"presign_policy,required" json:"presign_policy,required"`
	DirectDownload bool              `thrift:"direct_download,4,required" form:"direct_download,required" json:"direct_download,required"`
	CurrentDetail  map[string]string `thrift:"current_detail,5,required" form:"current_detail,required" json:"current_detail,required"`
	RemoteUsage    *StorageUsage     `thrift:"remote_usage,6,required" form:"remote_usage,required" json:"remote_usage,required"`
	LocalUsage     *StorageUsage     `thrift:"local_usage,7,required" form:"local_usage,required" json:"local_usage,required"`
	TodayTraffic   *TodayTraffic     `thrift:"today_traffic,8,required" form:"today_traffic,required" json:"today_traffic,required"`
	PresignOrphans int64             `thrift:"presign_orphans,9,required" form:"presign_orphans,required" json:"presign_orphans,required"`
	AliveShares    int64             `thrift:"alive_shares,10,required" form:"alive_shares,required" json:"alive_shares,required"`
	SoftDeleted    int64             `thrift:"soft_deleted,11,required" form:"soft_deleted,required" json:"soft_deleted,required"`
}
var GetStorageInsightsResp_Data_DEFAULT *StorageInsightsData

func NewStorageInsightsData

func NewStorageInsightsData() *StorageInsightsData

func (*StorageInsightsData) GetAliveShares

func (p *StorageInsightsData) GetAliveShares() (v int64)

func (*StorageInsightsData) GetCurrentDetail

func (p *StorageInsightsData) GetCurrentDetail() (v map[string]string)

func (*StorageInsightsData) GetCurrentType

func (p *StorageInsightsData) GetCurrentType() (v string)

func (*StorageInsightsData) GetDirectDownload

func (p *StorageInsightsData) GetDirectDownload() (v bool)

func (*StorageInsightsData) GetEffectiveType

func (p *StorageInsightsData) GetEffectiveType() (v string)

func (*StorageInsightsData) GetLocalUsage

func (p *StorageInsightsData) GetLocalUsage() (v *StorageUsage)

func (*StorageInsightsData) GetPresignOrphans

func (p *StorageInsightsData) GetPresignOrphans() (v int64)

func (*StorageInsightsData) GetPresignPolicy

func (p *StorageInsightsData) GetPresignPolicy() (v string)

func (*StorageInsightsData) GetRemoteUsage

func (p *StorageInsightsData) GetRemoteUsage() (v *StorageUsage)

func (*StorageInsightsData) GetSoftDeleted

func (p *StorageInsightsData) GetSoftDeleted() (v int64)

func (*StorageInsightsData) GetTodayTraffic

func (p *StorageInsightsData) GetTodayTraffic() (v *TodayTraffic)

func (*StorageInsightsData) InitDefault

func (p *StorageInsightsData) InitDefault()

func (*StorageInsightsData) IsSetLocalUsage

func (p *StorageInsightsData) IsSetLocalUsage() bool

func (*StorageInsightsData) IsSetRemoteUsage

func (p *StorageInsightsData) IsSetRemoteUsage() bool

func (*StorageInsightsData) IsSetTodayTraffic

func (p *StorageInsightsData) IsSetTodayTraffic() bool

func (*StorageInsightsData) Read

func (p *StorageInsightsData) Read(iprot thrift.TProtocol) (err error)

func (*StorageInsightsData) ReadField1

func (p *StorageInsightsData) ReadField1(iprot thrift.TProtocol) error

func (*StorageInsightsData) ReadField2

func (p *StorageInsightsData) ReadField2(iprot thrift.TProtocol) error

func (*StorageInsightsData) ReadField3

func (p *StorageInsightsData) ReadField3(iprot thrift.TProtocol) error

func (*StorageInsightsData) ReadField4

func (p *StorageInsightsData) ReadField4(iprot thrift.TProtocol) error

func (*StorageInsightsData) ReadField5

func (p *StorageInsightsData) ReadField5(iprot thrift.TProtocol) error

func (*StorageInsightsData) ReadField6

func (p *StorageInsightsData) ReadField6(iprot thrift.TProtocol) error

func (*StorageInsightsData) ReadField7

func (p *StorageInsightsData) ReadField7(iprot thrift.TProtocol) error

func (*StorageInsightsData) ReadField8

func (p *StorageInsightsData) ReadField8(iprot thrift.TProtocol) error

func (*StorageInsightsData) ReadField9

func (p *StorageInsightsData) ReadField9(iprot thrift.TProtocol) error

func (*StorageInsightsData) ReadField10

func (p *StorageInsightsData) ReadField10(iprot thrift.TProtocol) error

func (*StorageInsightsData) ReadField11

func (p *StorageInsightsData) ReadField11(iprot thrift.TProtocol) error

func (*StorageInsightsData) String

func (p *StorageInsightsData) String() string

func (*StorageInsightsData) Write

func (p *StorageInsightsData) Write(oprot thrift.TProtocol) (err error)

type StorageService

type StorageService interface {
	// GetStorageInfo 获取存储信息
	GetStorageInfo(ctx context.Context, req *GetStorageInfoReq) (r *GetStorageInfoResp, err error)
	// SwitchStorage 切换存储
	SwitchStorage(ctx context.Context, req *SwitchStorageReq) (r *SwitchStorageResp, err error)
	// MigrateStorage 存储迁移:把存量对象搬到目标后端(**全部复制成功后才切换**)
	MigrateStorage(ctx context.Context, req *MigrateStorageReq) (r *MigrateStorageResp, err error)
	// TestStorageConnection 测试存储连接
	TestStorageConnection(ctx context.Context, req *TestStorageConnectionReq) (r *TestStorageConnectionResp, err error)
	// UpdateStorageConfig 更新存储配置
	UpdateStorageConfig(ctx context.Context, req *UpdateStorageConfigReq) (r *UpdateStorageConfigResp, err error)
	// GetStorageInsights 存储洞察(双端用量/配额/今日流量/孤儿统计)
	GetStorageInsights(ctx context.Context, req *GetStorageInfoReq) (r *GetStorageInsightsResp, err error)
	// CleanPresignOrphans 清理远端 presign 孤儿对象(Init 后未 Complete 的直传残留)
	CleanPresignOrphans(ctx context.Context, req *GetStorageInfoReq) (r *CleanPresignOrphansResp, err error)
}

type StorageServiceCleanPresignOrphansArgs

type StorageServiceCleanPresignOrphansArgs struct {
	Req *GetStorageInfoReq `thrift:"req,1"`
}

func NewStorageServiceCleanPresignOrphansArgs

func NewStorageServiceCleanPresignOrphansArgs() *StorageServiceCleanPresignOrphansArgs

func (*StorageServiceCleanPresignOrphansArgs) GetReq

func (*StorageServiceCleanPresignOrphansArgs) InitDefault

func (p *StorageServiceCleanPresignOrphansArgs) InitDefault()

func (*StorageServiceCleanPresignOrphansArgs) IsSetReq

func (*StorageServiceCleanPresignOrphansArgs) Read

func (*StorageServiceCleanPresignOrphansArgs) ReadField1

func (*StorageServiceCleanPresignOrphansArgs) String

func (*StorageServiceCleanPresignOrphansArgs) Write

type StorageServiceCleanPresignOrphansResult

type StorageServiceCleanPresignOrphansResult struct {
	Success *CleanPresignOrphansResp `thrift:"success,0,optional"`
}

func NewStorageServiceCleanPresignOrphansResult

func NewStorageServiceCleanPresignOrphansResult() *StorageServiceCleanPresignOrphansResult

func (*StorageServiceCleanPresignOrphansResult) GetSuccess

func (*StorageServiceCleanPresignOrphansResult) InitDefault

func (p *StorageServiceCleanPresignOrphansResult) InitDefault()

func (*StorageServiceCleanPresignOrphansResult) IsSetSuccess

func (*StorageServiceCleanPresignOrphansResult) Read

func (*StorageServiceCleanPresignOrphansResult) ReadField0

func (*StorageServiceCleanPresignOrphansResult) String

func (*StorageServiceCleanPresignOrphansResult) Write

type StorageServiceClient

type StorageServiceClient struct {
	// contains filtered or unexported fields
}

func NewStorageServiceClient

func NewStorageServiceClient(c thrift.TClient) *StorageServiceClient

func NewStorageServiceClientProtocol

func NewStorageServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *StorageServiceClient

func (*StorageServiceClient) CleanPresignOrphans

func (p *StorageServiceClient) CleanPresignOrphans(ctx context.Context, req *GetStorageInfoReq) (r *CleanPresignOrphansResp, err error)

func (*StorageServiceClient) Client_

func (p *StorageServiceClient) Client_() thrift.TClient

func (*StorageServiceClient) GetStorageInfo

func (p *StorageServiceClient) GetStorageInfo(ctx context.Context, req *GetStorageInfoReq) (r *GetStorageInfoResp, err error)

func (*StorageServiceClient) GetStorageInsights

func (p *StorageServiceClient) GetStorageInsights(ctx context.Context, req *GetStorageInfoReq) (r *GetStorageInsightsResp, err error)

func (*StorageServiceClient) MigrateStorage added in v0.20.6

func (p *StorageServiceClient) MigrateStorage(ctx context.Context, req *MigrateStorageReq) (r *MigrateStorageResp, err error)

func (*StorageServiceClient) SwitchStorage

func (p *StorageServiceClient) SwitchStorage(ctx context.Context, req *SwitchStorageReq) (r *SwitchStorageResp, err error)

func (*StorageServiceClient) TestStorageConnection

func (p *StorageServiceClient) TestStorageConnection(ctx context.Context, req *TestStorageConnectionReq) (r *TestStorageConnectionResp, err error)

func (*StorageServiceClient) UpdateStorageConfig

func (p *StorageServiceClient) UpdateStorageConfig(ctx context.Context, req *UpdateStorageConfigReq) (r *UpdateStorageConfigResp, err error)

type StorageServiceGetStorageInfoArgs

type StorageServiceGetStorageInfoArgs struct {
	Req *GetStorageInfoReq `thrift:"req,1"`
}

func NewStorageServiceGetStorageInfoArgs

func NewStorageServiceGetStorageInfoArgs() *StorageServiceGetStorageInfoArgs

func (*StorageServiceGetStorageInfoArgs) GetReq

func (*StorageServiceGetStorageInfoArgs) InitDefault

func (p *StorageServiceGetStorageInfoArgs) InitDefault()

func (*StorageServiceGetStorageInfoArgs) IsSetReq

func (p *StorageServiceGetStorageInfoArgs) IsSetReq() bool

func (*StorageServiceGetStorageInfoArgs) Read

func (*StorageServiceGetStorageInfoArgs) ReadField1

func (*StorageServiceGetStorageInfoArgs) String

func (*StorageServiceGetStorageInfoArgs) Write

type StorageServiceGetStorageInfoResult

type StorageServiceGetStorageInfoResult struct {
	Success *GetStorageInfoResp `thrift:"success,0,optional"`
}

func NewStorageServiceGetStorageInfoResult

func NewStorageServiceGetStorageInfoResult() *StorageServiceGetStorageInfoResult

func (*StorageServiceGetStorageInfoResult) GetSuccess

func (*StorageServiceGetStorageInfoResult) InitDefault

func (p *StorageServiceGetStorageInfoResult) InitDefault()

func (*StorageServiceGetStorageInfoResult) IsSetSuccess

func (p *StorageServiceGetStorageInfoResult) IsSetSuccess() bool

func (*StorageServiceGetStorageInfoResult) Read

func (*StorageServiceGetStorageInfoResult) ReadField0

func (*StorageServiceGetStorageInfoResult) String

func (*StorageServiceGetStorageInfoResult) Write

type StorageServiceGetStorageInsightsArgs

type StorageServiceGetStorageInsightsArgs struct {
	Req *GetStorageInfoReq `thrift:"req,1"`
}

func NewStorageServiceGetStorageInsightsArgs

func NewStorageServiceGetStorageInsightsArgs() *StorageServiceGetStorageInsightsArgs

func (*StorageServiceGetStorageInsightsArgs) GetReq

func (*StorageServiceGetStorageInsightsArgs) InitDefault

func (p *StorageServiceGetStorageInsightsArgs) InitDefault()

func (*StorageServiceGetStorageInsightsArgs) IsSetReq

func (*StorageServiceGetStorageInsightsArgs) Read

func (*StorageServiceGetStorageInsightsArgs) ReadField1

func (*StorageServiceGetStorageInsightsArgs) String

func (*StorageServiceGetStorageInsightsArgs) Write

type StorageServiceGetStorageInsightsResult

type StorageServiceGetStorageInsightsResult struct {
	Success *GetStorageInsightsResp `thrift:"success,0,optional"`
}

func NewStorageServiceGetStorageInsightsResult

func NewStorageServiceGetStorageInsightsResult() *StorageServiceGetStorageInsightsResult

func (*StorageServiceGetStorageInsightsResult) GetSuccess

func (*StorageServiceGetStorageInsightsResult) InitDefault

func (p *StorageServiceGetStorageInsightsResult) InitDefault()

func (*StorageServiceGetStorageInsightsResult) IsSetSuccess

func (p *StorageServiceGetStorageInsightsResult) IsSetSuccess() bool

func (*StorageServiceGetStorageInsightsResult) Read

func (*StorageServiceGetStorageInsightsResult) ReadField0

func (*StorageServiceGetStorageInsightsResult) String

func (*StorageServiceGetStorageInsightsResult) Write

type StorageServiceMigrateStorageArgs added in v0.20.6

type StorageServiceMigrateStorageArgs struct {
	Req *MigrateStorageReq `thrift:"req,1"`
}

func NewStorageServiceMigrateStorageArgs added in v0.20.6

func NewStorageServiceMigrateStorageArgs() *StorageServiceMigrateStorageArgs

func (*StorageServiceMigrateStorageArgs) GetReq added in v0.20.6

func (*StorageServiceMigrateStorageArgs) InitDefault added in v0.20.6

func (p *StorageServiceMigrateStorageArgs) InitDefault()

func (*StorageServiceMigrateStorageArgs) IsSetReq added in v0.20.6

func (p *StorageServiceMigrateStorageArgs) IsSetReq() bool

func (*StorageServiceMigrateStorageArgs) Read added in v0.20.6

func (*StorageServiceMigrateStorageArgs) ReadField1 added in v0.20.6

func (*StorageServiceMigrateStorageArgs) String added in v0.20.6

func (*StorageServiceMigrateStorageArgs) Write added in v0.20.6

type StorageServiceMigrateStorageResult added in v0.20.6

type StorageServiceMigrateStorageResult struct {
	Success *MigrateStorageResp `thrift:"success,0,optional"`
}

func NewStorageServiceMigrateStorageResult added in v0.20.6

func NewStorageServiceMigrateStorageResult() *StorageServiceMigrateStorageResult

func (*StorageServiceMigrateStorageResult) GetSuccess added in v0.20.6

func (*StorageServiceMigrateStorageResult) InitDefault added in v0.20.6

func (p *StorageServiceMigrateStorageResult) InitDefault()

func (*StorageServiceMigrateStorageResult) IsSetSuccess added in v0.20.6

func (p *StorageServiceMigrateStorageResult) IsSetSuccess() bool

func (*StorageServiceMigrateStorageResult) Read added in v0.20.6

func (*StorageServiceMigrateStorageResult) ReadField0 added in v0.20.6

func (*StorageServiceMigrateStorageResult) String added in v0.20.6

func (*StorageServiceMigrateStorageResult) Write added in v0.20.6

type StorageServiceProcessor

type StorageServiceProcessor struct {
	// contains filtered or unexported fields
}

func NewStorageServiceProcessor

func NewStorageServiceProcessor(handler StorageService) *StorageServiceProcessor

func (*StorageServiceProcessor) AddToProcessorMap

func (p *StorageServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*StorageServiceProcessor) GetProcessorFunction

func (p *StorageServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*StorageServiceProcessor) Process

func (p *StorageServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*StorageServiceProcessor) ProcessorMap

type StorageServiceSwitchStorageArgs

type StorageServiceSwitchStorageArgs struct {
	Req *SwitchStorageReq `thrift:"req,1"`
}

func NewStorageServiceSwitchStorageArgs

func NewStorageServiceSwitchStorageArgs() *StorageServiceSwitchStorageArgs

func (*StorageServiceSwitchStorageArgs) GetReq

func (*StorageServiceSwitchStorageArgs) InitDefault

func (p *StorageServiceSwitchStorageArgs) InitDefault()

func (*StorageServiceSwitchStorageArgs) IsSetReq

func (p *StorageServiceSwitchStorageArgs) IsSetReq() bool

func (*StorageServiceSwitchStorageArgs) Read

func (*StorageServiceSwitchStorageArgs) ReadField1

func (*StorageServiceSwitchStorageArgs) String

func (*StorageServiceSwitchStorageArgs) Write

func (p *StorageServiceSwitchStorageArgs) Write(oprot thrift.TProtocol) (err error)

type StorageServiceSwitchStorageResult

type StorageServiceSwitchStorageResult struct {
	Success *SwitchStorageResp `thrift:"success,0,optional"`
}

func NewStorageServiceSwitchStorageResult

func NewStorageServiceSwitchStorageResult() *StorageServiceSwitchStorageResult

func (*StorageServiceSwitchStorageResult) GetSuccess

func (*StorageServiceSwitchStorageResult) InitDefault

func (p *StorageServiceSwitchStorageResult) InitDefault()

func (*StorageServiceSwitchStorageResult) IsSetSuccess

func (p *StorageServiceSwitchStorageResult) IsSetSuccess() bool

func (*StorageServiceSwitchStorageResult) Read

func (*StorageServiceSwitchStorageResult) ReadField0

func (*StorageServiceSwitchStorageResult) String

func (*StorageServiceSwitchStorageResult) Write

type StorageServiceTestStorageConnectionArgs

type StorageServiceTestStorageConnectionArgs struct {
	Req *TestStorageConnectionReq `thrift:"req,1"`
}

func NewStorageServiceTestStorageConnectionArgs

func NewStorageServiceTestStorageConnectionArgs() *StorageServiceTestStorageConnectionArgs

func (*StorageServiceTestStorageConnectionArgs) GetReq

func (*StorageServiceTestStorageConnectionArgs) InitDefault

func (p *StorageServiceTestStorageConnectionArgs) InitDefault()

func (*StorageServiceTestStorageConnectionArgs) IsSetReq

func (*StorageServiceTestStorageConnectionArgs) Read

func (*StorageServiceTestStorageConnectionArgs) ReadField1

func (*StorageServiceTestStorageConnectionArgs) String

func (*StorageServiceTestStorageConnectionArgs) Write

type StorageServiceTestStorageConnectionResult

type StorageServiceTestStorageConnectionResult struct {
	Success *TestStorageConnectionResp `thrift:"success,0,optional"`
}

func NewStorageServiceTestStorageConnectionResult

func NewStorageServiceTestStorageConnectionResult() *StorageServiceTestStorageConnectionResult

func (*StorageServiceTestStorageConnectionResult) GetSuccess

func (*StorageServiceTestStorageConnectionResult) InitDefault

func (*StorageServiceTestStorageConnectionResult) IsSetSuccess

func (*StorageServiceTestStorageConnectionResult) Read

func (*StorageServiceTestStorageConnectionResult) ReadField0

func (*StorageServiceTestStorageConnectionResult) String

func (*StorageServiceTestStorageConnectionResult) Write

type StorageServiceUpdateStorageConfigArgs

type StorageServiceUpdateStorageConfigArgs struct {
	Req *UpdateStorageConfigReq `thrift:"req,1"`
}

func NewStorageServiceUpdateStorageConfigArgs

func NewStorageServiceUpdateStorageConfigArgs() *StorageServiceUpdateStorageConfigArgs

func (*StorageServiceUpdateStorageConfigArgs) GetReq

func (*StorageServiceUpdateStorageConfigArgs) InitDefault

func (p *StorageServiceUpdateStorageConfigArgs) InitDefault()

func (*StorageServiceUpdateStorageConfigArgs) IsSetReq

func (*StorageServiceUpdateStorageConfigArgs) Read

func (*StorageServiceUpdateStorageConfigArgs) ReadField1

func (*StorageServiceUpdateStorageConfigArgs) String

func (*StorageServiceUpdateStorageConfigArgs) Write

type StorageServiceUpdateStorageConfigResult

type StorageServiceUpdateStorageConfigResult struct {
	Success *UpdateStorageConfigResp `thrift:"success,0,optional"`
}

func NewStorageServiceUpdateStorageConfigResult

func NewStorageServiceUpdateStorageConfigResult() *StorageServiceUpdateStorageConfigResult

func (*StorageServiceUpdateStorageConfigResult) GetSuccess

func (*StorageServiceUpdateStorageConfigResult) InitDefault

func (p *StorageServiceUpdateStorageConfigResult) InitDefault()

func (*StorageServiceUpdateStorageConfigResult) IsSetSuccess

func (*StorageServiceUpdateStorageConfigResult) Read

func (*StorageServiceUpdateStorageConfigResult) ReadField0

func (*StorageServiceUpdateStorageConfigResult) String

func (*StorageServiceUpdateStorageConfigResult) Write

type StorageUsage

type StorageUsage struct {
	ObjectCount int64  `thrift:"object_count,1,required" form:"object_count,required" json:"object_count,required"`
	TotalSize   int64  `thrift:"total_size,2,required" form:"total_size,required" json:"total_size,required"`
	QuotaUsed   *int64 `thrift:"quota_used,3,optional" form:"quota_used" json:"quota_used,omitempty"`
}

==================== 服务定义 ====================

var StorageBackendStatus_Usage_DEFAULT *StorageUsage
var StorageInsightsData_LocalUsage_DEFAULT *StorageUsage
var StorageInsightsData_RemoteUsage_DEFAULT *StorageUsage

func NewStorageUsage

func NewStorageUsage() *StorageUsage

func (*StorageUsage) GetObjectCount

func (p *StorageUsage) GetObjectCount() (v int64)

func (*StorageUsage) GetQuotaUsed

func (p *StorageUsage) GetQuotaUsed() (v int64)

func (*StorageUsage) GetTotalSize

func (p *StorageUsage) GetTotalSize() (v int64)

func (*StorageUsage) InitDefault

func (p *StorageUsage) InitDefault()

func (*StorageUsage) IsSetQuotaUsed

func (p *StorageUsage) IsSetQuotaUsed() bool

func (*StorageUsage) Read

func (p *StorageUsage) Read(iprot thrift.TProtocol) (err error)

func (*StorageUsage) ReadField1

func (p *StorageUsage) ReadField1(iprot thrift.TProtocol) error

func (*StorageUsage) ReadField2

func (p *StorageUsage) ReadField2(iprot thrift.TProtocol) error

func (*StorageUsage) ReadField3

func (p *StorageUsage) ReadField3(iprot thrift.TProtocol) error

func (*StorageUsage) String

func (p *StorageUsage) String() string

func (*StorageUsage) Write

func (p *StorageUsage) Write(oprot thrift.TProtocol) (err error)

type SwitchStorageData

type SwitchStorageData struct {
	Success     bool   `thrift:"success,1,required" form:"success,required" json:"success,required"`
	Message     string `thrift:"message,2,required" form:"message,required" json:"message,required"`
	CurrentType string `thrift:"current_type,3,required" form:"current_type,required" json:"current_type,required"`
}
var SwitchStorageResp_Data_DEFAULT *SwitchStorageData

func NewSwitchStorageData

func NewSwitchStorageData() *SwitchStorageData

func (*SwitchStorageData) GetCurrentType

func (p *SwitchStorageData) GetCurrentType() (v string)

func (*SwitchStorageData) GetMessage

func (p *SwitchStorageData) GetMessage() (v string)

func (*SwitchStorageData) GetSuccess

func (p *SwitchStorageData) GetSuccess() (v bool)

func (*SwitchStorageData) InitDefault

func (p *SwitchStorageData) InitDefault()

func (*SwitchStorageData) Read

func (p *SwitchStorageData) Read(iprot thrift.TProtocol) (err error)

func (*SwitchStorageData) ReadField1

func (p *SwitchStorageData) ReadField1(iprot thrift.TProtocol) error

func (*SwitchStorageData) ReadField2

func (p *SwitchStorageData) ReadField2(iprot thrift.TProtocol) error

func (*SwitchStorageData) ReadField3

func (p *SwitchStorageData) ReadField3(iprot thrift.TProtocol) error

func (*SwitchStorageData) String

func (p *SwitchStorageData) String() string

func (*SwitchStorageData) Write

func (p *SwitchStorageData) Write(oprot thrift.TProtocol) (err error)

type SwitchStorageReq

type SwitchStorageReq struct {
	Type string `thrift:"type,1,required" form:"type,required" json:"type,required"`
}

==================== 切换存储 ====================

var StorageServiceSwitchStorageArgs_Req_DEFAULT *SwitchStorageReq

func NewSwitchStorageReq

func NewSwitchStorageReq() *SwitchStorageReq

func (*SwitchStorageReq) GetType

func (p *SwitchStorageReq) GetType() (v string)

func (*SwitchStorageReq) InitDefault

func (p *SwitchStorageReq) InitDefault()

func (*SwitchStorageReq) Read

func (p *SwitchStorageReq) Read(iprot thrift.TProtocol) (err error)

func (*SwitchStorageReq) ReadField1

func (p *SwitchStorageReq) ReadField1(iprot thrift.TProtocol) error

func (*SwitchStorageReq) String

func (p *SwitchStorageReq) String() string

func (*SwitchStorageReq) Write

func (p *SwitchStorageReq) Write(oprot thrift.TProtocol) (err error)

type SwitchStorageResp

type SwitchStorageResp struct {
	Code    int32              `thrift:"code,1,required" form:"code,required" json:"code,required"`
	Message string             `thrift:"message,2,required" form:"message,required" json:"message,required"`
	Data    *SwitchStorageData `thrift:"data,3,required" form:"data,required" json:"data,required"`
}
var StorageServiceSwitchStorageResult_Success_DEFAULT *SwitchStorageResp

func NewSwitchStorageResp

func NewSwitchStorageResp() *SwitchStorageResp

func (*SwitchStorageResp) GetCode

func (p *SwitchStorageResp) GetCode() (v int32)

func (*SwitchStorageResp) GetData

func (p *SwitchStorageResp) GetData() (v *SwitchStorageData)

func (*SwitchStorageResp) GetMessage

func (p *SwitchStorageResp) GetMessage() (v string)

func (*SwitchStorageResp) InitDefault

func (p *SwitchStorageResp) InitDefault()

func (*SwitchStorageResp) IsSetData

func (p *SwitchStorageResp) IsSetData() bool

func (*SwitchStorageResp) Read

func (p *SwitchStorageResp) Read(iprot thrift.TProtocol) (err error)

func (*SwitchStorageResp) ReadField1

func (p *SwitchStorageResp) ReadField1(iprot thrift.TProtocol) error

func (*SwitchStorageResp) ReadField2

func (p *SwitchStorageResp) ReadField2(iprot thrift.TProtocol) error

func (*SwitchStorageResp) ReadField3

func (p *SwitchStorageResp) ReadField3(iprot thrift.TProtocol) error

func (*SwitchStorageResp) String

func (p *SwitchStorageResp) String() string

func (*SwitchStorageResp) Write

func (p *SwitchStorageResp) Write(oprot thrift.TProtocol) (err error)

type TestStorageConnectionReq

type TestStorageConnectionReq struct {
	Type string `thrift:"type,1,required" json:"type,required" path:"type,required"`
}

==================== 测试存储连接 ====================

var StorageServiceTestStorageConnectionArgs_Req_DEFAULT *TestStorageConnectionReq

func NewTestStorageConnectionReq

func NewTestStorageConnectionReq() *TestStorageConnectionReq

func (*TestStorageConnectionReq) GetType

func (p *TestStorageConnectionReq) GetType() (v string)

func (*TestStorageConnectionReq) InitDefault

func (p *TestStorageConnectionReq) InitDefault()

func (*TestStorageConnectionReq) Read

func (p *TestStorageConnectionReq) Read(iprot thrift.TProtocol) (err error)

func (*TestStorageConnectionReq) ReadField1

func (p *TestStorageConnectionReq) ReadField1(iprot thrift.TProtocol) error

func (*TestStorageConnectionReq) String

func (p *TestStorageConnectionReq) String() string

func (*TestStorageConnectionReq) Write

func (p *TestStorageConnectionReq) Write(oprot thrift.TProtocol) (err error)

type TestStorageConnectionResp

type TestStorageConnectionResp struct {
	Code    int32            `thrift:"code,1,required" form:"code,required" json:"code,required"`
	Message string           `thrift:"message,2,required" form:"message,required" json:"message,required"`
	Data    *TestStorageData `thrift:"data,3,required" form:"data,required" json:"data,required"`
}
var StorageServiceTestStorageConnectionResult_Success_DEFAULT *TestStorageConnectionResp

func NewTestStorageConnectionResp

func NewTestStorageConnectionResp() *TestStorageConnectionResp

func (*TestStorageConnectionResp) GetCode

func (p *TestStorageConnectionResp) GetCode() (v int32)

func (*TestStorageConnectionResp) GetData

func (p *TestStorageConnectionResp) GetData() (v *TestStorageData)

func (*TestStorageConnectionResp) GetMessage

func (p *TestStorageConnectionResp) GetMessage() (v string)

func (*TestStorageConnectionResp) InitDefault

func (p *TestStorageConnectionResp) InitDefault()

func (*TestStorageConnectionResp) IsSetData

func (p *TestStorageConnectionResp) IsSetData() bool

func (*TestStorageConnectionResp) Read

func (p *TestStorageConnectionResp) Read(iprot thrift.TProtocol) (err error)

func (*TestStorageConnectionResp) ReadField1

func (p *TestStorageConnectionResp) ReadField1(iprot thrift.TProtocol) error

func (*TestStorageConnectionResp) ReadField2

func (p *TestStorageConnectionResp) ReadField2(iprot thrift.TProtocol) error

func (*TestStorageConnectionResp) ReadField3

func (p *TestStorageConnectionResp) ReadField3(iprot thrift.TProtocol) error

func (*TestStorageConnectionResp) String

func (p *TestStorageConnectionResp) String() string

func (*TestStorageConnectionResp) Write

func (p *TestStorageConnectionResp) Write(oprot thrift.TProtocol) (err error)

type TestStorageData

type TestStorageData struct {
	Type   string `thrift:"type,1,required" form:"type,required" json:"type,required"`
	Status string `thrift:"status,2,required" form:"status,required" json:"status,required"`
}
var TestStorageConnectionResp_Data_DEFAULT *TestStorageData

func NewTestStorageData

func NewTestStorageData() *TestStorageData

func (*TestStorageData) GetStatus

func (p *TestStorageData) GetStatus() (v string)

func (*TestStorageData) GetType

func (p *TestStorageData) GetType() (v string)

func (*TestStorageData) InitDefault

func (p *TestStorageData) InitDefault()

func (*TestStorageData) Read

func (p *TestStorageData) Read(iprot thrift.TProtocol) (err error)

func (*TestStorageData) ReadField1

func (p *TestStorageData) ReadField1(iprot thrift.TProtocol) error

func (*TestStorageData) ReadField2

func (p *TestStorageData) ReadField2(iprot thrift.TProtocol) error

func (*TestStorageData) String

func (p *TestStorageData) String() string

func (*TestStorageData) Write

func (p *TestStorageData) Write(oprot thrift.TProtocol) (err error)

type TodayTraffic

type TodayTraffic struct {
	Uploads   int64 `thrift:"uploads,1,required" form:"uploads,required" json:"uploads,required"`
	Downloads int64 `thrift:"downloads,2,required" form:"downloads,required" json:"downloads,required"`
}
var StorageInsightsData_TodayTraffic_DEFAULT *TodayTraffic

func NewTodayTraffic

func NewTodayTraffic() *TodayTraffic

func (*TodayTraffic) GetDownloads

func (p *TodayTraffic) GetDownloads() (v int64)

func (*TodayTraffic) GetUploads

func (p *TodayTraffic) GetUploads() (v int64)

func (*TodayTraffic) InitDefault

func (p *TodayTraffic) InitDefault()

func (*TodayTraffic) Read

func (p *TodayTraffic) Read(iprot thrift.TProtocol) (err error)

func (*TodayTraffic) ReadField1

func (p *TodayTraffic) ReadField1(iprot thrift.TProtocol) error

func (*TodayTraffic) ReadField2

func (p *TodayTraffic) ReadField2(iprot thrift.TProtocol) error

func (*TodayTraffic) String

func (p *TodayTraffic) String() string

func (*TodayTraffic) Write

func (p *TodayTraffic) Write(oprot thrift.TProtocol) (err error)

type UpdateStorageConfigReq

type UpdateStorageConfigReq struct {
}

==================== 更新存储配置 ==================== 更新存储配置的请求体。

形态:**只有**扁平一种——请求体即 conf.StorageConfig 同构 JSON (type/storage_path/quota/s3/webdav/ftp/sftp/azureblob/hdfs/onedrive/oss..obs), 服务端整体校验 → Probe → 热切换 → 持久化。

旧嵌套形态 {type, config:{storage_path/webdav/s3}} **已退役**(2026-10-25 删除旧版本 兼容):它只能切 local/webdav/s3 三种、字段名与实际配置模型对不上(旧契约遗留)。

字段随厂商增长 ⇒ 沿用本仓「松散体」惯例(见 admin.thrift 的 AdminUpdateConfigReq): 结构体只作**声明面**,body 的实际字段由 conf.StorageConfig 决定。

var StorageServiceUpdateStorageConfigArgs_Req_DEFAULT *UpdateStorageConfigReq

func NewUpdateStorageConfigReq

func NewUpdateStorageConfigReq() *UpdateStorageConfigReq

func (*UpdateStorageConfigReq) InitDefault

func (p *UpdateStorageConfigReq) InitDefault()

func (*UpdateStorageConfigReq) Read

func (p *UpdateStorageConfigReq) Read(iprot thrift.TProtocol) (err error)

func (*UpdateStorageConfigReq) String

func (p *UpdateStorageConfigReq) String() string

func (*UpdateStorageConfigReq) Write

func (p *UpdateStorageConfigReq) Write(oprot thrift.TProtocol) (err error)

type UpdateStorageConfigResp

type UpdateStorageConfigResp struct {
	Code    int32  `thrift:"code,1,required" form:"code,required" json:"code,required"`
	Message string `thrift:"message,2,required" form:"message,required" json:"message,required"`
}
var StorageServiceUpdateStorageConfigResult_Success_DEFAULT *UpdateStorageConfigResp

func NewUpdateStorageConfigResp

func NewUpdateStorageConfigResp() *UpdateStorageConfigResp

func (*UpdateStorageConfigResp) GetCode

func (p *UpdateStorageConfigResp) GetCode() (v int32)

func (*UpdateStorageConfigResp) GetMessage

func (p *UpdateStorageConfigResp) GetMessage() (v string)

func (*UpdateStorageConfigResp) InitDefault

func (p *UpdateStorageConfigResp) InitDefault()

func (*UpdateStorageConfigResp) Read

func (p *UpdateStorageConfigResp) Read(iprot thrift.TProtocol) (err error)

func (*UpdateStorageConfigResp) ReadField1

func (p *UpdateStorageConfigResp) ReadField1(iprot thrift.TProtocol) error

func (*UpdateStorageConfigResp) ReadField2

func (p *UpdateStorageConfigResp) ReadField2(iprot thrift.TProtocol) error

func (*UpdateStorageConfigResp) String

func (p *UpdateStorageConfigResp) String() string

func (*UpdateStorageConfigResp) Write

func (p *UpdateStorageConfigResp) Write(oprot thrift.TProtocol) (err error)

type WebDAVConfig

type WebDAVConfig struct {
	Hostname string `thrift:"hostname,1,required" form:"hostname,required" json:"hostname,required"`
	Username string `thrift:"username,2,required" form:"username,required" json:"username,required"`
	Password string `thrift:"password,3,required" form:"password,required" json:"password,required"`
	RootPath string `thrift:"root_path,4,required" form:"root_path,required" json:"root_path,required"`
	URL      string `thrift:"url,5,required" form:"url,required" json:"url,required"`
}

==================== 存储详情 ====================

var StorageConfig_Webdav_DEFAULT *WebDAVConfig

func NewWebDAVConfig

func NewWebDAVConfig() *WebDAVConfig

func (*WebDAVConfig) GetHostname

func (p *WebDAVConfig) GetHostname() (v string)

func (*WebDAVConfig) GetPassword

func (p *WebDAVConfig) GetPassword() (v string)

func (*WebDAVConfig) GetRootPath

func (p *WebDAVConfig) GetRootPath() (v string)

func (*WebDAVConfig) GetURL

func (p *WebDAVConfig) GetURL() (v string)

func (*WebDAVConfig) GetUsername

func (p *WebDAVConfig) GetUsername() (v string)

func (*WebDAVConfig) InitDefault

func (p *WebDAVConfig) InitDefault()

func (*WebDAVConfig) Read

func (p *WebDAVConfig) Read(iprot thrift.TProtocol) (err error)

func (*WebDAVConfig) ReadField1

func (p *WebDAVConfig) ReadField1(iprot thrift.TProtocol) error

func (*WebDAVConfig) ReadField2

func (p *WebDAVConfig) ReadField2(iprot thrift.TProtocol) error

func (*WebDAVConfig) ReadField3

func (p *WebDAVConfig) ReadField3(iprot thrift.TProtocol) error

func (*WebDAVConfig) ReadField4

func (p *WebDAVConfig) ReadField4(iprot thrift.TProtocol) error

func (*WebDAVConfig) ReadField5

func (p *WebDAVConfig) ReadField5(iprot thrift.TProtocol) error

func (*WebDAVConfig) String

func (p *WebDAVConfig) String() string

func (*WebDAVConfig) Write

func (p *WebDAVConfig) Write(oprot thrift.TProtocol) (err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL