mocks

package
v0.0.0-...-11b31ba Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Backend 

type Backend struct {
	mock.Mock
}

Backend is an autogenerated mock type for the Backend type

func NewBackend 

func NewBackend(t interface {
	mock.TestingT
	Cleanup(func())
}) *Backend

NewBackend creates a new instance of Backend. 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 (*Backend) DeleteInvalidConsumers 

func (_m *Backend) DeleteInvalidConsumers(subscriptions []v1alpha2.Subscription) error

DeleteInvalidConsumers provides a mock function with given fields: subscriptions

func (*Backend) DeleteSubscription 

func (_m *Backend) DeleteSubscription(subscription *v1alpha2.Subscription) error

DeleteSubscription provides a mock function with given fields: subscription

func (*Backend) DeleteSubscriptionsOnly 

func (_m *Backend) DeleteSubscriptionsOnly(subscription *v1alpha2.Subscription) error

DeleteSubscriptionsOnly provides a mock function with given fields: subscription

func (*Backend) EXPECT 

func (_m *Backend) EXPECT() *Backend_Expecter

func (*Backend) GetConfig 

func (_m *Backend) GetConfig() env.NATSConfig

GetConfig provides a mock function with given fields:

func (*Backend) GetJetStreamContext 

func (_m *Backend) GetJetStreamContext() nats.JetStreamContext

GetJetStreamContext provides a mock function with given fields:

func (*Backend) GetJetStreamSubjects 

func (_m *Backend) GetJetStreamSubjects(source string, subjects []string, typeMatching v1alpha2.TypeMatching) []string

GetJetStreamSubjects provides a mock function with given fields: source, subjects, typeMatching

func (*Backend) Initialize 

func (_m *Backend) Initialize(connCloseHandler utils.ConnClosedHandler) error

Initialize provides a mock function with given fields: connCloseHandler

func (*Backend) Shutdown 

func (_m *Backend) Shutdown()

Shutdown provides a mock function with given fields:

func (*Backend) SyncSubscription 

func (_m *Backend) SyncSubscription(subscription *v1alpha2.Subscription) error

SyncSubscription provides a mock function with given fields: subscription

type Backend_DeleteInvalidConsumers_Call 

type Backend_DeleteInvalidConsumers_Call struct {
	*mock.Call
}

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

func (*Backend_DeleteInvalidConsumers_Call) Return 

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

func (*Backend_DeleteInvalidConsumers_Call) Run 

func (_c *Backend_DeleteInvalidConsumers_Call) Run(run func(subscriptions []v1alpha2.Subscription)) *Backend_DeleteInvalidConsumers_Call

func (*Backend_DeleteInvalidConsumers_Call) RunAndReturn 

func (_c *Backend_DeleteInvalidConsumers_Call) RunAndReturn(run func([]v1alpha2.Subscription) error) *Backend_DeleteInvalidConsumers_Call

type Backend_DeleteSubscription_Call 

type Backend_DeleteSubscription_Call struct {
	*mock.Call
}

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

func (*Backend_DeleteSubscription_Call) Return 

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

func (*Backend_DeleteSubscription_Call) Run 

func (_c *Backend_DeleteSubscription_Call) Run(run func(subscription *v1alpha2.Subscription)) *Backend_DeleteSubscription_Call

func (*Backend_DeleteSubscription_Call) RunAndReturn 

func (_c *Backend_DeleteSubscription_Call) RunAndReturn(run func(*v1alpha2.Subscription) error) *Backend_DeleteSubscription_Call

type Backend_DeleteSubscriptionsOnly_Call 

type Backend_DeleteSubscriptionsOnly_Call struct {
	*mock.Call
}

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

func (*Backend_DeleteSubscriptionsOnly_Call) Return 

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

func (*Backend_DeleteSubscriptionsOnly_Call) Run 

func (_c *Backend_DeleteSubscriptionsOnly_Call) Run(run func(subscription *v1alpha2.Subscription)) *Backend_DeleteSubscriptionsOnly_Call

func (*Backend_DeleteSubscriptionsOnly_Call) RunAndReturn 

func (_c *Backend_DeleteSubscriptionsOnly_Call) RunAndReturn(run func(*v1alpha2.Subscription) error) *Backend_DeleteSubscriptionsOnly_Call

type Backend_Expecter 

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

func (*Backend_Expecter) DeleteInvalidConsumers 

func (_e *Backend_Expecter) DeleteInvalidConsumers(subscriptions interface{}) *Backend_DeleteInvalidConsumers_Call

DeleteInvalidConsumers is a helper method to define mock.On call

  • subscriptions []v1alpha2.Subscription

func (*Backend_Expecter) DeleteSubscription 

func (_e *Backend_Expecter) DeleteSubscription(subscription interface{}) *Backend_DeleteSubscription_Call

DeleteSubscription is a helper method to define mock.On call

  • subscription *v1alpha2.Subscription

func (*Backend_Expecter) DeleteSubscriptionsOnly 

func (_e *Backend_Expecter) DeleteSubscriptionsOnly(subscription interface{}) *Backend_DeleteSubscriptionsOnly_Call

DeleteSubscriptionsOnly is a helper method to define mock.On call

  • subscription *v1alpha2.Subscription

func (*Backend_Expecter) GetConfig 

func (_e *Backend_Expecter) GetConfig() *Backend_GetConfig_Call

GetConfig is a helper method to define mock.On call

func (*Backend_Expecter) GetJetStreamContext 

func (_e *Backend_Expecter) GetJetStreamContext() *Backend_GetJetStreamContext_Call

GetJetStreamContext is a helper method to define mock.On call

func (*Backend_Expecter) GetJetStreamSubjects 

func (_e *Backend_Expecter) GetJetStreamSubjects(source interface{}, subjects interface{}, typeMatching interface{}) *Backend_GetJetStreamSubjects_Call

GetJetStreamSubjects is a helper method to define mock.On call

  • source string
  • subjects []string
  • typeMatching v1alpha2.TypeMatching

func (*Backend_Expecter) Initialize 

func (_e *Backend_Expecter) Initialize(connCloseHandler interface{}) *Backend_Initialize_Call

Initialize is a helper method to define mock.On call

  • connCloseHandler utils.ConnClosedHandler

func (*Backend_Expecter) Shutdown 

func (_e *Backend_Expecter) Shutdown() *Backend_Shutdown_Call

Shutdown is a helper method to define mock.On call

func (*Backend_Expecter) SyncSubscription 

func (_e *Backend_Expecter) SyncSubscription(subscription interface{}) *Backend_SyncSubscription_Call

SyncSubscription is a helper method to define mock.On call

  • subscription *v1alpha2.Subscription

type Backend_GetConfig_Call 

type Backend_GetConfig_Call struct {
	*mock.Call
}

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

func (*Backend_GetConfig_Call) Return 

func (_c *Backend_GetConfig_Call) Return(_a0 env.NATSConfig) *Backend_GetConfig_Call

func (*Backend_GetConfig_Call) Run 

func (_c *Backend_GetConfig_Call) Run(run func()) *Backend_GetConfig_Call

func (*Backend_GetConfig_Call) RunAndReturn 

func (_c *Backend_GetConfig_Call) RunAndReturn(run func() env.NATSConfig) *Backend_GetConfig_Call

type Backend_GetJetStreamContext_Call 

type Backend_GetJetStreamContext_Call struct {
	*mock.Call
}

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

func (*Backend_GetJetStreamContext_Call) Return 

func (_c *Backend_GetJetStreamContext_Call) Return(_a0 nats.JetStreamContext) *Backend_GetJetStreamContext_Call

func (*Backend_GetJetStreamContext_Call) Run 

func (_c *Backend_GetJetStreamContext_Call) Run(run func()) *Backend_GetJetStreamContext_Call

func (*Backend_GetJetStreamContext_Call) RunAndReturn 

func (_c *Backend_GetJetStreamContext_Call) RunAndReturn(run func() nats.JetStreamContext) *Backend_GetJetStreamContext_Call

type Backend_GetJetStreamSubjects_Call 

type Backend_GetJetStreamSubjects_Call struct {
	*mock.Call
}

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

func (*Backend_GetJetStreamSubjects_Call) Return 

func (_c *Backend_GetJetStreamSubjects_Call) Return(_a0 []string) *Backend_GetJetStreamSubjects_Call

func (*Backend_GetJetStreamSubjects_Call) Run 

