mocks

Documentation

Index

• type CasFunc
  • func NewCasFunc(t interface{ ... }) *CasFunc
  • func (_m *CasFunc) EXPECT() *CasFunc_Expecter
  • func (_m *CasFunc) Execute(current []byte) ([]byte, memcached.CasOp)
• type CasFunc_Execute_Call
  • 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
  • func (_e *CasFunc_Expecter) Execute(current interface{}) *CasFunc_Execute_Call
• type ClientIface
  • func NewClientIface(t interface{ ... }) *ClientIface
  • 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) CancelRangeScan(vb uint16, uuid []byte, opaque uint32, context ...*memcached.ClientContext) (*gomemcached.MCResponse, error)
  • func (_m *ClientIface) Close() error
  • func (_m *ClientIface) CollectionEnabled() bool
  • func (_m *ClientIface) CollectionsGetCID(scope string, collection string) (*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, withDocs bool, ...) (*gomemcached.MCResponse, error)
  • func (_m *ClientIface) CreateRangeScan(vb uint16, collId uint32, start []byte, excludeStart bool, end []byte, ...) (*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) EXPECT() *ClientIface_Expecter
  • func (_m *ClientIface) EnableDataPool(getter func(uint64) ([]byte, error), doneCb func([]byte)) 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) GetConnName() string
  • func (_m *ClientIface) GetErrorMap(errMapVersion gomemcached.ErrorMapVersion) (map[string]interface{}, 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) LastBucket() string
  • 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) Replica() bool
  • 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) SetConnName(name string)
  • func (_m *ClientIface) SetDeadline(t time.Time)
  • func (_m *ClientIface) SetKeepAliveOptions(interval time.Duration)
  • func (_m *ClientIface) SetReadDeadline(t time.Time)
  • func (_m *ClientIface) SetReplica(r bool)
  • func (_m *ClientIface) SetSubdoc(vb uint16, key string, ops []memcached.SubDocOp, ...) (*gomemcached.MCResponse, error)
  • func (_m *ClientIface) Stats(key string) ([]memcached.StatValue, error)
  • func (_m *ClientIface) StatsFunc(key string, fn func([]byte, []byte)) 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)
  • func (_m *ClientIface) ValidateKey(vb uint16, key string, context ...*memcached.ClientContext) (bool, error)
• type ClientIface_Add_Call
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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_EnableDataPool_Call
  • 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_EnableFeatures_Call
  • 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
  • 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
  • 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) EnableDataPool(getter interface{}, doneCb interface{}) *ClientIface_EnableDataPool_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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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 NewCollectionChangedEvent(t interface{ ... }) *CollectionChangedEvent
  • func (_m *CollectionChangedEvent) EXPECT() *CollectionChangedEvent_Expecter
  • func (_m *CollectionChangedEvent) GetCollectionId() (uint32, error)
  • func (_m *CollectionChangedEvent) GetManifestId() (uint64, error)
  • func (_m *CollectionChangedEvent) GetMaxTTL() (uint32, error)
• type CollectionChangedEvent_Expecter
  • 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
  • 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
  • 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
  • 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 NewCollectionCreateEvent(t interface{ ... }) *CollectionCreateEvent
  • func (_m *CollectionCreateEvent) EXPECT() *CollectionCreateEvent_Expecter
  • 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 CollectionCreateEvent_Expecter
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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 NewCollectionDropEvent(t interface{ ... }) *CollectionDropEvent
  • func (_m *CollectionDropEvent) EXPECT() *CollectionDropEvent_Expecter
  • func (_m *CollectionDropEvent) GetCollectionId() (uint32, error)
  • func (_m *CollectionDropEvent) GetManifestId() (uint64, error)
  • func (_m *CollectionDropEvent) GetScopeId() (uint32, error)
• type CollectionDropEvent_Expecter
  • 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
  • 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
  • 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
  • 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 NewScopeCreateEvent(t interface{ ... }) *ScopeCreateEvent
  • func (_m *ScopeCreateEvent) EXPECT() *ScopeCreateEvent_Expecter
  • func (_m *ScopeCreateEvent) GetManifestId() (uint64, error)
  • func (_m *ScopeCreateEvent) GetScopeId() (uint32, error)
  • func (_m *ScopeCreateEvent) GetSystemEventName() (string, error)
• type ScopeCreateEvent_Expecter
  • 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
  • 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
  • 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
  • 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 NewScopeDropEvent(t interface{ ... }) *ScopeDropEvent
  • func (_m *ScopeDropEvent) EXPECT() *ScopeDropEvent_Expecter
  • func (_m *ScopeDropEvent) GetManifestId() (uint64, error)
  • func (_m *ScopeDropEvent) GetScopeId() (uint32, error)
• type ScopeDropEvent_Expecter
  • func (_e *ScopeDropEvent_Expecter) GetManifestId() *ScopeDropEvent_GetManifestId_Call
  • func (_e *ScopeDropEvent_Expecter) GetScopeId() *ScopeDropEvent_GetScopeId_Call
• type ScopeDropEvent_GetManifestId_Call
  • 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
  • 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 NewUprFeedIface(t interface{ ... }) *UprFeedIface
  • 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) EXPECT() *UprFeedIface_Expecter
  • 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
• type UprFeedIface_ClientAck_Call
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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
  • 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

Types

type CasFunc

type CasFunc struct {
	mock.Mock
}

CasFunc is an autogenerated mock type for the CasFunc type

func NewCasFunc

func NewCasFunc(t interface {
	mock.TestingT
	Cleanup(func())
}) *CasFunc

NewCasFunc creates a new instance of CasFunc. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*CasFunc) EXPECT

func (_m *CasFunc) EXPECT() *CasFunc_Expecter

func (*CasFunc) Execute

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

Execute provides a mock function with given fields: current

type CasFunc_Execute_Call

type CasFunc_Execute_Call struct {
	*mock.Call
}

CasFunc_Execute_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Execute'

func (*CasFunc_Execute_Call) Return

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

func (*CasFunc_Execute_Call) Run

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

func (*CasFunc_Execute_Call) RunAndReturn

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

type CasFunc_Expecter

type CasFunc_Expecter struct {
	// contains filtered or unexported fields
}

func (*CasFunc_Expecter) Execute

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

Execute is a helper method to define mock.On call

• current []byte

type ClientIface

type ClientIface struct {
	mock.Mock
}

ClientIface is an autogenerated mock type for the ClientIface type

func NewClientIface

func NewClientIface(t interface {
	mock.TestingT
	Cleanup(func())
}) *ClientIface

NewClientIface creates a new instance of ClientIface. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ClientIface) Add

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

Add provides a mock function with given fields: vb, key, flags, exp, body, context

func (*ClientIface) Append

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

Append provides a mock function with given fields: vb, key, data, context

func (*ClientIface) Auth

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

Auth provides a mock function with given fields: user, pass

func (*ClientIface) AuthList

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

AuthList provides a mock function with given fields:

func (*ClientIface) AuthPlain

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

AuthPlain provides a mock function with given fields: user, pass

func (*ClientIface) AuthScramSha

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

AuthScramSha provides a mock function with given fields: user, pass

func (*ClientIface) CAS

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

CAS provides a mock function with given fields: vb, k, f, initexp

func (*ClientIface) CASNext

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

CASNext provides a mock function with given fields: vb, k, exp, state

func (*ClientIface) CancelRangeScan

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

CancelRangeScan provides a mock function with given fields: vb, uuid, opaque, context

func (*ClientIface) Close

func (_m *ClientIface) Close() error

Close provides a mock function with given fields:

func (*ClientIface) CollectionEnabled

func (_m *ClientIface) CollectionEnabled() bool

CollectionEnabled provides a mock function with given fields:

func (*ClientIface) CollectionsGetCID

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

CollectionsGetCID provides a mock function with given fields: scope, collection

func (*ClientIface) ContinueRangeScan

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

ContinueRangeScan provides a mock function with given fields: vb, uuid, opaque, items, maxSize, timeout, context

func (*ClientIface) CreateRandomScan

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

CreateRandomScan provides a mock function with given fields: vb, collId, sampleSize, withDocs, context

func (*ClientIface) CreateRangeScan

func (_m *ClientIface) CreateRangeScan(vb uint16, collId uint32, start []byte, excludeStart bool, end []byte, excludeEnd bool, withDocs bool, context ...*memcached.ClientContext) (*gomemcached.MCResponse, error)

CreateRangeScan provides a mock function with given fields: vb, collId, start, excludeStart, end, excludeEnd, withDocs, context

func (*ClientIface) Decr

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

Decr provides a mock function with given fields: vb, key, amt, def, exp, context

func (*ClientIface) Del

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

Del provides a mock function with given fields: vb, key, context

func (*ClientIface) EXPECT

func (_m *ClientIface) EXPECT() *ClientIface_Expecter

func (*ClientIface) EnableDataPool

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

EnableDataPool provides a mock function with given fields: getter, doneCb

func (*ClientIface) EnableFeatures

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

EnableFeatures provides a mock function with given fields: features

func (*ClientIface) EnableMutationToken

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

EnableMutationToken provides a mock function with given fields:

func (*ClientIface) Get

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

Get provides a mock function with given fields: vb, key, context

func (*ClientIface) GetAllVbSeqnos

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

GetAllVbSeqnos provides a mock function with given fields: vbSeqnoMap, context

func (*ClientIface) GetAndTouch

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

GetAndTouch provides a mock function with given fields: vb, key, exp, context

func (*ClientIface) GetBulk

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

GetBulk provides a mock function with given fields: vb, keys, rv, subPaths, context

func (*ClientIface) GetCollectionsManifest

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

GetCollectionsManifest provides a mock function with given fields:

func (*ClientIface) GetConnName

func (_m *ClientIface) GetConnName() string

GetConnName provides a mock function with given fields:

func (*ClientIface) GetErrorMap

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

GetErrorMap provides a mock function with given fields: errMapVersion

func (*ClientIface) GetMeta

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

GetMeta provides a mock function with given fields: vb, key, context

func (*ClientIface) GetRandomDoc

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

GetRandomDoc provides a mock function with given fields: context

