tools

package

Go to main page

Versions in this module

v1

v1.4.2

Jan 15, 2026

v1.4.1

Dec 5, 2025

Changes in this version

+ func IsClusterLocal() (isLocal bool, err error)

v1.4.0

Oct 7, 2025

Changes in this version

+ const DefaultNamespace

+ func DecommissionNode(bp api.BaseParams, actValue *apc.ActValRmNode) (xid string, err error)

+ func GetRandSize(objSizeRange [2]uint64, objSize uint64, fixedSize bool) (size uint64)

+ func PromptWaitOnHerr(herr *cmn.ErrHTTP)

+ func PutMultipartObject(bp api.BaseParams, bck cmn.Bck, objName string, size uint64, ...) error

+ func StartMaintenance(bp api.BaseParams, actValue *apc.ActValRmNode) (xid string, err error)

type PutObjectsArgs

+ MultipartNumChunks int

+ ObjSizeRange [2]uint64

+ Reader readers.Reader

+ SkipVC bool

v1.3.31

Jul 25, 2025

v1.3.30

Jul 21, 2025

v1.3.29

May 22, 2025

Changes in this version

+ var DefaultWaitRetry = WaitRetryOpts

+ func WaitForCondition(condition func() bool, opts WaitRetryOpts) error

v1.3.28

May 9, 2025

Changes in this version

+ func ReaderEqual(r1, r2 io.Reader) bool

type SkipTestArgs

+ MaxTargets int

v1.3.27

Feb 14, 2025

v1.3.26

Feb 7, 2025

Changes in this version

type PutObjectsArgs

+ ObjNameLn int

v1.3.25

Oct 6, 2024

v1.3.24

Sep 27, 2024

Changes in this version

+ func DisableRebalance(t *testing.T)

+ func EnableRebalance(t *testing.T)

+ func ModifyLOM(t *testing.T, fqn string, bck cmn.Bck, modify func(*testing.T, *core.LOM))

type DirTreeDesc

+ FileSize int64

v1.3.23

May 27, 2024

Changes in this version

+ func SetRemAisConfig(t *testing.T, nvs cos.StrKVs)

v1.3.22

Feb 25, 2024

Changes in this version

type SkipTestArgs

+ RequiredCloudProvider string

+ RequiresTLS bool

v1.3.21

Nov 5, 2023

Changes in this version

+ func WaitForDsortToFinish(proxyURL, managerUUID string) (allAborted bool, err error)

+ func WaitForPID(pid int) error

v1.3.20

Sep 12, 2023

Changes in this version

+ var ErrTimedOutStabilize = errors.New("timed out waiting for the cluster to stabilize")

+ func WaitNodePubAddrNotInUse(si *meta.Snode, timeout time.Duration) error

v1.3.19

Aug 29, 2023

Changes in this version

+ const BucketCleanupTimeout

+ const CopyBucketTimeout

+ const DsortFinishTimeout

+ const EvictPrefetchTimeout

+ const MaxCplaneTimeout

+ const MultiProxyTestTimeout

+ const RebalanceStartTimeout

+ const RebalanceTimeout

+ const WaitClusterStartup

+ func CreateBucket(tb testing.TB, proxyURL string, bck cmn.Bck, props *cmn.BucketPropsToUpdate, ...)

v1.3.18

Jul 9, 2023

Changes in this version

+ func RemoveNodeUnsafe(proxyURL, sid string) error

v1.3.17

Apr 10, 2023

v1.3.16

Mar 31, 2023

v1.3.15

Nov 13, 2022

v1.3.13

Nov 9, 2022

v1.3.12

Nov 7, 2022

Changes in this version

+ const MockDaemonID

+ var HTTPClient *http.Client

+ var LoggedUserToken string

+ var RemoteCluster struct

+ func AddMpath(t *testing.T, path string)

+ func AssertMountpathCount(t *testing.T, availableCount, disabledCount int)

+ func BaseAPIParams(urls ...string) api.BaseParams

+ func BucketExists(tb testing.TB, proxyURL string, bck cmn.Bck) (bool, error)

+ func BucketsContain(bcks cmn.Bcks, qbck cmn.QueryBcks) bool

+ func CheckErrIsNotFound(t *testing.T, err error)

+ func CheckObjIsPresent(proxyURL string, bck cmn.Bck, objName string) bool

+ func CheckPathExists(t *testing.T, path string, dir bool)

