jetstream

package
v0.0.0-...-7907c65 Latest Latest
Warning

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

 Go to latest Published: Apr 24, 2024 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 Consumer 

type Consumer struct {
	mock.Mock
}

Consumer is an autogenerated mock type for the Consumer type

func NewConsumer 

func NewConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *Consumer

NewConsumer creates a new instance of Consumer. 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 (*Consumer) CachedInfo 

func (_m *Consumer) CachedInfo() *jetstream.ConsumerInfo

CachedInfo provides a mock function with given fields:

func (*Consumer) Consume 

func (_m *Consumer) Consume(handler jetstream.MessageHandler, opts ...jetstream.PullConsumeOpt) (jetstream.ConsumeContext, error)

Consume provides a mock function with given fields: handler, opts

func (*Consumer) EXPECT 

func (_m *Consumer) EXPECT() *Consumer_Expecter

func (*Consumer) Fetch 

func (_m *Consumer) Fetch(batch int, opts ...jetstream.FetchOpt) (jetstream.MessageBatch, error)

Fetch provides a mock function with given fields: batch, opts

func (*Consumer) FetchBytes 

func (_m *Consumer) FetchBytes(maxBytes int, opts ...jetstream.FetchOpt) (jetstream.MessageBatch, error)

FetchBytes provides a mock function with given fields: maxBytes, opts

func (*Consumer) FetchNoWait 

func (_m *Consumer) FetchNoWait(batch int) (jetstream.MessageBatch, error)

FetchNoWait provides a mock function with given fields: batch

func (*Consumer) Info 

func (_m *Consumer) Info(_a0 context.Context) (*jetstream.ConsumerInfo, error)

Info provides a mock function with given fields: _a0

func (*Consumer) Messages 

func (_m *Consumer) Messages(opts ...jetstream.PullMessagesOpt) (jetstream.MessagesContext, error)

Messages provides a mock function with given fields: opts

func (*Consumer) Next 

func (_m *Consumer) Next(opts ...jetstream.FetchOpt) (jetstream.Msg, error)

Next provides a mock function with given fields: opts

type Consumer_CachedInfo_Call 

type Consumer_CachedInfo_Call struct {
	*mock.Call
}

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

func (*Consumer_CachedInfo_Call) Return 

func (_c *Consumer_CachedInfo_Call) Return(_a0 *jetstream.ConsumerInfo) *Consumer_CachedInfo_Call

func (*Consumer_CachedInfo_Call) Run 

func (_c *Consumer_CachedInfo_Call) Run(run func()) *Consumer_CachedInfo_Call

func (*Consumer_CachedInfo_Call) RunAndReturn 

func (_c *Consumer_CachedInfo_Call) RunAndReturn(run func() *jetstream.ConsumerInfo) *Consumer_CachedInfo_Call

type Consumer_Consume_Call 

type Consumer_Consume_Call struct {
	*mock.Call
}

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

func (*Consumer_Consume_Call) Return 

func (_c *Consumer_Consume_Call) Return(_a0 jetstream.ConsumeContext, _a1 error) *Consumer_Consume_Call

func (*Consumer_Consume_Call) Run 

func (_c *Consumer_Consume_Call) Run(run func(handler jetstream.MessageHandler, opts ...jetstream.PullConsumeOpt)) *Consumer_Consume_Call

func (*Consumer_Consume_Call) RunAndReturn 

func (_c *Consumer_Consume_Call) RunAndReturn(run func(jetstream.MessageHandler, ...jetstream.PullConsumeOpt) (jetstream.ConsumeContext, error)) *Consumer_Consume_Call

type Consumer_Expecter 

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

func (*Consumer_Expecter) CachedInfo 

func (_e *Consumer_Expecter) CachedInfo() *Consumer_CachedInfo_Call

CachedInfo is a helper method to define mock.On call

func (*Consumer_Expecter) Consume 

func (_e *Consumer_Expecter) Consume(handler interface{}, opts ...interface{}) *Consumer_Consume_Call

Consume is a helper method to define mock.On call

  • handler jetstream.MessageHandler
  • opts ...jetstream.PullConsumeOpt

func (*Consumer_Expecter) Fetch 

func (_e *Consumer_Expecter) Fetch(batch interface{}, opts ...interface{}) *Consumer_Fetch_Call

Fetch is a helper method to define mock.On call

  • batch int
  • opts ...jetstream.FetchOpt

func (*Consumer_Expecter) FetchBytes 

func (_e *Consumer_Expecter) FetchBytes(maxBytes interface{}, opts ...interface{}) *Consumer_FetchBytes_Call

FetchBytes is a helper method to define mock.On call

  • maxBytes int
  • opts ...jetstream.FetchOpt

func (*Consumer_Expecter) FetchNoWait 

func (_e *Consumer_Expecter) FetchNoWait(batch interface{}) *Consumer_FetchNoWait_Call

FetchNoWait is a helper method to define mock.On call

  • batch int

func (*Consumer_Expecter) Info 

func (_e *Consumer_Expecter) Info(_a0 interface{}) *Consumer_Info_Call

Info is a helper method to define mock.On call

  • _a0 context.Context

func (*Consumer_Expecter) Messages 

func (_e *Consumer_Expecter) Messages(opts ...interface{}) *Consumer_Messages_Call

Messages is a helper method to define mock.On call

  • opts ...jetstream.PullMessagesOpt

func (*Consumer_Expecter) Next 

func (_e *Consumer_Expecter) Next(opts ...interface{}) *Consumer_Next_Call

Next is a helper method to define mock.On call

  • opts ...jetstream.FetchOpt

type Consumer_FetchBytes_Call 

type Consumer_FetchBytes_Call struct {
	*mock.Call
}

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

func (*Consumer_FetchBytes_Call) Return 

func (_c *Consumer_FetchBytes_Call) Return(_a0 jetstream.MessageBatch, _a1 error) *Consumer_FetchBytes_Call

func (*Consumer_FetchBytes_Call) Run 

func (_c *Consumer_FetchBytes_Call) Run(run func(maxBytes int, opts ...jetstream.FetchOpt)) *Consumer_FetchBytes_Call

func (*Consumer_FetchBytes_Call) RunAndReturn 

func (_c *Consumer_FetchBytes_Call) RunAndReturn(run func(int, ...jetstream.FetchOpt) (jetstream.MessageBatch, error)) *Consumer_FetchBytes_Call

type Consumer_FetchNoWait_Call 

type Consumer_FetchNoWait_Call struct {
	*mock.Call
}

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

func (*Consumer_FetchNoWait_Call) Return 

func (_c *Consumer_FetchNoWait_Call) Return(_a0 jetstream.MessageBatch, _a1 error) *Consumer_FetchNoWait_Call

func (*Consumer_FetchNoWait_Call) Run 

func (_c *Consumer_FetchNoWait_Call) Run(run func(batch int)) *Consumer_FetchNoWait_Call

func (*Consumer_FetchNoWait_Call) RunAndReturn 

func (_c *Consumer_FetchNoWait_Call) RunAndReturn(run func(int) (jetstream.MessageBatch, error)) *Consumer_FetchNoWait_Call

type Consumer_Fetch_Call 

type Consumer_Fetch_Call struct {
	*mock.Call
}

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

func (*Consumer_Fetch_Call) Return 

func (_c *Consumer_Fetch_Call) Return(_a0 jetstream.MessageBatch, _a1 error) *Consumer_Fetch_Call

func (*Consumer_Fetch_Call) Run 

func (_c *Consumer_Fetch_Call) Run(run func(batch int, opts ...jetstream.FetchOpt)) *Consumer_Fetch_Call

func (*Consumer_Fetch_Call) RunAndReturn 

func (_c *Consumer_Fetch_Call) RunAndReturn(run func(int, ...jetstream.FetchOpt) (jetstream.MessageBatch, error)) *Consumer_Fetch_Call

type Consumer_Info_Call 

type Consumer_Info_Call struct {
	*mock.Call
}

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

func (*Consumer_Info_Call) Return 

func (_c *Consumer_Info_Call) Return(_a0 *jetstream.ConsumerInfo, _a1 error) *Consumer_Info_Call

func (*Consumer_Info_Call) Run 

func (_c *Consumer_Info_Call) Run(run func(_a0 context.Context)) *Consumer_Info_Call

func (*Consumer_Info_Call) RunAndReturn 