func (*ClientIface) GetSubdoc

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

GetSubdoc provides a mock function with given fields: vb, key, subPaths, context

func (*ClientIface) Hijack

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

Hijack provides a mock function with given fields:

func (*ClientIface) Incr

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

Incr provides a mock function with given fields: vb, key, amt, def, exp, context

func (*ClientIface) LastBucket

func (_m *ClientIface) LastBucket() string

LastBucket provides a mock function with given fields:

func (*ClientIface) NewUprFeed

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

NewUprFeed provides a mock function with given fields:

func (*ClientIface) NewUprFeedIface

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

NewUprFeedIface provides a mock function with given fields:

func (*ClientIface) NewUprFeedWithConfig

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

NewUprFeedWithConfig provides a mock function with given fields: ackByClient

func (*ClientIface) NewUprFeedWithConfigIface

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

NewUprFeedWithConfigIface provides a mock function with given fields: ackByClient

func (*ClientIface) Observe

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

Observe provides a mock function with given fields: vb, key

func (*ClientIface) ObserveSeq

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

ObserveSeq provides a mock function with given fields: vb, vbuuid

func (*ClientIface) Receive

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

Receive provides a mock function with given fields:

func (*ClientIface) ReceiveWithDeadline

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

ReceiveWithDeadline provides a mock function with given fields: deadline

func (*ClientIface) Replica

func (_m *ClientIface) Replica() bool

Replica provides a mock function with given fields:

func (*ClientIface) SelectBucket

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

SelectBucket provides a mock function with given fields: bucket

func (*ClientIface) Send

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

Send provides a mock function with given fields: req

func (*ClientIface) Set

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

Set provides a mock function with given fields: vb, key, flags, exp, body, context

func (*ClientIface) SetCas

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

SetCas provides a mock function with given fields: vb, key, flags, exp, cas, body, context

func (*ClientIface) SetConnName

func (_m *ClientIface) SetConnName(name string)

SetConnName provides a mock function with given fields: name

func (*ClientIface) SetDeadline

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

SetDeadline provides a mock function with given fields: t

func (*ClientIface) SetKeepAliveOptions

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

SetKeepAliveOptions provides a mock function with given fields: interval

func (*ClientIface) SetReadDeadline

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

SetReadDeadline provides a mock function with given fields: t

func (*ClientIface) SetReplica

func (_m *ClientIface) SetReplica(r bool)

SetReplica provides a mock function with given fields: r

func (*ClientIface) SetSubdoc

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

SetSubdoc provides a mock function with given fields: vb, key, ops, context

func (*ClientIface) Stats

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

Stats provides a mock function with given fields: key

func (*ClientIface) StatsFunc

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

StatsFunc provides a mock function with given fields: key, fn

func (*ClientIface) StatsMap

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

StatsMap provides a mock function with given fields: key

func (*ClientIface) StatsMapForSpecifiedStats

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

StatsMapForSpecifiedStats provides a mock function with given fields: key, statsMap

func (*ClientIface) Transmit

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

Transmit provides a mock function with given fields: req

func (*ClientIface) TransmitResponse

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

TransmitResponse provides a mock function with given fields: res

func (*ClientIface) TransmitWithDeadline

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

TransmitWithDeadline provides a mock function with given fields: req, deadline

func (*ClientIface) UprGetFailoverLog

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

UprGetFailoverLog provides a mock function with given fields: vb

func (*ClientIface) ValidateKey

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

ValidateKey provides a mock function with given fields: vb, key, context

type ClientIface_Add_Call

type ClientIface_Add_Call struct {
	*mock.Call
}

ClientIface_Add_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Add'

func (*ClientIface_Add_Call) Return

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

func (*ClientIface_Add_Call) Run

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

func (*ClientIface_Add_Call) RunAndReturn

func (_c *ClientIface_Add_Call) RunAndReturn(run func(uint16, string, int, int, []byte, ...*memcached.ClientContext) (*gomemcached.MCResponse, error)) *ClientIface_Add_Call

type ClientIface_Append_Call

type ClientIface_Append_Call struct {
	*mock.Call
}

ClientIface_Append_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Append'

func (*ClientIface_Append_Call) Return

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

func (*ClientIface_Append_Call) Run

func (_c *ClientIface_Append_Call) Run(run func(vb uint16, key string, data []byte, context ...*memcached.ClientContext)) *ClientIface_Append_Call

func (*ClientIface_Append_Call) RunAndReturn

func (_c *ClientIface_Append_Call) RunAndReturn(run func(uint16, string, []byte, ...*memcached.ClientContext) (*gomemcached.MCResponse, error)) *ClientIface_Append_Call

type ClientIface_AuthList_Call

type ClientIface_AuthList_Call struct {
	*mock.Call
}

ClientIface_AuthList_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AuthList'

func (*ClientIface_AuthList_Call) Return

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

func (*ClientIface_AuthList_Call) Run

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

func (*ClientIface_AuthList_Call) RunAndReturn

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

type ClientIface_AuthPlain_Call

type ClientIface_AuthPlain_Call struct {
	*mock.Call
}

ClientIface_AuthPlain_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AuthPlain'

func (*ClientIface_AuthPlain_Call) Return

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

func (*ClientIface_AuthPlain_Call) Run

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

func (*ClientIface_AuthPlain_Call) RunAndReturn

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

type ClientIface_AuthScramSha_Call

type ClientIface_AuthScramSha_Call struct {
	*mock.Call
}

ClientIface_AuthScramSha_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AuthScramSha'

func (*ClientIface_AuthScramSha_Call) Return

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

func (*ClientIface_AuthScramSha_Call) Run

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

func (*ClientIface_AuthScramSha_Call) RunAndReturn

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

type ClientIface_Auth_Call

type ClientIface_Auth_Call struct {
	*mock.Call
}

ClientIface_Auth_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Auth'

func (*ClientIface_Auth_Call) Return

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

func (*ClientIface_Auth_Call) Run

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

func (*ClientIface_Auth_Call) RunAndReturn

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

type ClientIface_CASNext_Call

type ClientIface_CASNext_Call struct {
	*mock.Call
}

ClientIface_CASNext_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CASNext'

func (*ClientIface_CASNext_Call) Return

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

func (*ClientIface_CASNext_Call) Run

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

func (*ClientIface_CASNext_Call) RunAndReturn

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

type ClientIface_CAS_Call

type ClientIface_CAS_Call struct {
	*mock.Call
}

ClientIface_CAS_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CAS'

func (*ClientIface_CAS_Call) Return

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

func (*ClientIface_CAS_Call) Run

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

func (*ClientIface_CAS_Call) RunAndReturn

func (_c *ClientIface_CAS_Call) RunAndReturn(run func(uint16, string, memcached.CasFunc, int) (*gomemcached.MCResponse, error)) *ClientIface_CAS_Call

type ClientIface_CancelRangeScan_Call

type ClientIface_CancelRangeScan_Call struct {
	*mock.Call
}

ClientIface_CancelRangeScan_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CancelRangeScan'

func (*ClientIface_CancelRangeScan_Call) Return

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

func (*ClientIface_CancelRangeScan_Call) Run

func (_c *ClientIface_CancelRangeScan_Call) Run(run func(vb uint16, uuid []byte, opaque uint32, context ...*memcached.ClientContext)) *ClientIface_CancelRangeScan_Call

func (*ClientIface_CancelRangeScan_Call) RunAndReturn

func (_c *ClientIface_CancelRangeScan_Call) RunAndReturn(run func(uint16, []byte, uint32, ...*memcached.ClientContext) (*gomemcached.MCResponse, error)) *ClientIface_CancelRangeScan_Call

type ClientIface_Close_Call

type ClientIface_Close_Call struct {
	*mock.Call
}

ClientIface_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*ClientIface_Close_Call) Return

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

func (*ClientIface_Close_Call) Run

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

func (*ClientIface_Close_Call) RunAndReturn

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

type ClientIface_CollectionEnabled_Call

type ClientIface_CollectionEnabled_Call struct {
	*mock.Call
}

ClientIface_CollectionEnabled_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CollectionEnabled'

func (*ClientIface_CollectionEnabled_Call) Return

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

func (*ClientIface_CollectionEnabled_Call) Run

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

func (*ClientIface_CollectionEnabled_Call) RunAndReturn

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

type ClientIface_CollectionsGetCID_Call

type ClientIface_CollectionsGetCID_Call struct {
	*mock.Call
}

ClientIface_CollectionsGetCID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CollectionsGetCID'

func (*ClientIface_CollectionsGetCID_Call) Return

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

func (*ClientIface_CollectionsGetCID_Call) Run

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

func (*ClientIface_CollectionsGetCID_Call) RunAndReturn

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

type ClientIface_ContinueRangeScan_Call

type ClientIface_ContinueRangeScan_Call struct {
	*mock.Call
}

ClientIface_ContinueRangeScan_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ContinueRangeScan'

func (*ClientIface_ContinueRangeScan_Call) Return

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

func (*ClientIface_ContinueRangeScan_Call) Run

func (_c *ClientIface_ContinueRangeScan_Call) Run(run func(vb uint16, uuid []byte, opaque uint32, items uint32, maxSize uint32, timeout uint32, context ...*memcached.ClientContext)) *ClientIface_ContinueRangeScan_Call

func (*ClientIface_ContinueRangeScan_Call) RunAndReturn

func (_c *ClientIface_ContinueRangeScan_Call) RunAndReturn(run func(uint16, []byte, uint32, uint32, uint32, uint32, ...*memcached.ClientContext) error) *ClientIface_ContinueRangeScan_Call

type ClientIface_CreateRandomScan_Call

type ClientIface_CreateRandomScan_Call struct {
	*mock.Call
}

ClientIface_CreateRandomScan_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateRandomScan'

func (*ClientIface_CreateRandomScan_Call) Return

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

func (*ClientIface_CreateRandomScan_Call) Run

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

func (*ClientIface_CreateRandomScan_Call) RunAndReturn

func (_c *ClientIface_CreateRandomScan_Call) RunAndReturn(run func(uint16, uint32, int, bool, ...*memcached.ClientContext) (*gomemcached.MCResponse, error)) *ClientIface_CreateRandomScan_Call