func (_c *Backend_GetJetStreamSubjects_Call) Run(run func(source string, subjects []string, typeMatching v1alpha2.TypeMatching)) *Backend_GetJetStreamSubjects_Call

func (*Backend_GetJetStreamSubjects_Call) RunAndReturn 

func (_c *Backend_GetJetStreamSubjects_Call) RunAndReturn(run func(string, []string, v1alpha2.TypeMatching) []string) *Backend_GetJetStreamSubjects_Call

type Backend_Initialize_Call 

type Backend_Initialize_Call struct {
	*mock.Call
}

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

func (*Backend_Initialize_Call) Return 

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

func (*Backend_Initialize_Call) Run 

func (_c *Backend_Initialize_Call) Run(run func(connCloseHandler utils.ConnClosedHandler)) *Backend_Initialize_Call

func (*Backend_Initialize_Call) RunAndReturn 

func (_c *Backend_Initialize_Call) RunAndReturn(run func(utils.ConnClosedHandler) error) *Backend_Initialize_Call

type Backend_Shutdown_Call 

type Backend_Shutdown_Call struct {
	*mock.Call
}

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

func (*Backend_Shutdown_Call) Return 

func (_c *Backend_Shutdown_Call) Return() *Backend_Shutdown_Call

func (*Backend_Shutdown_Call) Run 

func (_c *Backend_Shutdown_Call) Run(run func()) *Backend_Shutdown_Call

func (*Backend_Shutdown_Call) RunAndReturn 

func (_c *Backend_Shutdown_Call) RunAndReturn(run func()) *Backend_Shutdown_Call

type Backend_SyncSubscription_Call 

type Backend_SyncSubscription_Call struct {
	*mock.Call
}

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

func (*Backend_SyncSubscription_Call) Return 

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

func (*Backend_SyncSubscription_Call) Run 

func (_c *Backend_SyncSubscription_Call) Run(run func(subscription *v1alpha2.Subscription)) *Backend_SyncSubscription_Call

func (*Backend_SyncSubscription_Call) RunAndReturn 

func (_c *Backend_SyncSubscription_Call) RunAndReturn(run func(*v1alpha2.Subscription) error) *Backend_SyncSubscription_Call

type JetStreamContext 

type JetStreamContext struct {
	mock.Mock
}

JetStreamContext is an autogenerated mock type for the JetStreamContext type

func NewJetStreamContext 

func NewJetStreamContext(t interface {
	mock.TestingT
	Cleanup(func())
}) *JetStreamContext

NewJetStreamContext creates a new instance of JetStreamContext. 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 (*JetStreamContext) AccountInfo 

func (_m *JetStreamContext) AccountInfo(opts ...nats.JSOpt) (*nats.AccountInfo, error)

AccountInfo provides a mock function with given fields: opts

func (*JetStreamContext) AddConsumer 

func (_m *JetStreamContext) AddConsumer(stream string, cfg *nats.ConsumerConfig, opts ...nats.JSOpt) (*nats.ConsumerInfo, error)

AddConsumer provides a mock function with given fields: stream, cfg, opts

func (*JetStreamContext) AddStream 

func (_m *JetStreamContext) AddStream(cfg *nats.StreamConfig, opts ...nats.JSOpt) (*nats.StreamInfo, error)

AddStream provides a mock function with given fields: cfg, opts

func (*JetStreamContext) ChanQueueSubscribe 

func (_m *JetStreamContext) ChanQueueSubscribe(subj string, queue string, ch chan *nats.Msg, opts ...nats.SubOpt) (*nats.Subscription, error)

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

func (*JetStreamContext) ChanSubscribe 

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

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

func (*JetStreamContext) ConsumerInfo 

func (_m *JetStreamContext) ConsumerInfo(stream string, name string, opts ...nats.JSOpt) (*nats.ConsumerInfo, error)

ConsumerInfo provides a mock function with given fields: stream, name, opts

func (*JetStreamContext) ConsumerNames 

func (_m *JetStreamContext) ConsumerNames(stream string, opts ...nats.JSOpt) <-chan string

ConsumerNames provides a mock function with given fields: stream, opts

func (*JetStreamContext) Consumers 

func (_m *JetStreamContext) Consumers(stream string, opts ...nats.JSOpt) <-chan *nats.ConsumerInfo

Consumers provides a mock function with given fields: stream, opts

func (*JetStreamContext) ConsumersInfo 

func (_m *JetStreamContext) ConsumersInfo(stream string, opts ...nats.JSOpt) <-chan *nats.ConsumerInfo

ConsumersInfo provides a mock function with given fields: stream, opts

func (*JetStreamContext) CreateKeyValue 

func (_m *JetStreamContext) CreateKeyValue(cfg *nats.KeyValueConfig) (nats.KeyValue, error)

CreateKeyValue provides a mock function with given fields: cfg

func (*JetStreamContext) CreateObjectStore 

func (_m *JetStreamContext) CreateObjectStore(cfg *nats.ObjectStoreConfig) (nats.ObjectStore, error)

CreateObjectStore provides a mock function with given fields: cfg

func (*JetStreamContext) DeleteConsumer 

func (_m *JetStreamContext) DeleteConsumer(stream string, consumer string, opts ...nats.JSOpt) error

DeleteConsumer provides a mock function with given fields: stream, consumer, opts

func (*JetStreamContext) DeleteKeyValue 

func (_m *JetStreamContext) DeleteKeyValue(bucket string) error

DeleteKeyValue provides a mock function with given fields: bucket

func (*JetStreamContext) DeleteMsg 

func (_m *JetStreamContext) DeleteMsg(name string, seq uint64, opts ...nats.JSOpt) error

DeleteMsg provides a mock function with given fields: name, seq, opts

func (*JetStreamContext) DeleteObjectStore 

func (_m *JetStreamContext) DeleteObjectStore(bucket string) error

DeleteObjectStore provides a mock function with given fields: bucket

func (*JetStreamContext) DeleteStream 

func (_m *JetStreamContext) DeleteStream(name string, opts ...nats.JSOpt) error

DeleteStream provides a mock function with given fields: name, opts

func (*JetStreamContext) EXPECT 

func (_m *JetStreamContext) EXPECT() *JetStreamContext_Expecter

func (*JetStreamContext) GetLastMsg 

func (_m *JetStreamContext) GetLastMsg(name string, subject string, opts ...nats.JSOpt) (*nats.RawStreamMsg, error)

GetLastMsg provides a mock function with given fields: name, subject, opts

func (*JetStreamContext) GetMsg 

func (_m *JetStreamContext) GetMsg(name string, seq uint64, opts ...nats.JSOpt) (*nats.RawStreamMsg, error)

GetMsg provides a mock function with given fields: name, seq, opts

func (*JetStreamContext) KeyValue 

func (_m *JetStreamContext) KeyValue(bucket string) (nats.KeyValue, error)

KeyValue provides a mock function with given fields: bucket

func (*JetStreamContext) KeyValueStoreNames 

func (_m *JetStreamContext) KeyValueStoreNames() <-chan string

KeyValueStoreNames provides a mock function with given fields:

func (*JetStreamContext) KeyValueStores 

func (_m *JetStreamContext) KeyValueStores() <-chan nats.KeyValueStatus

KeyValueStores provides a mock function with given fields:

func (*JetStreamContext) ObjectStore 

func (_m *JetStreamContext) ObjectStore(bucket string) (nats.ObjectStore, error)

ObjectStore provides a mock function with given fields: bucket

func (*JetStreamContext) ObjectStoreNames 

func (_m *JetStreamContext) ObjectStoreNames(opts ...nats.ObjectOpt) <-chan string

ObjectStoreNames provides a mock function with given fields: opts

func (*JetStreamContext) ObjectStores 

func (_m *JetStreamContext) ObjectStores(opts ...nats.ObjectOpt) <-chan nats.ObjectStoreStatus

ObjectStores provides a mock function with given fields: opts

func (*JetStreamContext) Publish 

func (_m *JetStreamContext) Publish(subj string, data []byte, opts ...nats.PubOpt) (*nats.PubAck, error)

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

func (*JetStreamContext) PublishAsync 

func (_m *JetStreamContext) PublishAsync(subj string, data []byte, opts ...nats.PubOpt) (nats.PubAckFuture, error)

PublishAsync provides a mock function with given fields: subj, data, opts

func (*JetStreamContext) PublishAsyncComplete 

func (_m *JetStreamContext) PublishAsyncComplete() <-chan struct{}