func (_c *Consumer_Info_Call) RunAndReturn(run func(context.Context) (*jetstream.ConsumerInfo, error)) *Consumer_Info_Call

type Consumer_Messages_Call 

type Consumer_Messages_Call struct {
	*mock.Call
}

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

func (*Consumer_Messages_Call) Return 

func (_c *Consumer_Messages_Call) Return(_a0 jetstream.MessagesContext, _a1 error) *Consumer_Messages_Call

func (*Consumer_Messages_Call) Run 

func (_c *Consumer_Messages_Call) Run(run func(opts ...jetstream.PullMessagesOpt)) *Consumer_Messages_Call

func (*Consumer_Messages_Call) RunAndReturn 

func (_c *Consumer_Messages_Call) RunAndReturn(run func(...jetstream.PullMessagesOpt) (jetstream.MessagesContext, error)) *Consumer_Messages_Call

type Consumer_Next_Call 

type Consumer_Next_Call struct {
	*mock.Call
}

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

func (*Consumer_Next_Call) Return 

func (_c *Consumer_Next_Call) Return(_a0 jetstream.Msg, _a1 error) *Consumer_Next_Call

func (*Consumer_Next_Call) Run 

func (_c *Consumer_Next_Call) Run(run func(opts ...jetstream.FetchOpt)) *Consumer_Next_Call

func (*Consumer_Next_Call) RunAndReturn 

func (_c *Consumer_Next_Call) RunAndReturn(run func(...jetstream.FetchOpt) (jetstream.Msg, error)) *Consumer_Next_Call

type JetStream 

type JetStream struct {
	mock.Mock
}

JetStream is an autogenerated mock type for the JetStream type

func NewJetStream 

func NewJetStream(t interface {
	mock.TestingT
	Cleanup(func())
}) *JetStream

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

func (_m *JetStream) AccountInfo(ctx context.Context) (*jetstream.AccountInfo, error)

AccountInfo provides a mock function with given fields: ctx

func (*JetStream) Consumer 

func (_m *JetStream) Consumer(ctx context.Context, stream string, consumer string) (jetstream.Consumer, error)

Consumer provides a mock function with given fields: ctx, stream, consumer

func (*JetStream) CreateConsumer 

