mocks

package
v0.0.0-...-17eb709 Latest Latest
Warning

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

 Go to latest Published: Jun 4, 2019 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type NatsConn 

type NatsConn struct {
	mock.Mock
}

NatsConn is an autogenerated mock type for the NatsConn type

func (*NatsConn) AuthRequired 

func (_m *NatsConn) AuthRequired() bool

AuthRequired provides a mock function with given fields:

func (*NatsConn) Barrier 

func (_m *NatsConn) Barrier(f func()) error

Barrier provides a mock function with given fields: f

func (*NatsConn) Buffered 

func (_m *NatsConn) Buffered() (int, error)

Buffered provides a mock function with given fields:

func (*NatsConn) ChanQueueSubscribe 

func (_m *NatsConn) ChanQueueSubscribe(subj string, group string, ch chan *nats.Msg) (*nats.Subscription, error)

ChanQueueSubscribe provides a mock function with given fields: subj, group, ch

func (*NatsConn) ChanSubscribe 

func (_m *NatsConn) ChanSubscribe(subj string, ch chan *nats.Msg) (*nats.Subscription, error)

ChanSubscribe provides a mock function with given fields: subj, ch

func (*NatsConn) Close 

func (_m *NatsConn) Close()

Close provides a mock function with given fields:

func (*NatsConn) ConnectedAddr 

func (_m *NatsConn) ConnectedAddr() string

ConnectedAddr provides a mock function with given fields:

func (*NatsConn) ConnectedServerId 

func (_m *NatsConn) ConnectedServerId() string

ConnectedServerId provides a mock function with given fields:

func (*NatsConn) ConnectedUrl 

func (_m *NatsConn) ConnectedUrl() string

ConnectedUrl provides a mock function with given fields:

func (*NatsConn) DiscoveredServers 

func (_m *NatsConn) DiscoveredServers() []string

DiscoveredServers provides a mock function with given fields:

func (*NatsConn) Drain 

func (_m *NatsConn) Drain() error

Drain provides a mock function with given fields:

func (*NatsConn) Flush 

func (_m *NatsConn) Flush() error

Flush provides a mock function with given fields:

func (*NatsConn) FlushTimeout 

func (_m *NatsConn) FlushTimeout(timeout time.Duration) error

FlushTimeout provides a mock function with given fields: timeout

func (*NatsConn) FlushWithContext 

func (_m *NatsConn) FlushWithContext(ctx context.Context) error

FlushWithContext provides a mock function with given fields: ctx

func (*NatsConn) GetClientID 

func (_m *NatsConn) GetClientID() (uint64, error)

GetClientID provides a mock function with given fields:

func (*NatsConn) IsClosed 

func (_m *NatsConn) IsClosed() bool

IsClosed provides a mock function with given fields:

func (*NatsConn) IsConnected 

func (_m *NatsConn) IsConnected() bool

IsConnected provides a mock function with given fields:

func (*NatsConn) IsDraining 

func (_m *NatsConn) IsDraining() bool

IsDraining provides a mock function with given fields:

func (*NatsConn) IsReconnecting 

func (_m *NatsConn) IsReconnecting() bool

IsReconnecting provides a mock function with given fields:

func (*NatsConn) LastError 

func (_m *NatsConn) LastError() error

LastError provides a mock function with given fields:

func (*NatsConn) MaxPayload 

func (_m *NatsConn) MaxPayload() int64

MaxPayload provides a mock function with given fields:

func (*NatsConn) NewRespInbox 

func (_m *NatsConn) NewRespInbox() string

NewRespInbox provides a mock function with given fields:

func (*NatsConn) NumSubscriptions 

func (_m *NatsConn) NumSubscriptions() int

NumSubscriptions provides a mock function with given fields:

func (*NatsConn) Publish 

func (_m *NatsConn) Publish(subj string, data []byte) error

Publish provides a mock function with given fields: subj, data

func (*NatsConn) PublishMsg 

func (_m *NatsConn) PublishMsg(m *nats.Msg) error

PublishMsg provides a mock function with given fields: m

func (*NatsConn) PublishRequest 

func (_m *NatsConn) PublishRequest(subj string, reply string, data []byte) error

PublishRequest provides a mock function with given fields: subj, reply, data

func (*NatsConn) QueueSubscribe 

func (_m *NatsConn) QueueSubscribe(subj string, queue string, cb nats.MsgHandler) (*nats.Subscription, error)

QueueSubscribe provides a mock function with given fields: subj, queue, cb

func (*NatsConn) QueueSubscribeSync 

func (_m *NatsConn) QueueSubscribeSync(subj string, queue string) (*nats.Subscription, error)

QueueSubscribeSync provides a mock function with given fields: subj, queue

func (*NatsConn) QueueSubscribeSyncWithChan 

func (_m *NatsConn) QueueSubscribeSyncWithChan(subj string, queue string, ch chan *nats.Msg) (*nats.Subscription, error)

QueueSubscribeSyncWithChan provides a mock function with given fields: subj, queue, ch

