mocks

package
v0.1.4 Latest Latest
Warning

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

 Go to latest Published: Apr 8, 2024 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockConsumerInfoLister 

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

MockConsumerInfoLister is a mock of ConsumerInfoLister interface.

func NewMockConsumerInfoLister 

func NewMockConsumerInfoLister(ctrl *gomock.Controller) *MockConsumerInfoLister

NewMockConsumerInfoLister creates a new mock instance.

func (*MockConsumerInfoLister) EXPECT 

func (m *MockConsumerInfoLister) EXPECT() *MockConsumerInfoListerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockConsumerInfoLister) Err 

func (m *MockConsumerInfoLister) Err() error

Err mocks base method.

func (*MockConsumerInfoLister) Info 

func (m *MockConsumerInfoLister) Info() <-chan *jetstream.ConsumerInfo

Info mocks base method.

type MockConsumerInfoListerMockRecorder 

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

MockConsumerInfoListerMockRecorder is the mock recorder for MockConsumerInfoLister.

func (*MockConsumerInfoListerMockRecorder) Err 

func (mr *MockConsumerInfoListerMockRecorder) Err() *gomock.Call

Err indicates an expected call of Err.

func (*MockConsumerInfoListerMockRecorder) Info 

func (mr *MockConsumerInfoListerMockRecorder) Info() *gomock.Call

Info indicates an expected call of Info.

type MockJetStream 

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

MockJetStream is a mock of JetStream interface.

func NewMockJetStream 

func NewMockJetStream(ctrl *gomock.Controller) *MockJetStream

NewMockJetStream creates a new mock instance.

func (*MockJetStream) AccountInfo 

func (m *MockJetStream) AccountInfo(arg0 context.Context) (*jetstream.AccountInfo, error)

AccountInfo mocks base method.

func (*MockJetStream) Consumer 

func (m *MockJetStream) Consumer(arg0 context.Context, arg1, arg2 string) (jetstream.Consumer, error)

Consumer mocks base method.

func (*MockJetStream) CreateConsumer 