PublishAsyncComplete provides a mock function with given fields:

func (*JetStreamContext) PublishAsyncPending 

func (_m *JetStreamContext) PublishAsyncPending() int

PublishAsyncPending provides a mock function with given fields:

func (*JetStreamContext) PublishMsg 

func (_m *JetStreamContext) PublishMsg(m *nats.Msg, opts ...nats.PubOpt) (*nats.PubAck, error)

PublishMsg provides a mock function with given fields: m, opts

func (*JetStreamContext) PublishMsgAsync 

func (_m *JetStreamContext) PublishMsgAsync(m *nats.Msg, opts ...nats.PubOpt) (nats.PubAckFuture, error)

PublishMsgAsync provides a mock function with given fields: m, opts

func (*JetStreamContext) PullSubscribe 

func (_m *JetStreamContext) PullSubscribe(subj string, durable string, opts ...nats.SubOpt) (*nats.Subscription, error)

PullSubscribe provides a mock function with given fields: subj, durable, opts

func (*JetStreamContext) PurgeStream 

func (_m *JetStreamContext) PurgeStream(name string, opts ...nats.JSOpt) error

PurgeStream provides a mock function with given fields: name, opts

func (*JetStreamContext) QueueSubscribe 

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

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

func (*JetStreamContext) QueueSubscribeSync 

func (_m *JetStreamContext) QueueSubscribeSync(subj string, queue string, opts ...nats.SubOpt) (*nats.Subscription, error)

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

func (*JetStreamContext) SecureDeleteMsg 

func (_m *JetStreamContext) SecureDeleteMsg(name string, seq uint64, opts ...nats.JSOpt) error

SecureDeleteMsg provides a mock function with given fields: name, seq, opts

func (*JetStreamContext) StreamInfo 

func (_m *JetStreamContext) StreamInfo(stream string, opts ...nats.JSOpt) (*nats.StreamInfo, error)

StreamInfo provides a mock function with given fields: stream, opts

func (*JetStreamContext) StreamNameBySubject 

func (_m *JetStreamContext) StreamNameBySubject(_a0 string, _a1 ...nats.JSOpt) (string, error)

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

func (*JetStreamContext) StreamNames 

func (_m *JetStreamContext) StreamNames(opts ...nats.JSOpt) <-chan string

StreamNames provides a mock function with given fields: opts

func (*JetStreamContext) Streams 

func (_m *JetStreamContext) Streams(opts ...nats.JSOpt) <-chan *nats.StreamInfo

Streams provides a mock function with given fields: opts

func (*JetStreamContext) StreamsInfo 

func (_m *JetStreamContext) StreamsInfo(opts ...nats.JSOpt) <-chan *nats.StreamInfo

StreamsInfo provides a mock function with given fields: opts

func (*JetStreamContext) Subscribe 

func (_m *JetStreamContext) Subscribe(subj string, cb nats.MsgHandler, opts ...nats.SubOpt) (*nats.Subscription, error)

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

func (*JetStreamContext) SubscribeSync 

func (_m *JetStreamContext) SubscribeSync(subj string, opts ...nats.SubOpt) (*nats.Subscription, error)

SubscribeSync provides a mock function with given fields: subj, opts

func (*JetStreamContext) UpdateConsumer 

func (_m *JetStreamContext) UpdateConsumer(stream string, cfg *nats.ConsumerConfig, opts ...nats.JSOpt) (*nats.ConsumerInfo, error)

UpdateConsumer provides a mock function with given fields: stream, cfg, opts

func (*JetStreamContext) UpdateStream 

func (_m *JetStreamContext) UpdateStream(cfg *nats.StreamConfig, opts ...nats.JSOpt) (*nats.StreamInfo, error)

UpdateStream provides a mock function with given fields: cfg, opts

type JetStreamContext_AccountInfo_Call 

type JetStreamContext_AccountInfo_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_AccountInfo_Call) Return 

func (_c *JetStreamContext_AccountInfo_Call) Return(_a0 *nats.AccountInfo, _a1 error) *JetStreamContext_AccountInfo_Call

func (*JetStreamContext_AccountInfo_Call) Run 

func (_c *JetStreamContext_AccountInfo_Call) Run(run func(opts ...nats.JSOpt)) *JetStreamContext_AccountInfo_Call

func (*JetStreamContext_AccountInfo_Call) RunAndReturn 

func (_c *JetStreamContext_AccountInfo_Call) RunAndReturn(run func(...nats.JSOpt) (*nats.AccountInfo, error)) *JetStreamContext_AccountInfo_Call

type JetStreamContext_AddConsumer_Call 

type JetStreamContext_AddConsumer_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_AddConsumer_Call) Return 

func (_c *JetStreamContext_AddConsumer_Call) Return(_a0 *nats.ConsumerInfo, _a1 error) *JetStreamContext_AddConsumer_Call

func (*JetStreamContext_AddConsumer_Call) Run 

func (_c *JetStreamContext_AddConsumer_Call) Run(run func(stream string, cfg *nats.ConsumerConfig, opts ...nats.JSOpt)) *JetStreamContext_AddConsumer_Call

func (*JetStreamContext_AddConsumer_Call) RunAndReturn 

func (_c *JetStreamContext_AddConsumer_Call) RunAndReturn(run func(string, *nats.ConsumerConfig, ...nats.JSOpt) (*nats.ConsumerInfo, error)) *JetStreamContext_AddConsumer_Call

type JetStreamContext_AddStream_Call 

type JetStreamContext_AddStream_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_AddStream_Call) Return 

func (_c *JetStreamContext_AddStream_Call) Return(_a0 *nats.StreamInfo, _a1 error) *JetStreamContext_AddStream_Call

func (*JetStreamContext_AddStream_Call) Run 

func (_c *JetStreamContext_AddStream_Call) Run(run func(cfg *nats.StreamConfig, opts ...nats.JSOpt)) *JetStreamContext_AddStream_Call

func (*JetStreamContext_AddStream_Call) RunAndReturn 

func (_c *JetStreamContext_AddStream_Call) RunAndReturn(run func(*nats.StreamConfig, ...nats.JSOpt) (*nats.StreamInfo, error)) *JetStreamContext_AddStream_Call

type JetStreamContext_ChanQueueSubscribe_Call 

type JetStreamContext_ChanQueueSubscribe_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_ChanQueueSubscribe_Call) Return 

func (_c *JetStreamContext_ChanQueueSubscribe_Call) Return(_a0 *nats.Subscription, _a1 error) *JetStreamContext_ChanQueueSubscribe_Call

func (*JetStreamContext_ChanQueueSubscribe_Call) Run 

func (_c *JetStreamContext_ChanQueueSubscribe_Call) Run(run func(subj string, queue string, ch chan *nats.Msg, opts ...nats.SubOpt)) *JetStreamContext_ChanQueueSubscribe_Call

func (*JetStreamContext_ChanQueueSubscribe_Call) RunAndReturn 

func (_c *JetStreamContext_ChanQueueSubscribe_Call) RunAndReturn(run func(string, string, chan *nats.Msg, ...nats.SubOpt) (*nats.Subscription, error)) *JetStreamContext_ChanQueueSubscribe_Call

type JetStreamContext_ChanSubscribe_Call 

type JetStreamContext_ChanSubscribe_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_ChanSubscribe_Call) Return 

func (_c *JetStreamContext_ChanSubscribe_Call) Return(_a0 *nats.Subscription, _a1 error) *JetStreamContext_ChanSubscribe_Call

func (*JetStreamContext_ChanSubscribe_Call) Run 

func (_c *JetStreamContext_ChanSubscribe_Call) Run(run func(subj string, ch chan *nats.Msg, opts ...nats.SubOpt)) *JetStreamContext_ChanSubscribe_Call

func (*JetStreamContext_ChanSubscribe_Call) RunAndReturn 

func (_c *JetStreamContext_ChanSubscribe_Call) RunAndReturn(run func(string, chan *nats.Msg, ...nats.SubOpt) (*nats.Subscription, error)) *JetStreamContext_ChanSubscribe_Call

type JetStreamContext_ConsumerInfo_Call 

type JetStreamContext_ConsumerInfo_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_ConsumerInfo_Call) Return 

func (_c *JetStreamContext_ConsumerInfo_Call) Return(_a0 *nats.ConsumerInfo, _a1 error) *JetStreamContext_ConsumerInfo_Call

func (*JetStreamContext_ConsumerInfo_Call) Run 