func (*NatsConn) Request 

func (_m *NatsConn) Request(subj string, data []byte, timeout time.Duration) (*nats.Msg, error)

Request provides a mock function with given fields: subj, data, timeout

func (*NatsConn) RequestWithContext 

func (_m *NatsConn) RequestWithContext(ctx context.Context, subj string, data []byte) (*nats.Msg, error)

RequestWithContext provides a mock function with given fields: ctx, subj, data

func (*NatsConn) Servers 

func (_m *NatsConn) Servers() []string

Servers provides a mock function with given fields:

func (*NatsConn) SetClosedHandler 

func (_m *NatsConn) SetClosedHandler(cb nats.ConnHandler)

SetClosedHandler provides a mock function with given fields: cb

func (*NatsConn) SetDisconnectHandler 

func (_m *NatsConn) SetDisconnectHandler(dcb nats.ConnHandler)

SetDisconnectHandler provides a mock function with given fields: dcb

func (*NatsConn) SetDiscoveredServersHandler 

func (_m *NatsConn) SetDiscoveredServersHandler(dscb nats.ConnHandler)

SetDiscoveredServersHandler provides a mock function with given fields: dscb

func (*NatsConn) SetErrorHandler 

func (_m *NatsConn) SetErrorHandler(cb nats.ErrHandler)

SetErrorHandler provides a mock function with given fields: cb

func (*NatsConn) SetReconnectHandler 

func (_m *NatsConn) SetReconnectHandler(rcb nats.ConnHandler)

SetReconnectHandler provides a mock function with given fields: rcb

func (*NatsConn) Stats 

func (_m *NatsConn) Stats() nats.Statistics

Stats provides a mock function with given fields:

func (*NatsConn) Status 

func (_m *NatsConn) Status() nats.Status

Status provides a mock function with given fields:

func (*NatsConn) Subscribe 

func (_m *NatsConn) Subscribe(subj string, cb nats.MsgHandler) (*nats.Subscription, error)

Subscribe provides a mock function with given fields: subj, cb

func (*NatsConn) SubscribeSync 

func (_m *NatsConn) SubscribeSync(subj string) (*nats.Subscription, error)

SubscribeSync provides a mock function with given fields: subj

func (*NatsConn) TLSRequired 

func (_m *NatsConn) TLSRequired() bool

TLSRequired provides a mock function with given fields:

type NatsSubscription 

type NatsSubscription struct {
	mock.Mock
}

NatsSubscription is an autogenerated mock type for the NatsSubscription type

func (*NatsSubscription) AutoUnsubscribe 

func (_m *NatsSubscription) AutoUnsubscribe(max int) error

AutoUnsubscribe provides a mock function with given fields: max

func (*NatsSubscription) ClearMaxPending 

func (_m *NatsSubscription) ClearMaxPending() error

ClearMaxPending provides a mock function with given fields:

func (*NatsSubscription) Delivered 

func (_m *NatsSubscription) Delivered() (int64, error)

Delivered provides a mock function with given fields:

func (*NatsSubscription) Drain 

func (_m *NatsSubscription) Drain() error

Drain provides a mock function with given fields:

func (*NatsSubscription) Dropped 

func (_m *NatsSubscription) Dropped() (int, error)

Dropped provides a mock function with given fields:

func (*NatsSubscription) IsValid 

func (_m *NatsSubscription) IsValid() bool

IsValid provides a mock function with given fields:

func (*NatsSubscription) MaxPending 

func (_m *NatsSubscription) MaxPending() (int, int, error)

MaxPending provides a mock function with given fields:

func (*NatsSubscription) NextMsg 

func (_m *NatsSubscription) NextMsg(timeout time.Duration) (*nats.Msg, error)

NextMsg provides a mock function with given fields: timeout

func (*NatsSubscription) NextMsgWithContext 

func (_m *NatsSubscription) NextMsgWithContext(ctx context.Context) (*nats.Msg, error)

NextMsgWithContext provides a mock function with given fields: ctx

func (*NatsSubscription) Pending 

func (_m *NatsSubscription) Pending() (int, int, error)

Pending provides a mock function with given fields:

func (*NatsSubscription) PendingLimits 

func (_m *NatsSubscription) PendingLimits() (int, int, error)

PendingLimits provides a mock function with given fields:

func (*NatsSubscription) QueuedMsgs 

func (_m *NatsSubscription) QueuedMsgs() (int, error)

QueuedMsgs provides a mock function with given fields:

func (*NatsSubscription) SetPendingLimits 

func (_m *NatsSubscription) SetPendingLimits(msgLimit int, bytesLimit int) error

SetPendingLimits provides a mock function with given fields: msgLimit, bytesLimit

func (*NatsSubscription) Type 

func (_m *NatsSubscription) Type() nats.SubscriptionType

Type provides a mock function with given fields:

func (*NatsSubscription) Unsubscribe 

func (_m *NatsSubscription) Unsubscribe() error

Unsubscribe provides a mock function with given fields:

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.