func (_m *JetStream) CreateConsumer(ctx context.Context, stream string, cfg jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateConsumer provides a mock function with given fields: ctx, stream, cfg

func (*JetStream) CreateKeyValue 

func (_m *JetStream) CreateKeyValue(ctx context.Context, cfg jetstream.KeyValueConfig) (jetstream.KeyValue, error)

CreateKeyValue provides a mock function with given fields: ctx, cfg

func (*JetStream) CreateObjectStore 

func (_m *JetStream) CreateObjectStore(ctx context.Context, cfg jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)

CreateObjectStore provides a mock function with given fields: ctx, cfg

func (*JetStream) CreateOrUpdateConsumer 

func (_m *JetStream) CreateOrUpdateConsumer(ctx context.Context, stream string, cfg jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateOrUpdateConsumer provides a mock function with given fields: ctx, stream, cfg

func (*JetStream) CreateOrUpdateKeyValue 

func (_m *JetStream) CreateOrUpdateKeyValue(ctx context.Context, cfg jetstream.KeyValueConfig) (jetstream.KeyValue, error)

CreateOrUpdateKeyValue provides a mock function with given fields: ctx, cfg

func (*JetStream) CreateOrUpdateObjectStore 

func (_m *JetStream) CreateOrUpdateObjectStore(ctx context.Context, cfg jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)

CreateOrUpdateObjectStore provides a mock function with given fields: ctx, cfg

func (*JetStream) CreateOrUpdateStream 

func (_m *JetStream) CreateOrUpdateStream(ctx context.Context, cfg jetstream.StreamConfig) (jetstream.Stream, error)

CreateOrUpdateStream provides a mock function with given fields: ctx, cfg

func (*JetStream) CreateStream 

func (_m *JetStream) CreateStream(ctx context.Context, cfg jetstream.StreamConfig) (jetstream.Stream, error)

CreateStream provides a mock function with given fields: ctx, cfg

func (*JetStream) DeleteConsumer 

func (_m *JetStream) DeleteConsumer(ctx context.Context, stream string, consumer string) error

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

func (*JetStream) DeleteKeyValue 

func (_m *JetStream) DeleteKeyValue(ctx context.Context, bucket string) error

DeleteKeyValue provides a mock function with given fields: ctx, bucket

func (*JetStream) DeleteObjectStore 

func (_m *JetStream) DeleteObjectStore(ctx context.Context, bucket string) error

DeleteObjectStore provides a mock function with given fields: ctx, bucket

func (*JetStream) DeleteStream 

func (_m *JetStream) DeleteStream(ctx context.Context, stream string) error

DeleteStream provides a mock function with given fields: ctx, stream

func (*JetStream) EXPECT 

func (_m *JetStream) EXPECT() *JetStream_Expecter

func (*JetStream) KeyValue 

func (_m *JetStream) KeyValue(ctx context.Context, bucket string) (jetstream.KeyValue, error)

KeyValue provides a mock function with given fields: ctx, bucket

func (*JetStream) KeyValueStoreNames 

func (_m *JetStream) KeyValueStoreNames(ctx context.Context) jetstream.KeyValueNamesLister

KeyValueStoreNames provides a mock function with given fields: ctx

func (*JetStream) KeyValueStores 

func (_m *JetStream) KeyValueStores(ctx context.Context) jetstream.KeyValueLister

KeyValueStores provides a mock function with given fields: ctx

func (*JetStream) ListStreams 

func (_m *JetStream) ListStreams(_a0 context.Context, _a1 ...jetstream.StreamListOpt) jetstream.StreamInfoLister

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

func (*JetStream) ObjectStore 

func (_m *JetStream) ObjectStore(ctx context.Context, bucket string) (jetstream.ObjectStore, error)

ObjectStore provides a mock function with given fields: ctx, bucket

func (*JetStream) ObjectStoreNames 

func (_m *JetStream) ObjectStoreNames(ctx context.Context) jetstream.ObjectStoreNamesLister

ObjectStoreNames provides a mock function with given fields: ctx

func (*JetStream) ObjectStores 

func (_m *JetStream) ObjectStores(ctx context.Context) jetstream.ObjectStoresLister

ObjectStores provides a mock function with given fields: ctx

func (*JetStream) OrderedConsumer 

func (_m *JetStream) OrderedConsumer(ctx context.Context, stream string, cfg jetstream.OrderedConsumerConfig) (jetstream.Consumer, error)

OrderedConsumer provides a mock function with given fields: ctx, stream, cfg

func (*JetStream) Publish 

func (_m *JetStream) Publish(ctx context.Context, subject string, payload []byte, opts ...jetstream.PublishOpt) (*jetstream.PubAck, error)

Publish provides a mock function with given fields: ctx, subject, payload, opts

func (*JetStream) PublishAsync 

func (_m *JetStream) PublishAsync(subject string, payload []byte, opts ...jetstream.PublishOpt) (jetstream.PubAckFuture, error)

PublishAsync provides a mock function with given fields: subject, payload, opts

func (*JetStream) PublishAsyncComplete 

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

PublishAsyncComplete provides a mock function with given fields:

func (*JetStream) PublishAsyncPending 

func (_m *JetStream) PublishAsyncPending() int

PublishAsyncPending provides a mock function with given fields:

func (*JetStream) PublishMsg 

func (_m *JetStream) PublishMsg(ctx context.Context, msg *nats.Msg, opts ...jetstream.PublishOpt) (*jetstream.PubAck, error)

PublishMsg provides a mock function with given fields: ctx, msg, opts

func (*JetStream) PublishMsgAsync 

func (_m *JetStream) PublishMsgAsync(msg *nats.Msg, opts ...jetstream.PublishOpt) (jetstream.PubAckFuture, error)

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

func (*JetStream) Stream 

func (_m *JetStream) Stream(ctx context.Context, stream string) (jetstream.Stream, error)

Stream provides a mock function with given fields: ctx, stream

func (*JetStream) StreamNameBySubject 

func (_m *JetStream) StreamNameBySubject(ctx context.Context, subject string) (string, error)

StreamNameBySubject provides a mock function with given fields: ctx, subject

func (*JetStream) StreamNames 

func (_m *JetStream) StreamNames(_a0 context.Context, _a1 ...jetstream.StreamListOpt) jetstream.StreamNameLister

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

func (*JetStream) UpdateConsumer 

func (_m *JetStream) UpdateConsumer(ctx context.Context, stream string, cfg jetstream.ConsumerConfig) (jetstream.Consumer, error)

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

func (*JetStream) UpdateKeyValue 

func (_m *JetStream) UpdateKeyValue(ctx context.Context, cfg jetstream.KeyValueConfig) (jetstream.KeyValue, error)

UpdateKeyValue provides a mock function with given fields: ctx, cfg

func (*JetStream) UpdateObjectStore 

func (_m *JetStream) UpdateObjectStore(ctx context.Context, cfg jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)

UpdateObjectStore provides a mock function with given fields: ctx, cfg

func (*JetStream) UpdateStream 

func (_m *JetStream) UpdateStream(ctx context.Context, cfg jetstream.StreamConfig) (jetstream.Stream, error)

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

type JetStream_AccountInfo_Call 

type JetStream_AccountInfo_Call struct {
	*mock.Call
}

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

func (*JetStream_AccountInfo_Call) Return 

func (_c *JetStream_AccountInfo_Call) Return(_a0 *jetstream.AccountInfo, _a1 error) *JetStream_AccountInfo_Call

func (*JetStream_AccountInfo_Call) Run 

func (_c *JetStream_AccountInfo_Call) Run(run func(ctx context.Context)) *JetStream_AccountInfo_Call

func (*JetStream_AccountInfo_Call) RunAndReturn 

func (_c *JetStream_AccountInfo_Call) RunAndReturn(run func(context.Context) (*jetstream.AccountInfo, error)) *JetStream_AccountInfo_Call

type JetStream_Consumer_Call 

type JetStream_Consumer_Call struct {
	*mock.Call
}

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

func (*JetStream_Consumer_Call) Return 

func (_c *JetStream_Consumer_Call) Return(_a0 jetstream.Consumer, _a1 error) *JetStream_Consumer_Call

func (*JetStream_Consumer_Call) Run 

func (_c *JetStream_Consumer_Call) Run(run func(ctx context.Context, stream string, consumer string)) *JetStream_Consumer_Call

func (*JetStream_Consumer_Call) RunAndReturn 

func (_c *JetStream_Consumer_Call) RunAndReturn(run func(context.Context, string, string) (jetstream.Consumer, error)) *JetStream_Consumer_Call

type JetStream_CreateConsumer_Call 

type JetStream_CreateConsumer_Call struct {
	*mock.Call
}

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

func (*JetStream_CreateConsumer_Call) Return 

func (_c *JetStream_CreateConsumer_Call) Return(_a0 jetstream.Consumer, _a1 error) *JetStream_CreateConsumer_Call

func (*JetStream_CreateConsumer_Call) Run 

func (_c *JetStream_CreateConsumer_Call) Run(run func(ctx context.Context, stream string, cfg jetstream.ConsumerConfig)) *JetStream_CreateConsumer_Call

func (*JetStream_CreateConsumer_Call) RunAndReturn 

func (_c *JetStream_CreateConsumer_Call) RunAndReturn(run func(context.Context, string, jetstream.ConsumerConfig) (jetstream.Consumer, error)) *JetStream_CreateConsumer_Call

type JetStream_CreateKeyValue_Call 

type JetStream_CreateKeyValue_Call struct {
	*mock.Call
}

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

func (*JetStream_CreateKeyValue_Call) Return 

func (_c *JetStream_CreateKeyValue_Call) Return(_a0 jetstream.KeyValue, _a1 error) *JetStream_CreateKeyValue_Call

func (*JetStream_CreateKeyValue_Call) Run 

func (_c *JetStream_CreateKeyValue_Call) Run(run func(ctx context.Context, cfg jetstream.KeyValueConfig)) *JetStream_CreateKeyValue_Call

func (*JetStream_CreateKeyValue_Call) RunAndReturn 

func (_c *JetStream_CreateKeyValue_Call) RunAndReturn(run func(context.Context, jetstream.KeyValueConfig) (jetstream.KeyValue, error)) *JetStream_CreateKeyValue_Call

type JetStream_CreateObjectStore_Call 

type JetStream_CreateObjectStore_Call struct {
	*mock.Call
}

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

func (*JetStream_CreateObjectStore_Call) Return 

func (_c *JetStream_CreateObjectStore_Call) Return(_a0 jetstream.ObjectStore, _a1 error) *JetStream_CreateObjectStore_Call

func (*JetStream_CreateObjectStore_Call) Run 

func (_c *JetStream_CreateObjectStore_Call) Run(run func(ctx context.Context, cfg jetstream.ObjectStoreConfig)) *JetStream_CreateObjectStore_Call

func (*JetStream_CreateObjectStore_Call) RunAndReturn 

func (_c *JetStream_CreateObjectStore_Call) RunAndReturn(run func(context.Context, jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)) *JetStream_CreateObjectStore_Call

type JetStream_CreateOrUpdateConsumer_Call 

type JetStream_CreateOrUpdateConsumer_Call struct {
	*mock.Call
}

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

func (*JetStream_CreateOrUpdateConsumer_Call) Return 

func (_c *JetStream_CreateOrUpdateConsumer_Call) Return(_a0 jetstream.Consumer, _a1 error) *JetStream_CreateOrUpdateConsumer_Call

func (*JetStream_CreateOrUpdateConsumer_Call) Run 

func (_c *JetStream_CreateOrUpdateConsumer_Call) Run(run func(ctx context.Context, stream string, cfg jetstream.ConsumerConfig)) *JetStream_CreateOrUpdateConsumer_Call

func (*JetStream_CreateOrUpdateConsumer_Call) RunAndReturn 

func (_c *JetStream_CreateOrUpdateConsumer_Call) RunAndReturn(run func(context.Context, string, jetstream.ConsumerConfig) (jetstream.Consumer, error)) *JetStream_CreateOrUpdateConsumer_Call

type JetStream_CreateOrUpdateKeyValue_Call 

type JetStream_CreateOrUpdateKeyValue_Call struct {
	*mock.Call
}

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

func (*JetStream_CreateOrUpdateKeyValue_Call) Return 

func (_c *JetStream_CreateOrUpdateKeyValue_Call) Return(_a0 jetstream.KeyValue, _a1 error) *JetStream_CreateOrUpdateKeyValue_Call

func (*JetStream_CreateOrUpdateKeyValue_Call) Run 

func (_c *JetStream_CreateOrUpdateKeyValue_Call) Run(run func(ctx context.Context, cfg jetstream.KeyValueConfig)) *JetStream_CreateOrUpdateKeyValue_Call

func (*JetStream_CreateOrUpdateKeyValue_Call) RunAndReturn 

func (_c *JetStream_CreateOrUpdateKeyValue_Call) RunAndReturn(run func(context.Context, jetstream.KeyValueConfig) (jetstream.KeyValue, error)) *JetStream_CreateOrUpdateKeyValue_Call

type JetStream_CreateOrUpdateObjectStore_Call 

type JetStream_CreateOrUpdateObjectStore_Call struct {
	*mock.Call
}

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

func (*JetStream_CreateOrUpdateObjectStore_Call) Return 

func (_c *JetStream_CreateOrUpdateObjectStore_Call) Return(_a0 jetstream.ObjectStore, _a1 error) *JetStream_CreateOrUpdateObjectStore_Call

func (*JetStream_CreateOrUpdateObjectStore_Call) Run 

func (_c *JetStream_CreateOrUpdateObjectStore_Call) Run(run func(ctx context.Context, cfg jetstream.ObjectStoreConfig)) *JetStream_CreateOrUpdateObjectStore_Call

func (*JetStream_CreateOrUpdateObjectStore_Call) RunAndReturn 

func (_c *JetStream_CreateOrUpdateObjectStore_Call) RunAndReturn(run func(context.Context, jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)) *JetStream_CreateOrUpdateObjectStore_Call

type JetStream_CreateOrUpdateStream_Call 

type JetStream_CreateOrUpdateStream_Call struct {
	*mock.Call
}

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

func (*JetStream_CreateOrUpdateStream_Call) Return 

func (_c *JetStream_CreateOrUpdateStream_Call) Return(_a0 jetstream.Stream, _a1 error) *JetStream_CreateOrUpdateStream_Call

func (*JetStream_CreateOrUpdateStream_Call) Run 

func (_c *JetStream_CreateOrUpdateStream_Call) Run(run func(ctx context.Context, cfg jetstream.StreamConfig)) *JetStream_CreateOrUpdateStream_Call

func (*JetStream_CreateOrUpdateStream_Call) RunAndReturn 

func (_c *JetStream_CreateOrUpdateStream_Call) RunAndReturn(run func(context.Context, jetstream.StreamConfig) (jetstream.Stream, error)) *JetStream_CreateOrUpdateStream_Call

type JetStream_CreateStream_Call 

type JetStream_CreateStream_Call struct {
	*mock.Call
}

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

func (*JetStream_CreateStream_Call) Return 

func (_c *JetStream_CreateStream_Call) Return(_a0 jetstream.Stream, _a1 error) *JetStream_CreateStream_Call

func (*JetStream_CreateStream_Call) Run 

func (_c *JetStream_CreateStream_Call) Run(run func(ctx context.Context, cfg jetstream.StreamConfig)) *JetStream_CreateStream_Call

func (*JetStream_CreateStream_Call) RunAndReturn 

func (_c *JetStream_CreateStream_Call) RunAndReturn(run func(context.Context, jetstream.StreamConfig) (jetstream.Stream, error)) *JetStream_CreateStream_Call

type JetStream_DeleteConsumer_Call 

type JetStream_DeleteConsumer_Call struct {
	*mock.Call
}

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

func (*JetStream_DeleteConsumer_Call) Return 

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

func (*JetStream_DeleteConsumer_Call) Run 

func (_c *JetStream_DeleteConsumer_Call) Run(run func(ctx context.Context, stream string, consumer string)) *JetStream_DeleteConsumer_Call

func (*JetStream_DeleteConsumer_Call) RunAndReturn 

func (_c *JetStream_DeleteConsumer_Call) RunAndReturn(run func(context.Context, string, string) error) *JetStream_DeleteConsumer_Call

type JetStream_DeleteKeyValue_Call 

type JetStream_DeleteKeyValue_Call struct {
	*mock.Call
}

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

func (*JetStream_DeleteKeyValue_Call) Return 

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

func (*JetStream_DeleteKeyValue_Call) Run 

func (_c *JetStream_DeleteKeyValue_Call) Run(run func(ctx context.Context, bucket string)) *JetStream_DeleteKeyValue_Call

func (*JetStream_DeleteKeyValue_Call) RunAndReturn 

func (_c *JetStream_DeleteKeyValue_Call) RunAndReturn(run func(context.Context, string) error) *JetStream_DeleteKeyValue_Call

type JetStream_DeleteObjectStore_Call 

type JetStream_DeleteObjectStore_Call struct {
	*mock.Call
}

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

func (*JetStream_DeleteObjectStore_Call) Return 

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

func (*JetStream_DeleteObjectStore_Call) Run 

func (_c *JetStream_DeleteObjectStore_Call) Run(run func(ctx context.Context, bucket string)) *JetStream_DeleteObjectStore_Call

func (*JetStream_DeleteObjectStore_Call) RunAndReturn 

func (_c *JetStream_DeleteObjectStore_Call) RunAndReturn(run func(context.Context, string) error) *JetStream_DeleteObjectStore_Call

type JetStream_DeleteStream_Call 

type JetStream_DeleteStream_Call struct {
	*mock.Call
}

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

func (*JetStream_DeleteStream_Call) Return 

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

func (*JetStream_DeleteStream_Call) Run 

func (_c *JetStream_DeleteStream_Call) Run(run func(ctx context.Context, stream string)) *JetStream_DeleteStream_Call

func (*JetStream_DeleteStream_Call) RunAndReturn 

func (_c *JetStream_DeleteStream_Call) RunAndReturn(run func(context.Context, string) error) *JetStream_DeleteStream_Call

type JetStream_Expecter 

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

func (*JetStream_Expecter) AccountInfo 

func (_e *JetStream_Expecter) AccountInfo(ctx interface{}) *JetStream_AccountInfo_Call

AccountInfo is a helper method to define mock.On call

  • ctx context.Context

func (*JetStream_Expecter) Consumer 

func (_e *JetStream_Expecter) Consumer(ctx interface{}, stream interface{}, consumer interface{}) *JetStream_Consumer_Call

Consumer is a helper method to define mock.On call

  • ctx context.Context
  • stream string
  • consumer string

func (*JetStream_Expecter) CreateConsumer 

func (_e *JetStream_Expecter) CreateConsumer(ctx interface{}, stream interface{}, cfg interface{}) *JetStream_CreateConsumer_Call

CreateConsumer is a helper method to define mock.On call

  • ctx context.Context
  • stream string
  • cfg jetstream.ConsumerConfig

func (*JetStream_Expecter) CreateKeyValue 

func (_e *JetStream_Expecter) CreateKeyValue(ctx interface{}, cfg interface{}) *JetStream_CreateKeyValue_Call

CreateKeyValue is a helper method to define mock.On call

  • ctx context.Context
  • cfg jetstream.KeyValueConfig

func (*JetStream_Expecter) CreateObjectStore 

func (_e *JetStream_Expecter) CreateObjectStore(ctx interface{}, cfg interface{}) *JetStream_CreateObjectStore_Call

CreateObjectStore is a helper method to define mock.On call

  • ctx context.Context
  • cfg jetstream.ObjectStoreConfig

func (*JetStream_Expecter) CreateOrUpdateConsumer 

func (_e *JetStream_Expecter) CreateOrUpdateConsumer(ctx interface{}, stream interface{}, cfg interface{}) *JetStream_CreateOrUpdateConsumer_Call

CreateOrUpdateConsumer is a helper method to define mock.On call

  • ctx context.Context
  • stream string
  • cfg jetstream.ConsumerConfig

func (*JetStream_Expecter) CreateOrUpdateKeyValue 

func (_e *JetStream_Expecter) CreateOrUpdateKeyValue(ctx interface{}, cfg interface{}) *JetStream_CreateOrUpdateKeyValue_Call

CreateOrUpdateKeyValue is a helper method to define mock.On call

  • ctx context.Context
  • cfg jetstream.KeyValueConfig

func (*JetStream_Expecter) CreateOrUpdateObjectStore 

func (_e *JetStream_Expecter) CreateOrUpdateObjectStore(ctx interface{}, cfg interface{}) *JetStream_CreateOrUpdateObjectStore_Call

CreateOrUpdateObjectStore is a helper method to define mock.On call

  • ctx context.Context
  • cfg jetstream.ObjectStoreConfig

func (*JetStream_Expecter) CreateOrUpdateStream 

func (_e *JetStream_Expecter) CreateOrUpdateStream(ctx interface{}, cfg interface{}) *JetStream_CreateOrUpdateStream_Call

CreateOrUpdateStream is a helper method to define mock.On call

  • ctx context.Context
  • cfg jetstream.StreamConfig

func (*JetStream_Expecter) CreateStream 

func (_e *JetStream_Expecter) CreateStream(ctx interface{}, cfg interface{}) *JetStream_CreateStream_Call

CreateStream is a helper method to define mock.On call

  • ctx context.Context
  • cfg jetstream.StreamConfig

func (*JetStream_Expecter) DeleteConsumer 

func (_e *JetStream_Expecter) DeleteConsumer(ctx interface{}, stream interface{}, consumer interface{}) *JetStream_DeleteConsumer_Call

DeleteConsumer is a helper method to define mock.On call

  • ctx context.Context
  • stream string
  • consumer string

func (*JetStream_Expecter) DeleteKeyValue 

func (_e *JetStream_Expecter) DeleteKeyValue(ctx interface{}, bucket interface{}) *JetStream_DeleteKeyValue_Call

DeleteKeyValue is a helper method to define mock.On call

  • ctx context.Context
  • bucket string

func (*JetStream_Expecter) DeleteObjectStore 

func (_e *JetStream_Expecter) DeleteObjectStore(ctx interface{}, bucket interface{}) *JetStream_DeleteObjectStore_Call

DeleteObjectStore is a helper method to define mock.On call

  • ctx context.Context
  • bucket string

func (*JetStream_Expecter) DeleteStream 

func (_e *JetStream_Expecter) DeleteStream(ctx interface{}, stream interface{}) *JetStream_DeleteStream_Call

DeleteStream is a helper method to define mock.On call

  • ctx context.Context
  • stream string

func (*JetStream_Expecter) KeyValue 

func (_e *JetStream_Expecter) KeyValue(ctx interface{}, bucket interface{}) *JetStream_KeyValue_Call

KeyValue is a helper method to define mock.On call

  • ctx context.Context
  • bucket string

func (*JetStream_Expecter) KeyValueStoreNames 

func (_e *JetStream_Expecter) KeyValueStoreNames(ctx interface{}) *JetStream_KeyValueStoreNames_Call

KeyValueStoreNames is a helper method to define mock.On call

  • ctx context.Context

func (*JetStream_Expecter) KeyValueStores 

func (_e *JetStream_Expecter) KeyValueStores(ctx interface{}) *JetStream_KeyValueStores_Call

KeyValueStores is a helper method to define mock.On call

  • ctx context.Context

func (*JetStream_Expecter) ListStreams 

func (_e *JetStream_Expecter) ListStreams(_a0 interface{}, _a1 ...interface{}) *JetStream_ListStreams_Call

ListStreams is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 ...jetstream.StreamListOpt

func (*JetStream_Expecter) ObjectStore 

func (_e *JetStream_Expecter) ObjectStore(ctx interface{}, bucket interface{}) *JetStream_ObjectStore_Call

ObjectStore is a helper method to define mock.On call

  • ctx context.Context
  • bucket string

func (*JetStream_Expecter) ObjectStoreNames 

func (_e *JetStream_Expecter) ObjectStoreNames(ctx interface{}) *JetStream_ObjectStoreNames_Call

ObjectStoreNames is a helper method to define mock.On call

  • ctx context.Context

func (*JetStream_Expecter) ObjectStores 

func (_e *JetStream_Expecter) ObjectStores(ctx interface{}) *JetStream_ObjectStores_Call

ObjectStores is a helper method to define mock.On call

  • ctx context.Context

func (*JetStream_Expecter) OrderedConsumer 

func (_e *JetStream_Expecter) OrderedConsumer(ctx interface{}, stream interface{}, cfg interface{}) *JetStream_OrderedConsumer_Call

OrderedConsumer is a helper method to define mock.On call

  • ctx context.Context
  • stream string
  • cfg jetstream.OrderedConsumerConfig

func (*JetStream_Expecter) Publish 

func (_e *JetStream_Expecter) Publish(ctx interface{}, subject interface{}, payload interface{}, opts ...interface{}) *JetStream_Publish_Call

Publish is a helper method to define mock.On call

  • ctx context.Context
  • subject string
  • payload []byte
  • opts ...jetstream.PublishOpt

func (*JetStream_Expecter) PublishAsync 

func (_e *JetStream_Expecter) PublishAsync(subject interface{}, payload interface{}, opts ...interface{}) *JetStream_PublishAsync_Call

PublishAsync is a helper method to define mock.On call

  • subject string
  • payload []byte
  • opts ...jetstream.PublishOpt

func (*JetStream_Expecter) PublishAsyncComplete 

func (_e *JetStream_Expecter) PublishAsyncComplete() *JetStream_PublishAsyncComplete_Call

PublishAsyncComplete is a helper method to define mock.On call

func (*JetStream_Expecter) PublishAsyncPending 

func (_e *JetStream_Expecter) PublishAsyncPending() *JetStream_PublishAsyncPending_Call

PublishAsyncPending is a helper method to define mock.On call

func (*JetStream_Expecter) PublishMsg 

func (_e *JetStream_Expecter) PublishMsg(ctx interface{}, msg interface{}, opts ...interface{}) *JetStream_PublishMsg_Call

PublishMsg is a helper method to define mock.On call

  • ctx context.Context
  • msg *nats.Msg
  • opts ...jetstream.PublishOpt

func (*JetStream_Expecter) PublishMsgAsync 

func (_e *JetStream_Expecter) PublishMsgAsync(msg interface{}, opts ...interface{}) *JetStream_PublishMsgAsync_Call

PublishMsgAsync is a helper method to define mock.On call

  • msg *nats.Msg
  • opts ...jetstream.PublishOpt

func (*JetStream_Expecter) Stream 

func (_e *JetStream_Expecter) Stream(ctx interface{}, stream interface{}) *JetStream_Stream_Call

Stream is a helper method to define mock.On call

  • ctx context.Context
  • stream string

func (*JetStream_Expecter) StreamNameBySubject 

func (_e *JetStream_Expecter) StreamNameBySubject(ctx interface{}, subject interface{}) *JetStream_StreamNameBySubject_Call

StreamNameBySubject is a helper method to define mock.On call

  • ctx context.Context
  • subject string

func (*JetStream_Expecter) StreamNames 

func (_e *JetStream_Expecter) StreamNames(_a0 interface{}, _a1 ...interface{}) *JetStream_StreamNames_Call

StreamNames is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 ...jetstream.StreamListOpt

func (*JetStream_Expecter) UpdateConsumer 

func (_e *JetStream_Expecter) UpdateConsumer(ctx interface{}, stream interface{}, cfg interface{}) *JetStream_UpdateConsumer_Call

UpdateConsumer is a helper method to define mock.On call

  • ctx context.Context
  • stream string
  • cfg jetstream.ConsumerConfig

func (*JetStream_Expecter) UpdateKeyValue 

func (_e *JetStream_Expecter) UpdateKeyValue(ctx interface{}, cfg interface{}) *JetStream_UpdateKeyValue_Call

UpdateKeyValue is a helper method to define mock.On call

  • ctx context.Context
  • cfg jetstream.KeyValueConfig

func (*JetStream_Expecter) UpdateObjectStore 

func (_e *JetStream_Expecter) UpdateObjectStore(ctx interface{}, cfg interface{}) *JetStream_UpdateObjectStore_Call

UpdateObjectStore is a helper method to define mock.On call

  • ctx context.Context
  • cfg jetstream.ObjectStoreConfig

func (*JetStream_Expecter) UpdateStream 

func (_e *JetStream_Expecter) UpdateStream(ctx interface{}, cfg interface{}) *JetStream_UpdateStream_Call

UpdateStream is a helper method to define mock.On call

  • ctx context.Context
  • cfg jetstream.StreamConfig

type JetStream_KeyValueStoreNames_Call 

type JetStream_KeyValueStoreNames_Call struct {
	*mock.Call
}

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

func (*JetStream_KeyValueStoreNames_Call) Return 

func (_c *JetStream_KeyValueStoreNames_Call) Return(_a0 jetstream.KeyValueNamesLister) *JetStream_KeyValueStoreNames_Call

func (*JetStream_KeyValueStoreNames_Call) Run 

func (_c *JetStream_KeyValueStoreNames_Call) Run(run func(ctx context.Context)) *JetStream_KeyValueStoreNames_Call

func (*JetStream_KeyValueStoreNames_Call) RunAndReturn 

func (_c *JetStream_KeyValueStoreNames_Call) RunAndReturn(run func(context.Context) jetstream.KeyValueNamesLister) *JetStream_KeyValueStoreNames_Call

type JetStream_KeyValueStores_Call 

type JetStream_KeyValueStores_Call struct {
	*mock.Call
}

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

func (*JetStream_KeyValueStores_Call) Return 

func (_c *JetStream_KeyValueStores_Call) Return(_a0 jetstream.KeyValueLister) *JetStream_KeyValueStores_Call

func (*JetStream_KeyValueStores_Call) Run 

func (_c *JetStream_KeyValueStores_Call) Run(run func(ctx context.Context)) *JetStream_KeyValueStores_Call

func (*JetStream_KeyValueStores_Call) RunAndReturn 

func (_c *JetStream_KeyValueStores_Call) RunAndReturn(run func(context.Context) jetstream.KeyValueLister) *JetStream_KeyValueStores_Call

type JetStream_KeyValue_Call 

type JetStream_KeyValue_Call struct {
	*mock.Call
}

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

func (*JetStream_KeyValue_Call) Return 

func (_c *JetStream_KeyValue_Call) Return(_a0 jetstream.KeyValue, _a1 error) *JetStream_KeyValue_Call

func (*JetStream_KeyValue_Call) Run 

func (_c *JetStream_KeyValue_Call) Run(run func(ctx context.Context, bucket string)) *JetStream_KeyValue_Call

func (*JetStream_KeyValue_Call) RunAndReturn 

func (_c *JetStream_KeyValue_Call) RunAndReturn(run func(context.Context, string) (jetstream.KeyValue, error)) *JetStream_KeyValue_Call

type JetStream_ListStreams_Call 

type JetStream_ListStreams_Call struct {
	*mock.Call
}

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

func (*JetStream_ListStreams_Call) Return 

func (_c *JetStream_ListStreams_Call) Return(_a0 jetstream.StreamInfoLister) *JetStream_ListStreams_Call

func (*JetStream_ListStreams_Call) Run 

func (_c *JetStream_ListStreams_Call) Run(run func(_a0 context.Context, _a1 ...jetstream.StreamListOpt)) *JetStream_ListStreams_Call

func (*JetStream_ListStreams_Call) RunAndReturn 

func (_c *JetStream_ListStreams_Call) RunAndReturn(run func(context.Context, ...jetstream.StreamListOpt) jetstream.StreamInfoLister) *JetStream_ListStreams_Call

type JetStream_ObjectStoreNames_Call 

type JetStream_ObjectStoreNames_Call struct {
	*mock.Call
}

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

func (*JetStream_ObjectStoreNames_Call) Return 

func (_c *JetStream_ObjectStoreNames_Call) Return(_a0 jetstream.ObjectStoreNamesLister) *JetStream_ObjectStoreNames_Call

func (*JetStream_ObjectStoreNames_Call) Run 

func (_c *JetStream_ObjectStoreNames_Call) Run(run func(ctx context.Context)) *JetStream_ObjectStoreNames_Call

func (*JetStream_ObjectStoreNames_Call) RunAndReturn 

func (_c *JetStream_ObjectStoreNames_Call) RunAndReturn(run func(context.Context) jetstream.ObjectStoreNamesLister) *JetStream_ObjectStoreNames_Call

type JetStream_ObjectStore_Call 

type JetStream_ObjectStore_Call struct {
	*mock.Call
}

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

func (*JetStream_ObjectStore_Call) Return 

func (_c *JetStream_ObjectStore_Call) Return(_a0 jetstream.ObjectStore, _a1 error) *JetStream_ObjectStore_Call

func (*JetStream_ObjectStore_Call) Run 

func (_c *JetStream_ObjectStore_Call) Run(run func(ctx context.Context, bucket string)) *JetStream_ObjectStore_Call

func (*JetStream_ObjectStore_Call) RunAndReturn 

func (_c *JetStream_ObjectStore_Call) RunAndReturn(run func(context.Context, string) (jetstream.ObjectStore, error)) *JetStream_ObjectStore_Call

type JetStream_ObjectStores_Call 

type JetStream_ObjectStores_Call struct {
	*mock.Call
}

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

func (*JetStream_ObjectStores_Call) Return 

func (_c *JetStream_ObjectStores_Call) Return(_a0 jetstream.ObjectStoresLister) *JetStream_ObjectStores_Call

func (*JetStream_ObjectStores_Call) Run 

func (_c *JetStream_ObjectStores_Call) Run(run func(ctx context.Context)) *JetStream_ObjectStores_Call

func (*JetStream_ObjectStores_Call) RunAndReturn 

func (_c *JetStream_ObjectStores_Call) RunAndReturn(run func(context.Context) jetstream.ObjectStoresLister) *JetStream_ObjectStores_Call

type JetStream_OrderedConsumer_Call 

type JetStream_OrderedConsumer_Call struct {
	*mock.Call
}

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

func (*JetStream_OrderedConsumer_Call) Return 

func (_c *JetStream_OrderedConsumer_Call) Return(_a0 jetstream.Consumer, _a1 error) *JetStream_OrderedConsumer_Call

func (*JetStream_OrderedConsumer_Call) Run 

func (_c *JetStream_OrderedConsumer_Call) Run(run func(ctx context.Context, stream string, cfg jetstream.OrderedConsumerConfig)) *JetStream_OrderedConsumer_Call

func (*JetStream_OrderedConsumer_Call) RunAndReturn 

func (_c *JetStream_OrderedConsumer_Call) RunAndReturn(run func(context.Context, string, jetstream.OrderedConsumerConfig) (jetstream.Consumer, error)) *JetStream_OrderedConsumer_Call

type JetStream_PublishAsyncComplete_Call 

type JetStream_PublishAsyncComplete_Call struct {
	*mock.Call
}

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

func (*JetStream_PublishAsyncComplete_Call) Return 

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

func (*JetStream_PublishAsyncComplete_Call) Run 

func (_c *JetStream_PublishAsyncComplete_Call) Run(run func()) *JetStream_PublishAsyncComplete_Call

func (*JetStream_PublishAsyncComplete_Call) RunAndReturn 

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

type JetStream_PublishAsyncPending_Call 

type JetStream_PublishAsyncPending_Call struct {
	*mock.Call
}

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

func (*JetStream_PublishAsyncPending_Call) Return 

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

func (*JetStream_PublishAsyncPending_Call) Run 

func (_c *JetStream_PublishAsyncPending_Call) Run(run func()) *JetStream_PublishAsyncPending_Call

func (*JetStream_PublishAsyncPending_Call) RunAndReturn 

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

type JetStream_PublishAsync_Call 

type JetStream_PublishAsync_Call struct {
	*mock.Call
}

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

func (*JetStream_PublishAsync_Call) Return 

func (_c *JetStream_PublishAsync_Call) Return(_a0 jetstream.PubAckFuture, _a1 error) *JetStream_PublishAsync_Call

func (*JetStream_PublishAsync_Call) Run 

func (_c *JetStream_PublishAsync_Call) Run(run func(subject string, payload []byte, opts ...jetstream.PublishOpt)) *JetStream_PublishAsync_Call

func (*JetStream_PublishAsync_Call) RunAndReturn 

func (_c *JetStream_PublishAsync_Call) RunAndReturn(run func(string, []byte, ...jetstream.PublishOpt) (jetstream.PubAckFuture, error)) *JetStream_PublishAsync_Call

type JetStream_PublishMsgAsync_Call 

type JetStream_PublishMsgAsync_Call struct {
	*mock.Call
}

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

func (*JetStream_PublishMsgAsync_Call) Return 

func (_c *JetStream_PublishMsgAsync_Call) Return(_a0 jetstream.PubAckFuture, _a1 error) *JetStream_PublishMsgAsync_Call

func (*JetStream_PublishMsgAsync_Call) Run 

func (_c *JetStream_PublishMsgAsync_Call) Run(run func(msg *nats.Msg, opts ...jetstream.PublishOpt)) *JetStream_PublishMsgAsync_Call

func (*JetStream_PublishMsgAsync_Call) RunAndReturn 

func (_c *JetStream_PublishMsgAsync_Call) RunAndReturn(run func(*nats.Msg, ...jetstream.PublishOpt) (jetstream.PubAckFuture, error)) *JetStream_PublishMsgAsync_Call

type JetStream_PublishMsg_Call 

type JetStream_PublishMsg_Call struct {
	*mock.Call
}

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

func (*JetStream_PublishMsg_Call) Return 

func (_c *JetStream_PublishMsg_Call) Return(_a0 *jetstream.PubAck, _a1 error) *JetStream_PublishMsg_Call

func (*JetStream_PublishMsg_Call) Run 

func (_c *JetStream_PublishMsg_Call) Run(run func(ctx context.Context, msg *nats.Msg, opts ...jetstream.PublishOpt)) *JetStream_PublishMsg_Call

func (*JetStream_PublishMsg_Call) RunAndReturn 

func (_c *JetStream_PublishMsg_Call) RunAndReturn(run func(context.Context, *nats.Msg, ...jetstream.PublishOpt) (*jetstream.PubAck, error)) *JetStream_PublishMsg_Call

type JetStream_Publish_Call 

type JetStream_Publish_Call struct {
	*mock.Call
}

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

func (*JetStream_Publish_Call) Return 

func (_c *JetStream_Publish_Call) Return(_a0 *jetstream.PubAck, _a1 error) *JetStream_Publish_Call

func (*JetStream_Publish_Call) Run 

func (_c *JetStream_Publish_Call) Run(run func(ctx context.Context, subject string, payload []byte, opts ...jetstream.PublishOpt)) *JetStream_Publish_Call

func (*JetStream_Publish_Call) RunAndReturn 

func (_c *JetStream_Publish_Call) RunAndReturn(run func(context.Context, string, []byte, ...jetstream.PublishOpt) (*jetstream.PubAck, error)) *JetStream_Publish_Call

type JetStream_StreamNameBySubject_Call 

type JetStream_StreamNameBySubject_Call struct {
	*mock.Call
}

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

func (*JetStream_StreamNameBySubject_Call) Return 

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

func (*JetStream_StreamNameBySubject_Call) Run 

func (_c *JetStream_StreamNameBySubject_Call) Run(run func(ctx context.Context, subject string)) *JetStream_StreamNameBySubject_Call

func (*JetStream_StreamNameBySubject_Call) RunAndReturn 

func (_c *JetStream_StreamNameBySubject_Call) RunAndReturn(run func(context.Context, string) (string, error)) *JetStream_StreamNameBySubject_Call

type JetStream_StreamNames_Call 

type JetStream_StreamNames_Call struct {
	*mock.Call
}

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

func (*JetStream_StreamNames_Call) Return 

func (_c *JetStream_StreamNames_Call) Return(_a0 jetstream.StreamNameLister) *JetStream_StreamNames_Call

func (*JetStream_StreamNames_Call) Run 

func (_c *JetStream_StreamNames_Call) Run(run func(_a0 context.Context, _a1 ...jetstream.StreamListOpt)) *JetStream_StreamNames_Call

func (*JetStream_StreamNames_Call) RunAndReturn 

func (_c *JetStream_StreamNames_Call) RunAndReturn(run func(context.Context, ...jetstream.StreamListOpt) jetstream.StreamNameLister) *JetStream_StreamNames_Call

type JetStream_Stream_Call 

type JetStream_Stream_Call struct {
	*mock.Call
}

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

func (*JetStream_Stream_Call) Return 

func (_c *JetStream_Stream_Call) Return(_a0 jetstream.Stream, _a1 error) *JetStream_Stream_Call

func (*JetStream_Stream_Call) Run 

func (_c *JetStream_Stream_Call) Run(run func(ctx context.Context, stream string)) *JetStream_Stream_Call

func (*JetStream_Stream_Call) RunAndReturn 

func (_c *JetStream_Stream_Call) RunAndReturn(run func(context.Context, string) (jetstream.Stream, error)) *JetStream_Stream_Call

type JetStream_UpdateConsumer_Call 

type JetStream_UpdateConsumer_Call struct {
	*mock.Call
}

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

func (*JetStream_UpdateConsumer_Call) Return 

func (_c *JetStream_UpdateConsumer_Call) Return(_a0 jetstream.Consumer, _a1 error) *JetStream_UpdateConsumer_Call

func (*JetStream_UpdateConsumer_Call) Run 

func (_c *JetStream_UpdateConsumer_Call) Run(run func(ctx context.Context, stream string, cfg jetstream.ConsumerConfig)) *JetStream_UpdateConsumer_Call

func (*JetStream_UpdateConsumer_Call) RunAndReturn 

func (_c *JetStream_UpdateConsumer_Call) RunAndReturn(run func(context.Context, string, jetstream.ConsumerConfig) (jetstream.Consumer, error)) *JetStream_UpdateConsumer_Call

type JetStream_UpdateKeyValue_Call 

type JetStream_UpdateKeyValue_Call struct {
	*mock.Call
}

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

func (*JetStream_UpdateKeyValue_Call) Return 

func (_c *JetStream_UpdateKeyValue_Call) Return(_a0 jetstream.KeyValue, _a1 error) *JetStream_UpdateKeyValue_Call

func (*JetStream_UpdateKeyValue_Call) Run 

func (_c *JetStream_UpdateKeyValue_Call) Run(run func(ctx context.Context, cfg jetstream.KeyValueConfig)) *JetStream_UpdateKeyValue_Call

func (*JetStream_UpdateKeyValue_Call) RunAndReturn 

func (_c *JetStream_UpdateKeyValue_Call) RunAndReturn(run func(context.Context, jetstream.KeyValueConfig) (jetstream.KeyValue, error)) *JetStream_UpdateKeyValue_Call

type JetStream_UpdateObjectStore_Call 

type JetStream_UpdateObjectStore_Call struct {
	*mock.Call
}

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

func (*JetStream_UpdateObjectStore_Call) Return 

func (_c *JetStream_UpdateObjectStore_Call) Return(_a0 jetstream.ObjectStore, _a1 error) *JetStream_UpdateObjectStore_Call

func (*JetStream_UpdateObjectStore_Call) Run 

func (_c *JetStream_UpdateObjectStore_Call) Run(run func(ctx context.Context, cfg jetstream.ObjectStoreConfig)) *JetStream_UpdateObjectStore_Call

func (*JetStream_UpdateObjectStore_Call) RunAndReturn 

func (_c *JetStream_UpdateObjectStore_Call) RunAndReturn(run func(context.Context, jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)) *JetStream_UpdateObjectStore_Call

type JetStream_UpdateStream_Call 

type JetStream_UpdateStream_Call struct {
	*mock.Call
}

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

func (*JetStream_UpdateStream_Call) Return 

func (_c *JetStream_UpdateStream_Call) Return(_a0 jetstream.Stream, _a1 error) *JetStream_UpdateStream_Call

func (*JetStream_UpdateStream_Call) Run 

func (_c *JetStream_UpdateStream_Call) Run(run func(ctx context.Context, cfg jetstream.StreamConfig)) *JetStream_UpdateStream_Call

func (*JetStream_UpdateStream_Call) RunAndReturn 

func (_c *JetStream_UpdateStream_Call) RunAndReturn(run func(context.Context, jetstream.StreamConfig) (jetstream.Stream, error)) *JetStream_UpdateStream_Call

type MessageBatch 

type MessageBatch struct {
	mock.Mock
}

MessageBatch is an autogenerated mock type for the MessageBatch type

func NewMessageBatch 

func NewMessageBatch(t interface {
	mock.TestingT
	Cleanup(func())
}) *MessageBatch

NewMessageBatch creates a new instance of MessageBatch. 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 (*MessageBatch) EXPECT 

func (_m *MessageBatch) EXPECT() *MessageBatch_Expecter

func (*MessageBatch) Error 

func (_m *MessageBatch) Error() error

Error provides a mock function with given fields:

func (*MessageBatch) Messages 

func (_m *MessageBatch) Messages() <-chan jetstream.Msg

Messages provides a mock function with given fields:

type MessageBatch_Error_Call 

type MessageBatch_Error_Call struct {
	*mock.Call
}

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

func (*MessageBatch_Error_Call) Return 

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

func (*MessageBatch_Error_Call) Run 

func (_c *MessageBatch_Error_Call) Run(run func()) *MessageBatch_Error_Call

func (*MessageBatch_Error_Call) RunAndReturn 

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

type MessageBatch_Expecter 

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

func (*MessageBatch_Expecter) Error 

func (_e *MessageBatch_Expecter) Error() *MessageBatch_Error_Call

Error is a helper method to define mock.On call

func (*MessageBatch_Expecter) Messages 

func (_e *MessageBatch_Expecter) Messages() *MessageBatch_Messages_Call

Messages is a helper method to define mock.On call

type MessageBatch_Messages_Call 

type MessageBatch_Messages_Call struct {
	*mock.Call
}

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

func (*MessageBatch_Messages_Call) Return 

func (_c *MessageBatch_Messages_Call) Return(_a0 <-chan jetstream.Msg) *MessageBatch_Messages_Call

func (*MessageBatch_Messages_Call) Run 

func (_c *MessageBatch_Messages_Call) Run(run func()) *MessageBatch_Messages_Call

func (*MessageBatch_Messages_Call) RunAndReturn 

func (_c *MessageBatch_Messages_Call) RunAndReturn(run func() <-chan jetstream.Msg) *MessageBatch_Messages_Call

type Msg 

type Msg struct {
	mock.Mock
}

Msg is an autogenerated mock type for the Msg type

func NewMsg 

func NewMsg(t interface {
	mock.TestingT
	Cleanup(func())
}) *Msg

NewMsg creates a new instance of Msg. 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 (*Msg) Ack 

func (_m *Msg) Ack() error

Ack provides a mock function with given fields:

func (*Msg) Data 

func (_m *Msg) Data() []byte

Data provides a mock function with given fields:

func (*Msg) DoubleAck 

func (_m *Msg) DoubleAck(_a0 context.Context) error

DoubleAck provides a mock function with given fields: _a0

func (*Msg) EXPECT 

func (_m *Msg) EXPECT() *Msg_Expecter

func (*Msg) Headers 

func (_m *Msg) Headers() nats.Header

Headers provides a mock function with given fields:

func (*Msg) InProgress 

func (_m *Msg) InProgress() error

InProgress provides a mock function with given fields:

func (*Msg) Metadata 

func (_m *Msg) Metadata() (*jetstream.MsgMetadata, error)

Metadata provides a mock function with given fields:

func (*Msg) Nak 

func (_m *Msg) Nak() error

Nak provides a mock function with given fields:

func (*Msg) NakWithDelay 

func (_m *Msg) NakWithDelay(delay time.Duration) error

NakWithDelay provides a mock function with given fields: delay

func (*Msg) Reply 

func (_m *Msg) Reply() string

Reply provides a mock function with given fields:

func (*Msg) Subject 

func (_m *Msg) Subject() string

Subject provides a mock function with given fields:

func (*Msg) Term 

func (_m *Msg) Term() error

Term provides a mock function with given fields:

func (*Msg) TermWithReason 

func (_m *Msg) TermWithReason(reason string) error

TermWithReason provides a mock function with given fields: reason

type Msg_Ack_Call 

type Msg_Ack_Call struct {
	*mock.Call
}

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

func (*Msg_Ack_Call) Return 

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

func (*Msg_Ack_Call) Run 

func (_c *Msg_Ack_Call) Run(run func()) *Msg_Ack_Call

func (*Msg_Ack_Call) RunAndReturn 

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

type Msg_Data_Call 

type Msg_Data_Call struct {
	*mock.Call
}

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

func (*Msg_Data_Call) Return 

func (_c *Msg_Data_Call) Return(_a0 []byte) *Msg_Data_Call

func (*Msg_Data_Call) Run 

func (_c *Msg_Data_Call) Run(run func()) *Msg_Data_Call

func (*Msg_Data_Call) RunAndReturn 

func (_c *Msg_Data_Call) RunAndReturn(run func() []byte) *Msg_Data_Call

type Msg_DoubleAck_Call 

type Msg_DoubleAck_Call struct {
	*mock.Call
}

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

func (*Msg_DoubleAck_Call) Return 

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

func (*Msg_DoubleAck_Call) Run 

func (_c *Msg_DoubleAck_Call) Run(run func(_a0 context.Context)) *Msg_DoubleAck_Call

func (*Msg_DoubleAck_Call) RunAndReturn 

func (_c *Msg_DoubleAck_Call) RunAndReturn(run func(context.Context) error) *Msg_DoubleAck_Call

type Msg_Expecter 

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

func (*Msg_Expecter) Ack 

func (_e *Msg_Expecter) Ack() *Msg_Ack_Call

Ack is a helper method to define mock.On call

func (*Msg_Expecter) Data 

func (_e *Msg_Expecter) Data() *Msg_Data_Call

Data is a helper method to define mock.On call

func (*Msg_Expecter) DoubleAck 

func (_e *Msg_Expecter) DoubleAck(_a0 interface{}) *Msg_DoubleAck_Call

DoubleAck is a helper method to define mock.On call

  • _a0 context.Context

func (*Msg_Expecter) Headers 

func (_e *Msg_Expecter) Headers() *Msg_Headers_Call

Headers is a helper method to define mock.On call

func (*Msg_Expecter) InProgress 

func (_e *Msg_Expecter) InProgress() *Msg_InProgress_Call

InProgress is a helper method to define mock.On call

func (*Msg_Expecter) Metadata 

func (_e *Msg_Expecter) Metadata() *Msg_Metadata_Call

Metadata is a helper method to define mock.On call

func (*Msg_Expecter) Nak 

func (_e *Msg_Expecter) Nak() *Msg_Nak_Call

Nak is a helper method to define mock.On call

func (*Msg_Expecter) NakWithDelay 

func (_e *Msg_Expecter) NakWithDelay(delay interface{}) *Msg_NakWithDelay_Call

NakWithDelay is a helper method to define mock.On call

  • delay time.Duration

func (*Msg_Expecter) Reply 

func (_e *Msg_Expecter) Reply() *Msg_Reply_Call

Reply is a helper method to define mock.On call

func (*Msg_Expecter) Subject 

func (_e *Msg_Expecter) Subject() *Msg_Subject_Call

Subject is a helper method to define mock.On call

func (*Msg_Expecter) Term 

func (_e *Msg_Expecter) Term() *Msg_Term_Call

Term is a helper method to define mock.On call

func (*Msg_Expecter) TermWithReason 

func (_e *Msg_Expecter) TermWithReason(reason interface{}) *Msg_TermWithReason_Call

TermWithReason is a helper method to define mock.On call

  • reason string

type Msg_Headers_Call 

type Msg_Headers_Call struct {
	*mock.Call
}

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

func (*Msg_Headers_Call) Return 

func (_c *Msg_Headers_Call) Return(_a0 nats.Header) *Msg_Headers_Call

func (*Msg_Headers_Call) Run 

func (_c *Msg_Headers_Call) Run(run func()) *Msg_Headers_Call

func (*Msg_Headers_Call) RunAndReturn 

func (_c *Msg_Headers_Call) RunAndReturn(run func() nats.Header) *Msg_Headers_Call

type Msg_InProgress_Call 

type Msg_InProgress_Call struct {
	*mock.Call
}

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

func (*Msg_InProgress_Call) Return 

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

func (*Msg_InProgress_Call) Run 

func (_c *Msg_InProgress_Call) Run(run func()) *Msg_InProgress_Call

func (*Msg_InProgress_Call) RunAndReturn 

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

type Msg_Metadata_Call 

type Msg_Metadata_Call struct {
	*mock.Call
}

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

func (*Msg_Metadata_Call) Return 

func (_c *Msg_Metadata_Call) Return(_a0 *jetstream.MsgMetadata, _a1 error) *Msg_Metadata_Call

func (*Msg_Metadata_Call) Run 

func (_c *Msg_Metadata_Call) Run(run func()) *Msg_Metadata_Call

func (*Msg_Metadata_Call) RunAndReturn 

func (_c *Msg_Metadata_Call) RunAndReturn(run func() (*jetstream.MsgMetadata, error)) *Msg_Metadata_Call

type Msg_NakWithDelay_Call 

type Msg_NakWithDelay_Call struct {
	*mock.Call
}

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

func (*Msg_NakWithDelay_Call) Return 

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

func (*Msg_NakWithDelay_Call) Run 

func (_c *Msg_NakWithDelay_Call) Run(run func(delay time.Duration)) *Msg_NakWithDelay_Call

func (*Msg_NakWithDelay_Call) RunAndReturn 

func (_c *Msg_NakWithDelay_Call) RunAndReturn(run func(time.Duration) error) *Msg_NakWithDelay_Call

type Msg_Nak_Call 

type Msg_Nak_Call struct {
	*mock.Call
}

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

func (*Msg_Nak_Call) Return 

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

func (*Msg_Nak_Call) Run 

func (_c *Msg_Nak_Call) Run(run func()) *Msg_Nak_Call

func (*Msg_Nak_Call) RunAndReturn 

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

type Msg_Reply_Call 

type Msg_Reply_Call struct {
	*mock.Call
}

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

func (*Msg_Reply_Call) Return 

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

func (*Msg_Reply_Call) Run 

func (_c *Msg_Reply_Call) Run(run func()) *Msg_Reply_Call

func (*Msg_Reply_Call) RunAndReturn 

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

type Msg_Subject_Call 

type Msg_Subject_Call struct {
	*mock.Call
}

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

func (*Msg_Subject_Call) Return 

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

func (*Msg_Subject_Call) Run 

func (_c *Msg_Subject_Call) Run(run func()) *Msg_Subject_Call

func (*Msg_Subject_Call) RunAndReturn 

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

type Msg_TermWithReason_Call 

type Msg_TermWithReason_Call struct {
	*mock.Call
}

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

func (*Msg_TermWithReason_Call) Return 

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

func (*Msg_TermWithReason_Call) Run 

func (_c *Msg_TermWithReason_Call) Run(run func(reason string)) *Msg_TermWithReason_Call

func (*Msg_TermWithReason_Call) RunAndReturn 

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

type Msg_Term_Call 

type Msg_Term_Call struct {
	*mock.Call
}

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

func (*Msg_Term_Call) Return 

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

func (*Msg_Term_Call) Run 

func (_c *Msg_Term_Call) Run(run func()) *Msg_Term_Call

func (*Msg_Term_Call) RunAndReturn 

func (_c *Msg_Term_Call) RunAndReturn(run func() error) *Msg_Term_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.