mocks

package
v0.1.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 30, 2021 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CasFunc added in v0.1.4

type CasFunc struct {
	mock.Mock
}

CasFunc is an autogenerated mock type for the CasFunc type

func (*CasFunc) Execute added in v0.1.4

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

Execute provides a mock function with given fields: current

type ClientIface

type ClientIface struct {
	mock.Mock
}

ClientIface is an autogenerated mock type for the ClientIface type

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) 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) 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) 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) 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 added in v0.1.2

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) SelectBucket

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

SelectBucket provides a mock function with given fields: bucket

func (*ClientIface) Send

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) 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 added in v0.1.4

func (_m *ClientIface) SetReplica(r bool)

SetReplica provides a mock function with given fields: r

func (*ClientIface) Stats

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

Stats provides a mock function with given fields: key

func (*ClientIface) StatsFunc added in v0.1.2

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

type CollectionChangedEvent

type CollectionChangedEvent struct {
	mock.Mock
}

CollectionChangedEvent is an autogenerated mock type for the CollectionChangedEvent type

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 CollectionCreateEvent

type CollectionCreateEvent struct {
	mock.Mock
}

CollectionCreateEvent is an autogenerated mock type for the CollectionCreateEvent type

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 CollectionDropEvent

type CollectionDropEvent struct {
	mock.Mock
}

CollectionDropEvent is an autogenerated mock type for the CollectionDropEvent type

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 RequestHandler

type RequestHandler struct {
	mock.Mock
}

RequestHandler is an autogenerated mock type for the RequestHandler type

func (*RequestHandler) HandleMessage

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

HandleMessage provides a mock function with given fields: _a0, _a1

type ScopeCreateEvent

type ScopeCreateEvent struct {
	mock.Mock
}

ScopeCreateEvent is an autogenerated mock type for the ScopeCreateEvent type

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 ScopeDropEvent

type ScopeDropEvent struct {
	mock.Mock
}

ScopeDropEvent is an autogenerated mock type for the ScopeDropEvent type

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 TapItemParser added in v0.1.4

type TapItemParser struct {
	mock.Mock
}

TapItemParser is an autogenerated mock type for the TapItemParser type

func (*TapItemParser) Execute added in v0.1.4

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

Execute provides a mock function with given fields: _a0

type UprFeedIface

type UprFeedIface struct {
	mock.Mock
}

UprFeedIface is an autogenerated mock type for the UprFeedIface type

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) 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

Jump to

Keyboard shortcuts

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