+ func CheckPathNotExists(t *testing.T, path string)

+ func CheckSkip(tb testing.TB, args SkipTestArgs)

+ func CleanupNode(t *testing.T, pid int)

+ func CleanupRemoteBucket(t *testing.T, proxyURL string, bck cmn.Bck, prefix string)

+ func ClearMaintenance(bp api.BaseParams, tsi *cluster.Snode)

+ func CreateBucketWithCleanup(tb testing.TB, proxyURL string, bck cmn.Bck, props *cmn.BucketPropsToUpdate)

+ func CreateFileFromReader(t *testing.T, fileName string, r io.Reader) string

+ func Del(proxyURL string, bck cmn.Bck, object string, wg *sync.WaitGroup, ...) error

+ func DeployNode(t *testing.T, node *cluster.Snode, conf *cmn.Config, ...) int

+ func DestroyBucket(tb testing.TB, proxyURL string, bck cmn.Bck)

+ func EnsureObjectsExist(t *testing.T, params api.BaseParams, bck cmn.Bck, objectsNames ...string)

+ func EnsureOrigClusterState(t *testing.T)

+ func EvictObjects(t *testing.T, proxyURL string, bck cmn.Bck, objList []string)

+ func EvictRemoteBucket(tb testing.TB, proxyURL string, bck cmn.Bck)

+ func FilesEqual(file1, file2 string) (bool, error)

+ func GenerateNonexistentBucketName(prefix string, baseParams api.BaseParams) (string, error)

+ func GenerateNotConflictingObjectName(baseName, newNamePrefix string, bck cmn.Bck, smap *cluster.Smap) string

+ func GetClusterConfig(t *testing.T) (config *cmn.Config)

+ func GetClusterMap(tb testing.TB, url string) *cluster.Smap

+ func GetClusterStats(t *testing.T, proxyURL string) stats.ClusterStats

+ func GetDaemonConfig(t *testing.T, node *cluster.Snode) *cmn.Config

+ func GetDaemonStats(t *testing.T, u string) (stats map[string]any)

+ func GetICProxy(t testing.TB, smap *cluster.Smap, ignoreID string) *cluster.Snode

+ func GetNamedStatsVal(ds *stats.DaemonStats, name string) int64

+ func GetObjectAtime(t *testing.T, baseParams api.BaseParams, bck cmn.Bck, ...) (time.Time, string)

+ func GetPrimaryProxy(proxyURL string) (*cluster.Snode, error)

+ func GetPrimaryURL() string

+ func GetProxyReadiness(proxyURL string) error

+ func GetTargetsMountpaths(t *testing.T, smap *cluster.Smap, params api.BaseParams) map[*cluster.Snode][]string

+ func InitCluster(proxyURL string, clusterType ClusterType) (err error)

+ func InitLocalCluster()

+ func JoinCluster(proxyURL string, node *cluster.Snode) (string, error)

+ func ListObjectNames(proxyURL string, bck cmn.Bck, prefix string, objectCountLimit uint) ([]string, error)

+ func NewClientWithProxy(proxyURL string) *http.Client

+ func PrepareDirTree(tb testing.TB, desc DirTreeDesc) (string, []string)

+ func PrepareMountPaths(t *testing.T, cnt int) fs.MPI

+ func Put(proxyURL string, bck cmn.Bck, object string, reader readers.Reader, ...)

+ func PutObjRR(baseParams api.BaseParams, bck cmn.Bck, objName string, objSize int64, ...) error

+ func PutObject(t *testing.T, bck cmn.Bck, objName string, reader readers.Reader)

+ func PutObjectInRemoteBucketWithoutCachingLocally(t *testing.T, bck cmn.Bck, object string, objContent cos.ReadOpenCloser)

+ func PutRR(tb testing.TB, baseParams api.BaseParams, objSize int64, cksumType string, ...) []string

+ func PutRandObjs(args PutObjectsArgs) ([]string, int, error)

+ func RandomObjDir(dirLen, maxDepth int) (dir string)

+ func RandomProxyURL(ts ...*testing.T) (url string)

+ func RemoveMpaths(t *testing.T, mpaths fs.MPI)

+ func RemoveNodeFromSmap(proxyURL, sid string) error

+ func RestoreNode(cmd RestoreCmd, asPrimary bool, tag string) error