type ClientIface_CreateRangeScan_Call

type ClientIface_CreateRangeScan_Call struct {
	*mock.Call
}

ClientIface_CreateRangeScan_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateRangeScan'

func (*ClientIface_CreateRangeScan_Call) Return

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

func (*ClientIface_CreateRangeScan_Call) Run

func (_c *ClientIface_CreateRangeScan_Call) Run(run func(vb uint16, collId uint32, start []byte, excludeStart bool, end []byte, excludeEnd bool, withDocs bool, context ...*memcached.ClientContext)) *ClientIface_CreateRangeScan_Call

func (*ClientIface_CreateRangeScan_Call) RunAndReturn

func (_c *ClientIface_CreateRangeScan_Call) RunAndReturn(run func(uint16, uint32, []byte, bool, []byte, bool, bool, ...*memcached.ClientContext) (*gomemcached.MCResponse, error)) *ClientIface_CreateRangeScan_Call

type ClientIface_Decr_Call

type ClientIface_Decr_Call struct {
	*mock.Call
}

ClientIface_Decr_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Decr'

func (*ClientIface_Decr_Call) Return

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

func (*ClientIface_Decr_Call) Run

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

func (*ClientIface_Decr_Call) RunAndReturn

func (_c *ClientIface_Decr_Call) RunAndReturn(run func(uint16, string, uint64, uint64, int, ...*memcached.ClientContext) (uint64, error)) *ClientIface_Decr_Call

type ClientIface_Del_Call

type ClientIface_Del_Call struct {
	*mock.Call
}

ClientIface_Del_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Del'

func (*ClientIface_Del_Call) Return

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

func (*ClientIface_Del_Call) Run

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

func (*ClientIface_Del_Call) RunAndReturn

func (_c *ClientIface_Del_Call) RunAndReturn(run func(uint16, string, ...*memcached.ClientContext) (*gomemcached.MCResponse, error)) *ClientIface_Del_Call

type ClientIface_EnableDataPool_Call

type ClientIface_EnableDataPool_Call struct {
	*mock.Call
}

ClientIface_EnableDataPool_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EnableDataPool'

func (*ClientIface_EnableDataPool_Call) Return

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

func (*ClientIface_EnableDataPool_Call) Run

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

func (*ClientIface_EnableDataPool_Call) RunAndReturn

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

type ClientIface_EnableFeatures_Call

type ClientIface_EnableFeatures_Call struct {
	*mock.Call
}

ClientIface_EnableFeatures_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EnableFeatures'

func (*ClientIface_EnableFeatures_Call) Return

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

func (*ClientIface_EnableFeatures_Call) Run

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

func (*ClientIface_EnableFeatures_Call) RunAndReturn

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

type ClientIface_EnableMutationToken_Call

type ClientIface_EnableMutationToken_Call struct {
	*mock.Call
}

ClientIface_EnableMutationToken_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EnableMutationToken'

func (*ClientIface_EnableMutationToken_Call) Return

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

func (*ClientIface_EnableMutationToken_Call) Run

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

func (*ClientIface_EnableMutationToken_Call) RunAndReturn

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

type ClientIface_Expecter

type ClientIface_Expecter struct {
	// contains filtered or unexported fields
}

func (*ClientIface_Expecter) Add

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

Add is a helper method to define mock.On call

• vb uint16
• key string
• flags int
• exp int
• body []byte
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) Append

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

Append is a helper method to define mock.On call

• vb uint16
• key string
• data []byte
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) Auth

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

Auth is a helper method to define mock.On call

• user string
• pass string

func (*ClientIface_Expecter) AuthList

func (_e *ClientIface_Expecter) AuthList() *ClientIface_AuthList_Call

AuthList is a helper method to define mock.On call

func (*ClientIface_Expecter) AuthPlain

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

AuthPlain is a helper method to define mock.On call

• user string
• pass string

func (*ClientIface_Expecter) AuthScramSha

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

AuthScramSha is a helper method to define mock.On call

• user string
• pass string

func (*ClientIface_Expecter) CAS

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

CAS is a helper method to define mock.On call

• vb uint16
• k string
• f memcached.CasFunc
• initexp int

func (*ClientIface_Expecter) CASNext

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

CASNext is a helper method to define mock.On call

• vb uint16
• k string
• exp int
• state *memcached.CASState

func (*ClientIface_Expecter) CancelRangeScan

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

CancelRangeScan is a helper method to define mock.On call

• vb uint16
• uuid []byte
• opaque uint32
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) Close

func (_e *ClientIface_Expecter) Close() *ClientIface_Close_Call

Close is a helper method to define mock.On call

func (*ClientIface_Expecter) CollectionEnabled

func (_e *ClientIface_Expecter) CollectionEnabled() *ClientIface_CollectionEnabled_Call

CollectionEnabled is a helper method to define mock.On call

func (*ClientIface_Expecter) CollectionsGetCID

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

CollectionsGetCID is a helper method to define mock.On call

• scope string
• collection string

func (*ClientIface_Expecter) ContinueRangeScan

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

ContinueRangeScan is a helper method to define mock.On call

• vb uint16
• uuid []byte
• opaque uint32
• items uint32
• maxSize uint32
• timeout uint32
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) CreateRandomScan

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

CreateRandomScan is a helper method to define mock.On call

• vb uint16
• collId uint32
• sampleSize int
• withDocs bool
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) CreateRangeScan

func (_e *ClientIface_Expecter) CreateRangeScan(vb interface{}, collId interface{}, start interface{}, excludeStart interface{}, end interface{}, excludeEnd interface{}, withDocs interface{}, context ...interface{}) *ClientIface_CreateRangeScan_Call

CreateRangeScan is a helper method to define mock.On call

• vb uint16
• collId uint32
• start []byte
• excludeStart bool
• end []byte
• excludeEnd bool
• withDocs bool
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) Decr

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

Decr is a helper method to define mock.On call

• vb uint16
• key string
• amt uint64
• def uint64
• exp int
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) Del

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

Del is a helper method to define mock.On call

• vb uint16
• key string
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) EnableDataPool

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

EnableDataPool is a helper method to define mock.On call

• getter func(uint64)([]byte , error)
• doneCb func([]byte)

func (*ClientIface_Expecter) EnableFeatures

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

EnableFeatures is a helper method to define mock.On call

• features memcached.Features

func (*ClientIface_Expecter) EnableMutationToken

func (_e *ClientIface_Expecter) EnableMutationToken() *ClientIface_EnableMutationToken_Call

EnableMutationToken is a helper method to define mock.On call

func (*ClientIface_Expecter) Get

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

Get is a helper method to define mock.On call

• vb uint16
• key string
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) GetAllVbSeqnos

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

GetAllVbSeqnos is a helper method to define mock.On call

• vbSeqnoMap map[uint16]uint64
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) GetAndTouch

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

GetAndTouch is a helper method to define mock.On call

• vb uint16
• key string
• exp int
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) GetBulk

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

GetBulk is a helper method to define mock.On call

• vb uint16
• keys []string
• rv map[string]*gomemcached.MCResponse
• subPaths []string
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) GetCollectionsManifest

func (_e *ClientIface_Expecter) GetCollectionsManifest() *ClientIface_GetCollectionsManifest_Call

GetCollectionsManifest is a helper method to define mock.On call

func (*ClientIface_Expecter) GetConnName

func (_e *ClientIface_Expecter) GetConnName() *ClientIface_GetConnName_Call

GetConnName is a helper method to define mock.On call

func (*ClientIface_Expecter) GetErrorMap

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

GetErrorMap is a helper method to define mock.On call

• errMapVersion gomemcached.ErrorMapVersion

func (*ClientIface_Expecter) GetMeta

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

GetMeta is a helper method to define mock.On call

• vb uint16
• key string
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) GetRandomDoc

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

GetRandomDoc is a helper method to define mock.On call

• context ...*memcached.ClientContext

func (*ClientIface_Expecter) GetSubdoc

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

GetSubdoc is a helper method to define mock.On call

• vb uint16
• key string
• subPaths []string
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) Hijack

func (_e *ClientIface_Expecter) Hijack() *ClientIface_Hijack_Call

Hijack is a helper method to define mock.On call

func (*ClientIface_Expecter) Incr

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

Incr is a helper method to define mock.On call

• vb uint16
• key string
• amt uint64
• def uint64
• exp int
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) LastBucket

func (_e *ClientIface_Expecter) LastBucket() *ClientIface_LastBucket_Call

LastBucket is a helper method to define mock.On call

func (*ClientIface_Expecter) NewUprFeed

func (_e *ClientIface_Expecter) NewUprFeed() *ClientIface_NewUprFeed_Call

NewUprFeed is a helper method to define mock.On call

func (*ClientIface_Expecter) NewUprFeedIface

func (_e *ClientIface_Expecter) NewUprFeedIface() *ClientIface_NewUprFeedIface_Call

NewUprFeedIface is a helper method to define mock.On call

func (*ClientIface_Expecter) NewUprFeedWithConfig

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

NewUprFeedWithConfig is a helper method to define mock.On call

• ackByClient bool

func (*ClientIface_Expecter) NewUprFeedWithConfigIface

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

NewUprFeedWithConfigIface is a helper method to define mock.On call

• ackByClient bool

func (*ClientIface_Expecter) Observe

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

Observe is a helper method to define mock.On call

• vb uint16
• key string

func (*ClientIface_Expecter) ObserveSeq

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

ObserveSeq is a helper method to define mock.On call

• vb uint16
• vbuuid uint64

func (*ClientIface_Expecter) Receive

func (_e *ClientIface_Expecter) Receive() *ClientIface_Receive_Call

Receive is a helper method to define mock.On call

func (*ClientIface_Expecter) ReceiveWithDeadline

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

ReceiveWithDeadline is a helper method to define mock.On call

• deadline time.Time

func (*ClientIface_Expecter) Replica

func (_e *ClientIface_Expecter) Replica() *ClientIface_Replica_Call

Replica is a helper method to define mock.On call

func (*ClientIface_Expecter) SelectBucket

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

SelectBucket is a helper method to define mock.On call

• bucket string

