Versions in this module Expand all Collapse all v1 v1.3.19 Jun 6, 2023 v1.3.18 Jun 6, 2023 Changes in this version + func AbortDSort(bp BaseParams, managerUUID string) error + func AbortDownload(bp BaseParams, id string) error + func AbortXaction(bp BaseParams, args xact.ArgsMsg) (err error) + func AccessAttrs(v apc.AccessAttrs) *apc.AccessAttrs + func AppendObject(args AppendArgs) (string, error) + func ArchiveMultiObj(bp BaseParams, bckFrom cmn.Bck, msg cmn.ArchiveBckMsg) (string, error) + func AttachMountpath(bp BaseParams, node *meta.Snode, mountpath string, force bool) error + func AttachRemoteAIS(bp BaseParams, alias, u string) error + func Bool(v bool) *bool + func CopyBucket(bp BaseParams, bckFrom, bckTo cmn.Bck, msg *apc.CopyBckMsg, fltPresence ...int) (xid string, err error) + func CopyMultiObj(bp BaseParams, bckFrom cmn.Bck, msg cmn.TCObjsMsg, fltPresence ...int) (xid string, err error) + func CreateBucket(bp BaseParams, bck cmn.Bck, props *cmn.BucketPropsToUpdate) error + func DecommissionCluster(bp BaseParams, rmUserData bool) error + func DecommissionNode(bp BaseParams, actValue *apc.ActValRmNode) (xid string, err error) + func DeleteList(bp BaseParams, bck cmn.Bck, filesList []string) (string, error) + func DeleteObject(bp BaseParams, bck cmn.Bck, object string) error + func DeleteRange(bp BaseParams, bck cmn.Bck, rng string) (string, error) + func DestroyBucket(bp BaseParams, bck cmn.Bck) error + func DetachMountpath(bp BaseParams, node *meta.Snode, mountpath string, dontResilver bool) error + func DetachRemoteAIS(bp BaseParams, alias string) error + func DisableMountpath(bp BaseParams, node *meta.Snode, mountpath string, dontResilver bool) error + func DoWithRetry(client *http.Client, cb NewRequestCB, reqArgs *cmn.HreqArgs) (resp *http.Response, err error) + func DownloadBackend(bp BaseParams, descr string, bck cmn.Bck, prefix, suffix string, ...) (string, error) + func DownloadGetList(bp BaseParams, regex string, onlyActive bool) (dlList dload.JobInfos, err error) + func DownloadMulti(bp BaseParams, description string, bck cmn.Bck, msg any, ...) (string, error) + func DownloadRange(bp BaseParams, description string, bck cmn.Bck, template string, ...) (string, error) + func DownloadSingle(bp BaseParams, description string, bck cmn.Bck, objName, link string, ...) (string, error) + func DownloadStatus(bp BaseParams, id string, onlyActive bool) (dlStatus *dload.StatusResp, err error) + func DownloadWithParam(bp BaseParams, dlt dload.Type, body any) (id string, err error) + func Duration(v time.Duration) *time.Duration + func ECEncodeBucket(bp BaseParams, bck cmn.Bck, data, parity int) (xid string, err error) + func ETLBucket(bp BaseParams, bckFrom, bckTo cmn.Bck, msg *apc.TCBMsg, fltPresence ...int) (xid string, err error) + func ETLDelete(bp BaseParams, etlName string) (err error) + func ETLGetInitMsg(params BaseParams, etlName string) (etl.InitMsg, error) + func ETLHealth(params BaseParams, etlName string) (healths etl.HealthByTarget, err error) + func ETLInit(bp BaseParams, msg etl.InitMsg) (xid string, err error) + func ETLList(bp BaseParams) (list []etl.Info, err error) + func ETLLogs(bp BaseParams, etlName string, targetID ...string) (logs etl.LogsByTarget, err error) + func ETLMetrics(params BaseParams, etlName string) (healths etl.CPUMemByTarget, err error) + func ETLMultiObj(bp BaseParams, bckFrom cmn.Bck, msg cmn.TCObjsMsg, fltPresence ...int) (xid string, err error) + func ETLObject(bp BaseParams, etlName string, bck cmn.Bck, objName string, w io.Writer) (err error) + func ETLStart(bp BaseParams, etlName string) (err error) + func ETLStop(bp BaseParams, etlName string) (err error) + func EnableMountpath(bp BaseParams, node *meta.Snode, mountpath string) error + func EvictList(bp BaseParams, bck cmn.Bck, fileslist []string) (string, error) + func EvictObject(bp BaseParams, bck cmn.Bck, object string) error + func EvictRange(bp BaseParams, bck cmn.Bck, rng string) (string, error) + func EvictRemoteBucket(bp BaseParams, bck cmn.Bck, keepMD bool) error + func FlushObject(args FlushArgs) error + func FreeRp(reqParams *ReqParams) + func GetAllRunningXactions(bp BaseParams, kindOrName string) (out []string, err error) + func GetAllXactionStatus(bp BaseParams, args xact.ArgsMsg, force bool) (matching nl.StatusVec, err error) + func GetBMD(bp BaseParams) (*meta.BMD, error) + func GetBucketInfo(bp BaseParams, bck cmn.Bck, fltPresence int) (p *cmn.BucketProps, info *cmn.BsummResult, err error) + func GetBucketSummary(bp BaseParams, qbck cmn.QueryBcks, msg *apc.BsummCtrlMsg) (cmn.AllBsummResults, error) + func GetClusterConfig(bp BaseParams) (*cmn.ClusterConfig, error) + func GetClusterMap(bp BaseParams) (smap *meta.Smap, err error) + func GetClusterStats(bp BaseParams) (res stats.Cluster, err error) + func GetClusterSysInfo(bp BaseParams) (info apc.ClusterSysInfo, err error) + func GetDaemonConfig(bp BaseParams, node *meta.Snode) (config *cmn.Config, err error) + func GetDaemonLog(bp BaseParams, node *meta.Snode, args GetLogInput) (int64, error) + func GetDaemonStats(bp BaseParams, node *meta.Snode) (ds *stats.Node, err error) + func GetDiskStats(bp BaseParams, tid string) (res ios.AllDiskStats, err error) + func GetMetricNames(bp BaseParams, node *meta.Snode) (kvs cos.StrKVs, err error) + func GetMountpaths(bp BaseParams, node *meta.Snode) (mpl *apc.MountpathList, err error) + func GetNodeClusterMap(bp BaseParams, sid string) (smap *meta.Smap, err error) + func GetObjectReader(bp BaseParams, bck cmn.Bck, object string, args *GetArgs) (r io.ReadCloser, err error) + func GetObjectS3(bp BaseParams, bck cmn.Bck, objectName string, args ...GetArgs) (int64, error) + func GetOneXactionStatus(bp BaseParams, args xact.ArgsMsg) (status *nl.Status, err error) + func GetProxyReadiness(bp BaseParams) error + func GetRemoteAIS(bp BaseParams) (remais cluster.Remotes, err error) + func GetStatsAndStatus(bp BaseParams, node *meta.Snode) (daeStatus *stats.NodeStatus, err error) + func GetWhatRawQuery(getWhat, getProps string) string + func HTTPStatus(err error) int + func HeadBucket(bp BaseParams, bck cmn.Bck, dontAddRemote bool) (p *cmn.BucketProps, err error) + func HeadObject(bp BaseParams, bck cmn.Bck, object string, fltPresence int) (*cmn.ObjectProps, error) + func Health(bp BaseParams, readyToRebalance ...bool) error + func HealthUptime(bp BaseParams, readyToRebalance ...bool) (string, string, error) + func Int(v int) *int + func Int64(v int64) *int64 + func JoinCluster(bp BaseParams, nodeInfo *meta.Snode) (rebID, sid string, err error) + func ListBuckets(bp BaseParams, qbck cmn.QueryBcks, fltPresence int) (cmn.Bcks, error) + func ListDSort(bp BaseParams, regex string, onlyActive bool) (jobInfos []*dsort.JobInfo, err error) + func ListObjects(bp BaseParams, bck cmn.Bck, lsmsg *apc.LsoMsg, numObj uint) (*cmn.LsoResult, error) + func ListObjectsInvalidateCache(bp BaseParams, bck cmn.Bck) error + func ListObjectsPage(bp BaseParams, bck cmn.Bck, lsmsg *apc.LsoMsg) (*cmn.LsoResult, error) + func ListObjectsWithOpts(bp BaseParams, bck cmn.Bck, lsmsg *apc.LsoMsg, numObj uint, ...) (*cmn.LsoResult, error) + func MakeNCopies(bp BaseParams, bck cmn.Bck, copies int) (xid string, err error) + func MetricsDSort(bp BaseParams, managerUUID string) (metrics map[string]*dsort.Metrics, err error) + func PrefetchList(bp BaseParams, bck cmn.Bck, fileslist []string) (string, error) + func PrefetchRange(bp BaseParams, bck cmn.Bck, rng string) (string, error) + func Promote(args *PromoteArgs) (xid string, err error) + func PutApndArch(args PutApndArchArgs) (err error) + func QueryBuckets(bp BaseParams, qbck cmn.QueryBcks, fltPresence int) (bool, error) + func QueryXactionSnaps(bp BaseParams, args xact.ArgsMsg) (xs xact.MultiSnap, err error) + func RemoveDSort(bp BaseParams, managerUUID string) error + func RemoveDownload(bp BaseParams, id string) error + func RemoveNodeUnsafe(bp BaseParams, sid string) error + func RenameBucket(bp BaseParams, bckFrom, bckTo cmn.Bck) (xid string, err error) + func RenameObject(bp BaseParams, bck cmn.Bck, oldName, newName string) error + func ResetBucketProps(bp BaseParams, bck cmn.Bck) (string, error) + func ResetClusterConfig(bp BaseParams) error + func ResetClusterStats(bp BaseParams, errorsOnly bool) (err error) + func ResetDaemonConfig(bp BaseParams, nodeID string) error + func ResetDaemonStats(bp BaseParams, node *meta.Snode, errorsOnly bool) (err error) + func SetAuxHeaders(r *http.Request, bp *BaseParams) + func SetBucketProps(bp BaseParams, bck cmn.Bck, props *cmn.BucketPropsToUpdate) (string, error) + func SetClusterConfig(bp BaseParams, nvs cos.StrKVs, transient bool) error + func SetClusterConfigUsingMsg(bp BaseParams, configToUpdate *cmn.ConfigToUpdate, transient bool) error + func SetDaemonConfig(bp BaseParams, nodeID string, nvs cos.StrKVs, transient ...bool) error + func SetObjectCustomProps(bp BaseParams, bck cmn.Bck, object string, custom cos.StrKVs, setNew bool) error + func SetPrimaryProxy(bp BaseParams, newPrimaryID string, force bool) error + func ShutdownCluster(bp BaseParams) error + func ShutdownNode(bp BaseParams, actValue *apc.ActValRmNode) (id string, err error) + func StartDSort(bp BaseParams, rs dsort.RequestSpec) (id string, err error) + func StartMaintenance(bp BaseParams, actValue *apc.ActValRmNode) (xid string, err error) + func StartXaction(bp BaseParams, args xact.ArgsMsg) (xid string, err error) + func StopMaintenance(bp BaseParams, actValue *apc.ActValRmNode) (xid string, err error) + func String(v string) *string + func WaitForXactionIC(bp BaseParams, args xact.ArgsMsg) (status *nl.Status, err error) + func WaitForXactionIdle(bp BaseParams, args xact.ArgsMsg) error + func WaitForXactionNode(bp BaseParams, args xact.ArgsMsg, fn func(xact.MultiSnap) (bool, bool)) error + func WritePolicy(v apc.WritePolicy) *apc.WritePolicy + type AppendArgs struct + BaseParams BaseParams + Bck cmn.Bck + Handle string + Object string + Reader cos.ReadOpenCloser + Size int64 + type BaseParams struct + Client *http.Client + Method string + Token string + UA string + URL string + type FlushArgs struct + BaseParams BaseParams + Bck cmn.Bck + Cksum *cos.Cksum + Handle string + Object string + type GetArgs struct + Header http.Header + Query url.Values + Writer io.Writer + type GetLogInput struct + Offset int64 + Severity string + Writer io.Writer + type NewRequestCB func(args *cmn.HreqArgs) (*http.Request, error) + type ObjAttrs struct + func GetObject(bp BaseParams, bck cmn.Bck, object string, args *GetArgs) (oah ObjAttrs, err error) + func GetObjectWithValidation(bp BaseParams, bck cmn.Bck, object string, args *GetArgs) (oah ObjAttrs, err error) + func PutObject(args PutArgs) (oah ObjAttrs, err error) + func (oah *ObjAttrs) Attrs() (out cmn.ObjAttrs) + func (oah *ObjAttrs) RespHeader() http.Header + func (oah *ObjAttrs) Size() int64 + type ProgressCallback = func(pi *ProgressContext) + type ProgressContext struct + func NewProgressContext(cb ProgressCallback, after time.Duration) *ProgressContext + func (ctx *ProgressContext) Elapsed() time.Duration + func (ctx *ProgressContext) Info() ProgressInfo + func (ctx *ProgressContext) IsFinished() bool + type ProgressInfo struct + Count int + Percent float64 + Total int + type PromoteArgs struct + BaseParams BaseParams + Bck cmn.Bck + type PutApndArchArgs struct + ArchPath string + Flags int64 + Mime string + type PutArgs struct + BaseParams BaseParams + Bck cmn.Bck + Cksum *cos.Cksum + ObjName string + Reader cos.ReadOpenCloser + Size uint64 + SkipVC bool + type ReqParams struct + BaseParams BaseParams + Body []byte + Header http.Header + Password string + Path string + Query url.Values + User string + func AllocRp() *ReqParams + func (reqParams *ReqParams) DoReqAny(out any) (int, error) + func (reqParams *ReqParams) DoRequest() error
Go to main page