func (m *MockJetStream) CreateConsumer(arg0 context.Context, arg1 string, arg2 jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateConsumer mocks base method.

func (*MockJetStream) CreateKeyValue 

func (m *MockJetStream) CreateKeyValue(arg0 context.Context, arg1 jetstream.KeyValueConfig) (jetstream.KeyValue, error)

CreateKeyValue mocks base method.

func (*MockJetStream) CreateObjectStore 

func (m *MockJetStream) CreateObjectStore(arg0 context.Context, arg1 jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)

CreateObjectStore mocks base method.

func (*MockJetStream) CreateOrUpdateConsumer 

func (m *MockJetStream) CreateOrUpdateConsumer(arg0 context.Context, arg1 string, arg2 jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateOrUpdateConsumer mocks base method.

func (*MockJetStream) CreateOrUpdateKeyValue 

func (m *MockJetStream) CreateOrUpdateKeyValue(arg0 context.Context, arg1 jetstream.KeyValueConfig) (jetstream.KeyValue, error)

CreateOrUpdateKeyValue mocks base method.

func (*MockJetStream) CreateOrUpdateObjectStore 

func (m *MockJetStream) CreateOrUpdateObjectStore(arg0 context.Context, arg1 jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)

CreateOrUpdateObjectStore mocks base method.

func (*MockJetStream) CreateOrUpdateStream 

func (m *MockJetStream) CreateOrUpdateStream(arg0 context.Context, arg1 jetstream.StreamConfig) (jetstream.Stream, error)

CreateOrUpdateStream mocks base method.

func (*MockJetStream) CreateStream 

func (m *MockJetStream) CreateStream(arg0 context.Context, arg1 jetstream.StreamConfig) (jetstream.Stream, error)

CreateStream mocks base method.

func (*MockJetStream) DeleteConsumer 

func (m *MockJetStream) DeleteConsumer(arg0 context.Context, arg1, arg2 string) error

DeleteConsumer mocks base method.

func (*MockJetStream) DeleteKeyValue 

func (m *MockJetStream) DeleteKeyValue(arg0 context.Context, arg1 string) error

DeleteKeyValue mocks base method.

func (*MockJetStream) DeleteObjectStore 

func (m *MockJetStream) DeleteObjectStore(arg0 context.Context, arg1 string) error

DeleteObjectStore mocks base method.

func (*MockJetStream) DeleteStream 

func (m *MockJetStream) DeleteStream(arg0 context.Context, arg1 string) error

DeleteStream mocks base method.

func (*MockJetStream) EXPECT 

func (m *MockJetStream) EXPECT() *MockJetStreamMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockJetStream) KeyValue 

func (m *MockJetStream) KeyValue(arg0 context.Context, arg1 string) (jetstream.KeyValue, error)

KeyValue mocks base method.

func (*MockJetStream) KeyValueStoreNames 

func (m *MockJetStream) KeyValueStoreNames(arg0 context.Context) jetstream.KeyValueNamesLister

KeyValueStoreNames mocks base method.

func (*MockJetStream) KeyValueStores 

func (m *MockJetStream) KeyValueStores(arg0 context.Context) jetstream.KeyValueLister

KeyValueStores mocks base method.

func (*MockJetStream) ListStreams 

func (m *MockJetStream) ListStreams(arg0 context.Context, arg1 ...jetstream.StreamListOpt) jetstream.StreamInfoLister

ListStreams mocks base method.

func (*MockJetStream) ObjectStore 

func (m *MockJetStream) ObjectStore(arg0 context.Context, arg1 string) (jetstream.ObjectStore, error)

ObjectStore mocks base method.

func (*MockJetStream) ObjectStoreNames 

func (m *MockJetStream) ObjectStoreNames(arg0 context.Context) jetstream.ObjectStoreNamesLister

ObjectStoreNames mocks base method.

func (*MockJetStream) ObjectStores 

func (m *MockJetStream) ObjectStores(arg0 context.Context) jetstream.ObjectStoresLister

ObjectStores mocks base method.

func (*MockJetStream) OrderedConsumer 

func (m *MockJetStream) OrderedConsumer(arg0 context.Context, arg1 string, arg2 jetstream.OrderedConsumerConfig) (jetstream.Consumer, error)

OrderedConsumer mocks base method.

func (*MockJetStream) Publish 

func (m *MockJetStream) Publish(arg0 context.Context, arg1 string, arg2 []byte, arg3 ...jetstream.PublishOpt) (*jetstream.PubAck, error)

Publish mocks base method.

func (*MockJetStream) PublishAsync 

func (m *MockJetStream) PublishAsync(arg0 string, arg1 []byte, arg2 ...jetstream.PublishOpt) (jetstream.PubAckFuture, error)

PublishAsync mocks base method.

func (*MockJetStream) PublishAsyncComplete 

func (m *MockJetStream) PublishAsyncComplete() <-chan struct{}

PublishAsyncComplete mocks base method.

func (*MockJetStream) PublishAsyncPending 

func (m *MockJetStream) PublishAsyncPending() int

PublishAsyncPending mocks base method.

func (*MockJetStream) PublishMsg 

func (m *MockJetStream) PublishMsg(arg0 context.Context, arg1 *nats.Msg, arg2 ...jetstream.PublishOpt) (*jetstream.PubAck, error)

PublishMsg mocks base method.

func (*MockJetStream) PublishMsgAsync 

func (m *MockJetStream) PublishMsgAsync(arg0 *nats.Msg, arg1 ...jetstream.PublishOpt) (jetstream.PubAckFuture, error)

PublishMsgAsync mocks base method.

func (*MockJetStream) Stream 

func (m *MockJetStream) Stream(arg0 context.Context, arg1 string) (jetstream.Stream, error)

Stream mocks base method.

func (*MockJetStream) StreamNameBySubject 

func (m *MockJetStream) StreamNameBySubject(arg0 context.Context, arg1 string) (string, error)

StreamNameBySubject mocks base method.

func (*MockJetStream) StreamNames 

func (m *MockJetStream) StreamNames(arg0 context.Context, arg1 ...jetstream.StreamListOpt) jetstream.StreamNameLister

StreamNames mocks base method.

func (*MockJetStream) UpdateConsumer 

func (m *MockJetStream) UpdateConsumer(arg0 context.Context, arg1 string, arg2 jetstream.ConsumerConfig) (jetstream.Consumer, error)

UpdateConsumer mocks base method.

func (*MockJetStream) UpdateKeyValue 

func (m *MockJetStream) UpdateKeyValue(arg0 context.Context, arg1 jetstream.KeyValueConfig) (jetstream.KeyValue, error)

UpdateKeyValue mocks base method.

func (*MockJetStream) UpdateObjectStore 

func (m *MockJetStream) UpdateObjectStore(arg0 context.Context, arg1 jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)

UpdateObjectStore mocks base method.

func (*MockJetStream) UpdateStream 

func (m *MockJetStream) UpdateStream(arg0 context.Context, arg1 jetstream.StreamConfig) (jetstream.Stream, error)

UpdateStream mocks base method.

type MockJetStreamMockRecorder 

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

MockJetStreamMockRecorder is the mock recorder for MockJetStream.

func (*MockJetStreamMockRecorder) AccountInfo 

func (mr *MockJetStreamMockRecorder) AccountInfo(arg0 any) *gomock.Call

AccountInfo indicates an expected call of AccountInfo.

func (*MockJetStreamMockRecorder) Consumer 

func (mr *MockJetStreamMockRecorder) Consumer(arg0, arg1, arg2 any) *gomock.Call

Consumer indicates an expected call of Consumer.

func (*MockJetStreamMockRecorder) CreateConsumer 

func (mr *MockJetStreamMockRecorder) CreateConsumer(arg0, arg1, arg2 any) *gomock.Call

CreateConsumer indicates an expected call of CreateConsumer.

func (*MockJetStreamMockRecorder) CreateKeyValue 

func (mr *MockJetStreamMockRecorder) CreateKeyValue(arg0, arg1 any) *gomock.Call

CreateKeyValue indicates an expected call of CreateKeyValue.

func (*MockJetStreamMockRecorder) CreateObjectStore 

func (mr *MockJetStreamMockRecorder) CreateObjectStore(arg0, arg1 any) *gomock.Call

CreateObjectStore indicates an expected call of CreateObjectStore.

func (*MockJetStreamMockRecorder) CreateOrUpdateConsumer 

func (mr *MockJetStreamMockRecorder) CreateOrUpdateConsumer(arg0, arg1, arg2 any) *gomock.Call

CreateOrUpdateConsumer indicates an expected call of CreateOrUpdateConsumer.

func (*MockJetStreamMockRecorder) CreateOrUpdateKeyValue 

func (mr *MockJetStreamMockRecorder) CreateOrUpdateKeyValue(arg0, arg1 any) *gomock.Call

CreateOrUpdateKeyValue indicates an expected call of CreateOrUpdateKeyValue.

func (*MockJetStreamMockRecorder) CreateOrUpdateObjectStore 

func (mr *MockJetStreamMockRecorder) CreateOrUpdateObjectStore(arg0, arg1 any) *gomock.Call

CreateOrUpdateObjectStore indicates an expected call of CreateOrUpdateObjectStore.

func (*MockJetStreamMockRecorder) CreateOrUpdateStream 

func (mr *MockJetStreamMockRecorder) CreateOrUpdateStream(arg0, arg1 any) *gomock.Call

CreateOrUpdateStream indicates an expected call of CreateOrUpdateStream.

func (*MockJetStreamMockRecorder) CreateStream 

func (mr *MockJetStreamMockRecorder) CreateStream(arg0, arg1 any) *gomock.Call

CreateStream indicates an expected call of CreateStream.

func (*MockJetStreamMockRecorder) DeleteConsumer 

func (mr *MockJetStreamMockRecorder) DeleteConsumer(arg0, arg1, arg2 any) *gomock.Call

DeleteConsumer indicates an expected call of DeleteConsumer.

func (*MockJetStreamMockRecorder) DeleteKeyValue 

func (mr *MockJetStreamMockRecorder) DeleteKeyValue(arg0, arg1 any) *gomock.Call

DeleteKeyValue indicates an expected call of DeleteKeyValue.

func (*MockJetStreamMockRecorder) DeleteObjectStore 

func (mr *MockJetStreamMockRecorder) DeleteObjectStore(arg0, arg1 any) *gomock.Call

DeleteObjectStore indicates an expected call of DeleteObjectStore.

func (*MockJetStreamMockRecorder) DeleteStream 

func (mr *MockJetStreamMockRecorder) DeleteStream(arg0, arg1 any) *gomock.Call

DeleteStream indicates an expected call of DeleteStream.

func (*MockJetStreamMockRecorder) KeyValue 

func (mr *MockJetStreamMockRecorder) KeyValue(arg0, arg1 any) *gomock.Call

KeyValue indicates an expected call of KeyValue.

func (*MockJetStreamMockRecorder) KeyValueStoreNames 

func (mr *MockJetStreamMockRecorder) KeyValueStoreNames(arg0 any) *gomock.Call

KeyValueStoreNames indicates an expected call of KeyValueStoreNames.

func (*MockJetStreamMockRecorder) KeyValueStores 

func (mr *MockJetStreamMockRecorder) KeyValueStores(arg0 any) *gomock.Call

KeyValueStores indicates an expected call of KeyValueStores.

func (*MockJetStreamMockRecorder) ListStreams 

func (mr *MockJetStreamMockRecorder) ListStreams(arg0 any, arg1 ...any) *gomock.Call

ListStreams indicates an expected call of ListStreams.

func (*MockJetStreamMockRecorder) ObjectStore 

func (mr *MockJetStreamMockRecorder) ObjectStore(arg0, arg1 any) *gomock.Call

ObjectStore indicates an expected call of ObjectStore.

func (*MockJetStreamMockRecorder) ObjectStoreNames 

func (mr *MockJetStreamMockRecorder) ObjectStoreNames(arg0 any) *gomock.Call

ObjectStoreNames indicates an expected call of ObjectStoreNames.

func (*MockJetStreamMockRecorder) ObjectStores 

func (mr *MockJetStreamMockRecorder) ObjectStores(arg0 any) *gomock.Call

ObjectStores indicates an expected call of ObjectStores.

func (*MockJetStreamMockRecorder) OrderedConsumer 

func (mr *MockJetStreamMockRecorder) OrderedConsumer(arg0, arg1, arg2 any) *gomock.Call

OrderedConsumer indicates an expected call of OrderedConsumer.

func (*MockJetStreamMockRecorder) Publish 

func (mr *MockJetStreamMockRecorder) Publish(arg0, arg1, arg2 any, arg3 ...any) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockJetStreamMockRecorder) PublishAsync 

