mocks

package

Go to main page

Versions in this module

v0

v0.3.1

Mar 13, 2024

Changes in this version

type ClientIface

+ func (_m *ClientIface) EnableDataPool(getter func(uint64) ([]byte, error), doneCb func([]byte)) error

+ type ClientIface_EnableDataPool_Call struct

+ func (_c *ClientIface_EnableDataPool_Call) Return(_a0 error) *ClientIface_EnableDataPool_Call

+ func (_c *ClientIface_EnableDataPool_Call) Run(run func(getter func(uint64) ([]byte, error), doneCb func([]byte))) *ClientIface_EnableDataPool_Call

+ func (_c *ClientIface_EnableDataPool_Call) RunAndReturn(run func(func(uint64) ([]byte, error), func([]byte)) error) *ClientIface_EnableDataPool_Call

type ClientIface_Expecter

+ func (_e *ClientIface_Expecter) EnableDataPool(getter interface{}, doneCb interface{}) *ClientIface_EnableDataPool_Call

v0.3.0

Nov 13, 2023

Changes in this version

type CasFunc

+ func (_m *CasFunc) EXPECT() *CasFunc_Expecter

+ type CasFunc_Execute_Call struct

+ func (_c *CasFunc_Execute_Call) Return(_a0 []byte, _a1 memcached.CasOp) *CasFunc_Execute_Call

+ func (_c *CasFunc_Execute_Call) Run(run func(current []byte)) *CasFunc_Execute_Call

+ func (_c *CasFunc_Execute_Call) RunAndReturn(run func([]byte) ([]byte, memcached.CasOp)) *CasFunc_Execute_Call

+ type CasFunc_Expecter struct

+ func (_e *CasFunc_Expecter) Execute(current interface{}) *CasFunc_Execute_Call

type ClientIface

+ func (_m *ClientIface) EXPECT() *ClientIface_Expecter

+ func (_m *ClientIface) GetConnName() string

+ func (_m *ClientIface) GetErrorMap(errMapVersion gomemcached.ErrorMapVersion) (map[string]interface{}, error)

+ func (_m *ClientIface) Replica() bool

+ func (_m *ClientIface) SetConnName(name string)

+ func (_m *ClientIface) SetSubdoc(vb uint16, key string, ops []memcached.SubDocOp, ...) (*gomemcached.MCResponse, error)

+ type ClientIface_Add_Call struct