func (_c *JetStreamContext_ConsumerInfo_Call) Run(run func(stream string, name string, opts ...nats.JSOpt)) *JetStreamContext_ConsumerInfo_Call

func (*JetStreamContext_ConsumerInfo_Call) RunAndReturn 

func (_c *JetStreamContext_ConsumerInfo_Call) RunAndReturn(run func(string, string, ...nats.JSOpt) (*nats.ConsumerInfo, error)) *JetStreamContext_ConsumerInfo_Call

type JetStreamContext_ConsumerNames_Call 

type JetStreamContext_ConsumerNames_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_ConsumerNames_Call) Return 

func (_c *JetStreamContext_ConsumerNames_Call) Return(_a0 <-chan string) *JetStreamContext_ConsumerNames_Call

func (*JetStreamContext_ConsumerNames_Call) Run 

func (_c *JetStreamContext_ConsumerNames_Call) Run(run func(stream string, opts ...nats.JSOpt)) *JetStreamContext_ConsumerNames_Call

func (*JetStreamContext_ConsumerNames_Call) RunAndReturn 

func (_c *JetStreamContext_ConsumerNames_Call) RunAndReturn(run func(string, ...nats.JSOpt) <-chan string) *JetStreamContext_ConsumerNames_Call

type JetStreamContext_ConsumersInfo_Call 

type JetStreamContext_ConsumersInfo_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_ConsumersInfo_Call) Return 

func (_c *JetStreamContext_ConsumersInfo_Call) Return(_a0 <-chan *nats.ConsumerInfo) *JetStreamContext_ConsumersInfo_Call

func (*JetStreamContext_ConsumersInfo_Call) Run 

func (_c *JetStreamContext_ConsumersInfo_Call) Run(run func(stream string, opts ...nats.JSOpt)) *JetStreamContext_ConsumersInfo_Call

func (*JetStreamContext_ConsumersInfo_Call) RunAndReturn 

func (_c *JetStreamContext_ConsumersInfo_Call) RunAndReturn(run func(string, ...nats.JSOpt) <-chan *nats.ConsumerInfo) *JetStreamContext_ConsumersInfo_Call

type JetStreamContext_Consumers_Call 

type JetStreamContext_Consumers_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_Consumers_Call) Return 

func (_c *JetStreamContext_Consumers_Call) Return(_a0 <-chan *nats.ConsumerInfo) *JetStreamContext_Consumers_Call

func (*JetStreamContext_Consumers_Call) Run 

func (_c *JetStreamContext_Consumers_Call) Run(run func(stream string, opts ...nats.JSOpt)) *JetStreamContext_Consumers_Call

func (*JetStreamContext_Consumers_Call) RunAndReturn 

func (_c *JetStreamContext_Consumers_Call) RunAndReturn(run func(string, ...nats.JSOpt) <-chan *nats.ConsumerInfo) *JetStreamContext_Consumers_Call

type JetStreamContext_CreateKeyValue_Call 

type JetStreamContext_CreateKeyValue_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_CreateKeyValue_Call) Return 

func (_c *JetStreamContext_CreateKeyValue_Call) Return(_a0 nats.KeyValue, _a1 error) *JetStreamContext_CreateKeyValue_Call

func (*JetStreamContext_CreateKeyValue_Call) Run 

func (_c *JetStreamContext_CreateKeyValue_Call) Run(run func(cfg *nats.KeyValueConfig)) *JetStreamContext_CreateKeyValue_Call

func (*JetStreamContext_CreateKeyValue_Call) RunAndReturn 

func (_c *JetStreamContext_CreateKeyValue_Call) RunAndReturn(run func(*nats.KeyValueConfig) (nats.KeyValue, error)) *JetStreamContext_CreateKeyValue_Call

type JetStreamContext_CreateObjectStore_Call 

type JetStreamContext_CreateObjectStore_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_CreateObjectStore_Call) Return 

func (_c *JetStreamContext_CreateObjectStore_Call) Return(_a0 nats.ObjectStore, _a1 error) *JetStreamContext_CreateObjectStore_Call

func (*JetStreamContext_CreateObjectStore_Call) Run 

func (_c *JetStreamContext_CreateObjectStore_Call) Run(run func(cfg *nats.ObjectStoreConfig)) *JetStreamContext_CreateObjectStore_Call

func (*JetStreamContext_CreateObjectStore_Call) RunAndReturn 

func (_c *JetStreamContext_CreateObjectStore_Call) RunAndReturn(run func(*nats.ObjectStoreConfig) (nats.ObjectStore, error)) *JetStreamContext_CreateObjectStore_Call

type JetStreamContext_DeleteConsumer_Call 

type JetStreamContext_DeleteConsumer_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_DeleteConsumer_Call) Return 

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

func (*JetStreamContext_DeleteConsumer_Call) Run 

func (_c *JetStreamContext_DeleteConsumer_Call) Run(run func(stream string, consumer string, opts ...nats.JSOpt)) *JetStreamContext_DeleteConsumer_Call

func (*JetStreamContext_DeleteConsumer_Call) RunAndReturn 

func (_c *JetStreamContext_DeleteConsumer_Call) RunAndReturn(run func(string, string, ...nats.JSOpt) error) *JetStreamContext_DeleteConsumer_Call

type JetStreamContext_DeleteKeyValue_Call 

type JetStreamContext_DeleteKeyValue_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_DeleteKeyValue_Call) Return 

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

func (*JetStreamContext_DeleteKeyValue_Call) Run 

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

func (*JetStreamContext_DeleteKeyValue_Call) RunAndReturn 

func (_c *JetStreamContext_DeleteKeyValue_Call) RunAndReturn(run func(string) error) *JetStreamContext_DeleteKeyValue_Call

type JetStreamContext_DeleteMsg_Call 

type JetStreamContext_DeleteMsg_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_DeleteMsg_Call) Return 

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

func (*JetStreamContext_DeleteMsg_Call) Run 

func (_c *JetStreamContext_DeleteMsg_Call) Run(run func(name string, seq uint64, opts ...nats.JSOpt)) *JetStreamContext_DeleteMsg_Call

func (*JetStreamContext_DeleteMsg_Call) RunAndReturn 

func (_c *JetStreamContext_DeleteMsg_Call) RunAndReturn(run func(string, uint64, ...nats.JSOpt) error) *JetStreamContext_DeleteMsg_Call

type JetStreamContext_DeleteObjectStore_Call 

type JetStreamContext_DeleteObjectStore_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_DeleteObjectStore_Call) Return 

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

func (*JetStreamContext_DeleteObjectStore_Call) Run 

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

func (*JetStreamContext_DeleteObjectStore_Call) RunAndReturn 

func (_c *JetStreamContext_DeleteObjectStore_Call) RunAndReturn(run func(string) error) *JetStreamContext_DeleteObjectStore_Call

type JetStreamContext_DeleteStream_Call 

type JetStreamContext_DeleteStream_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_DeleteStream_Call) Return 

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

func (*JetStreamContext_DeleteStream_Call) Run 

func (_c *JetStreamContext_DeleteStream_Call) Run(run func(name string, opts ...nats.JSOpt)) *JetStreamContext_DeleteStream_Call

func (*JetStreamContext_DeleteStream_Call) RunAndReturn 

func (_c *JetStreamContext_DeleteStream_Call) RunAndReturn(run func(string, ...nats.JSOpt) error) *JetStreamContext_DeleteStream_Call

type JetStreamContext_Expecter 

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

func (*JetStreamContext_Expecter) AccountInfo 

func (_e *JetStreamContext_Expecter) AccountInfo(opts ...interface{}) *JetStreamContext_AccountInfo_Call

AccountInfo is a helper method to define mock.On call

  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) AddConsumer 

func (_e *JetStreamContext_Expecter) AddConsumer(stream interface{}, cfg interface{}, opts ...interface{}) *JetStreamContext_AddConsumer_Call

AddConsumer is a helper method to define mock.On call

  • stream string
  • cfg *nats.ConsumerConfig
  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) AddStream 

func (_e *JetStreamContext_Expecter) AddStream(cfg interface{}, opts ...interface{}) *JetStreamContext_AddStream_Call

AddStream is a helper method to define mock.On call

  • cfg *nats.StreamConfig
  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) ChanQueueSubscribe 

func (_e *JetStreamContext_Expecter) ChanQueueSubscribe(subj interface{}, queue interface{}, ch interface{}, opts ...interface{}) *JetStreamContext_ChanQueueSubscribe_Call

