Home
last modified time | relevance | path

Searched refs:utils (Results 1 - 25 of 118) sorted by relevance

12345

/6.0.3/goproj/src/github.com/couchbase/goxdcr/parts/
H A Dxmem_nozzle_test.go8 utilsReal "github.com/couchbase/goxdcr/utils"
9 utilsMock "github.com/couchbase/goxdcr/utils/mocks"
37 func setupMocksCommon(utils *utilsMock.UtilsIface) {
38 utils.On("ValidateSettings", mock.Anything, mock.Anything, mock.Anything).Return(nil)
39 utils.On("ExponentialBackoffExecutorWithFinishSignal", mock.Anything, mock.Anything, mock.Anything, mock.Anything, mock.Anything, mock.Anything, mock.Anything).Return(&mcMock.ClientIface{}, nil)
42 func setupMocksCompressNeg(utils *utilsMock.UtilsIface) {
43 setupMocksCommon(utils)
48 utils.On("SendHELOWithFeatures", mock.Anything, mock.Anything, mock.Anything, mock.Anything, mock.Anything, mock.Anything).Return(noCompressFeature, nil)
51 func setupMocksXmem(utils *utilsMock.UtilsIface) {
52 setupMocksCommon(utils)
[all...]
H A Ddcp_nozzle_test.go14 utilsReal "github.com/couchbase/goxdcr/utils"
15 utilsMock "github.com/couchbase/goxdcr/utils/mocks"
103 utils *utilsMock.UtilsIface,
112 setupMocks(xdcrTopology, utils, nozzle, settings, mcClient, uprFeed)
117 utils *utilsMock.UtilsIface,
127 setupMocksInternal(xdcrTopology, utils, nozzle, settings, mcClient, uprFeed, features)
131 utils *utilsMock.UtilsIface,
141 // utils mock
142 utils.On("ValidateSettings", mock.Anything, mock.Anything, mock.Anything).Return(nil)
143 utils
[all...]
H A Drouter.go21 utilities "github.com/couchbase/goxdcr/utils"
45 utils utilities.UtilsIface
79 utils: utilsIn,
169 if !router.utils.RegexpMatch(router.filterRegexp, uprEvent.Key) {
177 return nil, router.utils.NewEnhancedError("Error creating new memcached request.", err)
/6.0.3/goproj/src/github.com/couchbase/goxdcr/main/
H A Dmain.go21 utilities "github.com/couchbase/goxdcr/utils"
90 utils := utilities.NewUtilities()
92 cluster_info_svc := service_impl.NewClusterInfoSvc(nil, utils)
93 top_svc, err := service_impl.NewXDCRTopologySvc(uint16(options.sourceKVAdminPort), uint16(options.xdcrRestPort), options.isEnterprise, options.isIpv6, cluster_info_svc, nil, utils)
101 metakv_svc, err := metadata_svc.NewMetaKVMetadataSvc(nil, utils)
113 audit_svc, err := service_impl.NewAuditSvc(top_svc, nil, utils)
120 bucketSettings_svc := metadata_svc.NewBucketSettingsService(metakv_svc, top_svc, nil, utils)
124 remote_cluster_svc, err := metadata_svc.NewRemoteClusterService(nil, metakv_svc, top_svc, cluster_info_svc, nil, utils)
129 replication_spec_svc, err := metadata_svc.NewReplicationSpecService(nil, remote_cluster_svc, metakv_svc, top_svc, cluster_info_svc, nil, utils)
139 nil, utils)
[all...]
/6.0.3/goproj/src/github.com/couchbase/goxdcr/capi_utils/
H A Dcapi_utils.go9 utilities "github.com/couchbase/goxdcr/utils"
16 func ConstructVBCouchApiBaseMap(targetBucketName string, targetBucketInfo map[string]interface{}, remoteClusterRef *metadata.RemoteClusterReference, utils utilities.UtilsIface) (map[uint16]string, error) {
17 serverCouchApiBaseMap, err := ConstructServerCouchApiBaseMap(targetBucketName, targetBucketInfo, remoteClusterRef, utils)
24 vbMap, err := utils.GetRemoteServerVBucketsMap(remoteClusterRef.HostName(), targetBucketName, targetBucketInfo)
40 func ConstructServerCouchApiBaseMap(targetBucketName string, targetBucketInfo map[string]interface{}, remoteClusterRef *metadata.RemoteClusterReference, utils utilities.UtilsIface) (map[string]string, error) {
41 return ConstructCapiServiceEndPointMap(targetBucketName, targetBucketInfo, remoteClusterRef, utils, true /*useCouchApiBase*/)
45 func ConstructCapiServiceEndPointMap(targetBucketName string, targetBucketInfo map[string]interface{}, remoteClusterRef *metadata.RemoteClusterReference, utils utilities.UtilsIface, useCouchApiBase bool) (map[string]string, error) {
48 nodeList, err := utils.GetNodeListFromInfoMap(targetBucketInfo, logger_capi_utils)
63 hostname, err = utils.GetHostNameFromNodeInfo(remoteClusterRef.HostName(), nodeMap, logger_capi_utils)
85 endPoint = utils
[all...]
/6.0.3/phosphor/tests/module/
H A Dstring_utils_test.cc23 #include "utils/string_utils.h"
25 using phosphor::utils::format_string;
43 using phosphor::utils::to_json;
51 using phosphor::utils::split_string;
68 using phosphor::utils::join_string; in TEST()
77 using phosphor::utils::string_replace;
86 using phosphor::utils::glob_match;
H A Dmemory_test.cc22 #include "utils/memory.h"
25 std::unique_ptr<int> unique_int = phosphor::utils::make_unique<int>(5); in TEST()
38 EXPECT_THROW(phosphor::utils::make_unique<AlwaysThrow>(), in TEST()
/6.0.3/goproj/src/github.com/couchbase/goxdcr/service_impl/
H A Dcluster_info_service.go16 utilities "github.com/couchbase/goxdcr/utils"
21 utils utilities.UtilsIface
27 utils: utilsIn,
40 bucketInfo, err := ci_svc.utils.GetBucketInfo(connStr, bucketName, userName, password, httpAuthMech, certificate, sanInCertificate, clientCertificate, clientKey, ci_svc.logger)
51 return ci_svc.utils.GetServerVBucketsMap(connStr, bucketName, bucketInfo)
70 nodeList, err := ci_svc.utils.GetNodeListWithFullInfo(connStr, username, password, httpAuthMech, certificate, sanInCertificate, clientCertificate, clientKey, ci_svc.logger)
72 clusterCompatibility, err := ci_svc.utils.GetClusterCompatibilityFromNodeList(nodeList)
H A Duilog_service.go16 utilities "github.com/couchbase/goxdcr/utils"
23 utils utilities.UtilsIface
30 utils: utilsIn,
59 body, _ := service.utils.EncodeMapIntoByteArray(paramMap)
61 err, statusCode := service.utils.InvokeRestWithRetry(hostname, base.UILogPath, false, base.MethodPost, "", body, 0, nil, nil, false, service.logger, base.UILogRetry)
H A Daudit_service.go22 utilities "github.com/couchbase/goxdcr/utils"
38 utils utilities.UtilsIface
46 utils: utilsIn,
71 err = service.utils.NewEnhancedError(service_def.ErrorWritingAudit, err)
137 return service.utils.NewEnhancedError(ErrorInitializingAuditService+" Error getting memcached address of current host.", err)
147 client, err := service.utils.GetMemcachedConnection(service.kvaddr, "" /*bucketName*/, AuditServiceUserAgent,
H A Dxdcr_comp_topology_service.go18 utilities "github.com/couchbase/goxdcr/utils"
33 utils utilities.UtilsIface
46 utils: utilsIn,
231 err, statusCode := top_svc.utils.QueryRestApi(top_svc.staticHostAddr(), base.PoolsPath, false, base.MethodGet, "", nil, 0, &poolsInfo, top_svc.logger)
250 err, statusCode := top_svc.utils.QueryRestApi(top_svc.staticHostAddr(), base.PoolsPath, false, base.MethodGet, "", nil, 0, &poolsInfo, top_svc.logger)
309 err, statusCode := top_svc.utils.QueryRestApi(top_svc.staticHostAddr(), base.NodesPath, false, base.MethodGet, "", nil, 0, &nodesInfo, top_svc.logger)
/6.0.3/phosphor/src/
H A Dtrace_config.cc24 #include "utils/memory.h"
25 #include "utils/string_utils.h"
57 startup_trace = utils::make_unique<TraceConfig>(_startup_trace); in setStartupTrace()
168 auto arguments(phosphor::utils::split_string(config, ';')); in fromString()
177 auto kv(phosphor::utils::split_string(argument, ':')); in fromString()
225 config_obj.setCategories(utils::split_string(enabled_categories, ','), in fromString()
226 utils::split_string(disabled_categories, ',')); in fromString()
236 << utils::join_string(enabled_categories, ',') << ";"; in toString()
238 << utils::join_string(disabled_categories, ',') << ""; in toString()
H A Dtrace_event.cc21 #include "utils/string_utils.h"
76 return utils::format_string( in to_string()
94 output += "{\"name\":" + utils::to_json(getName()); in to_json()
95 output += ",\"cat\":" + utils::to_json(getCategory()); in to_json()
114 output += utils::to_json(tpi->argument_names[i]) + ":"; in to_json()
189 utils::format_string(",\"id\": \"0x%X\"", args[0].as_int); in typeToJSON()
194 utils::format_string(",\"id\": \"0x%X\"", args[0].as_int); in typeToJSON()
215 res.extras = utils::format_string(",\"dur\":%.3f", duration_us); in typeToJSON()
H A Dcategory_registry.cc21 #include "utils/string_utils.h"
73 utils::split_string(category_group, ',')); in calculateEnabled()
82 return utils::glob_match(enabled, category); in calculateEnabled()
93 return utils::glob_match(enabled, category); in calculateEnabled()
/6.0.3/goproj/src/github.com/couchbase/goxdcr/service_def/
H A Dcapi_svc.go19 utilities "github.com/couchbase/goxdcr/utils"
39 utils utilities.UtilsIface
52 utils: utilsIn,
79 targetBucketInfo, err := remoteBucket.utils.GetBucketInfo(connStr, remoteBucket.BucketName, username, password, httpAuthMech, certificate, sanInCertificate, clientCertificate, clientKey, remoteBucket.logger)
113 remoteBucket.VBServerMap, err = remoteBucket.utils.GetRemoteServerVBucketsMap(connStr, remoteBucket.BucketName, targetBucketInfo)
121 isTargetES := remoteBucket.utils.CheckWhetherClusterIsESBasedOnBucketInfo(targetBucketInfo)
126 clusterCompatibility, err := remoteBucket.utils.GetClusterCompatibilityFromBucketInfo(targetBucketInfo, remoteBucket.logger)
134 urlmap, err := capi_utils.ConstructCapiServiceEndPointMap(remoteBucket.BucketName, targetBucketInfo, remoteBucket.RemoteClusterRef, remoteBucket.utils, remoteBucket.UseCouchApiBase)
155 http_client, err := remoteBucket.utils.GetHttpClient(username, remoteBucket.RemoteClusterRef.HttpAuthMech(), certificate, sanInCertificate, clientCertificate, clientKey, hostAddr, remoteBucket.logger)
/6.0.3/phosphor/tests/benchmark/
H A Dcategory_registry_bench.cc24 #include <utils/memory.h>
49 registry = utils::make_unique<CategoryRegistry>(); in NewCategories()
62 registry = utils::make_unique<CategoryRegistry>(); in NewCategories()
/6.0.3/goproj/src/github.com/couchbase/goxdcr/tests/capi_svc/
H A Dcapi_service_run.go24 utilities "github.com/couchbase/goxdcr/utils"
130 utils := utilities.NewUtilities()
131 top_svc, err := service_impl.NewXDCRTopologySvc(uint16(options.sourceKVPort), uint16(options.xdcrRestPort), options.isEnterprise, cluster_info_svc, nil, utils)
136 remote_cluster_svc, err := metadata_svc.NewRemoteClusterService(nil, metadatakv_svc, top_svc, cluster_info_svc, log.DefaultLoggerContext, utils)
141 capi_svc := service_impl.NewCAPIService(cluster_info_svc, log.DefaultLoggerContext, utils)
146 remoteBucket, err := service_def.NewRemoteBucketInfo(options.remoteName, "default", nil, remote_cluster_svc, logger, utils)
219 err, _ = utils.QueryRestApiWithAuth(url,
263 return utils.EncodeMapIntoByteArray(params)
269 err, _ := utils.QueryRestApiWithAuth(url,
/6.0.3/goproj/src/github.com/couchbase/goxdcr/tests/router/
H A Drouter_run.go23 utils "github.com/couchbase/goxdcr/utils"
104 b, err := utils.LocalBucket(cluster, bucketn)
179 utils := utils.NewUtilities()
186 router, _ = parts.NewRouter("router1", "router1", options.filter_expression, partMap, buildVbMap(partMap), base.CRMode_RevId, couchlog.DefaultLoggerContext, nil, utils)
/6.0.3/phosphor/src/tools/
H A Dexport.cc24 #include "utils/memory.h"
25 #include "utils/string_utils.h"
32 return utils::format_string( in threadAssociationToString()
145 auto fp = utils::make_unique_FILE(formatted_path.c_str(), "w"); in operator ()()
170 utils::string_replace( in generateFilePath()
182 utils::string_replace(target, "%d", timestamp); in generateFilePath()
/6.0.3/goproj/src/github.com/couchbase/goxdcr/tests/pipeline/
H A Dxdcr_pipeline.go26 utilities "github.com/couchbase/goxdcr/utils"
120 utils := utilities.NewUtilities()
121 top_svc, err := service_impl.NewXDCRTopologySvc(uint16(options.source_kv_port), base.AdminportNumber, 11997, true, cluster_info_svc, nil, utils)
141 audit_svc, err := service_impl.NewAuditSvc(top_svc, nil, utils)
147 uilog_svc := service_impl.NewUILogSvc(top_svc, nil, utils)
148 remote_cluster_svc, err := metadata_svc.NewRemoteClusterService(uilog_svc, metakv_svc, top_svc, cluster_info_svc, nil, utils)
166 metadata_svc.NewCheckpointsService(metakv_svc, nil), service_impl.NewCAPIService(cluster_info_svc, nil, utils),
317 output := &utils.CouchBucket{}
319 err, _ := utils.QueryRestApiWithAuth("http://"+clusterAddress,
339 err, _ := utils
[all...]
/6.0.3/goproj/src/github.com/couchbase/goxdcr/metadata_svc/
H A Dreplication_spec_service.go22 utilities "github.com/couchbase/goxdcr/utils"
103 utils utilities.UtilsIface
124 utils: utilities_in,
177 _, sourceBucketType, sourceBucketUUID, sourceConflictResolutionType, sourceEvictionPolicy, _, err_source := service.utils.BucketValidationInfo(local_connStr, sourceBucket, "", "", base.HttpAuthMechPlain, nil, false, nil, nil, service.logger)
219 errorMap[base.ToCluster] = service.utils.NewEnhancedError("cannot find remote cluster", err)
224 errorMap[base.ToCluster] = service.utils.NewEnhancedError("Invalid remote cluster. MyConnectionStr() failed.", err)
229 errorMap[base.ToCluster] = service.utils.NewEnhancedError("Invalid remote cluster. MyCredentials() failed.", err)
260 isTargetES := service.utils.CheckWhetherClusterIsESBasedOnBucketInfo(targetBucketInfo)
263 targetClusterCompatibility, err = service.utils.GetClusterCompatibilityFromBucketInfo(targetBucketInfo, service.logger)
277 password, err = service.utils
[all...]
H A Dmetakv_metadata_service.go19 utilities "github.com/couchbase/goxdcr/utils"
27 utils utilities.UtilsIface
33 utils: utilsIn,
61 expOpErr := meta_svc.utils.ExponentialBackoffExecutor("metakv_svc_getOp", base.RetryIntervalMetakv, base.MaxNumOfMetakvRetries,
120 expOpErr := meta_svc.utils.ExponentialBackoffExecutor("metakv_svc_addOp", base.RetryIntervalMetakv, base.MaxNumOfMetakvRetries,
190 expOpErr := meta_svc.utils.ExponentialBackoffExecutor("metakv_svc_setOp", base.RetryIntervalMetakv, base.MaxNumOfMetakvRetries,
222 expOpErr := meta_svc.utils.ExponentialBackoffExecutor("metakv_svc_delOp", base.RetryIntervalMetakv, base.MaxNumOfMetakvRetries,
254 expOpErr := meta_svc.utils.ExponentialBackoffExecutor("metakv_svc_delROp", base.RetryIntervalMetakv, base.MaxNumOfMetakvRetries,
284 expOpErr := meta_svc.utils.ExponentialBackoffExecutor("metakv_svc_getAllMetaOp", base.RetryIntervalMetakv, base.MaxNumOfMetakvRetries,
/6.0.3/goproj/src/github.com/couchbase/goxdcr/tests/factory/
H A Dfactory_run.go15 utilities "github.com/couchbase/goxdcr/utils"
83 utils := utilities.NewUtilities()
84 top_svc, err := service_impl.NewXDCRTopologySvc(uint16(options.sourceKVAdminPort), base.AdminportNumber, 12001, true, cluster_info_svc, nil, utils)
102 audit_svc, err := service_impl.NewAuditSvc(top_svc, nil, utils)
108 uilog_svc := service_impl.NewUILogSvc(top_svc, nil, utils)
109 remote_cluster_svc, err := metadata_svc.NewRemoteClusterService(uilog_svc, msvc, top_svc, cluster_info_svc, nil, utils)
126 capi_svc := service_impl.NewCAPIService(cluster_info_svc, nil, utils)
/6.0.3/phosphor/include/phosphor/
H A Dinline_zstring.h28 #include "utils/string_utils.h"
69 return std::string{_s, utils::strnlen_s(_s, max_length) in operator std::string()
78 stream.write(izs._s, utils::strnlen_s(izs._s, max_length)); in operator <<()
/6.0.3/goproj/src/github.com/couchbase/goxdcr/tests/xmem/
H A Dxmem_run.go23 utils "github.com/couchbase/goxdcr/utils"
82 err, _ = utils.QueryRestApiWithAuth(options.target_cluster_addr,
102 output := &utils.CouchBucket{}
104 err, _ := utils.QueryRestApiWithAuth(options.target_cluster_addr,
162 b, err := utils.LocalBucket(cluster, bucketn)

Completed in 42 milliseconds

12345