Documentation ¶
Overview ¶
Package mock_nats is a generated GoMock package.
Index ¶
- type MockJetStreamContext
- func (m *MockJetStreamContext) AccountInfo(opts ...nats.JSOpt) (*nats.AccountInfo, error)
- func (m *MockJetStreamContext) AddConsumer(stream string, cfg *nats.ConsumerConfig, opts ...nats.JSOpt) (*nats.ConsumerInfo, error)
- func (m *MockJetStreamContext) AddStream(cfg *nats.StreamConfig, opts ...nats.JSOpt) (*nats.StreamInfo, error)
- func (m *MockJetStreamContext) ChanQueueSubscribe(subj, queue string, ch chan *nats.Msg, opts ...nats.SubOpt) (*nats.Subscription, error)
- func (m *MockJetStreamContext) ChanSubscribe(subj string, ch chan *nats.Msg, opts ...nats.SubOpt) (*nats.Subscription, error)
- func (m *MockJetStreamContext) ConsumerInfo(stream, name string, opts ...nats.JSOpt) (*nats.ConsumerInfo, error)
- func (m *MockJetStreamContext) ConsumerNames(stream string, opts ...nats.JSOpt) <-chan string
- func (m *MockJetStreamContext) ConsumersInfo(stream string, opts ...nats.JSOpt) <-chan *nats.ConsumerInfo
- func (m *MockJetStreamContext) CreateKeyValue(cfg *nats.KeyValueConfig) (nats.KeyValue, error)
- func (m *MockJetStreamContext) CreateObjectStore(cfg *nats.ObjectStoreConfig) (nats.ObjectStore, error)
- func (m *MockJetStreamContext) DeleteConsumer(stream, consumer string, opts ...nats.JSOpt) error
- func (m *MockJetStreamContext) DeleteKeyValue(bucket string) error
- func (m *MockJetStreamContext) DeleteMsg(name string, seq uint64, opts ...nats.JSOpt) error
- func (m *MockJetStreamContext) DeleteObjectStore(bucket string) error
- func (m *MockJetStreamContext) DeleteStream(name string, opts ...nats.JSOpt) error
- func (m *MockJetStreamContext) EXPECT() *MockJetStreamContextMockRecorder
- func (m *MockJetStreamContext) GetMsg(name string, seq uint64, opts ...nats.JSOpt) (*nats.RawStreamMsg, error)
- func (m *MockJetStreamContext) KeyValue(bucket string) (nats.KeyValue, error)
- func (m *MockJetStreamContext) ObjectStore(bucket string) (nats.ObjectStore, error)
- func (m *MockJetStreamContext) Publish(subj string, data []byte, opts ...nats.PubOpt) (*nats.PubAck, error)
- func (m *MockJetStreamContext) PublishAsync(subj string, data []byte, opts ...nats.PubOpt) (nats.PubAckFuture, error)
- func (m *MockJetStreamContext) PublishAsyncComplete() <-chan struct{}
- func (m *MockJetStreamContext) PublishAsyncPending() int
- func (m_2 *MockJetStreamContext) PublishMsg(m *nats.Msg, opts ...nats.PubOpt) (*nats.PubAck, error)
- func (m_2 *MockJetStreamContext) PublishMsgAsync(m *nats.Msg, opts ...nats.PubOpt) (nats.PubAckFuture, error)
- func (m *MockJetStreamContext) PullSubscribe(subj, durable string, opts ...nats.SubOpt) (*nats.Subscription, error)
- func (m *MockJetStreamContext) PurgeStream(name string, opts ...nats.JSOpt) error
- func (m *MockJetStreamContext) QueueSubscribe(subj, queue string, cb nats.MsgHandler, opts ...nats.SubOpt) (*nats.Subscription, error)
- func (m *MockJetStreamContext) QueueSubscribeSync(subj, queue string, opts ...nats.SubOpt) (*nats.Subscription, error)
- func (m *MockJetStreamContext) StreamInfo(stream string, opts ...nats.JSOpt) (*nats.StreamInfo, error)
- func (m *MockJetStreamContext) StreamNames(opts ...nats.JSOpt) <-chan string
- func (m *MockJetStreamContext) StreamsInfo(opts ...nats.JSOpt) <-chan *nats.StreamInfo
- func (m *MockJetStreamContext) Subscribe(subj string, cb nats.MsgHandler, opts ...nats.SubOpt) (*nats.Subscription, error)
- func (m *MockJetStreamContext) SubscribeSync(subj string, opts ...nats.SubOpt) (*nats.Subscription, error)
- func (m *MockJetStreamContext) UpdateConsumer(stream string, cfg *nats.ConsumerConfig, opts ...nats.JSOpt) (*nats.ConsumerInfo, error)
- func (m *MockJetStreamContext) UpdateStream(cfg *nats.StreamConfig, opts ...nats.JSOpt) (*nats.StreamInfo, error)
- type MockJetStreamContextMockRecorder
- func (mr *MockJetStreamContextMockRecorder) AccountInfo(opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) AddConsumer(stream, cfg interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) AddStream(cfg interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) ChanQueueSubscribe(subj, queue, ch interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) ChanSubscribe(subj, ch interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) ConsumerInfo(stream, name interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) ConsumerNames(stream interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) ConsumersInfo(stream interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) CreateKeyValue(cfg interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) CreateObjectStore(cfg interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) DeleteConsumer(stream, consumer interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) DeleteKeyValue(bucket interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) DeleteMsg(name, seq interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) DeleteObjectStore(bucket interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) DeleteStream(name interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) GetMsg(name, seq interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) KeyValue(bucket interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) ObjectStore(bucket interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) Publish(subj, data interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) PublishAsync(subj, data interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) PublishAsyncComplete() *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) PublishAsyncPending() *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) PublishMsg(m interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) PublishMsgAsync(m interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) PullSubscribe(subj, durable interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) PurgeStream(name interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) QueueSubscribe(subj, queue, cb interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) QueueSubscribeSync(subj, queue interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) StreamInfo(stream interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) StreamNames(opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) StreamsInfo(opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) Subscribe(subj, cb interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) SubscribeSync(subj interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) UpdateConsumer(stream, cfg interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockJetStreamContextMockRecorder) UpdateStream(cfg interface{}, opts ...interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockJetStreamContext ¶
type MockJetStreamContext struct {
// contains filtered or unexported fields
}
MockJetStreamContext is a mock of JetStreamContext interface.
func NewMockJetStreamContext ¶
func NewMockJetStreamContext(ctrl *gomock.Controller) *MockJetStreamContext
NewMockJetStreamContext creates a new mock instance.
func (*MockJetStreamContext) AccountInfo ¶
func (m *MockJetStreamContext) AccountInfo(opts ...nats.JSOpt) (*nats.AccountInfo, error)
AccountInfo mocks base method.
func (*MockJetStreamContext) AddConsumer ¶
func (m *MockJetStreamContext) AddConsumer(stream string, cfg *nats.ConsumerConfig, opts ...nats.JSOpt) (*nats.ConsumerInfo, error)
AddConsumer mocks base method.
func (*MockJetStreamContext) AddStream ¶
func (m *MockJetStreamContext) AddStream(cfg *nats.StreamConfig, opts ...nats.JSOpt) (*nats.StreamInfo, error)
AddStream mocks base method.
func (*MockJetStreamContext) ChanQueueSubscribe ¶
func (m *MockJetStreamContext) ChanQueueSubscribe(subj, queue string, ch chan *nats.Msg, opts ...nats.SubOpt) (*nats.Subscription, error)
ChanQueueSubscribe mocks base method.
func (*MockJetStreamContext) ChanSubscribe ¶
func (m *MockJetStreamContext) ChanSubscribe(subj string, ch chan *nats.Msg, opts ...nats.SubOpt) (*nats.Subscription, error)
ChanSubscribe mocks base method.
func (*MockJetStreamContext) ConsumerInfo ¶
func (m *MockJetStreamContext) ConsumerInfo(stream, name string, opts ...nats.JSOpt) (*nats.ConsumerInfo, error)
ConsumerInfo mocks base method.
func (*MockJetStreamContext) ConsumerNames ¶
func (m *MockJetStreamContext) ConsumerNames(stream string, opts ...nats.JSOpt) <-chan string
ConsumerNames mocks base method.
func (*MockJetStreamContext) ConsumersInfo ¶
func (m *MockJetStreamContext) ConsumersInfo(stream string, opts ...nats.JSOpt) <-chan *nats.ConsumerInfo
ConsumersInfo mocks base method.
func (*MockJetStreamContext) CreateKeyValue ¶
func (m *MockJetStreamContext) CreateKeyValue(cfg *nats.KeyValueConfig) (nats.KeyValue, error)
CreateKeyValue mocks base method.
func (*MockJetStreamContext) CreateObjectStore ¶
func (m *MockJetStreamContext) CreateObjectStore(cfg *nats.ObjectStoreConfig) (nats.ObjectStore, error)
CreateObjectStore mocks base method.
func (*MockJetStreamContext) DeleteConsumer ¶
func (m *MockJetStreamContext) DeleteConsumer(stream, consumer string, opts ...nats.JSOpt) error
DeleteConsumer mocks base method.
func (*MockJetStreamContext) DeleteKeyValue ¶
func (m *MockJetStreamContext) DeleteKeyValue(bucket string) error
DeleteKeyValue mocks base method.
func (*MockJetStreamContext) DeleteObjectStore ¶
func (m *MockJetStreamContext) DeleteObjectStore(bucket string) error
DeleteObjectStore mocks base method.
func (*MockJetStreamContext) DeleteStream ¶
func (m *MockJetStreamContext) DeleteStream(name string, opts ...nats.JSOpt) error
DeleteStream mocks base method.
func (*MockJetStreamContext) EXPECT ¶
func (m *MockJetStreamContext) EXPECT() *MockJetStreamContextMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockJetStreamContext) GetMsg ¶
func (m *MockJetStreamContext) GetMsg(name string, seq uint64, opts ...nats.JSOpt) (*nats.RawStreamMsg, error)
GetMsg mocks base method.
func (*MockJetStreamContext) KeyValue ¶
func (m *MockJetStreamContext) KeyValue(bucket string) (nats.KeyValue, error)
KeyValue mocks base method.
func (*MockJetStreamContext) ObjectStore ¶
func (m *MockJetStreamContext) ObjectStore(bucket string) (nats.ObjectStore, error)
ObjectStore mocks base method.
func (*MockJetStreamContext) Publish ¶
func (m *MockJetStreamContext) Publish(subj string, data []byte, opts ...nats.PubOpt) (*nats.PubAck, error)
Publish mocks base method.
func (*MockJetStreamContext) PublishAsync ¶
func (m *MockJetStreamContext) PublishAsync(subj string, data []byte, opts ...nats.PubOpt) (nats.PubAckFuture, error)
PublishAsync mocks base method.
func (*MockJetStreamContext) PublishAsyncComplete ¶
func (m *MockJetStreamContext) PublishAsyncComplete() <-chan struct{}
PublishAsyncComplete mocks base method.
func (*MockJetStreamContext) PublishAsyncPending ¶
func (m *MockJetStreamContext) PublishAsyncPending() int
PublishAsyncPending mocks base method.
func (*MockJetStreamContext) PublishMsg ¶
PublishMsg mocks base method.
func (*MockJetStreamContext) PublishMsgAsync ¶
func (m_2 *MockJetStreamContext) PublishMsgAsync(m *nats.Msg, opts ...nats.PubOpt) (nats.PubAckFuture, error)
PublishMsgAsync mocks base method.
func (*MockJetStreamContext) PullSubscribe ¶
func (m *MockJetStreamContext) PullSubscribe(subj, durable string, opts ...nats.SubOpt) (*nats.Subscription, error)
PullSubscribe mocks base method.
func (*MockJetStreamContext) PurgeStream ¶
func (m *MockJetStreamContext) PurgeStream(name string, opts ...nats.JSOpt) error
PurgeStream mocks base method.
func (*MockJetStreamContext) QueueSubscribe ¶
func (m *MockJetStreamContext) QueueSubscribe(subj, queue string, cb nats.MsgHandler, opts ...nats.SubOpt) (*nats.Subscription, error)
QueueSubscribe mocks base method.
func (*MockJetStreamContext) QueueSubscribeSync ¶
func (m *MockJetStreamContext) QueueSubscribeSync(subj, queue string, opts ...nats.SubOpt) (*nats.Subscription, error)
QueueSubscribeSync mocks base method.
func (*MockJetStreamContext) StreamInfo ¶
func (m *MockJetStreamContext) StreamInfo(stream string, opts ...nats.JSOpt) (*nats.StreamInfo, error)
StreamInfo mocks base method.
func (*MockJetStreamContext) StreamNames ¶
func (m *MockJetStreamContext) StreamNames(opts ...nats.JSOpt) <-chan string
StreamNames mocks base method.
func (*MockJetStreamContext) StreamsInfo ¶
func (m *MockJetStreamContext) StreamsInfo(opts ...nats.JSOpt) <-chan *nats.StreamInfo
StreamsInfo mocks base method.
func (*MockJetStreamContext) Subscribe ¶
func (m *MockJetStreamContext) Subscribe(subj string, cb nats.MsgHandler, opts ...nats.SubOpt) (*nats.Subscription, error)
Subscribe mocks base method.
func (*MockJetStreamContext) SubscribeSync ¶
func (m *MockJetStreamContext) SubscribeSync(subj string, opts ...nats.SubOpt) (*nats.Subscription, error)
SubscribeSync mocks base method.
func (*MockJetStreamContext) UpdateConsumer ¶
func (m *MockJetStreamContext) UpdateConsumer(stream string, cfg *nats.ConsumerConfig, opts ...nats.JSOpt) (*nats.ConsumerInfo, error)
UpdateConsumer mocks base method.
func (*MockJetStreamContext) UpdateStream ¶
func (m *MockJetStreamContext) UpdateStream(cfg *nats.StreamConfig, opts ...nats.JSOpt) (*nats.StreamInfo, error)
UpdateStream mocks base method.
type MockJetStreamContextMockRecorder ¶
type MockJetStreamContextMockRecorder struct {
// contains filtered or unexported fields
}
MockJetStreamContextMockRecorder is the mock recorder for MockJetStreamContext.
func (*MockJetStreamContextMockRecorder) AccountInfo ¶
func (mr *MockJetStreamContextMockRecorder) AccountInfo(opts ...interface{}) *gomock.Call
AccountInfo indicates an expected call of AccountInfo.
func (*MockJetStreamContextMockRecorder) AddConsumer ¶
func (mr *MockJetStreamContextMockRecorder) AddConsumer(stream, cfg interface{}, opts ...interface{}) *gomock.Call
AddConsumer indicates an expected call of AddConsumer.
func (*MockJetStreamContextMockRecorder) AddStream ¶
func (mr *MockJetStreamContextMockRecorder) AddStream(cfg interface{}, opts ...interface{}) *gomock.Call
AddStream indicates an expected call of AddStream.
func (*MockJetStreamContextMockRecorder) ChanQueueSubscribe ¶
func (mr *MockJetStreamContextMockRecorder) ChanQueueSubscribe(subj, queue, ch interface{}, opts ...interface{}) *gomock.Call
ChanQueueSubscribe indicates an expected call of ChanQueueSubscribe.
func (*MockJetStreamContextMockRecorder) ChanSubscribe ¶
func (mr *MockJetStreamContextMockRecorder) ChanSubscribe(subj, ch interface{}, opts ...interface{}) *gomock.Call
ChanSubscribe indicates an expected call of ChanSubscribe.
func (*MockJetStreamContextMockRecorder) ConsumerInfo ¶
func (mr *MockJetStreamContextMockRecorder) ConsumerInfo(stream, name interface{}, opts ...interface{}) *gomock.Call
ConsumerInfo indicates an expected call of ConsumerInfo.
func (*MockJetStreamContextMockRecorder) ConsumerNames ¶
func (mr *MockJetStreamContextMockRecorder) ConsumerNames(stream interface{}, opts ...interface{}) *gomock.Call
ConsumerNames indicates an expected call of ConsumerNames.
func (*MockJetStreamContextMockRecorder) ConsumersInfo ¶
func (mr *MockJetStreamContextMockRecorder) ConsumersInfo(stream interface{}, opts ...interface{}) *gomock.Call
ConsumersInfo indicates an expected call of ConsumersInfo.
func (*MockJetStreamContextMockRecorder) CreateKeyValue ¶
func (mr *MockJetStreamContextMockRecorder) CreateKeyValue(cfg interface{}) *gomock.Call
CreateKeyValue indicates an expected call of CreateKeyValue.
func (*MockJetStreamContextMockRecorder) CreateObjectStore ¶
func (mr *MockJetStreamContextMockRecorder) CreateObjectStore(cfg interface{}) *gomock.Call
CreateObjectStore indicates an expected call of CreateObjectStore.
func (*MockJetStreamContextMockRecorder) DeleteConsumer ¶
func (mr *MockJetStreamContextMockRecorder) DeleteConsumer(stream, consumer interface{}, opts ...interface{}) *gomock.Call
DeleteConsumer indicates an expected call of DeleteConsumer.
func (*MockJetStreamContextMockRecorder) DeleteKeyValue ¶
func (mr *MockJetStreamContextMockRecorder) DeleteKeyValue(bucket interface{}) *gomock.Call
DeleteKeyValue indicates an expected call of DeleteKeyValue.
func (*MockJetStreamContextMockRecorder) DeleteMsg ¶
func (mr *MockJetStreamContextMockRecorder) DeleteMsg(name, seq interface{}, opts ...interface{}) *gomock.Call
DeleteMsg indicates an expected call of DeleteMsg.
func (*MockJetStreamContextMockRecorder) DeleteObjectStore ¶
func (mr *MockJetStreamContextMockRecorder) DeleteObjectStore(bucket interface{}) *gomock.Call
DeleteObjectStore indicates an expected call of DeleteObjectStore.
func (*MockJetStreamContextMockRecorder) DeleteStream ¶
func (mr *MockJetStreamContextMockRecorder) DeleteStream(name interface{}, opts ...interface{}) *gomock.Call
DeleteStream indicates an expected call of DeleteStream.
func (*MockJetStreamContextMockRecorder) GetMsg ¶
func (mr *MockJetStreamContextMockRecorder) GetMsg(name, seq interface{}, opts ...interface{}) *gomock.Call
GetMsg indicates an expected call of GetMsg.
func (*MockJetStreamContextMockRecorder) KeyValue ¶
func (mr *MockJetStreamContextMockRecorder) KeyValue(bucket interface{}) *gomock.Call
KeyValue indicates an expected call of KeyValue.
func (*MockJetStreamContextMockRecorder) ObjectStore ¶
func (mr *MockJetStreamContextMockRecorder) ObjectStore(bucket interface{}) *gomock.Call
ObjectStore indicates an expected call of ObjectStore.
func (*MockJetStreamContextMockRecorder) Publish ¶
func (mr *MockJetStreamContextMockRecorder) Publish(subj, data interface{}, opts ...interface{}) *gomock.Call
Publish indicates an expected call of Publish.
func (*MockJetStreamContextMockRecorder) PublishAsync ¶
func (mr *MockJetStreamContextMockRecorder) PublishAsync(subj, data interface{}, opts ...interface{}) *gomock.Call
PublishAsync indicates an expected call of PublishAsync.
func (*MockJetStreamContextMockRecorder) PublishAsyncComplete ¶
func (mr *MockJetStreamContextMockRecorder) PublishAsyncComplete() *gomock.Call
PublishAsyncComplete indicates an expected call of PublishAsyncComplete.
func (*MockJetStreamContextMockRecorder) PublishAsyncPending ¶
func (mr *MockJetStreamContextMockRecorder) PublishAsyncPending() *gomock.Call
PublishAsyncPending indicates an expected call of PublishAsyncPending.
func (*MockJetStreamContextMockRecorder) PublishMsg ¶
func (mr *MockJetStreamContextMockRecorder) PublishMsg(m interface{}, opts ...interface{}) *gomock.Call
PublishMsg indicates an expected call of PublishMsg.
func (*MockJetStreamContextMockRecorder) PublishMsgAsync ¶
func (mr *MockJetStreamContextMockRecorder) PublishMsgAsync(m interface{}, opts ...interface{}) *gomock.Call
PublishMsgAsync indicates an expected call of PublishMsgAsync.
func (*MockJetStreamContextMockRecorder) PullSubscribe ¶
func (mr *MockJetStreamContextMockRecorder) PullSubscribe(subj, durable interface{}, opts ...interface{}) *gomock.Call
PullSubscribe indicates an expected call of PullSubscribe.
func (*MockJetStreamContextMockRecorder) PurgeStream ¶
func (mr *MockJetStreamContextMockRecorder) PurgeStream(name interface{}, opts ...interface{}) *gomock.Call
PurgeStream indicates an expected call of PurgeStream.
func (*MockJetStreamContextMockRecorder) QueueSubscribe ¶
func (mr *MockJetStreamContextMockRecorder) QueueSubscribe(subj, queue, cb interface{}, opts ...interface{}) *gomock.Call
QueueSubscribe indicates an expected call of QueueSubscribe.
func (*MockJetStreamContextMockRecorder) QueueSubscribeSync ¶
func (mr *MockJetStreamContextMockRecorder) QueueSubscribeSync(subj, queue interface{}, opts ...interface{}) *gomock.Call
QueueSubscribeSync indicates an expected call of QueueSubscribeSync.
func (*MockJetStreamContextMockRecorder) StreamInfo ¶
func (mr *MockJetStreamContextMockRecorder) StreamInfo(stream interface{}, opts ...interface{}) *gomock.Call
StreamInfo indicates an expected call of StreamInfo.
func (*MockJetStreamContextMockRecorder) StreamNames ¶
func (mr *MockJetStreamContextMockRecorder) StreamNames(opts ...interface{}) *gomock.Call
StreamNames indicates an expected call of StreamNames.
func (*MockJetStreamContextMockRecorder) StreamsInfo ¶
func (mr *MockJetStreamContextMockRecorder) StreamsInfo(opts ...interface{}) *gomock.Call
StreamsInfo indicates an expected call of StreamsInfo.
func (*MockJetStreamContextMockRecorder) Subscribe ¶
func (mr *MockJetStreamContextMockRecorder) Subscribe(subj, cb interface{}, opts ...interface{}) *gomock.Call
Subscribe indicates an expected call of Subscribe.
func (*MockJetStreamContextMockRecorder) SubscribeSync ¶
func (mr *MockJetStreamContextMockRecorder) SubscribeSync(subj interface{}, opts ...interface{}) *gomock.Call
SubscribeSync indicates an expected call of SubscribeSync.
func (*MockJetStreamContextMockRecorder) UpdateConsumer ¶
func (mr *MockJetStreamContextMockRecorder) UpdateConsumer(stream, cfg interface{}, opts ...interface{}) *gomock.Call
UpdateConsumer indicates an expected call of UpdateConsumer.
func (*MockJetStreamContextMockRecorder) UpdateStream ¶
func (mr *MockJetStreamContextMockRecorder) UpdateStream(cfg interface{}, opts ...interface{}) *gomock.Call
UpdateStream indicates an expected call of UpdateStream.