func (*ClientIface_Expecter) Send

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

Send is a helper method to define mock.On call

• req *gomemcached.MCRequest

func (*ClientIface_Expecter) Set

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

Set is a helper method to define mock.On call

• vb uint16
• key string
• flags int
• exp int
• body []byte
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) SetCas

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

SetCas is a helper method to define mock.On call

• vb uint16
• key string
• flags int
• exp int
• cas uint64
• body []byte
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) SetConnName

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

SetConnName is a helper method to define mock.On call

• name string

func (*ClientIface_Expecter) SetDeadline

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

SetDeadline is a helper method to define mock.On call

• t time.Time

func (*ClientIface_Expecter) SetKeepAliveOptions

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

SetKeepAliveOptions is a helper method to define mock.On call

• interval time.Duration

func (*ClientIface_Expecter) SetReadDeadline

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

SetReadDeadline is a helper method to define mock.On call

• t time.Time

func (*ClientIface_Expecter) SetReplica

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

SetReplica is a helper method to define mock.On call

• r bool

func (*ClientIface_Expecter) SetSubdoc

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

SetSubdoc is a helper method to define mock.On call

• vb uint16
• key string
• ops []memcached.SubDocOp
• context ...*memcached.ClientContext

func (*ClientIface_Expecter) Stats

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

Stats is a helper method to define mock.On call

• key string

func (*ClientIface_Expecter) StatsFunc

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

StatsFunc is a helper method to define mock.On call

• key string
• fn func([]byte , []byte)

func (*ClientIface_Expecter) StatsMap

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

StatsMap is a helper method to define mock.On call

• key string

func (*ClientIface_Expecter) StatsMapForSpecifiedStats

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

StatsMapForSpecifiedStats is a helper method to define mock.On call

• key string
• statsMap map[string]string

func (*ClientIface_Expecter) Transmit

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

Transmit is a helper method to define mock.On call

• req *gomemcached.MCRequest

func (*ClientIface_Expecter) TransmitResponse

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

TransmitResponse is a helper method to define mock.On call

• res *gomemcached.MCResponse

func (*ClientIface_Expecter) TransmitWithDeadline

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

TransmitWithDeadline is a helper method to define mock.On call

• req *gomemcached.MCRequest
• deadline time.Time

func (*ClientIface_Expecter) UprGetFailoverLog

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

UprGetFailoverLog is a helper method to define mock.On call

• vb []uint16

func (*ClientIface_Expecter) ValidateKey

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

ValidateKey is a helper method to define mock.On call

• vb uint16
• key string
• context ...*memcached.ClientContext

type ClientIface_GetAllVbSeqnos_Call

type ClientIface_GetAllVbSeqnos_Call struct {
	*mock.Call
}

ClientIface_GetAllVbSeqnos_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAllVbSeqnos'

func (*ClientIface_GetAllVbSeqnos_Call) Return

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

func (*ClientIface_GetAllVbSeqnos_Call) Run

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

func (*ClientIface_GetAllVbSeqnos_Call) RunAndReturn

func (_c *ClientIface_GetAllVbSeqnos_Call) RunAndReturn(run func(map[uint16]uint64, ...*memcached.ClientContext) (map[uint16]uint64, error)) *ClientIface_GetAllVbSeqnos_Call

type ClientIface_GetAndTouch_Call

type ClientIface_GetAndTouch_Call struct {
	*mock.Call
}

ClientIface_GetAndTouch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAndTouch'

func (*ClientIface_GetAndTouch_Call) Return

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

func (*ClientIface_GetAndTouch_Call) Run

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

func (*ClientIface_GetAndTouch_Call) RunAndReturn

func (_c *ClientIface_GetAndTouch_Call) RunAndReturn(run func(uint16, string, int, ...*memcached.ClientContext) (*gomemcached.MCResponse, error)) *ClientIface_GetAndTouch_Call

type ClientIface_GetBulk_Call

type ClientIface_GetBulk_Call struct {
	*mock.Call
}

ClientIface_GetBulk_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBulk'

func (*ClientIface_GetBulk_Call) Return

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

func (*ClientIface_GetBulk_Call) Run

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

func (*ClientIface_GetBulk_Call) RunAndReturn

func (_c *ClientIface_GetBulk_Call) RunAndReturn(run func(uint16, []string, map[string]*gomemcached.MCResponse, []string, ...*memcached.ClientContext) error) *ClientIface_GetBulk_Call

type ClientIface_GetCollectionsManifest_Call

type ClientIface_GetCollectionsManifest_Call struct {
	*mock.Call
}

ClientIface_GetCollectionsManifest_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCollectionsManifest'

func (*ClientIface_GetCollectionsManifest_Call) Return

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

func (*ClientIface_GetCollectionsManifest_Call) Run

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

func (*ClientIface_GetCollectionsManifest_Call) RunAndReturn

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

type ClientIface_GetConnName_Call

type ClientIface_GetConnName_Call struct {
	*mock.Call
}

ClientIface_GetConnName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetConnName'

func (*ClientIface_GetConnName_Call) Return

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

func (*ClientIface_GetConnName_Call) Run

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

func (*ClientIface_GetConnName_Call) RunAndReturn

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

type ClientIface_GetErrorMap_Call

type ClientIface_GetErrorMap_Call struct {
	*mock.Call
}

ClientIface_GetErrorMap_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetErrorMap'

func (*ClientIface_GetErrorMap_Call) Return

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

func (*ClientIface_GetErrorMap_Call) Run

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

func (*ClientIface_GetErrorMap_Call) RunAndReturn

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

type ClientIface_GetMeta_Call

type ClientIface_GetMeta_Call struct {
	*mock.Call
}

ClientIface_GetMeta_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetMeta'

func (*ClientIface_GetMeta_Call) Return

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

func (*ClientIface_GetMeta_Call) Run

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

func (*ClientIface_GetMeta_Call) RunAndReturn

func (_c *ClientIface_GetMeta_Call) RunAndReturn(run func(uint16, string, ...*memcached.ClientContext) (*gomemcached.MCResponse, error)) *ClientIface_GetMeta_Call

type ClientIface_GetRandomDoc_Call

type ClientIface_GetRandomDoc_Call struct {
	*mock.Call
}

ClientIface_GetRandomDoc_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRandomDoc'

func (*ClientIface_GetRandomDoc_Call) Return

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

func (*ClientIface_GetRandomDoc_Call) Run

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

func (*ClientIface_GetRandomDoc_Call) RunAndReturn

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

type ClientIface_GetSubdoc_Call

type ClientIface_GetSubdoc_Call struct {
	*mock.Call
}

ClientIface_GetSubdoc_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSubdoc'

func (*ClientIface_GetSubdoc_Call) Return

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

func (*ClientIface_GetSubdoc_Call) Run

func (_c *ClientIface_GetSubdoc_Call) Run(run func(vb uint16, key string, subPaths []string, context ...*memcached.ClientContext)) *ClientIface_GetSubdoc_Call

func (*ClientIface_GetSubdoc_Call) RunAndReturn

func (_c *ClientIface_GetSubdoc_Call) RunAndReturn(run func(uint16, string, []string, ...*memcached.ClientContext) (*gomemcached.MCResponse, error)) *ClientIface_GetSubdoc_Call

type ClientIface_Get_Call

type ClientIface_Get_Call struct {
	*mock.Call
}

ClientIface_Get_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Get'

func (*ClientIface_Get_Call) Return

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

func (*ClientIface_Get_Call) Run

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

func (*ClientIface_Get_Call) RunAndReturn

func (_c *ClientIface_Get_Call) RunAndReturn(run func(uint16, string, ...*memcached.ClientContext) (*gomemcached.MCResponse, error)) *ClientIface_Get_Call

type ClientIface_Hijack_Call

type ClientIface_Hijack_Call struct {
	*mock.Call
}

ClientIface_Hijack_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Hijack'

func (*ClientIface_Hijack_Call) Return

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

func (*ClientIface_Hijack_Call) Run

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

func (*ClientIface_Hijack_Call) RunAndReturn

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

type ClientIface_Incr_Call

type ClientIface_Incr_Call struct {
	*mock.Call
}

ClientIface_Incr_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Incr'

func (*ClientIface_Incr_Call) Return

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

func (*ClientIface_Incr_Call) Run

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

func (*ClientIface_Incr_Call) RunAndReturn

func (_c *ClientIface_Incr_Call) RunAndReturn(run func(uint16, string, uint64, uint64, int, ...*memcached.ClientContext) (uint64, error)) *ClientIface_Incr_Call

type ClientIface_LastBucket_Call

type ClientIface_LastBucket_Call struct {
	*mock.Call
}

ClientIface_LastBucket_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LastBucket'

func (*ClientIface_LastBucket_Call) Return

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

func (*ClientIface_LastBucket_Call) Run

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

func (*ClientIface_LastBucket_Call) RunAndReturn

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

type ClientIface_NewUprFeedIface_Call

type ClientIface_NewUprFeedIface_Call struct {
	*mock.Call
}

ClientIface_NewUprFeedIface_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewUprFeedIface'

func (*ClientIface_NewUprFeedIface_Call) Return

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

func (*ClientIface_NewUprFeedIface_Call) Run

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

func (*ClientIface_NewUprFeedIface_Call) RunAndReturn

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

type ClientIface_NewUprFeedWithConfigIface_Call

type ClientIface_NewUprFeedWithConfigIface_Call struct {
	*mock.Call
}

ClientIface_NewUprFeedWithConfigIface_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewUprFeedWithConfigIface'

func (*ClientIface_NewUprFeedWithConfigIface_Call) Return

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

func (*ClientIface_NewUprFeedWithConfigIface_Call) Run

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

func (*ClientIface_NewUprFeedWithConfigIface_Call) RunAndReturn

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

type ClientIface_NewUprFeedWithConfig_Call

type ClientIface_NewUprFeedWithConfig_Call struct {
	*mock.Call
}

ClientIface_NewUprFeedWithConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewUprFeedWithConfig'

func (*ClientIface_NewUprFeedWithConfig_Call) Return

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

func (*ClientIface_NewUprFeedWithConfig_Call) Run

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

