| /trunk/goproj/src/github.com/couchbase/goxdcr/utils/mocks/ |
| D | mock_UtilsIface.go | 191 func (_c *UtilsIface_BucketNotFoundError_Call) Return(_a0 error) *UtilsIface_BucketNotFoundError_Ca… func
304 func (_c *UtilsIface_BucketUUID_Call) Return(_a0 string, _a1 error) *UtilsIface_BucketUUID_Call { func
857 func (_c *UtilsIface_EnforcePrefix_Call) Return(_a0 string) *UtilsIface_EnforcePrefix_Call { func
4825 func (_c *UtilsIface_NewDataPool_Call) Return(_a0 base.DataPool) *UtilsIface_NewDataPool_Call { func
5271 func (_c *UtilsIface_RecoverPanic_Call) Return() *UtilsIface_RecoverPanic_Call { func
5415 func (_c *UtilsIface_RemovePrefix_Call) Return(_a0 string) *UtilsIface_RemovePrefix_Call { func
5546 func (_c *UtilsIface_SendHELO_Call) Return(_a0 error) *UtilsIface_SendHELO_Call { func
5649 func (_c *UtilsIface_StartDebugExec_Call) Return(_a0 func()) *UtilsIface_StartDebugExec_Call { func
5728 func (_c *UtilsIface_TranslateKvVbMap_Call) Return() *UtilsIface_TranslateKvVbMap_Call { func
5770 func (_c *UtilsIface_UnwrapError_Call) Return(err error) *UtilsIface_UnwrapError_Call { func
[all …]
|
| /trunk/goproj/src/github.com/couchbase/goxdcr/pipeline/mocks/ |
| D | mock_ReplicationStatusIface.go | 54 func (_c *ReplicationStatusIface_AddError_Call) Return() *ReplicationStatusIface_AddError_Call { func
87 func (_c *ReplicationStatusIface_AddErrorsFromMap_Call) Return() *ReplicationStatusIface_AddErrorsF… func
271 func (_c *ReplicationStatusIface_ClearErrors_Call) Return() *ReplicationStatusIface_ClearErrors_Cal… func
779 func (_c *ReplicationStatusIface_Publish_Call) Return() *ReplicationStatusIface_Publish_Call { func
953 func (_c *ReplicationStatusIface_RepId_Call) Return(_a0 string) *ReplicationStatusIface_RepId_Call { func
986 func (_c *ReplicationStatusIface_ResetStorage_Call) Return() *ReplicationStatusIface_ResetStorage_C… func
1128 func (_c *ReplicationStatusIface_SetPipeline_Call) Return() *ReplicationStatusIface_SetPipeline_Cal… func
1163 func (_c *ReplicationStatusIface_SetStats_Call) Return() *ReplicationStatusIface_SetStats_Call { func
1238 func (_c *ReplicationStatusIface_SetVbList_Call) Return() *ReplicationStatusIface_SetVbList_Call { func
1409 func (_c *ReplicationStatusIface_String_Call) Return(_a0 string) *ReplicationStatusIface_String_Cal… func
[all …]
|
| /trunk/goproj/src/github.com/couchbase/goxdcr/common/mocks/ |
| D | mock_Pipeline.go | 58 func (_c *Pipeline_FullTopic_Call) Return(_a0 string) *Pipeline_FullTopic_Call { func
248 func (_c *Pipeline_InstanceId_Call) Return(_a0 string) *Pipeline_InstanceId_Call { func
281 func (_c *Pipeline_ReportProgress_Call) Return() *Pipeline_ReportProgress_Call { func
390 func (_c *Pipeline_SetBrokenMap_Call) Return() *Pipeline_SetBrokenMap_Call { func
456 func (_c *Pipeline_SetRuntimeContext_Call) Return() *Pipeline_SetRuntimeContext_Call { func
498 func (_c *Pipeline_SetState_Call) Return(_a0 error) *Pipeline_SetState_Call { func
671 func (_c *Pipeline_Start_Call) Return(_a0 base.ErrorMap) *Pipeline_Start_Call { func
712 func (_c *Pipeline_State_Call) Return(_a0 common.PipelineState) *Pipeline_State_Call { func
755 func (_c *Pipeline_Stop_Call) Return(_a0 base.ErrorMap) *Pipeline_Stop_Call { func
839 func (_c *Pipeline_Topic_Call) Return(_a0 string) *Pipeline_Topic_Call { func
[all …]
|
| D | mock_OutNozzle.go | 99 func (_c *OutNozzle_Close_Call) Return(_a0 error) *OutNozzle_Close_Call { func
183 func (_c *OutNozzle_Id_Call) Return(_a0 string) *OutNozzle_Id_Call { func
224 func (_c *OutNozzle_IsOpen_Call) Return(_a0 bool) *OutNozzle_IsOpen_Call { func
265 func (_c *OutNozzle_Open_Call) Return(_a0 error) *OutNozzle_Open_Call { func
298 func (_c *OutNozzle_RaiseEvent_Call) Return() *OutNozzle_RaiseEvent_Call { func
340 func (_c *OutNozzle_Receive_Call) Return(_a0 error) *OutNozzle_Receive_Call { func
373 func (_c *OutNozzle_RecycleDataObj_Call) Return() *OutNozzle_RecycleDataObj_Call { func
501 func (_c *OutNozzle_SetConnector_Call) Return(_a0 error) *OutNozzle_SetConnector_Call { func
609 func (_c *OutNozzle_Start_Call) Return(_a0 error) *OutNozzle_Start_Call { func
650 func (_c *OutNozzle_State_Call) Return(_a0 common.PartState) *OutNozzle_State_Call { func
[all …]
|
| D | mock_Connector.go | 58 func (_c *Connector_AddDownStream_Call) Return(_a0 error) *Connector_AddDownStream_Call { func
144 func (_c *Connector_DownStreams_Call) Return(_a0 map[string]common.Part) *Connector_DownStreams_Cal… func
186 func (_c *Connector_Forward_Call) Return(_a0 error) *Connector_Forward_Call { func
229 func (_c *Connector_GetUpstreamObjRecycler_Call) Return(_a0 func(interface{})) *Connector_GetUpstre… func
270 func (_c *Connector_Id_Call) Return(_a0 string) *Connector_Id_Call { func
311 func (_c *Connector_IsStartable_Call) Return(_a0 bool) *Connector_IsStartable_Call { func
344 func (_c *Connector_RaiseEvent_Call) Return() *Connector_RaiseEvent_Call { func
387 func (_c *Connector_RegisterComponentEventListener_Call) Return(_a0 error) *Connector_RegisterCompo… func
428 func (_c *Connector_Start_Call) Return(_a0 error) *Connector_Start_Call { func
469 func (_c *Connector_Stop_Call) Return(_a0 error) *Connector_Stop_Call { func
[all …]
|
| D | mock_Nozzle.go | 99 func (_c *Nozzle_Close_Call) Return(_a0 error) *Nozzle_Close_Call { func
183 func (_c *Nozzle_Id_Call) Return(_a0 string) *Nozzle_Id_Call { func
224 func (_c *Nozzle_IsOpen_Call) Return(_a0 bool) *Nozzle_IsOpen_Call { func
265 func (_c *Nozzle_Open_Call) Return(_a0 error) *Nozzle_Open_Call { func
298 func (_c *Nozzle_RaiseEvent_Call) Return() *Nozzle_RaiseEvent_Call { func
340 func (_c *Nozzle_Receive_Call) Return(_a0 error) *Nozzle_Receive_Call { func
373 func (_c *Nozzle_RecycleDataObj_Call) Return() *Nozzle_RecycleDataObj_Call { func
501 func (_c *Nozzle_SetConnector_Call) Return(_a0 error) *Nozzle_SetConnector_Call { func
543 func (_c *Nozzle_Start_Call) Return(_a0 error) *Nozzle_Start_Call { func
584 func (_c *Nozzle_State_Call) Return(_a0 common.PartState) *Nozzle_State_Call { func
[all …]
|
| D | mock_Part.go | 101 func (_c *Part_Connector_Call) Return(_a0 common.Connector) *Part_Connector_Call { func
142 func (_c *Part_Id_Call) Return(_a0 string) *Part_Id_Call { func
175 func (_c *Part_RaiseEvent_Call) Return() *Part_RaiseEvent_Call { func
217 func (_c *Part_Receive_Call) Return(_a0 error) *Part_Receive_Call { func
260 func (_c *Part_RegisterComponentEventListener_Call) Return(_a0 error) *Part_RegisterComponentEventL… func
302 func (_c *Part_SetConnector_Call) Return(_a0 error) *Part_SetConnector_Call { func
344 func (_c *Part_Start_Call) Return(_a0 error) *Part_Start_Call { func
385 func (_c *Part_State_Call) Return(_a0 common.PartState) *Part_State_Call { func
426 func (_c *Part_Stop_Call) Return(_a0 error) *Part_Stop_Call { func
469 func (_c *Part_UnRegisterComponentEventListener_Call) Return(_a0 error) *Part_UnRegisterComponentEv… func
[all …]
|
| /trunk/goproj/src/github.com/couchbase/gomemcached/client/mocks/ |
| D | mock_ClientIface.go | 484 func (_c *ClientIface_CASNext_Call) Return(_a0 bool) *ClientIface_CASNext_Call { func
596 func (_c *ClientIface_Close_Call) Return(_a0 error) *ClientIface_Close_Call { func
972 func (_c *ClientIface_Decr_Call) Return(_a0 uint64, _a1 error) *ClientIface_Decr_Call { func
1419 func (_c *ClientIface_GetBulk_Call) Return(_a0 error) *ClientIface_GetBulk_Call { func
1889 func (_c *ClientIface_Incr_Call) Return(_a0 uint64, _a1 error) *ClientIface_Incr_Call { func
2400 func (_c *ClientIface_Replica_Call) Return(_a0 bool) *ClientIface_Replica_Call { func
2688 func (_c *ClientIface_SetConnName_Call) Return() *ClientIface_SetConnName_Call { func
2721 func (_c *ClientIface_SetDeadline_Call) Return() *ClientIface_SetDeadline_Call { func
2820 func (_c *ClientIface_SetReplica_Call) Return() *ClientIface_SetReplica_Call { func
2988 func (_c *ClientIface_StatsFunc_Call) Return(_a0 error) *ClientIface_StatsFunc_Call { func
[all …]
|
| D | mock_UprFeedIface.go | 55 func (_c *UprFeedIface_ClientAck_Call) Return(_a0 error) *UprFeedIface_ClientAck_Call { func
87 func (_c *UprFeedIface_Close_Call) Return() *UprFeedIface_Close_Call { func
130 func (_c *UprFeedIface_CloseStream_Call) Return(_a0 error) *UprFeedIface_CloseStream_Call { func
171 func (_c *UprFeedIface_Closed_Call) Return(_a0 bool) *UprFeedIface_Closed_Call { func
212 func (_c *UprFeedIface_GetError_Call) Return(_a0 error) *UprFeedIface_GetError_Call { func
298 func (_c *UprFeedIface_GetUprStats_Call) Return(_a0 *memcached.UprStats) *UprFeedIface_GetUprStats_… func
340 func (_c *UprFeedIface_SetPriorityAsync_Call) Return(_a0 error) *UprFeedIface_SetPriorityAsync_Call… func
381 func (_c *UprFeedIface_StartFeed_Call) Return(_a0 error) *UprFeedIface_StartFeed_Call { func
467 func (_c *UprFeedIface_UprOpen_Call) Return(_a0 error) *UprFeedIface_UprOpen_Call { func
566 func (_c *UprFeedIface_UprOpenWithXATTR_Call) Return(_a0 error) *UprFeedIface_UprOpenWithXATTR_Call… func
[all …]
|
| /trunk/goproj/src/github.com/couchbase/goxdcr/service_def/mocks/ |
| D | mock_RemoteClusterSvc.go | 60 func (_c *RemoteClusterSvc_AddRemoteCluster_Call) Return(_a0 error) *RemoteClusterSvc_AddRemoteClus… func
273 func (_c *RemoteClusterSvc_GetCapability_Call) Return(_a0 metadata.Capability, _a1 error) *RemoteCl… func
792 func (_c *RemoteClusterSvc_RemoteClusterServiceCallback_Call) Return(_a0 error) *RemoteClusterSvc_R… func
887 func (_c *RemoteClusterSvc_RequestRemoteMonitoring_Call) Return(_a0 error) *RemoteClusterSvc_Reques… func
920 func (_c *RemoteClusterSvc_SetMetadataChangeHandlerCallback_Call) Return() *RemoteClusterSvc_SetMet… func
963 func (_c *RemoteClusterSvc_SetRemoteCluster_Call) Return(_a0 error) *RemoteClusterSvc_SetRemoteClus… func
1015 func (_c *RemoteClusterSvc_ShouldUseAlternateAddress_Call) Return(_a0 bool, _a1 error) *RemoteClust… func
1057 func (_c *RemoteClusterSvc_UnRequestRemoteMonitoring_Call) Return(_a0 error) *RemoteClusterSvc_UnRe… func
1099 func (_c *RemoteClusterSvc_ValidateAddRemoteCluster_Call) Return(_a0 error) *RemoteClusterSvc_Valid… func
1141 func (_c *RemoteClusterSvc_ValidateRemoteCluster_Call) Return(_a0 error) *RemoteClusterSvc_Validate… func
[all …]
|
| D | mock_XDCRCompTopologySvc.go | 54 func (_c *XDCRCompTopologySvc_GetLocalHostName_Call) Return(_a0 string) *XDCRCompTopologySvc_GetLoc… func
95 func (_c *XDCRCompTopologySvc_IsIpv4Blocked_Call) Return(_a0 bool) *XDCRCompTopologySvc_IsIpv4Block… func
136 func (_c *XDCRCompTopologySvc_IsIpv6Blocked_Call) Return(_a0 bool) *XDCRCompTopologySvc_IsIpv6Block… func
187 func (_c *XDCRCompTopologySvc_IsKVNode_Call) Return(_a0 bool, _a1 error) *XDCRCompTopologySvc_IsKVN… func
361 func (_c *XDCRCompTopologySvc_IsMyClusterIpv6_Call) Return(_a0 bool) *XDCRCompTopologySvc_IsMyClust… func
412 func (_c *XDCRCompTopologySvc_MyAdminPort_Call) Return(_a0 uint16, _a1 error) *XDCRCompTopologySvc_… func
514 func (_c *XDCRCompTopologySvc_MyClusterUuid_Call) Return(_a0 string, _a1 error) *XDCRCompTopologySv… func
715 func (_c *XDCRCompTopologySvc_MyHost_Call) Return(_a0 string, _a1 error) *XDCRCompTopologySvc_MyHos… func
766 func (_c *XDCRCompTopologySvc_MyHostAddr_Call) Return(_a0 string, _a1 error) *XDCRCompTopologySvc_M… func
819 func (_c *XDCRCompTopologySvc_MyKVNodes_Call) Return(_a0 []string, _a1 error) *XDCRCompTopologySvc_… func
[all …]
|
| D | mock_ReplicationSpecSvc.go | 60 func (_c *ReplicationSpecSvc_AddReplicationSpec_Call) Return(_a0 error) *ReplicationSpecSvc_AddRepl… func
166 func (_c *ReplicationSpecSvc_AllReplicationSpecIds_Call) Return(_a0 []string, _a1 error) *Replicati… func
546 func (_c *ReplicationSpecSvc_GetDerivedObj_Call) Return(_a0 interface{}, _a1 error) *ReplicationSpe… func
588 func (_c *ReplicationSpecSvc_IsReplicationValidationError_Call) Return(_a0 bool) *ReplicationSpecSv… func
642 func (_c *ReplicationSpecSvc_ReplicationSpec_Call) Return(_a0 *metadata.ReplicationSpecification, _… func
740 func (_c *ReplicationSpecSvc_ReplicationSpecServiceCallback_Call) Return(_a0 error) *ReplicationSpe… func
783 func (_c *ReplicationSpecSvc_SetDerivedObj_Call) Return(_a0 error) *ReplicationSpecSvc_SetDerivedOb… func
816 func (_c *ReplicationSpecSvc_SetManifestsGetter_Call) Return() *ReplicationSpecSvc_SetManifestsGett… func
853 func (_c *ReplicationSpecSvc_SetMetadataChangeHandlerCallback_Call) Return() *ReplicationSpecSvc_Se… func
895 func (_c *ReplicationSpecSvc_SetReplicationSpec_Call) Return(_a0 error) *ReplicationSpecSvc_SetRepl… func
[all …]
|
| D | mock_SourceNotification.go | 59 func (_c *SourceNotification_Clone_Call) Return(_a0 interface{}) *SourceNotification_Clone_Call { func
102 func (_c *SourceNotification_GetDcpStatsMap_Call) Return(_a0 base.DcpStatsMapType) *SourceNotificat… func
145 func (_c *SourceNotification_GetDcpStatsMapLegacy_Call) Return(_a0 base.DcpStatsMapType) *SourceNot… func
188 func (_c *SourceNotification_GetHighSeqnosMap_Call) Return(_a0 base.HighSeqnosMapType) *SourceNotif… func
274 func (_c *SourceNotification_GetKvVbMapRO_Call) Return(_a0 base.KvVBMapType) *SourceNotification_Ge… func
315 func (_c *SourceNotification_GetLocalTopologyUpdatedTime_Call) Return(_a0 time.Time) *SourceNotific… func
356 func (_c *SourceNotification_GetNumberOfSourceNodes_Call) Return(_a0 int) *SourceNotification_GetNu… func
509 func (_c *SourceNotification_GetSourceStorageBackend_Call) Return(_a0 string) *SourceNotification_G… func
552 func (_c *SourceNotification_GetSourceVBMapRO_Call) Return(_a0 base.KvVBMapType) *SourceNotificatio… func
593 func (_c *SourceNotification_IsSourceNotification_Call) Return(_a0 bool) *SourceNotification_IsSour… func
[all …]
|
| D | mock_BucketTopologySvc.go | 66 func (_c *BucketTopologySvc_RegisterGarbageCollect_Call) Return(_a0 error) *BucketTopologySvc_Regis… func
111 func (_c *BucketTopologySvc_ReplicationSpecChangeCallback_Call) Return(_a0 error) *BucketTopologySv… func
166 func (_c *BucketTopologySvc_SubscribeToLocalBucketDcpStatsFeed_Call) Return(_a0 chan service_def.So… func
276 func (_c *BucketTopologySvc_SubscribeToLocalBucketFeed_Call) Return(_a0 chan service_def.SourceNoti… func
461 func (_c *BucketTopologySvc_SubscribeToRemoteBucketFeed_Call) Return(_a0 chan service_def.TargetNot… func
504 func (_c *BucketTopologySvc_UnSubscribeLocalBucketFeed_Call) Return(_a0 error) *BucketTopologySvc_U… func
547 func (_c *BucketTopologySvc_UnSubscribeRemoteBucketFeed_Call) Return(_a0 error) *BucketTopologySvc_… func
590 func (_c *BucketTopologySvc_UnSubscribeToLocalBucketDcpStatsFeed_Call) Return(_a0 error) *BucketTop… func
633 func (_c *BucketTopologySvc_UnSubscribeToLocalBucketDcpStatsLegacyFeed_Call) Return(_a0 error) *Buc… func
676 func (_c *BucketTopologySvc_UnSubscribeToLocalBucketHighSeqnosFeed_Call) Return(_a0 error) *BucketT… func
[all …]
|
| D | mock_CheckpointsService.go | 118 func (_c *CheckpointsService_CheckpointsDoc_Call) Return(_a0 *metadata.CheckpointsDoc, _a1 error) *… func
217 func (_c *CheckpointsService_CollectionsManifestChangeCb_Call) Return(_a0 error) *CheckpointsServic… func
261 func (_c *CheckpointsService_DelCheckpointsDoc_Call) Return(_a0 error) *CheckpointsService_DelCheck… func
303 func (_c *CheckpointsService_DelCheckpointsDocs_Call) Return(_a0 error) *CheckpointsService_DelChec… func
336 func (_c *CheckpointsService_DisableRefCntDecrement_Call) Return() *CheckpointsService_DisableRefCn… func
369 func (_c *CheckpointsService_EnableRefCntDecrement_Call) Return() *CheckpointsService_EnableRefCntD… func
604 func (_c *CheckpointsService_PreUpsertBrokenMapping_Call) Return(_a0 error) *CheckpointsService_Pre… func
649 func (_c *CheckpointsService_ReplicationSpecChangeCallback_Call) Return(_a0 error) *CheckpointsServ… func
737 func (_c *CheckpointsService_UpsertBrokenMapping_Call) Return(_a0 error) *CheckpointsService_Upsert… func
792 func (_c *CheckpointsService_UpsertCheckpoints_Call) Return(_a0 int, _a1 error) *CheckpointsService… func
[all …]
|
| D | mock_CollectionsManifestAgentIface.go | 54 func (_c *CollectionsManifestAgentIface_ForceTargetManifestRefresh_Call) Return(_a0 error) *Collect… func
107 func (_c *CollectionsManifestAgentIface_GetLastPersistedManifests_Call) Return(_a0 *metadata.Collec… func
160 func (_c *CollectionsManifestAgentIface_GetSourceManifest_Call) Return(_a0 *metadata.CollectionsMan… func
214 func (_c *CollectionsManifestAgentIface_GetSpecificSourceManifest_Call) Return(_a0 *metadata.Collec… func
268 func (_c *CollectionsManifestAgentIface_GetSpecificTargetManifest_Call) Return(_a0 *metadata.Collec… func
321 func (_c *CollectionsManifestAgentIface_GetTargetManifest_Call) Return(_a0 *metadata.CollectionsMan… func
386 func (_c *CollectionsManifestAgentIface_PersistNeededManifests_Call) Return(_a0 error, _a1 error, _… func
418 func (_c *CollectionsManifestAgentIface_SetTempAgent_Call) Return() *CollectionsManifestAgentIface_… func
459 func (_c *CollectionsManifestAgentIface_Start_Call) Return(_a0 error) *CollectionsManifestAgentIfac… func
491 func (_c *CollectionsManifestAgentIface_Stop_Call) Return() *CollectionsManifestAgentIface_Stop_Cal… func
|
| /trunk/goproj/src/github.com/couchbase/goxdcr/parts/mocks/ |
| D | mock_DcpNozzleIface.go | 147 func (_c *DcpNozzleIface_Close_Call) Return(_a0 error) *DcpNozzleIface_Close_Call { func
324 func (_c *DcpNozzleIface_Id_Call) Return(_a0 string) *DcpNozzleIface_Id_Call { func
365 func (_c *DcpNozzleIface_IsOpen_Call) Return(_a0 bool) *DcpNozzleIface_IsOpen_Call { func
449 func (_c *DcpNozzleIface_Open_Call) Return(_a0 error) *DcpNozzleIface_Open_Call { func
514 func (_c *DcpNozzleIface_RaiseEvent_Call) Return() *DcpNozzleIface_RaiseEvent_Call { func
556 func (_c *DcpNozzleIface_Receive_Call) Return(_a0 error) *DcpNozzleIface_Receive_Call { func
589 func (_c *DcpNozzleIface_RecycleDataObj_Call) Return() *DcpNozzleIface_RecycleDataObj_Call { func
750 func (_c *DcpNozzleIface_SetMaxMissCount_Call) Return() *DcpNozzleIface_SetMaxMissCount_Call { func
792 func (_c *DcpNozzleIface_Start_Call) Return(_a0 error) *DcpNozzleIface_Start_Call { func
833 func (_c *DcpNozzleIface_State_Call) Return(_a0 common.PartState) *DcpNozzleIface_State_Call { func
[all …]
|
| /trunk/goproj/src/github.com/couchbase/goxdcr/pipeline_manager/mocks/ |
| D | mock_PipelineMgrForSerializer.go | 61 func (_c *PipelineMgrForSerializer_AutoPauseReplication_Call) Return(_a0 error) *PipelineMgrForSeri… func
189 func (_c *PipelineMgrForSerializer_CleanupPipeline_Call) Return(_a0 error) *PipelineMgrForSerialize… func
231 func (_c *PipelineMgrForSerializer_DismissEvent_Call) Return(_a0 error) *PipelineMgrForSerializer_D… func
358 func (_c *PipelineMgrForSerializer_GetLogSvc_Call) Return(_a0 service_def.UILogSvc) *PipelineMgrFor… func
584 func (_c *PipelineMgrForSerializer_PauseReplication_Call) Return(_a0 error) *PipelineMgrForSerializ… func
616 func (_c *PipelineMgrForSerializer_PostTopologyStatus_Call) Return() *PipelineMgrForSerializer_Post… func
700 func (_c *PipelineMgrForSerializer_StartBackfill_Call) Return(_a0 error) *PipelineMgrForSerializer_… func
776 func (_c *PipelineMgrForSerializer_StopAllUpdaters_Call) Return() *PipelineMgrForSerializer_StopAll… func
819 func (_c *PipelineMgrForSerializer_StopBackfill_Call) Return(_a0 error) *PipelineMgrForSerializer_S… func
908 func (_c *PipelineMgrForSerializer_StopPipeline_Call) Return(_a0 base.ErrorMap) *PipelineMgrForSeri… func
[all …]
|
| D | mock_PipelineMgrInternalIface.go | 61 func (_c *PipelineMgrInternalIface_AutoPauseReplication_Call) Return(_a0 error) *PipelineMgrInterna… func
103 func (_c *PipelineMgrInternalIface_ForceTargetRefreshManifest_Call) Return(_a0 error) *PipelineMgrI… func
145 func (_c *PipelineMgrInternalIface_GetLastUpdateResult_Call) Return(_a0 bool) *PipelineMgrInternalI… func
188 func (_c *PipelineMgrInternalIface_GetLogSvc_Call) Return(_a0 service_def.UILogSvc) *PipelineMgrInt… func
329 func (_c *PipelineMgrInternalIface_GetReplSpecSvc_Call) Return(_a0 service_def.ReplicationSpecSvc) … func
404 func (_c *PipelineMgrInternalIface_PostTopologyStatus_Call) Return() *PipelineMgrInternalIface_Post… func
446 func (_c *PipelineMgrInternalIface_RemoveReplicationStatus_Call) Return(_a0 error) *PipelineMgrInte… func
490 func (_c *PipelineMgrInternalIface_StartPipeline_Call) Return(_a0 base.ErrorMap) *PipelineMgrIntern… func
522 func (_c *PipelineMgrInternalIface_StopAllUpdaters_Call) Return() *PipelineMgrInternalIface_StopAll… func
566 func (_c *PipelineMgrInternalIface_StopPipeline_Call) Return(_a0 base.ErrorMap) *PipelineMgrInterna… func
[all …]
|
| D | mock_PipelineOpSerializerIface.go | 103 func (_c *PipelineOpSerializerIface_CleanBackfill_Call) Return(_a0 error) *PipelineOpSerializerIfac… func
145 func (_c *PipelineOpSerializerIface_Delete_Call) Return(_a0 error) *PipelineOpSerializerIface_Delet… func
188 func (_c *PipelineOpSerializerIface_DismissEvent_Call) Return(_a0 error) *PipelineOpSerializerIface… func
285 func (_c *PipelineOpSerializerIface_Init_Call) Return(_a0 error) *PipelineOpSerializerIface_Init_Ca… func
327 func (_c *PipelineOpSerializerIface_Pause_Call) Return(_a0 error) *PipelineOpSerializerIface_Pause_… func
369 func (_c *PipelineOpSerializerIface_ReInit_Call) Return(_a0 error) *PipelineOpSerializerIface_ReIni… func
411 func (_c *PipelineOpSerializerIface_StartBackfill_Call) Return(_a0 error) *PipelineOpSerializerIfac… func
443 func (_c *PipelineOpSerializerIface_Stop_Call) Return() *PipelineOpSerializerIface_Stop_Call { func
485 func (_c *PipelineOpSerializerIface_StopBackfill_Call) Return(_a0 error) *PipelineOpSerializerIface… func
530 func (_c *PipelineOpSerializerIface_StopBackfillWithCb_Call) Return(_a0 error) *PipelineOpSerialize… func
[all …]
|
| D | mock_PipelineMgrForUpdater.go | 61 func (_c *PipelineMgrForUpdater_AutoPauseReplication_Call) Return(_a0 error) *PipelineMgrForUpdater… func
103 func (_c *PipelineMgrForUpdater_ForceTargetRefreshManifest_Call) Return(_a0 error) *PipelineMgrForU… func
145 func (_c *PipelineMgrForUpdater_GetLastUpdateResult_Call) Return(_a0 bool) *PipelineMgrForUpdater_G… func
188 func (_c *PipelineMgrForUpdater_GetLogSvc_Call) Return(_a0 service_def.UILogSvc) *PipelineMgrForUpd… func
404 func (_c *PipelineMgrForUpdater_PostTopologyStatus_Call) Return() *PipelineMgrForUpdater_PostTopolo… func
446 func (_c *PipelineMgrForUpdater_RemoveReplicationStatus_Call) Return(_a0 error) *PipelineMgrForUpda… func
534 func (_c *PipelineMgrForUpdater_StartPipeline_Call) Return(_a0 base.ErrorMap) *PipelineMgrForUpdate… func
566 func (_c *PipelineMgrForUpdater_StopAllUpdaters_Call) Return() *PipelineMgrForUpdater_StopAllUpdate… func
611 func (_c *PipelineMgrForUpdater_StopBackfillPipeline_Call) Return(_a0 base.ErrorMap) *PipelineMgrFo… func
655 func (_c *PipelineMgrForUpdater_StopPipeline_Call) Return(_a0 base.ErrorMap) *PipelineMgrForUpdater… func
[all …]
|
| D | mock_PipelineMgrIface.go | 106 func (_c *PipelineMgrIface_AllReplications_Call) Return(_a0 []string) *PipelineMgrIface_AllReplicat… func
150 func (_c *PipelineMgrIface_AllReplicationsForBucket_Call) Return(_a0 []string) *PipelineMgrIface_Al… func
226 func (_c *PipelineMgrIface_CheckPipelines_Call) Return() *PipelineMgrIface_CheckPipelines_Call { func
268 func (_c *PipelineMgrIface_DeletePipeline_Call) Return(_a0 error) *PipelineMgrIface_DeletePipeline_… func
311 func (_c *PipelineMgrIface_DismissEventForPipeline_Call) Return(_a0 error) *PipelineMgrIface_Dismis… func
389 func (_c *PipelineMgrIface_HandlePeerCkptPush_Call) Return(_a0 error) *PipelineMgrIface_HandlePeerC… func
431 func (_c *PipelineMgrIface_InitiateRepStatus_Call) Return(_a0 error) *PipelineMgrIface_InitiateRepS… func
472 func (_c *PipelineMgrIface_OnExit_Call) Return(_a0 error) *PipelineMgrIface_OnExit_Call { func
514 func (_c *PipelineMgrIface_ReInitStreams_Call) Return(_a0 error) *PipelineMgrIface_ReInitStreams_Ca… func
654 func (_c *PipelineMgrIface_UpdatePipeline_Call) Return(_a0 error) *PipelineMgrIface_UpdatePipeline_… func
[all …]
|
| /trunk/goproj/src/github.com/couchbase/goxdcr/factory/mocks/ |
| D | mock_XDCRFactoryIface.go | 59 func (_c *XDCRFactoryIface_CheckpointBeforeStop_Call) Return(_a0 error) *XDCRFactoryIface_Checkpoin… func
121 func (_c *XDCRFactoryIface_ConstructSSLPortMap_Call) Return(_a0 map[string]uint16, _a1 bool, _a2 er… func
177 func (_c *XDCRFactoryIface_ConstructSettingsForConnector_Call) Return(_a0 metadata.ReplicationSetti… func
236 func (_c *XDCRFactoryIface_ConstructSettingsForPart_Call) Return(_a0 metadata.ReplicationSettingsMa… func
292 func (_c *XDCRFactoryIface_ConstructUpdateSettingsForConnector_Call) Return(_a0 metadata.Replicatio… func
348 func (_c *XDCRFactoryIface_ConstructUpdateSettingsForPart_Call) Return(_a0 metadata.ReplicationSett… func
404 func (_c *XDCRFactoryIface_ConstructUpdateSettingsForService_Call) Return(_a0 metadata.ReplicationS… func
459 func (_c *XDCRFactoryIface_NewPipeline_Call) Return(_a0 common.Pipeline, _a1 error) *XDCRFactoryIfa… func
516 func (_c *XDCRFactoryIface_NewSecondaryPipeline_Call) Return(_a0 common.Pipeline, _a1 error) *XDCRF… func
549 func (_c *XDCRFactoryIface_SetPipelineStopCallback_Call) Return() *XDCRFactoryIface_SetPipelineStop… func
[all …]
|
| /trunk/goproj/src/github.com/couchbase/goxdcr/metadata_svc/mocks/ |
| D | mock_RemoteClusterAgentIface.go | 68 func (_c *RemoteClusterAgentIface_DeleteReference_Call) Return(_a0 *metadata.RemoteClusterReference… func
119 func (_c *RemoteClusterAgentIface_GetCapability_Call) Return(_a0 metadata.Capability, _a1 error) *R… func
160 func (_c *RemoteClusterAgentIface_GetConnectionStringForCAPIRemoteCluster_Call) Return(_a0 string) … func
203 func (_c *RemoteClusterAgentIface_GetReferenceAndStatusClone_Call) Return(_a0 *metadata.RemoteClust… func
246 func (_c *RemoteClusterAgentIface_GetReferenceClone_Call) Return(_a0 *metadata.RemoteClusterReferen… func
287 func (_c *RemoteClusterAgentIface_Refresh_Call) Return(_a0 error) *RemoteClusterAgentIface_Refresh_… func
329 func (_c *RemoteClusterAgentIface_Start_Call) Return(_a0 error) *RemoteClusterAgentIface_Start_Call… func
361 func (_c *RemoteClusterAgentIface_Stop_Call) Return() *RemoteClusterAgentIface_Stop_Call { func
404 func (_c *RemoteClusterAgentIface_UpdateReferenceFrom_Call) Return(_a0 error) *RemoteClusterAgentIf… func
447 func (_c *RemoteClusterAgentIface_UpdateReferenceFromAsync_Call) Return(_a0 error) *RemoteClusterAg… func
[all …]
|
| /trunk/goproj/src/github.com/couchbase/goxdcr/peerToPeer/mocks/ |
| D | mock_P2PManager.go | 76 func (_c *P2PManager_CheckVBMaster_Call) Return(_a0 map[string]*peerToPeer.VBMasterCheckResp, _a1 e… func
117 func (_c *P2PManager_GetLifecycleId_Call) Return(_a0 string) *P2PManager_GetLifecycleId_Call { func
162 func (_c *P2PManager_ReplicationSpecChangeCallback_Call) Return(_a0 error) *P2PManager_ReplicationS… func
204 func (_c *P2PManager_RequestImmediateCkptBkfillPush_Call) Return(_a0 error) *P2PManager_RequestImme… func
299 func (_c *P2PManager_SendConnectionPreCheckRequest_Call) Return() *P2PManager_SendConnectionPreChec… func
341 func (_c *P2PManager_SendDelBackfill_Call) Return(_a0 error) *P2PManager_SendDelBackfill_Call { func
384 func (_c *P2PManager_SendManifests_Call) Return(_a0 error) *P2PManager_SendManifests_Call { func
427 func (_c *P2PManager_SendManualBackfill_Call) Return(_a0 error) *P2PManager_SendManualBackfill_Call… func
460 func (_c *P2PManager_SetPushReqMergerOnce_Call) Return() *P2PManager_SetPushReqMergerOnce_Call { func
513 func (_c *P2PManager_Start_Call) Return(_a0 peerToPeer.PeerToPeerCommAPI, _a1 error) *P2PManager_St… func
[all …]
|