func (mr *MockJetStreamMockRecorder) PublishAsync(arg0, arg1 any, arg2 ...any) *gomock.Call

PublishAsync indicates an expected call of PublishAsync.

func (*MockJetStreamMockRecorder) PublishAsyncComplete 

func (mr *MockJetStreamMockRecorder) PublishAsyncComplete() *gomock.Call

PublishAsyncComplete indicates an expected call of PublishAsyncComplete.

func (*MockJetStreamMockRecorder) PublishAsyncPending 

func (mr *MockJetStreamMockRecorder) PublishAsyncPending() *gomock.Call

PublishAsyncPending indicates an expected call of PublishAsyncPending.

func (*MockJetStreamMockRecorder) PublishMsg 

func (mr *MockJetStreamMockRecorder) PublishMsg(arg0, arg1 any, arg2 ...any) *gomock.Call

PublishMsg indicates an expected call of PublishMsg.

func (*MockJetStreamMockRecorder) PublishMsgAsync 

func (mr *MockJetStreamMockRecorder) PublishMsgAsync(arg0 any, arg1 ...any) *gomock.Call

PublishMsgAsync indicates an expected call of PublishMsgAsync.

func (*MockJetStreamMockRecorder) Stream 

func (mr *MockJetStreamMockRecorder) Stream(arg0, arg1 any) *gomock.Call