func (*ClientIface_NewUprFeedWithConfig_Call) RunAndReturn

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

type ClientIface_NewUprFeed_Call

type ClientIface_NewUprFeed_Call struct {
	*mock.Call
}

ClientIface_NewUprFeed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewUprFeed'

func (*ClientIface_NewUprFeed_Call) Return

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

func (*ClientIface_NewUprFeed_Call) Run

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

func (*ClientIface_NewUprFeed_Call) RunAndReturn

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

type ClientIface_ObserveSeq_Call

type ClientIface_ObserveSeq_Call struct {
	*mock.Call
}

ClientIface_ObserveSeq_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ObserveSeq'

func (*ClientIface_ObserveSeq_Call) Return

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

func (*ClientIface_ObserveSeq_Call) Run

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

func (*ClientIface_ObserveSeq_Call) RunAndReturn

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

type ClientIface_Observe_Call

type ClientIface_Observe_Call struct {
	*mock.Call
}

ClientIface_Observe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Observe'

func (*ClientIface_Observe_Call) Return

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

func (*ClientIface_Observe_Call) Run

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

func (*ClientIface_Observe_Call) RunAndReturn

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

type ClientIface_ReceiveWithDeadline_Call

type ClientIface_ReceiveWithDeadline_Call struct {
	*mock.Call
}

ClientIface_ReceiveWithDeadline_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReceiveWithDeadline'

func (*ClientIface_ReceiveWithDeadline_Call) Return

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

func (*ClientIface_ReceiveWithDeadline_Call) Run

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

func (*ClientIface_ReceiveWithDeadline_Call) RunAndReturn

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

type ClientIface_Receive_Call

type ClientIface_Receive_Call struct {
	*mock.Call
}

ClientIface_Receive_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Receive'

func (*ClientIface_Receive_Call) Return

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

func (*ClientIface_Receive_Call) Run

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

func (*ClientIface_Receive_Call) RunAndReturn

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

type ClientIface_Replica_Call

type ClientIface_Replica_Call struct {
	*mock.Call
}

ClientIface_Replica_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Replica'

func (*ClientIface_Replica_Call) Return

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

func (*ClientIface_Replica_Call) Run

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

func (*ClientIface_Replica_Call) RunAndReturn

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

type ClientIface_SelectBucket_Call

type ClientIface_SelectBucket_Call struct {
	*mock.Call
}

ClientIface_SelectBucket_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SelectBucket'

func (*ClientIface_SelectBucket_Call) Return

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

func (*ClientIface_SelectBucket_Call) Run

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

func (*ClientIface_SelectBucket_Call) RunAndReturn

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

type ClientIface_Send_Call

type ClientIface_Send_Call struct {
	*mock.Call
}

ClientIface_Send_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Send'

func (*ClientIface_Send_Call) Return

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

func (*ClientIface_Send_Call) Run

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

func (*ClientIface_Send_Call) RunAndReturn

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

type ClientIface_SetCas_Call

type ClientIface_SetCas_Call struct {
	*mock.Call
}

ClientIface_SetCas_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetCas'

func (*ClientIface_SetCas_Call) Return

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

func (*ClientIface_SetCas_Call) Run

func (_c *ClientIface_SetCas_Call) Run(run func(vb uint16, key string, flags int, exp int, cas uint64, body []byte, context ...*memcached.ClientContext)) *ClientIface_SetCas_Call

func (*ClientIface_SetCas_Call) RunAndReturn

func (_c *ClientIface_SetCas_Call) RunAndReturn(run func(uint16, string, int, int, uint64, []byte, ...*memcached.ClientContext) (*gomemcached.MCResponse, error)) *ClientIface_SetCas_Call

type ClientIface_SetConnName_Call

type ClientIface_SetConnName_Call struct {
	*mock.Call
}

ClientIface_SetConnName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetConnName'

func (*ClientIface_SetConnName_Call) Return

func (_c *ClientIface_SetConnName_Call) Return() *ClientIface_SetConnName_Call

func (*ClientIface_SetConnName_Call) Run

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

func (*ClientIface_SetConnName_Call) RunAndReturn

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

type ClientIface_SetDeadline_Call

type ClientIface_SetDeadline_Call struct {
	*mock.Call
}

ClientIface_SetDeadline_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetDeadline'

func (*ClientIface_SetDeadline_Call) Return

func (_c *ClientIface_SetDeadline_Call) Return() *ClientIface_SetDeadline_Call

func (*ClientIface_SetDeadline_Call) Run

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

func (*ClientIface_SetDeadline_Call) RunAndReturn

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

type ClientIface_SetKeepAliveOptions_Call

type ClientIface_SetKeepAliveOptions_Call struct {
	*mock.Call
}

ClientIface_SetKeepAliveOptions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetKeepAliveOptions'

func (*ClientIface_SetKeepAliveOptions_Call) Return

func (_c *ClientIface_SetKeepAliveOptions_Call) Return() *ClientIface_SetKeepAliveOptions_Call

func (*ClientIface_SetKeepAliveOptions_Call) Run

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

func (*ClientIface_SetKeepAliveOptions_Call) RunAndReturn

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

type ClientIface_SetReadDeadline_Call

type ClientIface_SetReadDeadline_Call struct {
	*mock.Call
}

ClientIface_SetReadDeadline_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetReadDeadline'

func (*ClientIface_SetReadDeadline_Call) Return

func (_c *ClientIface_SetReadDeadline_Call) Return() *ClientIface_SetReadDeadline_Call

func (*ClientIface_SetReadDeadline_Call) Run

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

func (*ClientIface_SetReadDeadline_Call) RunAndReturn

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

type ClientIface_SetReplica_Call

type ClientIface_SetReplica_Call struct {
	*mock.Call
}

ClientIface_SetReplica_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetReplica'

func (*ClientIface_SetReplica_Call) Return

func (_c *ClientIface_SetReplica_Call) Return() *ClientIface_SetReplica_Call

func (*ClientIface_SetReplica_Call) Run

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

func (*ClientIface_SetReplica_Call) RunAndReturn

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

type ClientIface_SetSubdoc_Call

type ClientIface_SetSubdoc_Call struct {
	*mock.Call
}

ClientIface_SetSubdoc_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetSubdoc'

func (*ClientIface_SetSubdoc_Call) Return

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

func (*ClientIface_SetSubdoc_Call) Run

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

func (*ClientIface_SetSubdoc_Call) RunAndReturn

func (_c *ClientIface_SetSubdoc_Call) RunAndReturn(run func(uint16, string, []memcached.SubDocOp, ...*memcached.ClientContext) (*gomemcached.MCResponse, error)) *ClientIface_SetSubdoc_Call

type ClientIface_Set_Call

type ClientIface_Set_Call struct {
	*mock.Call
}

ClientIface_Set_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Set'

func (*ClientIface_Set_Call) Return

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

func (*ClientIface_Set_Call) Run

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

func (*ClientIface_Set_Call) RunAndReturn

func (_c *ClientIface_Set_Call) RunAndReturn(run func(uint16, string, int, int, []byte, ...*memcached.ClientContext) (*gomemcached.MCResponse, error)) *ClientIface_Set_Call

type ClientIface_StatsFunc_Call

type ClientIface_StatsFunc_Call struct {
	*mock.Call
}

ClientIface_StatsFunc_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StatsFunc'

func (*ClientIface_StatsFunc_Call) Return

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

func (*ClientIface_StatsFunc_Call) Run

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

func (*ClientIface_StatsFunc_Call) RunAndReturn

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

type ClientIface_StatsMapForSpecifiedStats_Call

type ClientIface_StatsMapForSpecifiedStats_Call struct {
	*mock.Call
}

ClientIface_StatsMapForSpecifiedStats_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StatsMapForSpecifiedStats'

func (*ClientIface_StatsMapForSpecifiedStats_Call) Return

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

func (*ClientIface_StatsMapForSpecifiedStats_Call) Run

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

func (*ClientIface_StatsMapForSpecifiedStats_Call) RunAndReturn

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

type ClientIface_StatsMap_Call

type ClientIface_StatsMap_Call struct {
	*mock.Call
}

ClientIface_StatsMap_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StatsMap'

func (*ClientIface_StatsMap_Call) Return

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

func (*ClientIface_StatsMap_Call) Run

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

func (*ClientIface_StatsMap_Call) RunAndReturn

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

type ClientIface_Stats_Call

type ClientIface_Stats_Call struct {
	*mock.Call
}

ClientIface_Stats_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stats'

func (*ClientIface_Stats_Call) Return

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

func (*ClientIface_Stats_Call) Run

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

func (*ClientIface_Stats_Call) RunAndReturn

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

type ClientIface_TransmitResponse_Call

type ClientIface_TransmitResponse_Call struct {
	*mock.Call
}

ClientIface_TransmitResponse_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TransmitResponse'

func (*ClientIface_TransmitResponse_Call) Return

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

func (*ClientIface_TransmitResponse_Call) Run

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

func (*ClientIface_TransmitResponse_Call) RunAndReturn

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

type ClientIface_TransmitWithDeadline_Call

type ClientIface_TransmitWithDeadline_Call struct {
	*mock.Call
}

ClientIface_TransmitWithDeadline_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TransmitWithDeadline'

func (*ClientIface_TransmitWithDeadline_Call) Return

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

func (*ClientIface_TransmitWithDeadline_Call) Run

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

func (*ClientIface_TransmitWithDeadline_Call) RunAndReturn

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

type ClientIface_Transmit_Call

type ClientIface_Transmit_Call struct {
	*mock.Call
}

ClientIface_Transmit_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Transmit'

func (*ClientIface_Transmit_Call) Return

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

func (*ClientIface_Transmit_Call) Run

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

func (*ClientIface_Transmit_Call) RunAndReturn

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

type ClientIface_UprGetFailoverLog_Call

type ClientIface_UprGetFailoverLog_Call struct {
	*mock.Call
}

ClientIface_UprGetFailoverLog_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UprGetFailoverLog'

func (*ClientIface_UprGetFailoverLog_Call) Return

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

func (*ClientIface_UprGetFailoverLog_Call) Run

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