ChanQueueSubscribe is a helper method to define mock.On call

  • subj string
  • queue string
  • ch chan *nats.Msg
  • opts ...nats.SubOpt

func (*JetStreamContext_Expecter) ChanSubscribe 

func (_e *JetStreamContext_Expecter) ChanSubscribe(subj interface{}, ch interface{}, opts ...interface{}) *JetStreamContext_ChanSubscribe_Call

ChanSubscribe is a helper method to define mock.On call

  • subj string
  • ch chan *nats.Msg
  • opts ...nats.SubOpt

func (*JetStreamContext_Expecter) ConsumerInfo 

func (_e *JetStreamContext_Expecter) ConsumerInfo(stream interface{}, name interface{}, opts ...interface{}) *JetStreamContext_ConsumerInfo_Call

ConsumerInfo is a helper method to define mock.On call

  • stream string
  • name string
  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) ConsumerNames 

func (_e *JetStreamContext_Expecter) ConsumerNames(stream interface{}, opts ...interface{}) *JetStreamContext_ConsumerNames_Call

ConsumerNames is a helper method to define mock.On call

  • stream string
  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) Consumers 

func (_e *JetStreamContext_Expecter) Consumers(stream interface{}, opts ...interface{}) *JetStreamContext_Consumers_Call

Consumers is a helper method to define mock.On call

  • stream string
  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) ConsumersInfo 

func (_e *JetStreamContext_Expecter) ConsumersInfo(stream interface{}, opts ...interface{}) *JetStreamContext_ConsumersInfo_Call

ConsumersInfo is a helper method to define mock.On call

  • stream string
  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) CreateKeyValue 

func (_e *JetStreamContext_Expecter) CreateKeyValue(cfg interface{}) *JetStreamContext_CreateKeyValue_Call

CreateKeyValue is a helper method to define mock.On call

  • cfg *nats.KeyValueConfig

func (*JetStreamContext_Expecter) CreateObjectStore 

func (_e *JetStreamContext_Expecter) CreateObjectStore(cfg interface{}) *JetStreamContext_CreateObjectStore_Call

CreateObjectStore is a helper method to define mock.On call

  • cfg *nats.ObjectStoreConfig

func (*JetStreamContext_Expecter) DeleteConsumer 

func (_e *JetStreamContext_Expecter) DeleteConsumer(stream interface{}, consumer interface{}, opts ...interface{}) *JetStreamContext_DeleteConsumer_Call

DeleteConsumer is a helper method to define mock.On call

  • stream string
  • consumer string
  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) DeleteKeyValue 

func (_e *JetStreamContext_Expecter) DeleteKeyValue(bucket interface{}) *JetStreamContext_DeleteKeyValue_Call

DeleteKeyValue is a helper method to define mock.On call

  • bucket string

func (*JetStreamContext_Expecter) DeleteMsg 

func (_e *JetStreamContext_Expecter) DeleteMsg(name interface{}, seq interface{}, opts ...interface{}) *JetStreamContext_DeleteMsg_Call

DeleteMsg is a helper method to define mock.On call

  • name string
  • seq uint64
  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) DeleteObjectStore 

func (_e *JetStreamContext_Expecter) DeleteObjectStore(bucket interface{}) *JetStreamContext_DeleteObjectStore_Call

DeleteObjectStore is a helper method to define mock.On call

  • bucket string

func (*JetStreamContext_Expecter) DeleteStream 

func (_e *JetStreamContext_Expecter) DeleteStream(name interface{}, opts ...interface{}) *JetStreamContext_DeleteStream_Call

DeleteStream is a helper method to define mock.On call

  • name string
  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) GetLastMsg 

func (_e *JetStreamContext_Expecter) GetLastMsg(name interface{}, subject interface{}, opts ...interface{}) *JetStreamContext_GetLastMsg_Call

GetLastMsg is a helper method to define mock.On call

  • name string
  • subject string
  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) GetMsg 

func (_e *JetStreamContext_Expecter) GetMsg(name interface{}, seq interface{}, opts ...interface{}) *JetStreamContext_GetMsg_Call

GetMsg is a helper method to define mock.On call

  • name string
  • seq uint64
  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) KeyValue 

func (_e *JetStreamContext_Expecter) KeyValue(bucket interface{}) *JetStreamContext_KeyValue_Call

KeyValue is a helper method to define mock.On call

  • bucket string

func (*JetStreamContext_Expecter) KeyValueStoreNames 

func (_e *JetStreamContext_Expecter) KeyValueStoreNames() *JetStreamContext_KeyValueStoreNames_Call

KeyValueStoreNames is a helper method to define mock.On call

func (*JetStreamContext_Expecter) KeyValueStores 

func (_e *JetStreamContext_Expecter) KeyValueStores() *JetStreamContext_KeyValueStores_Call

KeyValueStores is a helper method to define mock.On call

func (*JetStreamContext_Expecter) ObjectStore 

func (_e *JetStreamContext_Expecter) ObjectStore(bucket interface{}) *JetStreamContext_ObjectStore_Call

ObjectStore is a helper method to define mock.On call

  • bucket string

func (*JetStreamContext_Expecter) ObjectStoreNames 

func (_e *JetStreamContext_Expecter) ObjectStoreNames(opts ...interface{}) *JetStreamContext_ObjectStoreNames_Call

ObjectStoreNames is a helper method to define mock.On call

  • opts ...nats.ObjectOpt

func (*JetStreamContext_Expecter) ObjectStores 

func (_e *JetStreamContext_Expecter) ObjectStores(opts ...interface{}) *JetStreamContext_ObjectStores_Call

ObjectStores is a helper method to define mock.On call

  • opts ...nats.ObjectOpt

func (*JetStreamContext_Expecter) Publish 

func (_e *JetStreamContext_Expecter) Publish(subj interface{}, data interface{}, opts ...interface{}) *JetStreamContext_Publish_Call

Publish is a helper method to define mock.On call

  • subj string
  • data []byte
  • opts ...nats.PubOpt

func (*JetStreamContext_Expecter) PublishAsync 

func (_e *JetStreamContext_Expecter) PublishAsync(subj interface{}, data interface{}, opts ...interface{}) *JetStreamContext_PublishAsync_Call

PublishAsync is a helper method to define mock.On call

  • subj string
  • data []byte
  • opts ...nats.PubOpt

func (*JetStreamContext_Expecter) PublishAsyncComplete 

func (_e *JetStreamContext_Expecter) PublishAsyncComplete() *JetStreamContext_PublishAsyncComplete_Call

PublishAsyncComplete is a helper method to define mock.On call

func (*JetStreamContext_Expecter) PublishAsyncPending 

func (_e *JetStreamContext_Expecter) PublishAsyncPending() *JetStreamContext_PublishAsyncPending_Call

PublishAsyncPending is a helper method to define mock.On call

func (*JetStreamContext_Expecter) PublishMsg 

func (_e *JetStreamContext_Expecter) PublishMsg(m interface{}, opts ...interface{}) *JetStreamContext_PublishMsg_Call

PublishMsg is a helper method to define mock.On call

  • m *nats.Msg
  • opts ...nats.PubOpt

func (*JetStreamContext_Expecter) PublishMsgAsync 

func (_e *JetStreamContext_Expecter) PublishMsgAsync(m interface{}, opts ...interface{}) *JetStreamContext_PublishMsgAsync_Call

PublishMsgAsync is a helper method to define mock.On call

  • m *nats.Msg
  • opts ...nats.PubOpt

func (*JetStreamContext_Expecter) PullSubscribe 

func (_e *JetStreamContext_Expecter) PullSubscribe(subj interface{}, durable interface{}, opts ...interface{}) *JetStreamContext_PullSubscribe_Call

PullSubscribe is a helper method to define mock.On call

  • subj string
  • durable string
  • opts ...nats.SubOpt

func (*JetStreamContext_Expecter) PurgeStream 

func (_e *JetStreamContext_Expecter) PurgeStream(name interface{}, opts ...interface{}) *JetStreamContext_PurgeStream_Call

PurgeStream is a helper method to define mock.On call

  • name string
  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) QueueSubscribe 

func (_e *JetStreamContext_Expecter) QueueSubscribe(subj interface{}, queue interface{}, cb interface{}, opts ...interface{}) *JetStreamContext_QueueSubscribe_Call