Stream indicates an expected call of Stream.

func (*MockJetStreamMockRecorder) StreamNameBySubject 

func (mr *MockJetStreamMockRecorder) StreamNameBySubject(arg0, arg1 any) *gomock.Call

StreamNameBySubject indicates an expected call of StreamNameBySubject.

func (*MockJetStreamMockRecorder) StreamNames 

func (mr *MockJetStreamMockRecorder) StreamNames(arg0 any, arg1 ...any) *gomock.Call

StreamNames indicates an expected call of StreamNames.

func (*MockJetStreamMockRecorder) UpdateConsumer 

func (mr *MockJetStreamMockRecorder) UpdateConsumer(arg0, arg1, arg2 any) *gomock.Call

UpdateConsumer indicates an expected call of UpdateConsumer.

func (*MockJetStreamMockRecorder) UpdateKeyValue 

func (mr *MockJetStreamMockRecorder) UpdateKeyValue(arg0, arg1 any) *gomock.Call

UpdateKeyValue indicates an expected call of UpdateKeyValue.

func (*MockJetStreamMockRecorder) UpdateObjectStore 

func (mr *MockJetStreamMockRecorder) UpdateObjectStore(arg0, arg1 any) *gomock.Call

UpdateObjectStore indicates an expected call of UpdateObjectStore.