+ func (_c *ClientIface_Add_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_Add_Call

+ func (_c *ClientIface_Add_Call) Run(run func(vb uint16, key string, flags int, exp int, body []byte, ...)) *ClientIface_Add_Call

+ func (_c *ClientIface_Add_Call) RunAndReturn(...) *ClientIface_Add_Call

+ type ClientIface_Append_Call struct

+ func (_c *ClientIface_Append_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_Append_Call

+ func (_c *ClientIface_Append_Call) Run(...) *ClientIface_Append_Call

+ func (_c *ClientIface_Append_Call) RunAndReturn(...) *ClientIface_Append_Call

+ type ClientIface_AuthList_Call struct

+ func (_c *ClientIface_AuthList_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_AuthList_Call

+ func (_c *ClientIface_AuthList_Call) Run(run func()) *ClientIface_AuthList_Call

+ func (_c *ClientIface_AuthList_Call) RunAndReturn(run func() (*gomemcached.MCResponse, error)) *ClientIface_AuthList_Call

+ type ClientIface_AuthPlain_Call struct

+ func (_c *ClientIface_AuthPlain_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_AuthPlain_Call

+ func (_c *ClientIface_AuthPlain_Call) Run(run func(user string, pass string)) *ClientIface_AuthPlain_Call

+ func (_c *ClientIface_AuthPlain_Call) RunAndReturn(run func(string, string) (*gomemcached.MCResponse, error)) *ClientIface_AuthPlain_Call

+ type ClientIface_AuthScramSha_Call struct

+ func (_c *ClientIface_AuthScramSha_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_AuthScramSha_Call

+ func (_c *ClientIface_AuthScramSha_Call) Run(run func(user string, pass string)) *ClientIface_AuthScramSha_Call

+ func (_c *ClientIface_AuthScramSha_Call) RunAndReturn(run func(string, string) (*gomemcached.MCResponse, error)) *ClientIface_AuthScramSha_Call

+ type ClientIface_Auth_Call struct

+ func (_c *ClientIface_Auth_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_Auth_Call

+ func (_c *ClientIface_Auth_Call) Run(run func(user string, pass string)) *ClientIface_Auth_Call

+ func (_c *ClientIface_Auth_Call) RunAndReturn(run func(string, string) (*gomemcached.MCResponse, error)) *ClientIface_Auth_Call

+ type ClientIface_CASNext_Call struct

+ func (_c *ClientIface_CASNext_Call) Return(_a0 bool) *ClientIface_CASNext_Call

+ func (_c *ClientIface_CASNext_Call) Run(run func(vb uint16, k string, exp int, state *memcached.CASState)) *ClientIface_CASNext_Call

+ func (_c *ClientIface_CASNext_Call) RunAndReturn(run func(uint16, string, int, *memcached.CASState) bool) *ClientIface_CASNext_Call

+ type ClientIface_CAS_Call struct

+ func (_c *ClientIface_CAS_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_CAS_Call

+ func (_c *ClientIface_CAS_Call) Run(run func(vb uint16, k string, f memcached.CasFunc, initexp int)) *ClientIface_CAS_Call

+ func (_c *ClientIface_CAS_Call) RunAndReturn(...) *ClientIface_CAS_Call

+ type ClientIface_CancelRangeScan_Call struct

+ func (_c *ClientIface_CancelRangeScan_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_CancelRangeScan_Call

+ func (_c *ClientIface_CancelRangeScan_Call) Run(...) *ClientIface_CancelRangeScan_Call

+ func (_c *ClientIface_CancelRangeScan_Call) RunAndReturn(...) *ClientIface_CancelRangeScan_Call

+ type ClientIface_Close_Call struct

+ func (_c *ClientIface_Close_Call) Return(_a0 error) *ClientIface_Close_Call

+ func (_c *ClientIface_Close_Call) Run(run func()) *ClientIface_Close_Call

+ func (_c *ClientIface_Close_Call) RunAndReturn(run func() error) *ClientIface_Close_Call

+ type ClientIface_CollectionEnabled_Call struct

+ func (_c *ClientIface_CollectionEnabled_Call) Return(_a0 bool) *ClientIface_CollectionEnabled_Call

+ func (_c *ClientIface_CollectionEnabled_Call) Run(run func()) *ClientIface_CollectionEnabled_Call

+ func (_c *ClientIface_CollectionEnabled_Call) RunAndReturn(run func() bool) *ClientIface_CollectionEnabled_Call

+ type ClientIface_CollectionsGetCID_Call struct

+ func (_c *ClientIface_CollectionsGetCID_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_CollectionsGetCID_Call

+ func (_c *ClientIface_CollectionsGetCID_Call) Run(run func(scope string, collection string)) *ClientIface_CollectionsGetCID_Call

+ func (_c *ClientIface_CollectionsGetCID_Call) RunAndReturn(run func(string, string) (*gomemcached.MCResponse, error)) *ClientIface_CollectionsGetCID_Call

+ type ClientIface_ContinueRangeScan_Call struct

+ func (_c *ClientIface_ContinueRangeScan_Call) Return(_a0 error) *ClientIface_ContinueRangeScan_Call

+ func (_c *ClientIface_ContinueRangeScan_Call) Run(...) *ClientIface_ContinueRangeScan_Call

+ func (_c *ClientIface_ContinueRangeScan_Call) RunAndReturn(...) *ClientIface_ContinueRangeScan_Call

+ type ClientIface_CreateRandomScan_Call struct

+ func (_c *ClientIface_CreateRandomScan_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_CreateRandomScan_Call

+ func (_c *ClientIface_CreateRandomScan_Call) Run(run func(vb uint16, collId uint32, sampleSize int, withDocs bool, ...)) *ClientIface_CreateRandomScan_Call

+ func (_c *ClientIface_CreateRandomScan_Call) RunAndReturn(...) *ClientIface_CreateRandomScan_Call

+ type ClientIface_CreateRangeScan_Call struct

+ func (_c *ClientIface_CreateRangeScan_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_CreateRangeScan_Call

+ func (_c *ClientIface_CreateRangeScan_Call) Run(...) *ClientIface_CreateRangeScan_Call

+ func (_c *ClientIface_CreateRangeScan_Call) RunAndReturn(...) *ClientIface_CreateRangeScan_Call

+ type ClientIface_Decr_Call struct

+ func (_c *ClientIface_Decr_Call) Return(_a0 uint64, _a1 error) *ClientIface_Decr_Call

+ func (_c *ClientIface_Decr_Call) Run(run func(vb uint16, key string, amt uint64, def uint64, exp int, ...)) *ClientIface_Decr_Call

+ func (_c *ClientIface_Decr_Call) RunAndReturn(...) *ClientIface_Decr_Call

+ type ClientIface_Del_Call struct

+ func (_c *ClientIface_Del_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_Del_Call

+ func (_c *ClientIface_Del_Call) Run(run func(vb uint16, key string, context ...*memcached.ClientContext)) *ClientIface_Del_Call

+ func (_c *ClientIface_Del_Call) RunAndReturn(...) *ClientIface_Del_Call

+ type ClientIface_EnableFeatures_Call struct

+ func (_c *ClientIface_EnableFeatures_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_EnableFeatures_Call

+ func (_c *ClientIface_EnableFeatures_Call) Run(run func(features memcached.Features)) *ClientIface_EnableFeatures_Call

+ func (_c *ClientIface_EnableFeatures_Call) RunAndReturn(run func(memcached.Features) (*gomemcached.MCResponse, error)) *ClientIface_EnableFeatures_Call

+ type ClientIface_EnableMutationToken_Call struct

+ func (_c *ClientIface_EnableMutationToken_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_EnableMutationToken_Call

+ func (_c *ClientIface_EnableMutationToken_Call) Run(run func()) *ClientIface_EnableMutationToken_Call

+ func (_c *ClientIface_EnableMutationToken_Call) RunAndReturn(run func() (*gomemcached.MCResponse, error)) *ClientIface_EnableMutationToken_Call

+ type ClientIface_Expecter struct

+ func (_e *ClientIface_Expecter) Add(vb interface{}, key interface{}, flags interface{}, exp interface{}, ...) *ClientIface_Add_Call

+ func (_e *ClientIface_Expecter) Append(vb interface{}, key interface{}, data interface{}, context ...interface{}) *ClientIface_Append_Call

+ func (_e *ClientIface_Expecter) Auth(user interface{}, pass interface{}) *ClientIface_Auth_Call

+ func (_e *ClientIface_Expecter) AuthList() *ClientIface_AuthList_Call

+ func (_e *ClientIface_Expecter) AuthPlain(user interface{}, pass interface{}) *ClientIface_AuthPlain_Call

+ func (_e *ClientIface_Expecter) AuthScramSha(user interface{}, pass interface{}) *ClientIface_AuthScramSha_Call

+ func (_e *ClientIface_Expecter) CAS(vb interface{}, k interface{}, f interface{}, initexp interface{}) *ClientIface_CAS_Call

+ func (_e *ClientIface_Expecter) CASNext(vb interface{}, k interface{}, exp interface{}, state interface{}) *ClientIface_CASNext_Call

+ func (_e *ClientIface_Expecter) CancelRangeScan(vb interface{}, uuid interface{}, opaque interface{}, context ...interface{}) *ClientIface_CancelRangeScan_Call

+ func (_e *ClientIface_Expecter) Close() *ClientIface_Close_Call

+ func (_e *ClientIface_Expecter) CollectionEnabled() *ClientIface_CollectionEnabled_Call

+ func (_e *ClientIface_Expecter) CollectionsGetCID(scope interface{}, collection interface{}) *ClientIface_CollectionsGetCID_Call

+ func (_e *ClientIface_Expecter) ContinueRangeScan(vb interface{}, uuid interface{}, opaque interface{}, items interface{}, ...) *ClientIface_ContinueRangeScan_Call

+ func (_e *ClientIface_Expecter) CreateRandomScan(vb interface{}, collId interface{}, sampleSize interface{}, ...) *ClientIface_CreateRandomScan_Call

+ func (_e *ClientIface_Expecter) CreateRangeScan(vb interface{}, collId interface{}, start interface{}, ...) *ClientIface_CreateRangeScan_Call

+ func (_e *ClientIface_Expecter) Decr(vb interface{}, key interface{}, amt interface{}, def interface{}, ...) *ClientIface_Decr_Call

+ func (_e *ClientIface_Expecter) Del(vb interface{}, key interface{}, context ...interface{}) *ClientIface_Del_Call

+ func (_e *ClientIface_Expecter) EnableFeatures(features interface{}) *ClientIface_EnableFeatures_Call

+ func (_e *ClientIface_Expecter) EnableMutationToken() *ClientIface_EnableMutationToken_Call

+ func (_e *ClientIface_Expecter) Get(vb interface{}, key interface{}, context ...interface{}) *ClientIface_Get_Call

+ func (_e *ClientIface_Expecter) GetAllVbSeqnos(vbSeqnoMap interface{}, context ...interface{}) *ClientIface_GetAllVbSeqnos_Call

+ func (_e *ClientIface_Expecter) GetAndTouch(vb interface{}, key interface{}, exp interface{}, context ...interface{}) *ClientIface_GetAndTouch_Call

+ func (_e *ClientIface_Expecter) GetBulk(vb interface{}, keys interface{}, rv interface{}, subPaths interface{}, ...) *ClientIface_GetBulk_Call

+ func (_e *ClientIface_Expecter) GetCollectionsManifest() *ClientIface_GetCollectionsManifest_Call

+ func (_e *ClientIface_Expecter) GetConnName() *ClientIface_GetConnName_Call

+ func (_e *ClientIface_Expecter) GetErrorMap(errMapVersion interface{}) *ClientIface_GetErrorMap_Call

+ func (_e *ClientIface_Expecter) GetMeta(vb interface{}, key interface{}, context ...interface{}) *ClientIface_GetMeta_Call

+ func (_e *ClientIface_Expecter) GetRandomDoc(context ...interface{}) *ClientIface_GetRandomDoc_Call

+ func (_e *ClientIface_Expecter) GetSubdoc(vb interface{}, key interface{}, subPaths interface{}, context ...interface{}) *ClientIface_GetSubdoc_Call

+ func (_e *ClientIface_Expecter) Hijack() *ClientIface_Hijack_Call

+ func (_e *ClientIface_Expecter) Incr(vb interface{}, key interface{}, amt interface{}, def interface{}, ...) *ClientIface_Incr_Call

+ func (_e *ClientIface_Expecter) LastBucket() *ClientIface_LastBucket_Call

+ func (_e *ClientIface_Expecter) NewUprFeed() *ClientIface_NewUprFeed_Call

+ func (_e *ClientIface_Expecter) NewUprFeedIface() *ClientIface_NewUprFeedIface_Call

+ func (_e *ClientIface_Expecter) NewUprFeedWithConfig(ackByClient interface{}) *ClientIface_NewUprFeedWithConfig_Call

+ func (_e *ClientIface_Expecter) NewUprFeedWithConfigIface(ackByClient interface{}) *ClientIface_NewUprFeedWithConfigIface_Call

+ func (_e *ClientIface_Expecter) Observe(vb interface{}, key interface{}) *ClientIface_Observe_Call

+ func (_e *ClientIface_Expecter) ObserveSeq(vb interface{}, vbuuid interface{}) *ClientIface_ObserveSeq_Call

+ func (_e *ClientIface_Expecter) Receive() *ClientIface_Receive_Call

+ func (_e *ClientIface_Expecter) ReceiveWithDeadline(deadline interface{}) *ClientIface_ReceiveWithDeadline_Call

+ func (_e *ClientIface_Expecter) Replica() *ClientIface_Replica_Call

+ func (_e *ClientIface_Expecter) SelectBucket(bucket interface{}) *ClientIface_SelectBucket_Call

+ func (_e *ClientIface_Expecter) Send(req interface{}) *ClientIface_Send_Call

+ func (_e *ClientIface_Expecter) Set(vb interface{}, key interface{}, flags interface{}, exp interface{}, ...) *ClientIface_Set_Call

+ func (_e *ClientIface_Expecter) SetCas(vb interface{}, key interface{}, flags interface{}, exp interface{}, ...) *ClientIface_SetCas_Call

+ func (_e *ClientIface_Expecter) SetConnName(name interface{}) *ClientIface_SetConnName_Call

+ func (_e *ClientIface_Expecter) SetDeadline(t interface{}) *ClientIface_SetDeadline_Call

+ func (_e *ClientIface_Expecter) SetKeepAliveOptions(interval interface{}) *ClientIface_SetKeepAliveOptions_Call

+ func (_e *ClientIface_Expecter) SetReadDeadline(t interface{}) *ClientIface_SetReadDeadline_Call

+ func (_e *ClientIface_Expecter) SetReplica(r interface{}) *ClientIface_SetReplica_Call

+ func (_e *ClientIface_Expecter) SetSubdoc(vb interface{}, key interface{}, ops interface{}, context ...interface{}) *ClientIface_SetSubdoc_Call

+ func (_e *ClientIface_Expecter) Stats(key interface{}) *ClientIface_Stats_Call

+ func (_e *ClientIface_Expecter) StatsFunc(key interface{}, fn interface{}) *ClientIface_StatsFunc_Call

+ func (_e *ClientIface_Expecter) StatsMap(key interface{}) *ClientIface_StatsMap_Call

+ func (_e *ClientIface_Expecter) StatsMapForSpecifiedStats(key interface{}, statsMap interface{}) *ClientIface_StatsMapForSpecifiedStats_Call

+ func (_e *ClientIface_Expecter) Transmit(req interface{}) *ClientIface_Transmit_Call

+ func (_e *ClientIface_Expecter) TransmitResponse(res interface{}) *ClientIface_TransmitResponse_Call

+ func (_e *ClientIface_Expecter) TransmitWithDeadline(req interface{}, deadline interface{}) *ClientIface_TransmitWithDeadline_Call

+ func (_e *ClientIface_Expecter) UprGetFailoverLog(vb interface{}) *ClientIface_UprGetFailoverLog_Call

+ func (_e *ClientIface_Expecter) ValidateKey(vb interface{}, key interface{}, context ...interface{}) *ClientIface_ValidateKey_Call

+ type ClientIface_GetAllVbSeqnos_Call struct

+ func (_c *ClientIface_GetAllVbSeqnos_Call) Return(_a0 map[uint16]uint64, _a1 error) *ClientIface_GetAllVbSeqnos_Call

+ func (_c *ClientIface_GetAllVbSeqnos_Call) Run(run func(vbSeqnoMap map[uint16]uint64, context ...*memcached.ClientContext)) *ClientIface_GetAllVbSeqnos_Call

+ func (_c *ClientIface_GetAllVbSeqnos_Call) RunAndReturn(...) *ClientIface_GetAllVbSeqnos_Call

+ type ClientIface_GetAndTouch_Call struct

+ func (_c *ClientIface_GetAndTouch_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_GetAndTouch_Call

+ func (_c *ClientIface_GetAndTouch_Call) Run(run func(vb uint16, key string, exp int, context ...*memcached.ClientContext)) *ClientIface_GetAndTouch_Call

+ func (_c *ClientIface_GetAndTouch_Call) RunAndReturn(...) *ClientIface_GetAndTouch_Call

+ type ClientIface_GetBulk_Call struct

+ func (_c *ClientIface_GetBulk_Call) Return(_a0 error) *ClientIface_GetBulk_Call

+ func (_c *ClientIface_GetBulk_Call) Run(run func(vb uint16, keys []string, rv map[string]*gomemcached.MCResponse, ...)) *ClientIface_GetBulk_Call

+ func (_c *ClientIface_GetBulk_Call) RunAndReturn(...) *ClientIface_GetBulk_Call

+ type ClientIface_GetCollectionsManifest_Call struct

+ func (_c *ClientIface_GetCollectionsManifest_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_GetCollectionsManifest_Call

+ func (_c *ClientIface_GetCollectionsManifest_Call) Run(run func()) *ClientIface_GetCollectionsManifest_Call

+ func (_c *ClientIface_GetCollectionsManifest_Call) RunAndReturn(run func() (*gomemcached.MCResponse, error)) *ClientIface_GetCollectionsManifest_Call

+ type ClientIface_GetConnName_Call struct

+ func (_c *ClientIface_GetConnName_Call) Return(_a0 string) *ClientIface_GetConnName_Call

+ func (_c *ClientIface_GetConnName_Call) Run(run func()) *ClientIface_GetConnName_Call

+ func (_c *ClientIface_GetConnName_Call) RunAndReturn(run func() string) *ClientIface_GetConnName_Call

+ type ClientIface_GetErrorMap_Call struct

+ func (_c *ClientIface_GetErrorMap_Call) Return(_a0 map[string]interface{}, _a1 error) *ClientIface_GetErrorMap_Call

+ func (_c *ClientIface_GetErrorMap_Call) Run(run func(errMapVersion gomemcached.ErrorMapVersion)) *ClientIface_GetErrorMap_Call

+ func (_c *ClientIface_GetErrorMap_Call) RunAndReturn(run func(gomemcached.ErrorMapVersion) (map[string]interface{}, error)) *ClientIface_GetErrorMap_Call

+ type ClientIface_GetMeta_Call struct

+ func (_c *ClientIface_GetMeta_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_GetMeta_Call

+ func (_c *ClientIface_GetMeta_Call) Run(run func(vb uint16, key string, context ...*memcached.ClientContext)) *ClientIface_GetMeta_Call

+ func (_c *ClientIface_GetMeta_Call) RunAndReturn(...) *ClientIface_GetMeta_Call

+ type ClientIface_GetRandomDoc_Call struct

+ func (_c *ClientIface_GetRandomDoc_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_GetRandomDoc_Call

+ func (_c *ClientIface_GetRandomDoc_Call) Run(run func(context ...*memcached.ClientContext)) *ClientIface_GetRandomDoc_Call

+ func (_c *ClientIface_GetRandomDoc_Call) RunAndReturn(run func(...*memcached.ClientContext) (*gomemcached.MCResponse, error)) *ClientIface_GetRandomDoc_Call

+ type ClientIface_GetSubdoc_Call struct

+ func (_c *ClientIface_GetSubdoc_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_GetSubdoc_Call

+ func (_c *ClientIface_GetSubdoc_Call) Run(...) *ClientIface_GetSubdoc_Call

+ func (_c *ClientIface_GetSubdoc_Call) RunAndReturn(...) *ClientIface_GetSubdoc_Call

+ type ClientIface_Get_Call struct

+ func (_c *ClientIface_Get_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_Get_Call

+ func (_c *ClientIface_Get_Call) Run(run func(vb uint16, key string, context ...*memcached.ClientContext)) *ClientIface_Get_Call

+ func (_c *ClientIface_Get_Call) RunAndReturn(...) *ClientIface_Get_Call

+ type ClientIface_Hijack_Call struct

+ func (_c *ClientIface_Hijack_Call) Return(_a0 io.ReadWriteCloser) *ClientIface_Hijack_Call

+ func (_c *ClientIface_Hijack_Call) Run(run func()) *ClientIface_Hijack_Call

+ func (_c *ClientIface_Hijack_Call) RunAndReturn(run func() io.ReadWriteCloser) *ClientIface_Hijack_Call

+ type ClientIface_Incr_Call struct

+ func (_c *ClientIface_Incr_Call) Return(_a0 uint64, _a1 error) *ClientIface_Incr_Call

+ func (_c *ClientIface_Incr_Call) Run(run func(vb uint16, key string, amt uint64, def uint64, exp int, ...)) *ClientIface_Incr_Call

+ func (_c *ClientIface_Incr_Call) RunAndReturn(...) *ClientIface_Incr_Call

+ type ClientIface_LastBucket_Call struct

+ func (_c *ClientIface_LastBucket_Call) Return(_a0 string) *ClientIface_LastBucket_Call

+ func (_c *ClientIface_LastBucket_Call) Run(run func()) *ClientIface_LastBucket_Call

+ func (_c *ClientIface_LastBucket_Call) RunAndReturn(run func() string) *ClientIface_LastBucket_Call

+ type ClientIface_NewUprFeedIface_Call struct

+ func (_c *ClientIface_NewUprFeedIface_Call) Return(_a0 memcached.UprFeedIface, _a1 error) *ClientIface_NewUprFeedIface_Call

+ func (_c *ClientIface_NewUprFeedIface_Call) Run(run func()) *ClientIface_NewUprFeedIface_Call

+ func (_c *ClientIface_NewUprFeedIface_Call) RunAndReturn(run func() (memcached.UprFeedIface, error)) *ClientIface_NewUprFeedIface_Call

+ type ClientIface_NewUprFeedWithConfigIface_Call struct

+ func (_c *ClientIface_NewUprFeedWithConfigIface_Call) Return(_a0 memcached.UprFeedIface, _a1 error) *ClientIface_NewUprFeedWithConfigIface_Call

+ func (_c *ClientIface_NewUprFeedWithConfigIface_Call) Run(run func(ackByClient bool)) *ClientIface_NewUprFeedWithConfigIface_Call

+ func (_c *ClientIface_NewUprFeedWithConfigIface_Call) RunAndReturn(run func(bool) (memcached.UprFeedIface, error)) *ClientIface_NewUprFeedWithConfigIface_Call

+ type ClientIface_NewUprFeedWithConfig_Call struct

+ func (_c *ClientIface_NewUprFeedWithConfig_Call) Return(_a0 *memcached.UprFeed, _a1 error) *ClientIface_NewUprFeedWithConfig_Call

+ func (_c *ClientIface_NewUprFeedWithConfig_Call) Run(run func(ackByClient bool)) *ClientIface_NewUprFeedWithConfig_Call

+ func (_c *ClientIface_NewUprFeedWithConfig_Call) RunAndReturn(run func(bool) (*memcached.UprFeed, error)) *ClientIface_NewUprFeedWithConfig_Call

+ type ClientIface_NewUprFeed_Call struct

+ func (_c *ClientIface_NewUprFeed_Call) Return(_a0 *memcached.UprFeed, _a1 error) *ClientIface_NewUprFeed_Call

+ func (_c *ClientIface_NewUprFeed_Call) Run(run func()) *ClientIface_NewUprFeed_Call

+ func (_c *ClientIface_NewUprFeed_Call) RunAndReturn(run func() (*memcached.UprFeed, error)) *ClientIface_NewUprFeed_Call

+ type ClientIface_ObserveSeq_Call struct

+ func (_c *ClientIface_ObserveSeq_Call) Return(result *memcached.ObserveSeqResult, err error) *ClientIface_ObserveSeq_Call

+ func (_c *ClientIface_ObserveSeq_Call) Run(run func(vb uint16, vbuuid uint64)) *ClientIface_ObserveSeq_Call

+ func (_c *ClientIface_ObserveSeq_Call) RunAndReturn(run func(uint16, uint64) (*memcached.ObserveSeqResult, error)) *ClientIface_ObserveSeq_Call

+ type ClientIface_Observe_Call struct

+ func (_c *ClientIface_Observe_Call) Return(result memcached.ObserveResult, err error) *ClientIface_Observe_Call

+ func (_c *ClientIface_Observe_Call) Run(run func(vb uint16, key string)) *ClientIface_Observe_Call

+ func (_c *ClientIface_Observe_Call) RunAndReturn(run func(uint16, string) (memcached.ObserveResult, error)) *ClientIface_Observe_Call

+ type ClientIface_ReceiveWithDeadline_Call struct

+ func (_c *ClientIface_ReceiveWithDeadline_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_ReceiveWithDeadline_Call

+ func (_c *ClientIface_ReceiveWithDeadline_Call) Run(run func(deadline time.Time)) *ClientIface_ReceiveWithDeadline_Call

+ func (_c *ClientIface_ReceiveWithDeadline_Call) RunAndReturn(run func(time.Time) (*gomemcached.MCResponse, error)) *ClientIface_ReceiveWithDeadline_Call

+ type ClientIface_Receive_Call struct

+ func (_c *ClientIface_Receive_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_Receive_Call

+ func (_c *ClientIface_Receive_Call) Run(run func()) *ClientIface_Receive_Call

+ func (_c *ClientIface_Receive_Call) RunAndReturn(run func() (*gomemcached.MCResponse, error)) *ClientIface_Receive_Call

+ type ClientIface_Replica_Call struct

+ func (_c *ClientIface_Replica_Call) Return(_a0 bool) *ClientIface_Replica_Call

+ func (_c *ClientIface_Replica_Call) Run(run func()) *ClientIface_Replica_Call

+ func (_c *ClientIface_Replica_Call) RunAndReturn(run func() bool) *ClientIface_Replica_Call

+ type ClientIface_SelectBucket_Call struct

+ func (_c *ClientIface_SelectBucket_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_SelectBucket_Call

+ func (_c *ClientIface_SelectBucket_Call) Run(run func(bucket string)) *ClientIface_SelectBucket_Call

+ func (_c *ClientIface_SelectBucket_Call) RunAndReturn(run func(string) (*gomemcached.MCResponse, error)) *ClientIface_SelectBucket_Call

+ type ClientIface_Send_Call struct

+ func (_c *ClientIface_Send_Call) Return(rv *gomemcached.MCResponse, err error) *ClientIface_Send_Call

+ func (_c *ClientIface_Send_Call) Run(run func(req *gomemcached.MCRequest)) *ClientIface_Send_Call

+ func (_c *ClientIface_Send_Call) RunAndReturn(run func(*gomemcached.MCRequest) (*gomemcached.MCResponse, error)) *ClientIface_Send_Call

+ type ClientIface_SetCas_Call struct

+ func (_c *ClientIface_SetCas_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_SetCas_Call

+ func (_c *ClientIface_SetCas_Call) Run(...) *ClientIface_SetCas_Call

+ func (_c *ClientIface_SetCas_Call) RunAndReturn(...) *ClientIface_SetCas_Call

+ type ClientIface_SetConnName_Call struct

+ func (_c *ClientIface_SetConnName_Call) Return() *ClientIface_SetConnName_Call

+ func (_c *ClientIface_SetConnName_Call) Run(run func(name string)) *ClientIface_SetConnName_Call

+ func (_c *ClientIface_SetConnName_Call) RunAndReturn(run func(string)) *ClientIface_SetConnName_Call

+ type ClientIface_SetDeadline_Call struct

+ func (_c *ClientIface_SetDeadline_Call) Return() *ClientIface_SetDeadline_Call

+ func (_c *ClientIface_SetDeadline_Call) Run(run func(t time.Time)) *ClientIface_SetDeadline_Call

+ func (_c *ClientIface_SetDeadline_Call) RunAndReturn(run func(time.Time)) *ClientIface_SetDeadline_Call

+ type ClientIface_SetKeepAliveOptions_Call struct

+ func (_c *ClientIface_SetKeepAliveOptions_Call) Return() *ClientIface_SetKeepAliveOptions_Call

+ func (_c *ClientIface_SetKeepAliveOptions_Call) Run(run func(interval time.Duration)) *ClientIface_SetKeepAliveOptions_Call

+ func (_c *ClientIface_SetKeepAliveOptions_Call) RunAndReturn(run func(time.Duration)) *ClientIface_SetKeepAliveOptions_Call

+ type ClientIface_SetReadDeadline_Call struct

+ func (_c *ClientIface_SetReadDeadline_Call) Return() *ClientIface_SetReadDeadline_Call

+ func (_c *ClientIface_SetReadDeadline_Call) Run(run func(t time.Time)) *ClientIface_SetReadDeadline_Call

+ func (_c *ClientIface_SetReadDeadline_Call) RunAndReturn(run func(time.Time)) *ClientIface_SetReadDeadline_Call

+ type ClientIface_SetReplica_Call struct

+ func (_c *ClientIface_SetReplica_Call) Return() *ClientIface_SetReplica_Call

+ func (_c *ClientIface_SetReplica_Call) Run(run func(r bool)) *ClientIface_SetReplica_Call

+ func (_c *ClientIface_SetReplica_Call) RunAndReturn(run func(bool)) *ClientIface_SetReplica_Call

+ type ClientIface_SetSubdoc_Call struct

+ func (_c *ClientIface_SetSubdoc_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_SetSubdoc_Call

+ func (_c *ClientIface_SetSubdoc_Call) Run(run func(vb uint16, key string, ops []memcached.SubDocOp, ...)) *ClientIface_SetSubdoc_Call

+ func (_c *ClientIface_SetSubdoc_Call) RunAndReturn(...) *ClientIface_SetSubdoc_Call

+ type ClientIface_Set_Call struct

+ func (_c *ClientIface_Set_Call) Return(_a0 *gomemcached.MCResponse, _a1 error) *ClientIface_Set_Call

+ func (_c *ClientIface_Set_Call) Run(run func(vb uint16, key string, flags int, exp int, body []byte, ...)) *ClientIface_Set_Call

+ func (_c *ClientIface_Set_Call) RunAndReturn(...) *ClientIface_Set_Call

+ type ClientIface_StatsFunc_Call struct

+ func (_c *ClientIface_StatsFunc_Call) Return(_a0 error) *ClientIface_StatsFunc_Call

+ func (_c *ClientIface_StatsFunc_Call) Run(run func(key string, fn func([]byte, []byte))) *ClientIface_StatsFunc_Call

+ func (_c *ClientIface_StatsFunc_Call) RunAndReturn(run func(string, func([]byte, []byte)) error) *ClientIface_StatsFunc_Call

+ type ClientIface_StatsMapForSpecifiedStats_Call struct

+ func (_c *ClientIface_StatsMapForSpecifiedStats_Call) Return(_a0 error) *ClientIface_StatsMapForSpecifiedStats_Call

+ func (_c *ClientIface_StatsMapForSpecifiedStats_Call) Run(run func(key string, statsMap map[string]string)) *ClientIface_StatsMapForSpecifiedStats_Call

+ func (_c *ClientIface_StatsMapForSpecifiedStats_Call) RunAndReturn(run func(string, map[string]string) error) *ClientIface_StatsMapForSpecifiedStats_Call

+ type ClientIface_StatsMap_Call struct

+ func (_c *ClientIface_StatsMap_Call) Return(_a0 map[string]string, _a1 error) *ClientIface_StatsMap_Call

+ func (_c *ClientIface_StatsMap_Call) Run(run func(key string)) *ClientIface_StatsMap_Call

+ func (_c *ClientIface_StatsMap_Call) RunAndReturn(run func(string) (map[string]string, error)) *ClientIface_StatsMap_Call

+ type ClientIface_Stats_Call struct

+ func (_c *ClientIface_Stats_Call) Return(_a0 []memcached.StatValue, _a1 error) *ClientIface_Stats_Call

+ func (_c *ClientIface_Stats_Call) Run(run func(key string)) *ClientIface_Stats_Call

+ func (_c *ClientIface_Stats_Call) RunAndReturn(run func(string) ([]memcached.StatValue, error)) *ClientIface_Stats_Call

+ type ClientIface_TransmitResponse_Call struct

+ func (_c *ClientIface_TransmitResponse_Call) Return(_a0 error) *ClientIface_TransmitResponse_Call

+ func (_c *ClientIface_TransmitResponse_Call) Run(run func(res *gomemcached.MCResponse)) *ClientIface_TransmitResponse_Call

+ func (_c *ClientIface_TransmitResponse_Call) RunAndReturn(run func(*gomemcached.MCResponse) error) *ClientIface_TransmitResponse_Call

+ type ClientIface_TransmitWithDeadline_Call struct

+ func (_c *ClientIface_TransmitWithDeadline_Call) Return(_a0 error) *ClientIface_TransmitWithDeadline_Call

+ func (_c *ClientIface_TransmitWithDeadline_Call) Run(run func(req *gomemcached.MCRequest, deadline time.Time)) *ClientIface_TransmitWithDeadline_Call

+ func (_c *ClientIface_TransmitWithDeadline_Call) RunAndReturn(run func(*gomemcached.MCRequest, time.Time) error) *ClientIface_TransmitWithDeadline_Call

+ type ClientIface_Transmit_Call struct

+ func (_c *ClientIface_Transmit_Call) Return(_a0 error) *ClientIface_Transmit_Call

+ func (_c *ClientIface_Transmit_Call) Run(run func(req *gomemcached.MCRequest)) *ClientIface_Transmit_Call

+ func (_c *ClientIface_Transmit_Call) RunAndReturn(run func(*gomemcached.MCRequest) error) *ClientIface_Transmit_Call

+ type ClientIface_UprGetFailoverLog_Call struct

+ func (_c *ClientIface_UprGetFailoverLog_Call) Return(_a0 map[uint16]*memcached.FailoverLog, _a1 error) *ClientIface_UprGetFailoverLog_Call

+ func (_c *ClientIface_UprGetFailoverLog_Call) Run(run func(vb []uint16)) *ClientIface_UprGetFailoverLog_Call

+ func (_c *ClientIface_UprGetFailoverLog_Call) RunAndReturn(run func([]uint16) (map[uint16]*memcached.FailoverLog, error)) *ClientIface_UprGetFailoverLog_Call

+ type ClientIface_ValidateKey_Call struct

+ func (_c *ClientIface_ValidateKey_Call) Return(_a0 bool, _a1 error) *ClientIface_ValidateKey_Call

+ func (_c *ClientIface_ValidateKey_Call) Run(run func(vb uint16, key string, context ...*memcached.ClientContext)) *ClientIface_ValidateKey_Call

+ func (_c *ClientIface_ValidateKey_Call) RunAndReturn(run func(uint16, string, ...*memcached.ClientContext) (bool, error)) *ClientIface_ValidateKey_Call

type CollectionChangedEvent

+ func (_m *CollectionChangedEvent) EXPECT() *CollectionChangedEvent_Expecter

+ type CollectionChangedEvent_Expecter struct

+ func (_e *CollectionChangedEvent_Expecter) GetCollectionId() *CollectionChangedEvent_GetCollectionId_Call

+ func (_e *CollectionChangedEvent_Expecter) GetManifestId() *CollectionChangedEvent_GetManifestId_Call

+ func (_e *CollectionChangedEvent_Expecter) GetMaxTTL() *CollectionChangedEvent_GetMaxTTL_Call

+ type CollectionChangedEvent_GetCollectionId_Call struct

+ func (_c *CollectionChangedEvent_GetCollectionId_Call) Return(_a0 uint32, _a1 error) *CollectionChangedEvent_GetCollectionId_Call

+ func (_c *CollectionChangedEvent_GetCollectionId_Call) Run(run func()) *CollectionChangedEvent_GetCollectionId_Call

+ func (_c *CollectionChangedEvent_GetCollectionId_Call) RunAndReturn(run func() (uint32, error)) *CollectionChangedEvent_GetCollectionId_Call

+ type CollectionChangedEvent_GetManifestId_Call struct

+ func (_c *CollectionChangedEvent_GetManifestId_Call) Return(_a0 uint64, _a1 error) *CollectionChangedEvent_GetManifestId_Call

+ func (_c *CollectionChangedEvent_GetManifestId_Call) Run(run func()) *CollectionChangedEvent_GetManifestId_Call

+ func (_c *CollectionChangedEvent_GetManifestId_Call) RunAndReturn(run func() (uint64, error)) *CollectionChangedEvent_GetManifestId_Call

+ type CollectionChangedEvent_GetMaxTTL_Call struct

+ func (_c *CollectionChangedEvent_GetMaxTTL_Call) Return(_a0 uint32, _a1 error) *CollectionChangedEvent_GetMaxTTL_Call

+ func (_c *CollectionChangedEvent_GetMaxTTL_Call) Run(run func()) *CollectionChangedEvent_GetMaxTTL_Call

+ func (_c *CollectionChangedEvent_GetMaxTTL_Call) RunAndReturn(run func() (uint32, error)) *CollectionChangedEvent_GetMaxTTL_Call

type CollectionCreateEvent

+ func (_m *CollectionCreateEvent) EXPECT() *CollectionCreateEvent_Expecter

+ type CollectionCreateEvent_Expecter struct

+ func (_e *CollectionCreateEvent_Expecter) GetCollectionId() *CollectionCreateEvent_GetCollectionId_Call

+ func (_e *CollectionCreateEvent_Expecter) GetManifestId() *CollectionCreateEvent_GetManifestId_Call

+ func (_e *CollectionCreateEvent_Expecter) GetMaxTTL() *CollectionCreateEvent_GetMaxTTL_Call

+ func (_e *CollectionCreateEvent_Expecter) GetScopeId() *CollectionCreateEvent_GetScopeId_Call

+ func (_e *CollectionCreateEvent_Expecter) GetSystemEventName() *CollectionCreateEvent_GetSystemEventName_Call

+ type CollectionCreateEvent_GetCollectionId_Call struct

+ func (_c *CollectionCreateEvent_GetCollectionId_Call) Return(_a0 uint32, _a1 error) *CollectionCreateEvent_GetCollectionId_Call

+ func (_c *CollectionCreateEvent_GetCollectionId_Call) Run(run func()) *CollectionCreateEvent_GetCollectionId_Call

+ func (_c *CollectionCreateEvent_GetCollectionId_Call) RunAndReturn(run func() (uint32, error)) *CollectionCreateEvent_GetCollectionId_Call

+ type CollectionCreateEvent_GetManifestId_Call struct

+ func (_c *CollectionCreateEvent_GetManifestId_Call) Return(_a0 uint64, _a1 error) *CollectionCreateEvent_GetManifestId_Call

+ func (_c *CollectionCreateEvent_GetManifestId_Call) Run(run func()) *CollectionCreateEvent_GetManifestId_Call

+ func (_c *CollectionCreateEvent_GetManifestId_Call) RunAndReturn(run func() (uint64, error)) *CollectionCreateEvent_GetManifestId_Call

+ type CollectionCreateEvent_GetMaxTTL_Call struct

+ func (_c *CollectionCreateEvent_GetMaxTTL_Call) Return(_a0 uint32, _a1 error) *CollectionCreateEvent_GetMaxTTL_Call

+ func (_c *CollectionCreateEvent_GetMaxTTL_Call) Run(run func()) *CollectionCreateEvent_GetMaxTTL_Call

+ func (_c *CollectionCreateEvent_GetMaxTTL_Call) RunAndReturn(run func() (uint32, error)) *CollectionCreateEvent_GetMaxTTL_Call

+ type CollectionCreateEvent_GetScopeId_Call struct

+ func (_c *CollectionCreateEvent_GetScopeId_Call) Return(_a0 uint32, _a1 error) *CollectionCreateEvent_GetScopeId_Call

+ func (_c *CollectionCreateEvent_GetScopeId_Call) Run(run func()) *CollectionCreateEvent_GetScopeId_Call

+ func (_c *CollectionCreateEvent_GetScopeId_Call) RunAndReturn(run func() (uint32, error)) *CollectionCreateEvent_GetScopeId_Call

+ type CollectionCreateEvent_GetSystemEventName_Call struct

+ func (_c *CollectionCreateEvent_GetSystemEventName_Call) Return(_a0 string, _a1 error) *CollectionCreateEvent_GetSystemEventName_Call

+ func (_c *CollectionCreateEvent_GetSystemEventName_Call) Run(run func()) *CollectionCreateEvent_GetSystemEventName_Call

+ func (_c *CollectionCreateEvent_GetSystemEventName_Call) RunAndReturn(run func() (string, error)) *CollectionCreateEvent_GetSystemEventName_Call

type CollectionDropEvent

+ func (_m *CollectionDropEvent) EXPECT() *CollectionDropEvent_Expecter

+ type CollectionDropEvent_Expecter struct

+ func (_e *CollectionDropEvent_Expecter) GetCollectionId() *CollectionDropEvent_GetCollectionId_Call

+ func (_e *CollectionDropEvent_Expecter) GetManifestId() *CollectionDropEvent_GetManifestId_Call

+ func (_e *CollectionDropEvent_Expecter) GetScopeId() *CollectionDropEvent_GetScopeId_Call

+ type CollectionDropEvent_GetCollectionId_Call struct

+ func (_c *CollectionDropEvent_GetCollectionId_Call) Return(_a0 uint32, _a1 error) *CollectionDropEvent_GetCollectionId_Call

+ func (_c *CollectionDropEvent_GetCollectionId_Call) Run(run func()) *CollectionDropEvent_GetCollectionId_Call

+ func (_c *CollectionDropEvent_GetCollectionId_Call) RunAndReturn(run func() (uint32, error)) *CollectionDropEvent_GetCollectionId_Call

+ type CollectionDropEvent_GetManifestId_Call struct

+ func (_c *CollectionDropEvent_GetManifestId_Call) Return(_a0 uint64, _a1 error) *CollectionDropEvent_GetManifestId_Call

+ func (_c *CollectionDropEvent_GetManifestId_Call) Run(run func()) *CollectionDropEvent_GetManifestId_Call

+ func (_c *CollectionDropEvent_GetManifestId_Call) RunAndReturn(run func() (uint64, error)) *CollectionDropEvent_GetManifestId_Call

+ type CollectionDropEvent_GetScopeId_Call struct

+ func (_c *CollectionDropEvent_GetScopeId_Call) Return(_a0 uint32, _a1 error) *CollectionDropEvent_GetScopeId_Call

+ func (_c *CollectionDropEvent_GetScopeId_Call) Run(run func()) *CollectionDropEvent_GetScopeId_Call

+ func (_c *CollectionDropEvent_GetScopeId_Call) RunAndReturn(run func() (uint32, error)) *CollectionDropEvent_GetScopeId_Call

type ScopeCreateEvent

+ func (_m *ScopeCreateEvent) EXPECT() *ScopeCreateEvent_Expecter

+ type ScopeCreateEvent_Expecter struct

+ func (_e *ScopeCreateEvent_Expecter) GetManifestId() *ScopeCreateEvent_GetManifestId_Call

+ func (_e *ScopeCreateEvent_Expecter) GetScopeId() *ScopeCreateEvent_GetScopeId_Call

+ func (_e *ScopeCreateEvent_Expecter) GetSystemEventName() *ScopeCreateEvent_GetSystemEventName_Call

+ type ScopeCreateEvent_GetManifestId_Call struct

+ func (_c *ScopeCreateEvent_GetManifestId_Call) Return(_a0 uint64, _a1 error) *ScopeCreateEvent_GetManifestId_Call

+ func (_c *ScopeCreateEvent_GetManifestId_Call) Run(run func()) *ScopeCreateEvent_GetManifestId_Call

+ func (_c *ScopeCreateEvent_GetManifestId_Call) RunAndReturn(run func() (uint64, error)) *ScopeCreateEvent_GetManifestId_Call

+ type ScopeCreateEvent_GetScopeId_Call struct

+ func (_c *ScopeCreateEvent_GetScopeId_Call) Return(_a0 uint32, _a1 error) *ScopeCreateEvent_GetScopeId_Call

+ func (_c *ScopeCreateEvent_GetScopeId_Call) Run(run func()) *ScopeCreateEvent_GetScopeId_Call

+ func (_c *ScopeCreateEvent_GetScopeId_Call) RunAndReturn(run func() (uint32, error)) *ScopeCreateEvent_GetScopeId_Call

+ type ScopeCreateEvent_GetSystemEventName_Call struct

+ func (_c *ScopeCreateEvent_GetSystemEventName_Call) Return(_a0 string, _a1 error) *ScopeCreateEvent_GetSystemEventName_Call

+ func (_c *ScopeCreateEvent_GetSystemEventName_Call) Run(run func()) *ScopeCreateEvent_GetSystemEventName_Call

+ func (_c *ScopeCreateEvent_GetSystemEventName_Call) RunAndReturn(run func() (string, error)) *ScopeCreateEvent_GetSystemEventName_Call

type ScopeDropEvent

+ func (_m *ScopeDropEvent) EXPECT() *ScopeDropEvent_Expecter

+ type ScopeDropEvent_Expecter struct

+ func (_e *ScopeDropEvent_Expecter) GetManifestId() *ScopeDropEvent_GetManifestId_Call

+ func (_e *ScopeDropEvent_Expecter) GetScopeId() *ScopeDropEvent_GetScopeId_Call

+ type ScopeDropEvent_GetManifestId_Call struct

+ func (_c *ScopeDropEvent_GetManifestId_Call) Return(_a0 uint64, _a1 error) *ScopeDropEvent_GetManifestId_Call

+ func (_c *ScopeDropEvent_GetManifestId_Call) Run(run func()) *ScopeDropEvent_GetManifestId_Call

+ func (_c *ScopeDropEvent_GetManifestId_Call) RunAndReturn(run func() (uint64, error)) *ScopeDropEvent_GetManifestId_Call

+ type ScopeDropEvent_GetScopeId_Call struct

+ func (_c *ScopeDropEvent_GetScopeId_Call) Return(_a0 uint32, _a1 error) *ScopeDropEvent_GetScopeId_Call

+ func (_c *ScopeDropEvent_GetScopeId_Call) Run(run func()) *ScopeDropEvent_GetScopeId_Call

+ func (_c *ScopeDropEvent_GetScopeId_Call) RunAndReturn(run func() (uint32, error)) *ScopeDropEvent_GetScopeId_Call

type UprFeedIface

+ func (_m *UprFeedIface) EXPECT() *UprFeedIface_Expecter

+ type UprFeedIface_ClientAck_Call struct

+ func (_c *UprFeedIface_ClientAck_Call) Return(_a0 error) *UprFeedIface_ClientAck_Call

+ func (_c *UprFeedIface_ClientAck_Call) Run(run func(event *memcached.UprEvent)) *UprFeedIface_ClientAck_Call

+ func (_c *UprFeedIface_ClientAck_Call) RunAndReturn(run func(*memcached.UprEvent) error) *UprFeedIface_ClientAck_Call

+ type UprFeedIface_CloseStream_Call struct

+ func (_c *UprFeedIface_CloseStream_Call) Return(_a0 error) *UprFeedIface_CloseStream_Call

+ func (_c *UprFeedIface_CloseStream_Call) Run(run func(vbno uint16, opaqueMSB uint16)) *UprFeedIface_CloseStream_Call

+ func (_c *UprFeedIface_CloseStream_Call) RunAndReturn(run func(uint16, uint16) error) *UprFeedIface_CloseStream_Call

+ type UprFeedIface_Close_Call struct

+ func (_c *UprFeedIface_Close_Call) Return() *UprFeedIface_Close_Call

+ func (_c *UprFeedIface_Close_Call) Run(run func()) *UprFeedIface_Close_Call

+ func (_c *UprFeedIface_Close_Call) RunAndReturn(run func()) *UprFeedIface_Close_Call

+ type UprFeedIface_Closed_Call struct

+ func (_c *UprFeedIface_Closed_Call) Return(_a0 bool) *UprFeedIface_Closed_Call

+ func (_c *UprFeedIface_Closed_Call) Run(run func()) *UprFeedIface_Closed_Call

+ func (_c *UprFeedIface_Closed_Call) RunAndReturn(run func() bool) *UprFeedIface_Closed_Call

+ type UprFeedIface_Expecter struct

+ func (_e *UprFeedIface_Expecter) ClientAck(event interface{}) *UprFeedIface_ClientAck_Call

+ func (_e *UprFeedIface_Expecter) Close() *UprFeedIface_Close_Call

+ func (_e *UprFeedIface_Expecter) CloseStream(vbno interface{}, opaqueMSB interface{}) *UprFeedIface_CloseStream_Call

+ func (_e *UprFeedIface_Expecter) Closed() *UprFeedIface_Closed_Call

+ func (_e *UprFeedIface_Expecter) GetError() *UprFeedIface_GetError_Call

+ func (_e *UprFeedIface_Expecter) GetUprEventCh() *UprFeedIface_GetUprEventCh_Call

+ func (_e *UprFeedIface_Expecter) GetUprStats() *UprFeedIface_GetUprStats_Call

+ func (_e *UprFeedIface_Expecter) SetPriorityAsync(p interface{}) *UprFeedIface_SetPriorityAsync_Call

+ func (_e *UprFeedIface_Expecter) StartFeed() *UprFeedIface_StartFeed_Call

+ func (_e *UprFeedIface_Expecter) StartFeedWithConfig(datachan_len interface{}) *UprFeedIface_StartFeedWithConfig_Call

+ func (_e *UprFeedIface_Expecter) UprOpen(name interface{}, sequence interface{}, bufSize interface{}) *UprFeedIface_UprOpen_Call

+ func (_e *UprFeedIface_Expecter) UprOpenWithFeatures(name interface{}, sequence interface{}, bufSize interface{}, ...) *UprFeedIface_UprOpenWithFeatures_Call

+ func (_e *UprFeedIface_Expecter) UprOpenWithXATTR(name interface{}, sequence interface{}, bufSize interface{}) *UprFeedIface_UprOpenWithXATTR_Call

+ func (_e *UprFeedIface_Expecter) UprRequestCollectionsStream(vbno interface{}, opaqueMSB interface{}, flags interface{}, vbuuid interface{}, ...) *UprFeedIface_UprRequestCollectionsStream_Call

+ func (_e *UprFeedIface_Expecter) UprRequestStream(vbno interface{}, opaqueMSB interface{}, flags interface{}, vuuid interface{}, ...) *UprFeedIface_UprRequestStream_Call

+ type UprFeedIface_GetError_Call struct

+ func (_c *UprFeedIface_GetError_Call) Return(_a0 error) *UprFeedIface_GetError_Call

+ func (_c *UprFeedIface_GetError_Call) Run(run func()) *UprFeedIface_GetError_Call

+ func (_c *UprFeedIface_GetError_Call) RunAndReturn(run func() error) *UprFeedIface_GetError_Call

+ type UprFeedIface_GetUprEventCh_Call struct

+ func (_c *UprFeedIface_GetUprEventCh_Call) Return(_a0 <-chan *memcached.UprEvent) *UprFeedIface_GetUprEventCh_Call

+ func (_c *UprFeedIface_GetUprEventCh_Call) Run(run func()) *UprFeedIface_GetUprEventCh_Call

+ func (_c *UprFeedIface_GetUprEventCh_Call) RunAndReturn(run func() <-chan *memcached.UprEvent) *UprFeedIface_GetUprEventCh_Call

+ type UprFeedIface_GetUprStats_Call struct

+ func (_c *UprFeedIface_GetUprStats_Call) Return(_a0 *memcached.UprStats) *UprFeedIface_GetUprStats_Call

+ func (_c *UprFeedIface_GetUprStats_Call) Run(run func()) *UprFeedIface_GetUprStats_Call

+ func (_c *UprFeedIface_GetUprStats_Call) RunAndReturn(run func() *memcached.UprStats) *UprFeedIface_GetUprStats_Call

+ type UprFeedIface_SetPriorityAsync_Call struct

+ func (_c *UprFeedIface_SetPriorityAsync_Call) Return(_a0 error) *UprFeedIface_SetPriorityAsync_Call

+ func (_c *UprFeedIface_SetPriorityAsync_Call) Run(run func(p memcached.PriorityType)) *UprFeedIface_SetPriorityAsync_Call

+ func (_c *UprFeedIface_SetPriorityAsync_Call) RunAndReturn(run func(memcached.PriorityType) error) *UprFeedIface_SetPriorityAsync_Call

+ type UprFeedIface_StartFeedWithConfig_Call struct

+ func (_c *UprFeedIface_StartFeedWithConfig_Call) Return(_a0 error) *UprFeedIface_StartFeedWithConfig_Call

+ func (_c *UprFeedIface_StartFeedWithConfig_Call) Run(run func(datachan_len int)) *UprFeedIface_StartFeedWithConfig_Call

+ func (_c *UprFeedIface_StartFeedWithConfig_Call) RunAndReturn(run func(int) error) *UprFeedIface_StartFeedWithConfig_Call

+ type UprFeedIface_StartFeed_Call struct

+ func (_c *UprFeedIface_StartFeed_Call) Return(_a0 error) *UprFeedIface_StartFeed_Call

+ func (_c *UprFeedIface_StartFeed_Call) Run(run func()) *UprFeedIface_StartFeed_Call

+ func (_c *UprFeedIface_StartFeed_Call) RunAndReturn(run func() error) *UprFeedIface_StartFeed_Call

+ type UprFeedIface_UprOpenWithFeatures_Call struct

+ func (_c *UprFeedIface_UprOpenWithFeatures_Call) Return(_a0 error, _a1 memcached.UprFeatures) *UprFeedIface_UprOpenWithFeatures_Call

+ func (_c *UprFeedIface_UprOpenWithFeatures_Call) Run(...) *UprFeedIface_UprOpenWithFeatures_Call

+ func (_c *UprFeedIface_UprOpenWithFeatures_Call) RunAndReturn(...) *UprFeedIface_UprOpenWithFeatures_Call

+ type UprFeedIface_UprOpenWithXATTR_Call struct

+ func (_c *UprFeedIface_UprOpenWithXATTR_Call) Return(_a0 error) *UprFeedIface_UprOpenWithXATTR_Call

+ func (_c *UprFeedIface_UprOpenWithXATTR_Call) Run(run func(name string, sequence uint32, bufSize uint32)) *UprFeedIface_UprOpenWithXATTR_Call

+ func (_c *UprFeedIface_UprOpenWithXATTR_Call) RunAndReturn(run func(string, uint32, uint32) error) *UprFeedIface_UprOpenWithXATTR_Call

+ type UprFeedIface_UprOpen_Call struct

+ func (_c *UprFeedIface_UprOpen_Call) Return(_a0 error) *UprFeedIface_UprOpen_Call

+ func (_c *UprFeedIface_UprOpen_Call) Run(run func(name string, sequence uint32, bufSize uint32)) *UprFeedIface_UprOpen_Call

+ func (_c *UprFeedIface_UprOpen_Call) RunAndReturn(run func(string, uint32, uint32) error) *UprFeedIface_UprOpen_Call

+ type UprFeedIface_UprRequestCollectionsStream_Call struct

+ func (_c *UprFeedIface_UprRequestCollectionsStream_Call) Return(_a0 error) *UprFeedIface_UprRequestCollectionsStream_Call

+ func (_c *UprFeedIface_UprRequestCollectionsStream_Call) Run(...) *UprFeedIface_UprRequestCollectionsStream_Call

+ func (_c *UprFeedIface_UprRequestCollectionsStream_Call) RunAndReturn(...) *UprFeedIface_UprRequestCollectionsStream_Call

+ type UprFeedIface_UprRequestStream_Call struct

+ func (_c *UprFeedIface_UprRequestStream_Call) Return(_a0 error) *UprFeedIface_UprRequestStream_Call

+ func (_c *UprFeedIface_UprRequestStream_Call) Run(run func(vbno uint16, opaqueMSB uint16, flags uint32, vuuid uint64, ...)) *UprFeedIface_UprRequestStream_Call

+ func (_c *UprFeedIface_UprRequestStream_Call) RunAndReturn(run func(uint16, uint16, uint32, uint64, uint64, uint64, uint64, uint64) error) *UprFeedIface_UprRequestStream_Call

v0.2.1

Nov 2, 2022

Changes in this version

type CasFunc

+ func NewCasFunc(t mockConstructorTestingTNewCasFunc) *CasFunc

type ClientIface

+ func NewClientIface(t mockConstructorTestingTNewClientIface) *ClientIface

+ func (_m *ClientIface) CancelRangeScan(vb uint16, uuid []byte, opaque uint32, context ...*memcached.ClientContext) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) ContinueRangeScan(vb uint16, uuid []byte, opaque uint32, items uint32, maxSize uint32, ...) error

+ func (_m *ClientIface) CreateRandomScan(vb uint16, collId uint32, sampleSize int, context ...*memcached.ClientContext) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) CreateRangeScan(vb uint16, collId uint32, start []byte, excludeStart bool, end []byte, ...) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) ValidateKey(vb uint16, key string, context ...*memcached.ClientContext) (bool, error)

type CollectionChangedEvent

+ func NewCollectionChangedEvent(t mockConstructorTestingTNewCollectionChangedEvent) *CollectionChangedEvent

type CollectionCreateEvent

+ func NewCollectionCreateEvent(t mockConstructorTestingTNewCollectionCreateEvent) *CollectionCreateEvent

type CollectionDropEvent

+ func NewCollectionDropEvent(t mockConstructorTestingTNewCollectionDropEvent) *CollectionDropEvent

type ScopeCreateEvent

+ func NewScopeCreateEvent(t mockConstructorTestingTNewScopeCreateEvent) *ScopeCreateEvent

type ScopeDropEvent

+ func NewScopeDropEvent(t mockConstructorTestingTNewScopeDropEvent) *ScopeDropEvent

type UprFeedIface

+ func NewUprFeedIface(t mockConstructorTestingTNewUprFeedIface) *UprFeedIface

v0.1.4

Sep 30, 2021

Changes in this version

+ type CasFunc struct

+ func (_m *CasFunc) Execute(current []byte) ([]byte, memcached.CasOp)

type ClientIface

+ func (_m *ClientIface) SetReplica(r bool)

v0.1.3

Apr 16, 2021

v0.1.2

Feb 5, 2021

Changes in this version

type ClientIface

+ func (_m *ClientIface) LastBucket() string

+ func (_m *ClientIface) StatsFunc(key string, fn func([]byte, []byte)) error

v0.1.1

Nov 9, 2020

v0.1.0

May 11, 2020

Changes in this version

+ type ClientIface struct

+ func (_m *ClientIface) Add(vb uint16, key string, flags int, exp int, body []byte, ...) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) Append(vb uint16, key string, data []byte, context ...*memcached.ClientContext) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) Auth(user string, pass string) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) AuthList() (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) AuthPlain(user string, pass string) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) AuthScramSha(user string, pass string) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) CAS(vb uint16, k string, f memcached.CasFunc, initexp int) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) CASNext(vb uint16, k string, exp int, state *memcached.CASState) bool

+ func (_m *ClientIface) Close() error

+ func (_m *ClientIface) CollectionEnabled() bool

+ func (_m *ClientIface) CollectionsGetCID(scope string, collection string) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) Decr(vb uint16, key string, amt uint64, def uint64, exp int, ...) (uint64, error)

+ func (_m *ClientIface) Del(vb uint16, key string, context ...*memcached.ClientContext) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) EnableFeatures(features memcached.Features) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) EnableMutationToken() (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) Get(vb uint16, key string, context ...*memcached.ClientContext) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) GetAllVbSeqnos(vbSeqnoMap map[uint16]uint64, context ...*memcached.ClientContext) (map[uint16]uint64, error)

+ func (_m *ClientIface) GetAndTouch(vb uint16, key string, exp int, context ...*memcached.ClientContext) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) GetBulk(vb uint16, keys []string, rv map[string]*gomemcached.MCResponse, ...) error

+ func (_m *ClientIface) GetCollectionsManifest() (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) GetMeta(vb uint16, key string, context ...*memcached.ClientContext) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) GetRandomDoc(context ...*memcached.ClientContext) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) GetSubdoc(vb uint16, key string, subPaths []string, context ...*memcached.ClientContext) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) Hijack() io.ReadWriteCloser

+ func (_m *ClientIface) Incr(vb uint16, key string, amt uint64, def uint64, exp int, ...) (uint64, error)

+ func (_m *ClientIface) NewUprFeed() (*memcached.UprFeed, error)

+ func (_m *ClientIface) NewUprFeedIface() (memcached.UprFeedIface, error)

+ func (_m *ClientIface) NewUprFeedWithConfig(ackByClient bool) (*memcached.UprFeed, error)

+ func (_m *ClientIface) NewUprFeedWithConfigIface(ackByClient bool) (memcached.UprFeedIface, error)

+ func (_m *ClientIface) Observe(vb uint16, key string) (memcached.ObserveResult, error)

+ func (_m *ClientIface) ObserveSeq(vb uint16, vbuuid uint64) (*memcached.ObserveSeqResult, error)

+ func (_m *ClientIface) Receive() (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) ReceiveWithDeadline(deadline time.Time) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) SelectBucket(bucket string) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) Send(req *gomemcached.MCRequest) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) Set(vb uint16, key string, flags int, exp int, body []byte, ...) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) SetCas(vb uint16, key string, flags int, exp int, cas uint64, body []byte, ...) (*gomemcached.MCResponse, error)

+ func (_m *ClientIface) SetDeadline(t time.Time)

+ func (_m *ClientIface) SetKeepAliveOptions(interval time.Duration)

+ func (_m *ClientIface) SetReadDeadline(t time.Time)

+ func (_m *ClientIface) Stats(key string) ([]memcached.StatValue, error)

+ func (_m *ClientIface) StatsMap(key string) (map[string]string, error)

+ func (_m *ClientIface) StatsMapForSpecifiedStats(key string, statsMap map[string]string) error

+ func (_m *ClientIface) Transmit(req *gomemcached.MCRequest) error

+ func (_m *ClientIface) TransmitResponse(res *gomemcached.MCResponse) error

+ func (_m *ClientIface) TransmitWithDeadline(req *gomemcached.MCRequest, deadline time.Time) error

+ func (_m *ClientIface) UprGetFailoverLog(vb []uint16) (map[uint16]*memcached.FailoverLog, error)

+ type CollectionChangedEvent struct

+ func (_m *CollectionChangedEvent) GetCollectionId() (uint32, error)

+ func (_m *CollectionChangedEvent) GetManifestId() (uint64, error)

+ func (_m *CollectionChangedEvent) GetMaxTTL() (uint32, error)

+ type CollectionCreateEvent struct

+ func (_m *CollectionCreateEvent) GetCollectionId() (uint32, error)

+ func (_m *CollectionCreateEvent) GetManifestId() (uint64, error)

+ func (_m *CollectionCreateEvent) GetMaxTTL() (uint32, error)

+ func (_m *CollectionCreateEvent) GetScopeId() (uint32, error)

+ func (_m *CollectionCreateEvent) GetSystemEventName() (string, error)

+ type CollectionDropEvent struct

+ func (_m *CollectionDropEvent) GetCollectionId() (uint32, error)

+ func (_m *CollectionDropEvent) GetManifestId() (uint64, error)

+ func (_m *CollectionDropEvent) GetScopeId() (uint32, error)

+ type ScopeCreateEvent struct

+ func (_m *ScopeCreateEvent) GetManifestId() (uint64, error)

+ func (_m *ScopeCreateEvent) GetScopeId() (uint32, error)

+ func (_m *ScopeCreateEvent) GetSystemEventName() (string, error)

+ type ScopeDropEvent struct

+ func (_m *ScopeDropEvent) GetManifestId() (uint64, error)

+ func (_m *ScopeDropEvent) GetScopeId() (uint32, error)

+ type UprFeedIface struct

+ func (_m *UprFeedIface) ClientAck(event *memcached.UprEvent) error

+ func (_m *UprFeedIface) Close()

+ func (_m *UprFeedIface) CloseStream(vbno uint16, opaqueMSB uint16) error

+ func (_m *UprFeedIface) Closed() bool

+ func (_m *UprFeedIface) GetError() error

+ func (_m *UprFeedIface) GetUprEventCh() <-chan *memcached.UprEvent

+ func (_m *UprFeedIface) GetUprStats() *memcached.UprStats

+ func (_m *UprFeedIface) SetPriorityAsync(p memcached.PriorityType) error

+ func (_m *UprFeedIface) StartFeed() error

+ func (_m *UprFeedIface) StartFeedWithConfig(datachan_len int) error

+ func (_m *UprFeedIface) UprOpen(name string, sequence uint32, bufSize uint32) error

+ func (_m *UprFeedIface) UprOpenWithFeatures(name string, sequence uint32, bufSize uint32, features memcached.UprFeatures) (error, memcached.UprFeatures)

+ func (_m *UprFeedIface) UprOpenWithXATTR(name string, sequence uint32, bufSize uint32) error

+ func (_m *UprFeedIface) UprRequestCollectionsStream(vbno uint16, opaqueMSB uint16, flags uint32, vbuuid uint64, startSeq uint64, ...) error

+ func (_m *UprFeedIface) UprRequestStream(vbno uint16, opaqueMSB uint16, flags uint32, vuuid uint64, ...) error

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