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 + 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 *meta.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 *meta.Snode, conf *cmn.Config, localConf *cmn.LocalConfig) 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, bp api.BaseParams) (string, error) + func GenerateNotConflictingObjectName(baseName, newNamePrefix string, bck cmn.Bck, smap *meta.Smap) string + func GetClusterConfig(t *testing.T) (config *cmn.Config) + func GetClusterMap(tb testing.TB, url string) *meta.Smap + func GetClusterStats(t *testing.T, proxyURL string) stats.Cluster + func GetDaemonConfig(t *testing.T, node *meta.Snode) *cmn.Config + func GetICProxy(t testing.TB, smap *meta.Smap, ignoreID string) *meta.Snode + func GetNamedStatsVal(ds *stats.Node, name string) int64 + func GetObjectAtime(t *testing.T, bp api.BaseParams, bck cmn.Bck, object, timeFormat string) (time.Time, string) + func GetPrimaryProxy(proxyURL string) (*meta.Snode, error) + func GetPrimaryURL() string + func GetProxyReadiness(proxyURL string) error + func GetTargetsMountpaths(t *testing.T, smap *meta.Smap, params api.BaseParams) map[*meta.Snode][]string + func InitCluster(proxyURL string, clusterType ClusterType) (err error) + func InitLocalCluster() + func JoinCluster(proxyURL string, node *meta.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, objName string, reader readers.Reader, ...) + func PutObjRR(bp 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, bp api.BaseParams, objSize int64, cksumType string, bck cmn.Bck, ...) []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 RemoveNodeUnsafe(proxyURL, sid string) error + func RestoreNode(cmd RestoreCmd, asPrimary bool, tag string) error + func RestoreTarget(t *testing.T, proxyURL string, target *meta.Snode) (rebID string, newSmap *meta.Smap) + func RmTargetSkipRebWait(t *testing.T, proxyURL string, smap *meta.Smap) (*meta.Smap, *meta.Snode) + func SetBackendBck(t *testing.T, bp 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) (*meta.Smap, error) + func WaitForClusterStateActual(proxyURL, reason string, origVersion int64, proxyCnt, targetCnt int, ...) (*meta.Smap, error) + func WaitForDSortToFinish(proxyURL, managerUUID string) (allAborted bool, err error) + func WaitForNewSmap(proxyURL string, prevVersion int64) (newSmap *meta.Smap, err error) + func WaitForNodeToTerminate(pid int, timeout ...time.Duration) error + func WaitForObjectToBeDowloaded(bp api.BaseParams, bck cmn.Bck, objName string, timeout time.Duration) error + func WaitForRebalAndResil(t testing.TB, bp api.BaseParams, timeouts ...time.Duration) + func WaitForRebalanceByID(t *testing.T, origTargetCnt int, bp api.BaseParams, rebID string, ...) + func WaitForResilvering(t *testing.T, bp api.BaseParams, target *meta.Snode) + func WaitNodeAdded(bp api.BaseParams, nodeID string) (*meta.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 *meta.Snode + PID int + func GetRestoreCmd(si *meta.Snode) RestoreCmd + func KillNode(node *meta.Snode) (cmd RestoreCmd, err error) + func ShutdownNode(_ *testing.T, bp api.BaseParams, node *meta.Snode) (pid int, cmd RestoreCmd, rebID string, 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
Go to main page