func (*ClientIface_UprGetFailoverLog_Call) RunAndReturn

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

type ClientIface_ValidateKey_Call

type ClientIface_ValidateKey_Call struct {
	*mock.Call
}

ClientIface_ValidateKey_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ValidateKey'

func (*ClientIface_ValidateKey_Call) Return

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

func (*ClientIface_ValidateKey_Call) Run

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

func (*ClientIface_ValidateKey_Call) RunAndReturn

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

type CollectionChangedEvent

type CollectionChangedEvent struct {
	mock.Mock
}

CollectionChangedEvent is an autogenerated mock type for the CollectionChangedEvent type

func NewCollectionChangedEvent

func NewCollectionChangedEvent(t interface {
	mock.TestingT
	Cleanup(func())
}) *CollectionChangedEvent

NewCollectionChangedEvent creates a new instance of CollectionChangedEvent. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*CollectionChangedEvent) EXPECT

func (_m *CollectionChangedEvent) EXPECT() *CollectionChangedEvent_Expecter

func (*CollectionChangedEvent) GetCollectionId

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

GetCollectionId provides a mock function with given fields:

func (*CollectionChangedEvent) GetManifestId

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

GetManifestId provides a mock function with given fields:

func (*CollectionChangedEvent) GetMaxTTL

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

GetMaxTTL provides a mock function with given fields:

type CollectionChangedEvent_Expecter

type CollectionChangedEvent_Expecter struct {
	// contains filtered or unexported fields
}

func (*CollectionChangedEvent_Expecter) GetCollectionId

func (_e *CollectionChangedEvent_Expecter) GetCollectionId() *CollectionChangedEvent_GetCollectionId_Call

GetCollectionId is a helper method to define mock.On call

func (*CollectionChangedEvent_Expecter) GetManifestId

func (_e *CollectionChangedEvent_Expecter) GetManifestId() *CollectionChangedEvent_GetManifestId_Call

GetManifestId is a helper method to define mock.On call

func (*CollectionChangedEvent_Expecter) GetMaxTTL

func (_e *CollectionChangedEvent_Expecter) GetMaxTTL() *CollectionChangedEvent_GetMaxTTL_Call

GetMaxTTL is a helper method to define mock.On call

type CollectionChangedEvent_GetCollectionId_Call

type CollectionChangedEvent_GetCollectionId_Call struct {
	*mock.Call
}

CollectionChangedEvent_GetCollectionId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCollectionId'

func (*CollectionChangedEvent_GetCollectionId_Call) Return

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

func (*CollectionChangedEvent_GetCollectionId_Call) Run

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

func (*CollectionChangedEvent_GetCollectionId_Call) RunAndReturn

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

type CollectionChangedEvent_GetManifestId_Call

type CollectionChangedEvent_GetManifestId_Call struct {
	*mock.Call
}

CollectionChangedEvent_GetManifestId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetManifestId'

func (*CollectionChangedEvent_GetManifestId_Call) Return

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

func (*CollectionChangedEvent_GetManifestId_Call) Run

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

func (*CollectionChangedEvent_GetManifestId_Call) RunAndReturn

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

type CollectionChangedEvent_GetMaxTTL_Call

type CollectionChangedEvent_GetMaxTTL_Call struct {
	*mock.Call
}

CollectionChangedEvent_GetMaxTTL_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetMaxTTL'

func (*CollectionChangedEvent_GetMaxTTL_Call) Return

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

func (*CollectionChangedEvent_GetMaxTTL_Call) Run

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

func (*CollectionChangedEvent_GetMaxTTL_Call) RunAndReturn

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

type CollectionCreateEvent

type CollectionCreateEvent struct {
	mock.Mock
}

CollectionCreateEvent is an autogenerated mock type for the CollectionCreateEvent type

func NewCollectionCreateEvent

func NewCollectionCreateEvent(t interface {
	mock.TestingT
	Cleanup(func())
}) *CollectionCreateEvent

NewCollectionCreateEvent creates a new instance of CollectionCreateEvent. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*CollectionCreateEvent) EXPECT

func (_m *CollectionCreateEvent) EXPECT() *CollectionCreateEvent_Expecter

func (*CollectionCreateEvent) GetCollectionId

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

GetCollectionId provides a mock function with given fields:

func (*CollectionCreateEvent) GetManifestId

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

GetManifestId provides a mock function with given fields:

func (*CollectionCreateEvent) GetMaxTTL

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

GetMaxTTL provides a mock function with given fields:

func (*CollectionCreateEvent) GetScopeId

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

GetScopeId provides a mock function with given fields:

func (*CollectionCreateEvent) GetSystemEventName

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

GetSystemEventName provides a mock function with given fields:

type CollectionCreateEvent_Expecter

type CollectionCreateEvent_Expecter struct {
	// contains filtered or unexported fields
}

func (*CollectionCreateEvent_Expecter) GetCollectionId

func (_e *CollectionCreateEvent_Expecter) GetCollectionId() *CollectionCreateEvent_GetCollectionId_Call

GetCollectionId is a helper method to define mock.On call

func (*CollectionCreateEvent_Expecter) GetManifestId

func (_e *CollectionCreateEvent_Expecter) GetManifestId() *CollectionCreateEvent_GetManifestId_Call

GetManifestId is a helper method to define mock.On call

func (*CollectionCreateEvent_Expecter) GetMaxTTL

func (_e *CollectionCreateEvent_Expecter) GetMaxTTL() *CollectionCreateEvent_GetMaxTTL_Call

GetMaxTTL is a helper method to define mock.On call

func (*CollectionCreateEvent_Expecter) GetScopeId

func (_e *CollectionCreateEvent_Expecter) GetScopeId() *CollectionCreateEvent_GetScopeId_Call

GetScopeId is a helper method to define mock.On call

func (*CollectionCreateEvent_Expecter) GetSystemEventName

func (_e *CollectionCreateEvent_Expecter) GetSystemEventName() *CollectionCreateEvent_GetSystemEventName_Call

GetSystemEventName is a helper method to define mock.On call

type CollectionCreateEvent_GetCollectionId_Call

type CollectionCreateEvent_GetCollectionId_Call struct {
	*mock.Call
}

CollectionCreateEvent_GetCollectionId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCollectionId'

func (*CollectionCreateEvent_GetCollectionId_Call) Return

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

func (*CollectionCreateEvent_GetCollectionId_Call) Run

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

func (*CollectionCreateEvent_GetCollectionId_Call) RunAndReturn

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

type CollectionCreateEvent_GetManifestId_Call

type CollectionCreateEvent_GetManifestId_Call struct {
	*mock.Call
}

CollectionCreateEvent_GetManifestId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetManifestId'

func (*CollectionCreateEvent_GetManifestId_Call) Return

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

func (*CollectionCreateEvent_GetManifestId_Call) Run

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

func (*CollectionCreateEvent_GetManifestId_Call) RunAndReturn

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

type CollectionCreateEvent_GetMaxTTL_Call

type CollectionCreateEvent_GetMaxTTL_Call struct {
	*mock.Call
}

CollectionCreateEvent_GetMaxTTL_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetMaxTTL'

func (*CollectionCreateEvent_GetMaxTTL_Call) Return

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

func (*CollectionCreateEvent_GetMaxTTL_Call) Run

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

func (*CollectionCreateEvent_GetMaxTTL_Call) RunAndReturn

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

type CollectionCreateEvent_GetScopeId_Call

type CollectionCreateEvent_GetScopeId_Call struct {
	*mock.Call
}

CollectionCreateEvent_GetScopeId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetScopeId'

func (*CollectionCreateEvent_GetScopeId_Call) Return

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

func (*CollectionCreateEvent_GetScopeId_Call) Run

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

func (*CollectionCreateEvent_GetScopeId_Call) RunAndReturn

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

type CollectionCreateEvent_GetSystemEventName_Call

type CollectionCreateEvent_GetSystemEventName_Call struct {
	*mock.Call
}

CollectionCreateEvent_GetSystemEventName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSystemEventName'

func (*CollectionCreateEvent_GetSystemEventName_Call) Return

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

func (*CollectionCreateEvent_GetSystemEventName_Call) Run

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

func (*CollectionCreateEvent_GetSystemEventName_Call) RunAndReturn

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

type CollectionDropEvent

type CollectionDropEvent struct {
	mock.Mock
}

CollectionDropEvent is an autogenerated mock type for the CollectionDropEvent type

func NewCollectionDropEvent

func NewCollectionDropEvent(t interface {
	mock.TestingT
	Cleanup(func())
}) *CollectionDropEvent

NewCollectionDropEvent creates a new instance of CollectionDropEvent. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*CollectionDropEvent) EXPECT

func (_m *CollectionDropEvent) EXPECT() *CollectionDropEvent_Expecter

func (*CollectionDropEvent) GetCollectionId

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

GetCollectionId provides a mock function with given fields:

func (*CollectionDropEvent) GetManifestId

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

GetManifestId provides a mock function with given fields:

func (*CollectionDropEvent) GetScopeId

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

GetScopeId provides a mock function with given fields:

type CollectionDropEvent_Expecter

type CollectionDropEvent_Expecter struct {
	// contains filtered or unexported fields
}

func (*CollectionDropEvent_Expecter) GetCollectionId

func (_e *CollectionDropEvent_Expecter) GetCollectionId() *CollectionDropEvent_GetCollectionId_Call

GetCollectionId is a helper method to define mock.On call

func (*CollectionDropEvent_Expecter) GetManifestId

func (_e *CollectionDropEvent_Expecter) GetManifestId() *CollectionDropEvent_GetManifestId_Call

GetManifestId is a helper method to define mock.On call

func (*CollectionDropEvent_Expecter) GetScopeId

func (_e *CollectionDropEvent_Expecter) GetScopeId() *CollectionDropEvent_GetScopeId_Call

GetScopeId is a helper method to define mock.On call

type CollectionDropEvent_GetCollectionId_Call

type CollectionDropEvent_GetCollectionId_Call struct {
	*mock.Call
}

CollectionDropEvent_GetCollectionId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCollectionId'

func (*CollectionDropEvent_GetCollectionId_Call) Return

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

