mocks

package

Go to main page

Versions in this module

v0

v0.3.4

Jan 22, 2026

v0.3.3

Jan 14, 2025

v0.3.2

Sep 18, 2024

v0.3.1

Mar 13, 2024

v0.3.0

Nov 13, 2023

Changes in this version

type RequestHandler

+ func (_m *RequestHandler) EXPECT() *RequestHandler_Expecter

+ type RequestHandler_Expecter struct

+ func (_e *RequestHandler_Expecter) HandleMessage(_a0 interface{}, _a1 interface{}) *RequestHandler_HandleMessage_Call

+ type RequestHandler_HandleMessage_Call struct

+ func (_c *RequestHandler_HandleMessage_Call) Return(_a0 *gomemcached.MCResponse) *RequestHandler_HandleMessage_Call

+ func (_c *RequestHandler_HandleMessage_Call) Run(run func(_a0 io.Writer, _a1 *gomemcached.MCRequest)) *RequestHandler_HandleMessage_Call

+ func (_c *RequestHandler_HandleMessage_Call) RunAndReturn(run func(io.Writer, *gomemcached.MCRequest) *gomemcached.MCResponse) *RequestHandler_HandleMessage_Call

type TapItemParser

+ func (_m *TapItemParser) EXPECT() *TapItemParser_Expecter

+ type TapItemParser_Execute_Call struct

+ func (_c *TapItemParser_Execute_Call) Return(_a0 interface{}, _a1 error) *TapItemParser_Execute_Call

+ func (_c *TapItemParser_Execute_Call) Run(run func(_a0 io.Reader)) *TapItemParser_Execute_Call

+ func (_c *TapItemParser_Execute_Call) RunAndReturn(run func(io.Reader) (interface{}, error)) *TapItemParser_Execute_Call

+ type TapItemParser_Expecter struct

+ func (_e *TapItemParser_Expecter) Execute(_a0 interface{}) *TapItemParser_Execute_Call

v0.2.1

Nov 2, 2022

Changes in this version

type CasFunc

+ func NewCasFunc(t mockConstructorTestingTNewCasFunc) *CasFunc

type ClientIface

+ func NewClientIface(t mockConstructorTestingTNewClientIface) *ClientIface

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

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

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

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

type CollectionChangedEvent

+ func NewCollectionChangedEvent(t mockConstructorTestingTNewCollectionChangedEvent) *CollectionChangedEvent

type CollectionCreateEvent

+ func NewCollectionCreateEvent(t mockConstructorTestingTNewCollectionCreateEvent) *CollectionCreateEvent

type CollectionDropEvent

+ func NewCollectionDropEvent(t mockConstructorTestingTNewCollectionDropEvent) *CollectionDropEvent

type RequestHandler

+ func NewRequestHandler(t mockConstructorTestingTNewRequestHandler) *RequestHandler

type ScopeCreateEvent

+ func NewScopeCreateEvent(t mockConstructorTestingTNewScopeCreateEvent) *ScopeCreateEvent

type ScopeDropEvent

+ func NewScopeDropEvent(t mockConstructorTestingTNewScopeDropEvent) *ScopeDropEvent

type TapItemParser

+ func NewTapItemParser(t mockConstructorTestingTNewTapItemParser) *TapItemParser

type UprFeedIface

+ func NewUprFeedIface(t mockConstructorTestingTNewUprFeedIface) *UprFeedIface

v0.1.4

Sep 30, 2021

Changes in this version

+ type CasFunc struct

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

type ClientIface

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

+ type TapItemParser struct

+ func (_m *TapItemParser) Execute(_a0 io.Reader) (interface{}, error)

v0.1.3

Apr 16, 2021

v0.1.2

Feb 5, 2021

Changes in this version

type ClientIface

+ func (_m *ClientIface) LastBucket() string

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

v0.1.1

Nov 9, 2020

v0.1.0

May 11, 2020

Changes in this version

+ type ClientIface struct

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

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

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

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

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

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

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

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

+ func (_m *ClientIface) Close() error

+ func (_m *ClientIface) CollectionEnabled() bool

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type CollectionChangedEvent struct

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

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

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

+ type CollectionCreateEvent struct

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

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

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

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

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

+ type CollectionDropEvent struct

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

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

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

+ type RequestHandler struct

+ func (_m *RequestHandler) HandleMessage(_a0 io.Writer, _a1 *gomemcached.MCRequest) *gomemcached.MCResponse

+ type ScopeCreateEvent struct

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

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

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

+ type ScopeDropEvent struct

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

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

+ type UprFeedIface struct

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

+ func (_m *UprFeedIface) Close()

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

+ func (_m *UprFeedIface) Closed() bool

+ func (_m *UprFeedIface) GetError() error

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

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

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

+ func (_m *UprFeedIface) StartFeed() error

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

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

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

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

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

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

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