mock_nats

package
v0.0.0-...-9fbc374 Latest Latest
Warning

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

 Go to latest Published: Jun 25, 2022 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Overview

Package mock_nats is a generated GoMock package.

Index

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

func (m *MockJetStreamContext) DeleteMsg(name string, seq uint64, opts ...nats.JSOpt) error

DeleteMsg 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 

func (m_2 *MockJetStreamContext) PublishMsg(m *nats.Msg, opts ...nats.PubOpt) (*nats.PubAck, error)

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.

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.