func (*CollectionDropEvent_GetCollectionId_Call) Run

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

func (*CollectionDropEvent_GetCollectionId_Call) RunAndReturn

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

type CollectionDropEvent_GetManifestId_Call

type CollectionDropEvent_GetManifestId_Call struct {
	*mock.Call
}

CollectionDropEvent_GetManifestId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetManifestId'

func (*CollectionDropEvent_GetManifestId_Call) Return

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

func (*CollectionDropEvent_GetManifestId_Call) Run

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

func (*CollectionDropEvent_GetManifestId_Call) RunAndReturn

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

type CollectionDropEvent_GetScopeId_Call

type CollectionDropEvent_GetScopeId_Call struct {
	*mock.Call
}

CollectionDropEvent_GetScopeId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetScopeId'

func (*CollectionDropEvent_GetScopeId_Call) Return

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

func (*CollectionDropEvent_GetScopeId_Call) Run

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

func (*CollectionDropEvent_GetScopeId_Call) RunAndReturn

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

type ScopeCreateEvent

type ScopeCreateEvent struct {
	mock.Mock
}

ScopeCreateEvent is an autogenerated mock type for the ScopeCreateEvent type

func NewScopeCreateEvent

func NewScopeCreateEvent(t interface {
	mock.TestingT
	Cleanup(func())
}) *ScopeCreateEvent

NewScopeCreateEvent creates a new instance of ScopeCreateEvent. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ScopeCreateEvent) EXPECT

func (_m *ScopeCreateEvent) EXPECT() *ScopeCreateEvent_Expecter

func (*ScopeCreateEvent) GetManifestId

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

GetManifestId provides a mock function with given fields:

func (*ScopeCreateEvent) GetScopeId

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

GetScopeId provides a mock function with given fields:

func (*ScopeCreateEvent) GetSystemEventName

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

GetSystemEventName provides a mock function with given fields:

type ScopeCreateEvent_Expecter

type ScopeCreateEvent_Expecter struct {
	// contains filtered or unexported fields
}

func (*ScopeCreateEvent_Expecter) GetManifestId

func (_e *ScopeCreateEvent_Expecter) GetManifestId() *ScopeCreateEvent_GetManifestId_Call

GetManifestId is a helper method to define mock.On call

func (*ScopeCreateEvent_Expecter) GetScopeId

func (_e *ScopeCreateEvent_Expecter) GetScopeId() *ScopeCreateEvent_GetScopeId_Call

GetScopeId is a helper method to define mock.On call

func (*ScopeCreateEvent_Expecter) GetSystemEventName

func (_e *ScopeCreateEvent_Expecter) GetSystemEventName() *ScopeCreateEvent_GetSystemEventName_Call

GetSystemEventName is a helper method to define mock.On call

type ScopeCreateEvent_GetManifestId_Call

type ScopeCreateEvent_GetManifestId_Call struct {
	*mock.Call
}

ScopeCreateEvent_GetManifestId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetManifestId'

func (*ScopeCreateEvent_GetManifestId_Call) Return

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

func (*ScopeCreateEvent_GetManifestId_Call) Run

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

func (*ScopeCreateEvent_GetManifestId_Call) RunAndReturn

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

type ScopeCreateEvent_GetScopeId_Call

type ScopeCreateEvent_GetScopeId_Call struct {
	*mock.Call
}

ScopeCreateEvent_GetScopeId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetScopeId'

func (*ScopeCreateEvent_GetScopeId_Call) Return

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

func (*ScopeCreateEvent_GetScopeId_Call) Run

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

func (*ScopeCreateEvent_GetScopeId_Call) RunAndReturn

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

type ScopeCreateEvent_GetSystemEventName_Call

type ScopeCreateEvent_GetSystemEventName_Call struct {
	*mock.Call
}

ScopeCreateEvent_GetSystemEventName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSystemEventName'

func (*ScopeCreateEvent_GetSystemEventName_Call) Return

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

func (*ScopeCreateEvent_GetSystemEventName_Call) Run

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

func (*ScopeCreateEvent_GetSystemEventName_Call) RunAndReturn

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

type ScopeDropEvent

type ScopeDropEvent struct {
	mock.Mock
}

ScopeDropEvent is an autogenerated mock type for the ScopeDropEvent type

func NewScopeDropEvent

func NewScopeDropEvent(t interface {
	mock.TestingT
	Cleanup(func())
}) *ScopeDropEvent

NewScopeDropEvent creates a new instance of ScopeDropEvent. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ScopeDropEvent) EXPECT

func (_m *ScopeDropEvent) EXPECT() *ScopeDropEvent_Expecter

func (*ScopeDropEvent) GetManifestId

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

GetManifestId provides a mock function with given fields:

func (*ScopeDropEvent) GetScopeId

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

GetScopeId provides a mock function with given fields:

type ScopeDropEvent_Expecter

type ScopeDropEvent_Expecter struct {
	// contains filtered or unexported fields
}

func (*ScopeDropEvent_Expecter) GetManifestId

func (_e *ScopeDropEvent_Expecter) GetManifestId() *ScopeDropEvent_GetManifestId_Call

GetManifestId is a helper method to define mock.On call

func (*ScopeDropEvent_Expecter) GetScopeId

func (_e *ScopeDropEvent_Expecter) GetScopeId() *ScopeDropEvent_GetScopeId_Call

GetScopeId is a helper method to define mock.On call

type ScopeDropEvent_GetManifestId_Call

type ScopeDropEvent_GetManifestId_Call struct {
	*mock.Call
}

ScopeDropEvent_GetManifestId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetManifestId'

func (*ScopeDropEvent_GetManifestId_Call) Return

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

func (*ScopeDropEvent_GetManifestId_Call) Run

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

func (*ScopeDropEvent_GetManifestId_Call) RunAndReturn

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

type ScopeDropEvent_GetScopeId_Call

type ScopeDropEvent_GetScopeId_Call struct {
	*mock.Call
}

ScopeDropEvent_GetScopeId_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetScopeId'

func (*ScopeDropEvent_GetScopeId_Call) Return

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

func (*ScopeDropEvent_GetScopeId_Call) Run

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

func (*ScopeDropEvent_GetScopeId_Call) RunAndReturn

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

type UprFeedIface

type UprFeedIface struct {
	mock.Mock
}

UprFeedIface is an autogenerated mock type for the UprFeedIface type

func NewUprFeedIface

func NewUprFeedIface(t interface {
	mock.TestingT
	Cleanup(func())
}) *UprFeedIface

NewUprFeedIface creates a new instance of UprFeedIface. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*UprFeedIface) ClientAck

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

ClientAck provides a mock function with given fields: event

func (*UprFeedIface) Close

func (_m *UprFeedIface) Close()

Close provides a mock function with given fields:

func (*UprFeedIface) CloseStream

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

CloseStream provides a mock function with given fields: vbno, opaqueMSB

func (*UprFeedIface) Closed

func (_m *UprFeedIface) Closed() bool

Closed provides a mock function with given fields:

func (*UprFeedIface) EXPECT

func (_m *UprFeedIface) EXPECT() *UprFeedIface_Expecter

func (*UprFeedIface) GetError

func (_m *UprFeedIface) GetError() error

GetError provides a mock function with given fields:

func (*UprFeedIface) GetUprEventCh

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

GetUprEventCh provides a mock function with given fields:

func (*UprFeedIface) GetUprStats

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

GetUprStats provides a mock function with given fields:

func (*UprFeedIface) SetPriorityAsync

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

SetPriorityAsync provides a mock function with given fields: p

func (*UprFeedIface) StartFeed

func (_m *UprFeedIface) StartFeed() error

StartFeed provides a mock function with given fields:

func (*UprFeedIface) StartFeedWithConfig

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

StartFeedWithConfig provides a mock function with given fields: datachan_len

func (*UprFeedIface) UprOpen

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

UprOpen provides a mock function with given fields: name, sequence, bufSize

func (*UprFeedIface) UprOpenWithFeatures

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

UprOpenWithFeatures provides a mock function with given fields: name, sequence, bufSize, features

func (*UprFeedIface) UprOpenWithXATTR

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

UprOpenWithXATTR provides a mock function with given fields: name, sequence, bufSize

func (*UprFeedIface) UprRequestCollectionsStream

func (_m *UprFeedIface) UprRequestCollectionsStream(vbno uint16, opaqueMSB uint16, flags uint32, vbuuid uint64, startSeq uint64, endSeq uint64, snapStart uint64, snapEnd uint64, filter *memcached.CollectionsFilter) error

UprRequestCollectionsStream provides a mock function with given fields: vbno, opaqueMSB, flags, vbuuid, startSeq, endSeq, snapStart, snapEnd, filter

func (*UprFeedIface) UprRequestStream

func (_m *UprFeedIface) UprRequestStream(vbno uint16, opaqueMSB uint16, flags uint32, vuuid uint64, startSequence uint64, endSequence uint64, snapStart uint64, snapEnd uint64) error

UprRequestStream provides a mock function with given fields: vbno, opaqueMSB, flags, vuuid, startSequence, endSequence, snapStart, snapEnd

type UprFeedIface_ClientAck_Call

type UprFeedIface_ClientAck_Call struct {
	*mock.Call
}

UprFeedIface_ClientAck_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ClientAck'

func (*UprFeedIface_ClientAck_Call) Return

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

func (*UprFeedIface_ClientAck_Call) Run

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

func (*UprFeedIface_ClientAck_Call) RunAndReturn

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

type UprFeedIface_CloseStream_Call

type UprFeedIface_CloseStream_Call struct {
	*mock.Call
}

UprFeedIface_CloseStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CloseStream'

func (*UprFeedIface_CloseStream_Call) Return

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

func (*UprFeedIface_CloseStream_Call) Run

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

func (*UprFeedIface_CloseStream_Call) RunAndReturn

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

type UprFeedIface_Close_Call

type UprFeedIface_Close_Call struct {
	*mock.Call
}

UprFeedIface_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*UprFeedIface_Close_Call) Return

func (_c *UprFeedIface_Close_Call) Return() *UprFeedIface_Close_Call

func (*UprFeedIface_Close_Call) Run

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