QueueSubscribe is a helper method to define mock.On call

  • subj string
  • queue string
  • cb nats.MsgHandler
  • opts ...nats.SubOpt

func (*JetStreamContext_Expecter) QueueSubscribeSync 

func (_e *JetStreamContext_Expecter) QueueSubscribeSync(subj interface{}, queue interface{}, opts ...interface{}) *JetStreamContext_QueueSubscribeSync_Call

QueueSubscribeSync is a helper method to define mock.On call

  • subj string
  • queue string
  • opts ...nats.SubOpt

func (*JetStreamContext_Expecter) SecureDeleteMsg 

func (_e *JetStreamContext_Expecter) SecureDeleteMsg(name interface{}, seq interface{}, opts ...interface{}) *JetStreamContext_SecureDeleteMsg_Call

SecureDeleteMsg is a helper method to define mock.On call

  • name string
  • seq uint64
  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) StreamInfo 

func (_e *JetStreamContext_Expecter) StreamInfo(stream interface{}, opts ...interface{}) *JetStreamContext_StreamInfo_Call

StreamInfo is a helper method to define mock.On call

  • stream string
  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) StreamNameBySubject 

func (_e *JetStreamContext_Expecter) StreamNameBySubject(_a0 interface{}, _a1 ...interface{}) *JetStreamContext_StreamNameBySubject_Call

StreamNameBySubject is a helper method to define mock.On call

  • _a0 string
  • _a1 ...nats.JSOpt

func (*JetStreamContext_Expecter) StreamNames 

func (_e *JetStreamContext_Expecter) StreamNames(opts ...interface{}) *JetStreamContext_StreamNames_Call

StreamNames is a helper method to define mock.On call

  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) Streams 

func (_e *JetStreamContext_Expecter) Streams(opts ...interface{}) *JetStreamContext_Streams_Call

Streams is a helper method to define mock.On call

  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) StreamsInfo 

func (_e *JetStreamContext_Expecter) StreamsInfo(opts ...interface{}) *JetStreamContext_StreamsInfo_Call

StreamsInfo is a helper method to define mock.On call

  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) Subscribe 

func (_e *JetStreamContext_Expecter) Subscribe(subj interface{}, cb interface{}, opts ...interface{}) *JetStreamContext_Subscribe_Call

Subscribe is a helper method to define mock.On call

  • subj string
  • cb nats.MsgHandler
  • opts ...nats.SubOpt

func (*JetStreamContext_Expecter) SubscribeSync 

func (_e *JetStreamContext_Expecter) SubscribeSync(subj interface{}, opts ...interface{}) *JetStreamContext_SubscribeSync_Call

SubscribeSync is a helper method to define mock.On call

  • subj string
  • opts ...nats.SubOpt

func (*JetStreamContext_Expecter) UpdateConsumer 

func (_e *JetStreamContext_Expecter) UpdateConsumer(stream interface{}, cfg interface{}, opts ...interface{}) *JetStreamContext_UpdateConsumer_Call

UpdateConsumer is a helper method to define mock.On call

  • stream string
  • cfg *nats.ConsumerConfig
  • opts ...nats.JSOpt

func (*JetStreamContext_Expecter) UpdateStream 

func (_e *JetStreamContext_Expecter) UpdateStream(cfg interface{}, opts ...interface{}) *JetStreamContext_UpdateStream_Call

UpdateStream is a helper method to define mock.On call

  • cfg *nats.StreamConfig
  • opts ...nats.JSOpt

type JetStreamContext_GetLastMsg_Call 

type JetStreamContext_GetLastMsg_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_GetLastMsg_Call) Return 

func (_c *JetStreamContext_GetLastMsg_Call) Return(_a0 *nats.RawStreamMsg, _a1 error) *JetStreamContext_GetLastMsg_Call

func (*JetStreamContext_GetLastMsg_Call) Run 

func (_c *JetStreamContext_GetLastMsg_Call) Run(run func(name string, subject string, opts ...nats.JSOpt)) *JetStreamContext_GetLastMsg_Call

func (*JetStreamContext_GetLastMsg_Call) RunAndReturn 

func (_c *JetStreamContext_GetLastMsg_Call) RunAndReturn(run func(string, string, ...nats.JSOpt) (*nats.RawStreamMsg, error)) *JetStreamContext_GetLastMsg_Call

type JetStreamContext_GetMsg_Call 

type JetStreamContext_GetMsg_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_GetMsg_Call) Return 

func (_c *JetStreamContext_GetMsg_Call) Return(_a0 *nats.RawStreamMsg, _a1 error) *JetStreamContext_GetMsg_Call

func (*JetStreamContext_GetMsg_Call) Run 

func (_c *JetStreamContext_GetMsg_Call) Run(run func(name string, seq uint64, opts ...nats.JSOpt)) *JetStreamContext_GetMsg_Call

func (*JetStreamContext_GetMsg_Call) RunAndReturn 

func (_c *JetStreamContext_GetMsg_Call) RunAndReturn(run func(string, uint64, ...nats.JSOpt) (*nats.RawStreamMsg, error)) *JetStreamContext_GetMsg_Call

type JetStreamContext_KeyValueStoreNames_Call 

type JetStreamContext_KeyValueStoreNames_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_KeyValueStoreNames_Call) Return 

func (_c *JetStreamContext_KeyValueStoreNames_Call) Return(_a0 <-chan string) *JetStreamContext_KeyValueStoreNames_Call

func (*JetStreamContext_KeyValueStoreNames_Call) Run 

func (_c *JetStreamContext_KeyValueStoreNames_Call) Run(run func()) *JetStreamContext_KeyValueStoreNames_Call

func (*JetStreamContext_KeyValueStoreNames_Call) RunAndReturn 

func (_c *JetStreamContext_KeyValueStoreNames_Call) RunAndReturn(run func() <-chan string) *JetStreamContext_KeyValueStoreNames_Call

type JetStreamContext_KeyValueStores_Call 

type JetStreamContext_KeyValueStores_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_KeyValueStores_Call) Return 

func (_c *JetStreamContext_KeyValueStores_Call) Return(_a0 <-chan nats.KeyValueStatus) *JetStreamContext_KeyValueStores_Call

func (*JetStreamContext_KeyValueStores_Call) Run 

func (_c *JetStreamContext_KeyValueStores_Call) Run(run func()) *JetStreamContext_KeyValueStores_Call

func (*JetStreamContext_KeyValueStores_Call) RunAndReturn 

func (_c *JetStreamContext_KeyValueStores_Call) RunAndReturn(run func() <-chan nats.KeyValueStatus) *JetStreamContext_KeyValueStores_Call

type JetStreamContext_KeyValue_Call 

type JetStreamContext_KeyValue_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_KeyValue_Call) Return 

func (_c *JetStreamContext_KeyValue_Call) Return(_a0 nats.KeyValue, _a1 error) *JetStreamContext_KeyValue_Call

func (*JetStreamContext_KeyValue_Call) Run 

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

func (*JetStreamContext_KeyValue_Call) RunAndReturn 

func (_c *JetStreamContext_KeyValue_Call) RunAndReturn(run func(string) (nats.KeyValue, error)) *JetStreamContext_KeyValue_Call

type JetStreamContext_ObjectStoreNames_Call 

type JetStreamContext_ObjectStoreNames_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_ObjectStoreNames_Call) Return 

func (_c *JetStreamContext_ObjectStoreNames_Call) Return(_a0 <-chan string) *JetStreamContext_ObjectStoreNames_Call

func (*JetStreamContext_ObjectStoreNames_Call) Run 

func (_c *JetStreamContext_ObjectStoreNames_Call) Run(run func(opts ...nats.ObjectOpt)) *JetStreamContext_ObjectStoreNames_Call

func (*JetStreamContext_ObjectStoreNames_Call) RunAndReturn 

func (_c *JetStreamContext_ObjectStoreNames_Call) RunAndReturn(run func(...nats.ObjectOpt) <-chan string) *JetStreamContext_ObjectStoreNames_Call

type JetStreamContext_ObjectStore_Call 

type JetStreamContext_ObjectStore_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_ObjectStore_Call) Return 

func (_c *JetStreamContext_ObjectStore_Call) Return(_a0 nats.ObjectStore, _a1 error) *JetStreamContext_ObjectStore_Call

func (*JetStreamContext_ObjectStore_Call) Run 

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

func (*JetStreamContext_ObjectStore_Call) RunAndReturn 