func (*MockJetStreamMockRecorder) UpdateStream 

func (mr *MockJetStreamMockRecorder) UpdateStream(arg0, arg1 any) *gomock.Call

UpdateStream indicates an expected call of UpdateStream.

type MockStream 

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

MockStream is a mock of Stream interface.

func NewMockStream 

func NewMockStream(ctrl *gomock.Controller) *MockStream

NewMockStream creates a new mock instance.

func (*MockStream) CachedInfo 

func (m *MockStream) CachedInfo() *jetstream.StreamInfo

CachedInfo mocks base method.

func (*MockStream) Consumer 

func (m *MockStream) Consumer(arg0 context.Context, arg1 string) (jetstream.Consumer, error)

Consumer mocks base method.

func (*MockStream) ConsumerNames 

func (m *MockStream) ConsumerNames(arg0 context.Context) jetstream.ConsumerNameLister

ConsumerNames mocks base method.

func (*MockStream) CreateConsumer 

func (m *MockStream) CreateConsumer(arg0 context.Context, arg1 jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateConsumer mocks base method.

func (*MockStream) CreateOrUpdateConsumer 

func (m *MockStream) CreateOrUpdateConsumer(arg0 context.Context, arg1 jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateOrUpdateConsumer mocks base method.

func (*MockStream) DeleteConsumer 

func (m *MockStream) DeleteConsumer(arg0 context.Context, arg1 string) error

DeleteConsumer mocks base method.

func (*MockStream) DeleteMsg 

func (m *MockStream) DeleteMsg(arg0 context.Context, arg1 uint64) error

DeleteMsg mocks base method.

func (*MockStream) EXPECT 

func (m *MockStream) EXPECT() *MockStreamMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStream) GetLastMsgForSubject 

func (m *MockStream) GetLastMsgForSubject(arg0 context.Context, arg1 string) (*jetstream.RawStreamMsg, error)

GetLastMsgForSubject mocks base method.

func (*MockStream) GetMsg 

func (m *MockStream) GetMsg(arg0 context.Context, arg1 uint64, arg2 ...jetstream.GetMsgOpt) (*jetstream.RawStreamMsg, error)

GetMsg mocks base method.

func (*MockStream) Info 

func (m *MockStream) Info(arg0 context.Context, arg1 ...jetstream.StreamInfoOpt) (*jetstream.StreamInfo, error)

Info mocks base method.

func (*MockStream) ListConsumers 

func (m *MockStream) ListConsumers(arg0 context.Context) jetstream.ConsumerInfoLister

ListConsumers mocks base method.

func (*MockStream) OrderedConsumer 

func (m *MockStream) OrderedConsumer(arg0 context.Context, arg1 jetstream.OrderedConsumerConfig) (jetstream.Consumer, error)

OrderedConsumer mocks base method.

func (*MockStream) Purge 

func (m *MockStream) Purge(arg0 context.Context, arg1 ...jetstream.StreamPurgeOpt) error

Purge mocks base method.

func (*MockStream) SecureDeleteMsg 

func (m *MockStream) SecureDeleteMsg(arg0 context.Context, arg1 uint64) error

SecureDeleteMsg mocks base method.

func (*MockStream) UpdateConsumer 

func (m *MockStream) UpdateConsumer(arg0 context.Context, arg1 jetstream.ConsumerConfig) (jetstream.Consumer, error)

UpdateConsumer mocks base method.

type MockStreamMockRecorder 

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

MockStreamMockRecorder is the mock recorder for MockStream.

func (*MockStreamMockRecorder) CachedInfo 

func (mr *MockStreamMockRecorder) CachedInfo() *gomock.Call

CachedInfo indicates an expected call of CachedInfo.

func (*MockStreamMockRecorder) Consumer 

func (mr *MockStreamMockRecorder) Consumer(arg0, arg1 any) *gomock.Call

Consumer indicates an expected call of Consumer.

func (*MockStreamMockRecorder) ConsumerNames 

func (mr *MockStreamMockRecorder) ConsumerNames(arg0 any) *gomock.Call

ConsumerNames indicates an expected call of ConsumerNames.

func (*MockStreamMockRecorder) CreateConsumer 

func (mr *MockStreamMockRecorder) CreateConsumer(arg0, arg1 any) *gomock.Call

CreateConsumer indicates an expected call of CreateConsumer.

func (*MockStreamMockRecorder) CreateOrUpdateConsumer 

func (mr *MockStreamMockRecorder) CreateOrUpdateConsumer(arg0, arg1 any) *gomock.Call

CreateOrUpdateConsumer indicates an expected call of CreateOrUpdateConsumer.

func (*MockStreamMockRecorder) DeleteConsumer 

func (mr *MockStreamMockRecorder) DeleteConsumer(arg0, arg1 any) *gomock.Call

DeleteConsumer indicates an expected call of DeleteConsumer.

func (*MockStreamMockRecorder) DeleteMsg 

func (mr *MockStreamMockRecorder) DeleteMsg(arg0, arg1 any) *gomock.Call

DeleteMsg indicates an expected call of DeleteMsg.

func (*MockStreamMockRecorder) GetLastMsgForSubject 

func (mr *MockStreamMockRecorder) GetLastMsgForSubject(arg0, arg1 any) *gomock.Call

GetLastMsgForSubject indicates an expected call of GetLastMsgForSubject.

func (*MockStreamMockRecorder) GetMsg 

func (mr *MockStreamMockRecorder) GetMsg(arg0, arg1 any, arg2 ...any) *gomock.Call

GetMsg indicates an expected call of GetMsg.

func (*MockStreamMockRecorder) Info 

func (mr *MockStreamMockRecorder) Info(arg0 any, arg1 ...any) *gomock.Call

Info indicates an expected call of Info.

func (*MockStreamMockRecorder) ListConsumers 

func (mr *MockStreamMockRecorder) ListConsumers(arg0 any) *gomock.Call

ListConsumers indicates an expected call of ListConsumers.

func (*MockStreamMockRecorder) OrderedConsumer 

func (mr *MockStreamMockRecorder) OrderedConsumer(arg0, arg1 any) *gomock.Call

OrderedConsumer indicates an expected call of OrderedConsumer.

func (*MockStreamMockRecorder) Purge 

func (mr *MockStreamMockRecorder) Purge(arg0 any, arg1 ...any) *gomock.Call

Purge indicates an expected call of Purge.

func (*MockStreamMockRecorder) SecureDeleteMsg 

func (mr *MockStreamMockRecorder) SecureDeleteMsg(arg0, arg1 any) *gomock.Call

SecureDeleteMsg indicates an expected call of SecureDeleteMsg.

func (*MockStreamMockRecorder) UpdateConsumer 

func (mr *MockStreamMockRecorder) UpdateConsumer(arg0, arg1 any) *gomock.Call

UpdateConsumer indicates an expected call of UpdateConsumer.

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.