+ func RestoreTarget(t *testing.T, proxyURL string, target *cluster.Snode) (rebID string, newSmap *cluster.Smap)

+ func RmTargetSkipRebWait(t *testing.T, proxyURL string, smap *cluster.Smap) (*cluster.Smap, *cluster.Snode)

+ func SetBackendBck(t *testing.T, baseParams api.BaseParams, srcBck, dstBck cmn.Bck)

+ func SetClusterConfig(t *testing.T, nvs cos.StrKVs)

+ func SetClusterConfigUsingMsg(t *testing.T, toUpdate *cmn.ConfigToUpdate)

+ func SetXattrCksum(fqn string, bck cmn.Bck, cksum *cos.Cksum) error

+ func ShortSkipf(tb testing.TB, a ...any)

+ func WaitForBucket(proxyURL string, query cmn.QueryBcks, exists bool) error

+ func WaitForClusterState(proxyURL, reason string, origVer int64, pcnt, tcnt int, ignoreIDs ...string) (*cluster.Smap, error)

+ func WaitForClusterStateActual(proxyURL, reason string, origVersion int64, proxyCnt, targetCnt int, ...) (*cluster.Smap, error)

+ func WaitForDSortToFinish(proxyURL, managerUUID string) (allAborted bool, err error)

+ func WaitForNewSmap(proxyURL string, prevVersion int64) (newSmap *cluster.Smap, err error)

+ func WaitForNodeToTerminate(pid int, timeout ...time.Duration) error

+ func WaitForObjectToBeDowloaded(baseParams api.BaseParams, bck cmn.Bck, objName string, timeout time.Duration) error

+ func WaitForRebalAndResil(t testing.TB, baseParams api.BaseParams, timeouts ...time.Duration)

+ func WaitForRebalanceByID(t *testing.T, origTargetCnt int, baseParams api.BaseParams, rebID string, ...)

+ func WaitForResilver(t *testing.T, baseParams api.BaseParams, timeouts ...time.Duration)

+ func WaitForResilvering(t *testing.T, bp api.BaseParams, target *cluster.Snode)

+ func WaitNodeAdded(bp api.BaseParams, nodeID string) (*cluster.Smap, error)

+ func WaitNodeReady(url string, opts ...*WaitRetryOpts) (err error)

+ type ClusterType string

+ const ClusterTypeDocker

+ const ClusterTypeK8s

+ const ClusterTypeLocal

+ type ContentTypeDesc struct

+ ContentCnt int

+ Type string

+ type Ctx struct

+ Client *http.Client

+ Log func(format string, a ...any)

+ type DirTreeDesc struct

+ Depth int

+ Dirs int

+ Empty bool

+ Files int

+ InitDir string

+ type E2EFramework struct

+ Dir string

+ Vars map[string]string

+ func (f *E2EFramework) RunE2ETest(fileName string)

+ type ObjectsDesc struct

+ CTs []ContentTypeDesc

+ MountpathsCnt int

+ ObjectSize int64

+ type ObjectsOut struct

+ Bck cmn.Bck

+ Dir string

+ FQNs map[string][]string

+ MpathObjectsCnt map[string]int

+ T cluster.Target

+ func PrepareObjects(t *testing.T, desc ObjectsDesc) *ObjectsOut

+ type PutObjectsArgs struct

+ Bck cmn.Bck

+ CksumType string

+ FixedSize bool

+ IgnoreErr bool

+ ObjCnt int

+ ObjPath string

+ ObjSize uint64

+ Ordered bool

+ ProxyURL string

+ WorkerCnt int

+ type RestoreCmd struct

+ Args []string

+ Cmd string

+ Node *cluster.Snode

+ PID int

+ func GetRestoreCmd(si *cluster.Snode) RestoreCmd

+ func KillNode(node *cluster.Snode) (cmd RestoreCmd, err error)

+ func ShutdownNode(_ *testing.T, bp api.BaseParams, node *cluster.Snode) (pid int, cmd RestoreCmd, err error)

+ type SkipTestArgs struct

+ Bck cmn.Bck

+ CloudBck bool

+ K8s bool

+ Local bool

+ Long bool

+ MinMountpaths int

+ MinProxies int

+ MinTargets int

+ RemoteBck bool

+ RequiredDeployment ClusterType

+ RequiresAuth bool

+ RequiresRemoteCluster bool

+ type WaitRetryOpts struct

+ Interval time.Duration

+ MaxRetries int

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