func (_c *JetStreamContext_ObjectStore_Call) RunAndReturn(run func(string) (nats.ObjectStore, error)) *JetStreamContext_ObjectStore_Call

type JetStreamContext_ObjectStores_Call 

type JetStreamContext_ObjectStores_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_ObjectStores_Call) Return 

func (_c *JetStreamContext_ObjectStores_Call) Return(_a0 <-chan nats.ObjectStoreStatus) *JetStreamContext_ObjectStores_Call

func (*JetStreamContext_ObjectStores_Call) Run 

func (_c *JetStreamContext_ObjectStores_Call) Run(run func(opts ...nats.ObjectOpt)) *JetStreamContext_ObjectStores_Call

func (*JetStreamContext_ObjectStores_Call) RunAndReturn 

func (_c *JetStreamContext_ObjectStores_Call) RunAndReturn(run func(...nats.ObjectOpt) <-chan nats.ObjectStoreStatus) *JetStreamContext_ObjectStores_Call

type JetStreamContext_PublishAsyncComplete_Call 

type JetStreamContext_PublishAsyncComplete_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_PublishAsyncComplete_Call) Return 

func (_c *JetStreamContext_PublishAsyncComplete_Call) Return(_a0 <-chan struct{}) *JetStreamContext_PublishAsyncComplete_Call

func (*JetStreamContext_PublishAsyncComplete_Call) Run 

func (_c *JetStreamContext_PublishAsyncComplete_Call) Run(run func()) *JetStreamContext_PublishAsyncComplete_Call

func (*JetStreamContext_PublishAsyncComplete_Call) RunAndReturn 

func (_c *JetStreamContext_PublishAsyncComplete_Call) RunAndReturn(run func() <-chan struct{}) *JetStreamContext_PublishAsyncComplete_Call

type JetStreamContext_PublishAsyncPending_Call 

type JetStreamContext_PublishAsyncPending_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_PublishAsyncPending_Call) Return 

func (_c *JetStreamContext_PublishAsyncPending_Call) Return(_a0 int) *JetStreamContext_PublishAsyncPending_Call

func (*JetStreamContext_PublishAsyncPending_Call) Run 

func (_c *JetStreamContext_PublishAsyncPending_Call) Run(run func()) *JetStreamContext_PublishAsyncPending_Call

func (*JetStreamContext_PublishAsyncPending_Call) RunAndReturn 

func (_c *JetStreamContext_PublishAsyncPending_Call) RunAndReturn(run func() int) *JetStreamContext_PublishAsyncPending_Call

type JetStreamContext_PublishAsync_Call 

type JetStreamContext_PublishAsync_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_PublishAsync_Call) Return 

func (_c *JetStreamContext_PublishAsync_Call) Return(_a0 nats.PubAckFuture, _a1 error) *JetStreamContext_PublishAsync_Call

func (*JetStreamContext_PublishAsync_Call) Run 

func (_c *JetStreamContext_PublishAsync_Call) Run(run func(subj string, data []byte, opts ...nats.PubOpt)) *JetStreamContext_PublishAsync_Call

func (*JetStreamContext_PublishAsync_Call) RunAndReturn 

func (_c *JetStreamContext_PublishAsync_Call) RunAndReturn(run func(string, []byte, ...nats.PubOpt) (nats.PubAckFuture, error)) *JetStreamContext_PublishAsync_Call

type JetStreamContext_PublishMsgAsync_Call 

type JetStreamContext_PublishMsgAsync_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_PublishMsgAsync_Call) Return 

func (_c *JetStreamContext_PublishMsgAsync_Call) Return(_a0 nats.PubAckFuture, _a1 error) *JetStreamContext_PublishMsgAsync_Call

func (*JetStreamContext_PublishMsgAsync_Call) Run 

func (_c *JetStreamContext_PublishMsgAsync_Call) Run(run func(m *nats.Msg, opts ...nats.PubOpt)) *JetStreamContext_PublishMsgAsync_Call

func (*JetStreamContext_PublishMsgAsync_Call) RunAndReturn 

func (_c *JetStreamContext_PublishMsgAsync_Call) RunAndReturn(run func(*nats.Msg, ...nats.PubOpt) (nats.PubAckFuture, error)) *JetStreamContext_PublishMsgAsync_Call

type JetStreamContext_PublishMsg_Call 

type JetStreamContext_PublishMsg_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_PublishMsg_Call) Return 

func (_c *JetStreamContext_PublishMsg_Call) Return(_a0 *nats.PubAck, _a1 error) *JetStreamContext_PublishMsg_Call

func (*JetStreamContext_PublishMsg_Call) Run 

func (_c *JetStreamContext_PublishMsg_Call) Run(run func(m *nats.Msg, opts ...nats.PubOpt)) *JetStreamContext_PublishMsg_Call

func (*JetStreamContext_PublishMsg_Call) RunAndReturn 

func (_c *JetStreamContext_PublishMsg_Call) RunAndReturn(run func(*nats.Msg, ...nats.PubOpt) (*nats.PubAck, error)) *JetStreamContext_PublishMsg_Call

type JetStreamContext_Publish_Call 

type JetStreamContext_Publish_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_Publish_Call) Return 

func (_c *JetStreamContext_Publish_Call) Return(_a0 *nats.PubAck, _a1 error) *JetStreamContext_Publish_Call

func (*JetStreamContext_Publish_Call) Run 

func (_c *JetStreamContext_Publish_Call) Run(run func(subj string, data []byte, opts ...nats.PubOpt)) *JetStreamContext_Publish_Call

func (*JetStreamContext_Publish_Call) RunAndReturn 

func (_c *JetStreamContext_Publish_Call) RunAndReturn(run func(string, []byte, ...nats.PubOpt) (*nats.PubAck, error)) *JetStreamContext_Publish_Call

type JetStreamContext_PullSubscribe_Call 

type JetStreamContext_PullSubscribe_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_PullSubscribe_Call) Return 

func (_c *JetStreamContext_PullSubscribe_Call) Return(_a0 *nats.Subscription, _a1 error) *JetStreamContext_PullSubscribe_Call

func (*JetStreamContext_PullSubscribe_Call) Run 

func (_c *JetStreamContext_PullSubscribe_Call) Run(run func(subj string, durable string, opts ...nats.SubOpt)) *JetStreamContext_PullSubscribe_Call

func (*JetStreamContext_PullSubscribe_Call) RunAndReturn 

func (_c *JetStreamContext_PullSubscribe_Call) RunAndReturn(run func(string, string, ...nats.SubOpt) (*nats.Subscription, error)) *JetStreamContext_PullSubscribe_Call

type JetStreamContext_PurgeStream_Call 

type JetStreamContext_PurgeStream_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_PurgeStream_Call) Return 

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

func (*JetStreamContext_PurgeStream_Call) Run 

func (_c *JetStreamContext_PurgeStream_Call) Run(run func(name string, opts ...nats.JSOpt)) *JetStreamContext_PurgeStream_Call

func (*JetStreamContext_PurgeStream_Call) RunAndReturn 

func (_c *JetStreamContext_PurgeStream_Call) RunAndReturn(run func(string, ...nats.JSOpt) error) *JetStreamContext_PurgeStream_Call

type JetStreamContext_QueueSubscribeSync_Call 

type JetStreamContext_QueueSubscribeSync_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_QueueSubscribeSync_Call) Return 

func (_c *JetStreamContext_QueueSubscribeSync_Call) Return(_a0 *nats.Subscription, _a1 error) *JetStreamContext_QueueSubscribeSync_Call

func (*JetStreamContext_QueueSubscribeSync_Call) Run 

func (_c *JetStreamContext_QueueSubscribeSync_Call) Run(run func(subj string, queue string, opts ...nats.SubOpt)) *JetStreamContext_QueueSubscribeSync_Call

func (*JetStreamContext_QueueSubscribeSync_Call) RunAndReturn 

func (_c *JetStreamContext_QueueSubscribeSync_Call) RunAndReturn(run func(string, string, ...nats.SubOpt) (*nats.Subscription, error)) *JetStreamContext_QueueSubscribeSync_Call

type JetStreamContext_QueueSubscribe_Call 

type JetStreamContext_QueueSubscribe_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_QueueSubscribe_Call) Return 

func (_c *JetStreamContext_QueueSubscribe_Call) Return(_a0 *nats.Subscription, _a1 error) *JetStreamContext_QueueSubscribe_Call

func (*JetStreamContext_QueueSubscribe_Call) Run 