func (*UprFeedIface_Close_Call) RunAndReturn

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

type UprFeedIface_Closed_Call

type UprFeedIface_Closed_Call struct {
	*mock.Call
}

UprFeedIface_Closed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Closed'

func (*UprFeedIface_Closed_Call) Return

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

func (*UprFeedIface_Closed_Call) Run

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

func (*UprFeedIface_Closed_Call) RunAndReturn

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

type UprFeedIface_Expecter

type UprFeedIface_Expecter struct {
	// contains filtered or unexported fields
}

func (*UprFeedIface_Expecter) ClientAck

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

ClientAck is a helper method to define mock.On call

• event *memcached.UprEvent

func (*UprFeedIface_Expecter) Close

func (_e *UprFeedIface_Expecter) Close() *UprFeedIface_Close_Call

Close is a helper method to define mock.On call

func (*UprFeedIface_Expecter) CloseStream

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

CloseStream is a helper method to define mock.On call

• vbno uint16
• opaqueMSB uint16

func (*UprFeedIface_Expecter) Closed

func (_e *UprFeedIface_Expecter) Closed() *UprFeedIface_Closed_Call

Closed is a helper method to define mock.On call

func (*UprFeedIface_Expecter) GetError

func (_e *UprFeedIface_Expecter) GetError() *UprFeedIface_GetError_Call

GetError is a helper method to define mock.On call

func (*UprFeedIface_Expecter) GetUprEventCh

func (_e *UprFeedIface_Expecter) GetUprEventCh() *UprFeedIface_GetUprEventCh_Call

GetUprEventCh is a helper method to define mock.On call

func (*UprFeedIface_Expecter) GetUprStats

func (_e *UprFeedIface_Expecter) GetUprStats() *UprFeedIface_GetUprStats_Call

GetUprStats is a helper method to define mock.On call

func (*UprFeedIface_Expecter) SetPriorityAsync

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

SetPriorityAsync is a helper method to define mock.On call

• p memcached.PriorityType

func (*UprFeedIface_Expecter) StartFeed

func (_e *UprFeedIface_Expecter) StartFeed() *UprFeedIface_StartFeed_Call

StartFeed is a helper method to define mock.On call

func (*UprFeedIface_Expecter) StartFeedWithConfig

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

StartFeedWithConfig is a helper method to define mock.On call

• datachan_len int

func (*UprFeedIface_Expecter) UprOpen

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

UprOpen is a helper method to define mock.On call

• name string
• sequence uint32
• bufSize uint32

func (*UprFeedIface_Expecter) UprOpenWithFeatures

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

UprOpenWithFeatures is a helper method to define mock.On call

• name string
• sequence uint32
• bufSize uint32
• features memcached.UprFeatures

func (*UprFeedIface_Expecter) UprOpenWithXATTR

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

UprOpenWithXATTR is a helper method to define mock.On call

• name string
• sequence uint32
• bufSize uint32

func (*UprFeedIface_Expecter) UprRequestCollectionsStream

func (_e *UprFeedIface_Expecter) UprRequestCollectionsStream(vbno interface{}, opaqueMSB interface{}, flags interface{}, vbuuid interface{}, startSeq interface{}, endSeq interface{}, snapStart interface{}, snapEnd interface{}, filter interface{}) *UprFeedIface_UprRequestCollectionsStream_Call

UprRequestCollectionsStream is a helper method to define mock.On call

• vbno uint16
• opaqueMSB uint16
• flags uint32
• vbuuid uint64
• startSeq uint64
• endSeq uint64
• snapStart uint64
• snapEnd uint64
• filter *memcached.CollectionsFilter

func (*UprFeedIface_Expecter) UprRequestStream

func (_e *UprFeedIface_Expecter) UprRequestStream(vbno interface{}, opaqueMSB interface{}, flags interface{}, vuuid interface{}, startSequence interface{}, endSequence interface{}, snapStart interface{}, snapEnd interface{}) *UprFeedIface_UprRequestStream_Call

UprRequestStream is a helper method to define mock.On call

• vbno uint16
• opaqueMSB uint16
• flags uint32
• vuuid uint64
• startSequence uint64
• endSequence uint64
• snapStart uint64
• snapEnd uint64

type UprFeedIface_GetError_Call

type UprFeedIface_GetError_Call struct {
	*mock.Call
}

UprFeedIface_GetError_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetError'

func (*UprFeedIface_GetError_Call) Return

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

func (*UprFeedIface_GetError_Call) Run

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

func (*UprFeedIface_GetError_Call) RunAndReturn

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

type UprFeedIface_GetUprEventCh_Call

type UprFeedIface_GetUprEventCh_Call struct {
	*mock.Call
}

UprFeedIface_GetUprEventCh_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetUprEventCh'

func (*UprFeedIface_GetUprEventCh_Call) Return

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

func (*UprFeedIface_GetUprEventCh_Call) Run

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

func (*UprFeedIface_GetUprEventCh_Call) RunAndReturn

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

type UprFeedIface_GetUprStats_Call

type UprFeedIface_GetUprStats_Call struct {
	*mock.Call
}

UprFeedIface_GetUprStats_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetUprStats'

func (*UprFeedIface_GetUprStats_Call) Return

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

func (*UprFeedIface_GetUprStats_Call) Run

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

func (*UprFeedIface_GetUprStats_Call) RunAndReturn

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

type UprFeedIface_SetPriorityAsync_Call

type UprFeedIface_SetPriorityAsync_Call struct {
	*mock.Call
}

UprFeedIface_SetPriorityAsync_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetPriorityAsync'

func (*UprFeedIface_SetPriorityAsync_Call) Return

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

func (*UprFeedIface_SetPriorityAsync_Call) Run

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

func (*UprFeedIface_SetPriorityAsync_Call) RunAndReturn

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

type UprFeedIface_StartFeedWithConfig_Call

type UprFeedIface_StartFeedWithConfig_Call struct {
	*mock.Call
}

UprFeedIface_StartFeedWithConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartFeedWithConfig'

func (*UprFeedIface_StartFeedWithConfig_Call) Return

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

func (*UprFeedIface_StartFeedWithConfig_Call) Run

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

func (*UprFeedIface_StartFeedWithConfig_Call) RunAndReturn

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

type UprFeedIface_StartFeed_Call

type UprFeedIface_StartFeed_Call struct {
	*mock.Call
}

UprFeedIface_StartFeed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartFeed'

func (*UprFeedIface_StartFeed_Call) Return

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

func (*UprFeedIface_StartFeed_Call) Run

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

func (*UprFeedIface_StartFeed_Call) RunAndReturn

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

type UprFeedIface_UprOpenWithFeatures_Call

type UprFeedIface_UprOpenWithFeatures_Call struct {
	*mock.Call
}

UprFeedIface_UprOpenWithFeatures_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UprOpenWithFeatures'

func (*UprFeedIface_UprOpenWithFeatures_Call) Return

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

func (*UprFeedIface_UprOpenWithFeatures_Call) Run

func (_c *UprFeedIface_UprOpenWithFeatures_Call) Run(run func(name string, sequence uint32, bufSize uint32, features memcached.UprFeatures)) *UprFeedIface_UprOpenWithFeatures_Call

func (*UprFeedIface_UprOpenWithFeatures_Call) RunAndReturn

func (_c *UprFeedIface_UprOpenWithFeatures_Call) RunAndReturn(run func(string, uint32, uint32, memcached.UprFeatures) (error, memcached.UprFeatures)) *UprFeedIface_UprOpenWithFeatures_Call

type UprFeedIface_UprOpenWithXATTR_Call

type UprFeedIface_UprOpenWithXATTR_Call struct {
	*mock.Call
}

UprFeedIface_UprOpenWithXATTR_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UprOpenWithXATTR'

func (*UprFeedIface_UprOpenWithXATTR_Call) Return

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

func (*UprFeedIface_UprOpenWithXATTR_Call) Run

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

func (*UprFeedIface_UprOpenWithXATTR_Call) RunAndReturn

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

type UprFeedIface_UprOpen_Call

type UprFeedIface_UprOpen_Call struct {
	*mock.Call
}

UprFeedIface_UprOpen_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UprOpen'

func (*UprFeedIface_UprOpen_Call) Return

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

func (*UprFeedIface_UprOpen_Call) Run

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

func (*UprFeedIface_UprOpen_Call) RunAndReturn

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

type UprFeedIface_UprRequestCollectionsStream_Call

type UprFeedIface_UprRequestCollectionsStream_Call struct {
	*mock.Call
}

UprFeedIface_UprRequestCollectionsStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UprRequestCollectionsStream'

func (*UprFeedIface_UprRequestCollectionsStream_Call) Return

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

func (*UprFeedIface_UprRequestCollectionsStream_Call) Run

func (_c *UprFeedIface_UprRequestCollectionsStream_Call) Run(run func(vbno uint16, opaqueMSB uint16, flags uint32, vbuuid uint64, startSeq uint64, endSeq uint64, snapStart uint64, snapEnd uint64, filter *memcached.CollectionsFilter)) *UprFeedIface_UprRequestCollectionsStream_Call

func (*UprFeedIface_UprRequestCollectionsStream_Call) RunAndReturn

func (_c *UprFeedIface_UprRequestCollectionsStream_Call) RunAndReturn(run func(uint16, uint16, uint32, uint64, uint64, uint64, uint64, uint64, *memcached.CollectionsFilter) error) *UprFeedIface_UprRequestCollectionsStream_Call

type UprFeedIface_UprRequestStream_Call

type UprFeedIface_UprRequestStream_Call struct {
	*mock.Call
}

UprFeedIface_UprRequestStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UprRequestStream'

func (*UprFeedIface_UprRequestStream_Call) Return

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

func (*UprFeedIface_UprRequestStream_Call) Run

func (_c *UprFeedIface_UprRequestStream_Call) Run(run func(vbno uint16, opaqueMSB uint16, flags uint32, vuuid uint64, startSequence uint64, endSequence uint64, snapStart uint64, snapEnd uint64)) *UprFeedIface_UprRequestStream_Call

func (*UprFeedIface_UprRequestStream_Call) RunAndReturn

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