mocks

package
v0.0.0-...-ea047a2 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Backend 

type Backend struct {
	mock.Mock
}

Backend is an autogenerated mock type for the Backend type

func NewBackend 

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

NewBackend creates a new instance of Backend. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Backend) DeleteInvalidConsumers 

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

DeleteInvalidConsumers provides a mock function with given fields: subscriptions

func (*Backend) DeleteSubscription 

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

DeleteSubscription provides a mock function with given fields: subscription

func (*Backend) DeleteSubscriptionsOnly 

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

DeleteSubscriptionsOnly provides a mock function with given fields: subscription

func (*Backend) GetConfig 

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

GetConfig provides a mock function with given fields:

func (*Backend) GetJetStreamContext 

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

GetJetStreamContext provides a mock function with given fields:

func (*Backend) GetJetStreamSubjects 

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

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

func (*Backend) Initialize 

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

Initialize provides a mock function with given fields: connCloseHandler

func (*Backend) SyncSubscription 

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

SyncSubscription provides a mock function with given fields: subscription

type JetStreamContext 

type JetStreamContext struct {
	mock.Mock
}

JetStreamContext is an autogenerated mock type for the JetStreamContext type

func NewJetStreamContext 

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

NewJetStreamContext creates a new instance of JetStreamContext. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*JetStreamContext) AccountInfo 

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

AccountInfo provides a mock function with given fields: opts

func (*JetStreamContext) AddConsumer 

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

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

func (*JetStreamContext) AddStream 

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

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

func (*JetStreamContext) ChanQueueSubscribe 

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

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

func (*JetStreamContext) ChanSubscribe 

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

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

func (*JetStreamContext) ConsumerInfo 

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

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

func (*JetStreamContext) ConsumerNames 

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

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

func (*JetStreamContext) Consumers 

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

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

func (*JetStreamContext) ConsumersInfo 

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

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

func (*JetStreamContext) CreateKeyValue 

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

CreateKeyValue provides a mock function with given fields: cfg

func (*JetStreamContext) CreateObjectStore 

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

CreateObjectStore provides a mock function with given fields: cfg

func (*JetStreamContext) DeleteConsumer 

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

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

func (*JetStreamContext) DeleteKeyValue 

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

DeleteKeyValue provides a mock function with given fields: bucket

func (*JetStreamContext) DeleteMsg 

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

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

func (*JetStreamContext) DeleteObjectStore 

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

DeleteObjectStore provides a mock function with given fields: bucket

func (*JetStreamContext) DeleteStream 

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

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

func (*JetStreamContext) GetLastMsg 

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

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

func (*JetStreamContext) GetMsg 

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

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

func (*JetStreamContext) KeyValue 

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

KeyValue provides a mock function with given fields: bucket

func (*JetStreamContext) KeyValueStoreNames 

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

KeyValueStoreNames provides a mock function with given fields:

func (*JetStreamContext) KeyValueStores 

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

KeyValueStores provides a mock function with given fields:

func (*JetStreamContext) ObjectStore 

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

ObjectStore provides a mock function with given fields: bucket

func (*JetStreamContext) ObjectStoreNames 

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

ObjectStoreNames provides a mock function with given fields: opts

func (*JetStreamContext) ObjectStores 

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

ObjectStores provides a mock function with given fields: opts

func (*JetStreamContext) Publish 

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

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

func (*JetStreamContext) PublishAsync 

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

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

func (*JetStreamContext) PublishAsyncComplete 

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

PublishAsyncComplete provides a mock function with given fields:

func (*JetStreamContext) PublishAsyncPending 

func (_m *JetStreamContext) PublishAsyncPending() int

PublishAsyncPending provides a mock function with given fields:

func (*JetStreamContext) PublishMsg 

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

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

func (*JetStreamContext) PublishMsgAsync 

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

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

func (*JetStreamContext) PullSubscribe 

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

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

func (*JetStreamContext) PurgeStream 

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

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

func (*JetStreamContext) QueueSubscribe 

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

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

func (*JetStreamContext) QueueSubscribeSync 

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

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

func (*JetStreamContext) SecureDeleteMsg 

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

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

func (*JetStreamContext) StreamInfo 

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

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

func (*JetStreamContext) StreamNameBySubject 

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

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

func (*JetStreamContext) StreamNames 

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

StreamNames provides a mock function with given fields: opts

func (*JetStreamContext) Streams 

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

Streams provides a mock function with given fields: opts

func (*JetStreamContext) StreamsInfo 

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

StreamsInfo provides a mock function with given fields: opts

func (*JetStreamContext) Subscribe 

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

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

func (*JetStreamContext) SubscribeSync 

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

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

func (*JetStreamContext) UpdateConsumer 

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

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

func (*JetStreamContext) UpdateStream 

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

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

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.