func (_c *JetStreamContext_QueueSubscribe_Call) Run(run func(subj string, queue string, cb nats.MsgHandler, opts ...nats.SubOpt)) *JetStreamContext_QueueSubscribe_Call

func (*JetStreamContext_QueueSubscribe_Call) RunAndReturn 

func (_c *JetStreamContext_QueueSubscribe_Call) RunAndReturn(run func(string, string, nats.MsgHandler, ...nats.SubOpt) (*nats.Subscription, error)) *JetStreamContext_QueueSubscribe_Call

type JetStreamContext_SecureDeleteMsg_Call 

type JetStreamContext_SecureDeleteMsg_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_SecureDeleteMsg_Call) Return 

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

func (*JetStreamContext_SecureDeleteMsg_Call) Run 

func (_c *JetStreamContext_SecureDeleteMsg_Call) Run(run func(name string, seq uint64, opts ...nats.JSOpt)) *JetStreamContext_SecureDeleteMsg_Call

func (*JetStreamContext_SecureDeleteMsg_Call) RunAndReturn 

func (_c *JetStreamContext_SecureDeleteMsg_Call) RunAndReturn(run func(string, uint64, ...nats.JSOpt) error) *JetStreamContext_SecureDeleteMsg_Call

type JetStreamContext_StreamInfo_Call 

type JetStreamContext_StreamInfo_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_StreamInfo_Call) Return 

func (_c *JetStreamContext_StreamInfo_Call) Return(_a0 *nats.StreamInfo, _a1 error) *JetStreamContext_StreamInfo_Call

func (*JetStreamContext_StreamInfo_Call) Run 

func (_c *JetStreamContext_StreamInfo_Call) Run(run func(stream string, opts ...nats.JSOpt)) *JetStreamContext_StreamInfo_Call

func (*JetStreamContext_StreamInfo_Call) RunAndReturn 

func (_c *JetStreamContext_StreamInfo_Call) RunAndReturn(run func(string, ...nats.JSOpt) (*nats.StreamInfo, error)) *JetStreamContext_StreamInfo_Call

type JetStreamContext_StreamNameBySubject_Call 

type JetStreamContext_StreamNameBySubject_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_StreamNameBySubject_Call) Return 

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

func (*JetStreamContext_StreamNameBySubject_Call) Run 

func (_c *JetStreamContext_StreamNameBySubject_Call) Run(run func(_a0 string, _a1 ...nats.JSOpt)) *JetStreamContext_StreamNameBySubject_Call

func (*JetStreamContext_StreamNameBySubject_Call) RunAndReturn 

func (_c *JetStreamContext_StreamNameBySubject_Call) RunAndReturn(run func(string, ...nats.JSOpt) (string, error)) *JetStreamContext_StreamNameBySubject_Call

type JetStreamContext_StreamNames_Call 

type JetStreamContext_StreamNames_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_StreamNames_Call) Return 

func (_c *JetStreamContext_StreamNames_Call) Return(_a0 <-chan string) *JetStreamContext_StreamNames_Call

func (*JetStreamContext_StreamNames_Call) Run 

func (_c *JetStreamContext_StreamNames_Call) Run(run func(opts ...nats.JSOpt)) *JetStreamContext_StreamNames_Call

func (*JetStreamContext_StreamNames_Call) RunAndReturn 

func (_c *JetStreamContext_StreamNames_Call) RunAndReturn(run func(...nats.JSOpt) <-chan string) *JetStreamContext_StreamNames_Call

type JetStreamContext_StreamsInfo_Call 

type JetStreamContext_StreamsInfo_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_StreamsInfo_Call) Return 

func (_c *JetStreamContext_StreamsInfo_Call) Return(_a0 <-chan *nats.StreamInfo) *JetStreamContext_StreamsInfo_Call

func (*JetStreamContext_StreamsInfo_Call) Run 

func (_c *JetStreamContext_StreamsInfo_Call) Run(run func(opts ...nats.JSOpt)) *JetStreamContext_StreamsInfo_Call

func (*JetStreamContext_StreamsInfo_Call) RunAndReturn 

func (_c *JetStreamContext_StreamsInfo_Call) RunAndReturn(run func(...nats.JSOpt) <-chan *nats.StreamInfo) *JetStreamContext_StreamsInfo_Call

type JetStreamContext_Streams_Call 

type JetStreamContext_Streams_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_Streams_Call) Return 

func (_c *JetStreamContext_Streams_Call) Return(_a0 <-chan *nats.StreamInfo) *JetStreamContext_Streams_Call

func (*JetStreamContext_Streams_Call) Run 

func (_c *JetStreamContext_Streams_Call) Run(run func(opts ...nats.JSOpt)) *JetStreamContext_Streams_Call

func (*JetStreamContext_Streams_Call) RunAndReturn 

func (_c *JetStreamContext_Streams_Call) RunAndReturn(run func(...nats.JSOpt) <-chan *nats.StreamInfo) *JetStreamContext_Streams_Call

type JetStreamContext_SubscribeSync_Call 

type JetStreamContext_SubscribeSync_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_SubscribeSync_Call) Return 

func (_c *JetStreamContext_SubscribeSync_Call) Return(_a0 *nats.Subscription, _a1 error) *JetStreamContext_SubscribeSync_Call

func (*JetStreamContext_SubscribeSync_Call) Run 

func (_c *JetStreamContext_SubscribeSync_Call) Run(run func(subj string, opts ...nats.SubOpt)) *JetStreamContext_SubscribeSync_Call

func (*JetStreamContext_SubscribeSync_Call) RunAndReturn 

func (_c *JetStreamContext_SubscribeSync_Call) RunAndReturn(run func(string, ...nats.SubOpt) (*nats.Subscription, error)) *JetStreamContext_SubscribeSync_Call

type JetStreamContext_Subscribe_Call 

type JetStreamContext_Subscribe_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_Subscribe_Call) Return 

func (_c *JetStreamContext_Subscribe_Call) Return(_a0 *nats.Subscription, _a1 error) *JetStreamContext_Subscribe_Call

func (*JetStreamContext_Subscribe_Call) Run 

func (_c *JetStreamContext_Subscribe_Call) Run(run func(subj string, cb nats.MsgHandler, opts ...nats.SubOpt)) *JetStreamContext_Subscribe_Call

func (*JetStreamContext_Subscribe_Call) RunAndReturn 

func (_c *JetStreamContext_Subscribe_Call) RunAndReturn(run func(string, nats.MsgHandler, ...nats.SubOpt) (*nats.Subscription, error)) *JetStreamContext_Subscribe_Call

type JetStreamContext_UpdateConsumer_Call 

type JetStreamContext_UpdateConsumer_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_UpdateConsumer_Call) Return 

func (_c *JetStreamContext_UpdateConsumer_Call) Return(_a0 *nats.ConsumerInfo, _a1 error) *JetStreamContext_UpdateConsumer_Call

func (*JetStreamContext_UpdateConsumer_Call) Run 

func (_c *JetStreamContext_UpdateConsumer_Call) Run(run func(stream string, cfg *nats.ConsumerConfig, opts ...nats.JSOpt)) *JetStreamContext_UpdateConsumer_Call

func (*JetStreamContext_UpdateConsumer_Call) RunAndReturn 

func (_c *JetStreamContext_UpdateConsumer_Call) RunAndReturn(run func(string, *nats.ConsumerConfig, ...nats.JSOpt) (*nats.ConsumerInfo, error)) *JetStreamContext_UpdateConsumer_Call

type JetStreamContext_UpdateStream_Call 

type JetStreamContext_UpdateStream_Call struct {
	*mock.Call
}

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

func (*JetStreamContext_UpdateStream_Call) Return 

func (_c *JetStreamContext_UpdateStream_Call) Return(_a0 *nats.StreamInfo, _a1 error) *JetStreamContext_UpdateStream_Call

func (*JetStreamContext_UpdateStream_Call) Run 

func (_c *JetStreamContext_UpdateStream_Call) Run(run func(cfg *nats.StreamConfig, opts ...nats.JSOpt)) *JetStreamContext_UpdateStream_Call

func (*JetStreamContext_UpdateStream_Call) RunAndReturn 

func (_c *JetStreamContext_UpdateStream_Call) RunAndReturn(run func(*nats.StreamConfig, ...nats.JSOpt) (*nats.StreamInfo, error)) *JetStreamContext_UpdateStream_Call

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.