mock

package
v1.1.0 Latest Latest
Warning

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

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

Documentation

Overview

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SetupRPC 

func SetupRPC(sender *MockAMQPSenderCloser, receiver *MockAMQPReceiverCloser, expectedCount int, handler func(sent *amqp.Message, response *amqp.Message))

Types

type MockAMQPClient 

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

MockAMQPClient is a mock of AMQPClient interface.

func NewMockAMQPClient 

func NewMockAMQPClient(ctrl *gomock.Controller) *MockAMQPClient

NewMockAMQPClient creates a new mock instance.

func (*MockAMQPClient) Close 

func (m *MockAMQPClient) Close() error

Close mocks base method.

func (*MockAMQPClient) EXPECT 

func (m *MockAMQPClient) EXPECT() *MockAMQPClientMockRecorder

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

func (*MockAMQPClient) ID added in v1.0.1 

func (m *MockAMQPClient) ID() uint64

ID mocks base method.

func (*MockAMQPClient) NewSession 

func (m *MockAMQPClient) NewSession(ctx context.Context, opts *amqp.SessionOptions) (amqpwrap.AMQPSession, error)

NewSession mocks base method.

type MockAMQPClientMockRecorder 

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

MockAMQPClientMockRecorder is the mock recorder for MockAMQPClient.

func (*MockAMQPClientMockRecorder) Close 

func (mr *MockAMQPClientMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockAMQPClientMockRecorder) ID added in v1.0.1 

func (mr *MockAMQPClientMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID.

func (*MockAMQPClientMockRecorder) NewSession 

func (mr *MockAMQPClientMockRecorder) NewSession(ctx, opts interface{}) *gomock.Call

NewSession indicates an expected call of NewSession.

type MockAMQPReceiver 

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

MockAMQPReceiver is a mock of AMQPReceiver interface.

func NewMockAMQPReceiver 

func NewMockAMQPReceiver(ctrl *gomock.Controller) *MockAMQPReceiver

NewMockAMQPReceiver creates a new mock instance.

func (*MockAMQPReceiver) AcceptMessage 

func (m *MockAMQPReceiver) AcceptMessage(ctx context.Context, msg *amqp.Message) error

AcceptMessage mocks base method.

func (*MockAMQPReceiver) ConnID added in v1.0.1 

func (m *MockAMQPReceiver) ConnID() uint64

ConnID mocks base method.

func (*MockAMQPReceiver) Credits 

func (m *MockAMQPReceiver) Credits() uint32

Credits mocks base method.

func (*MockAMQPReceiver) EXPECT 

func (m *MockAMQPReceiver) EXPECT() *MockAMQPReceiverMockRecorder

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

func (*MockAMQPReceiver) IssueCredit 

func (m *MockAMQPReceiver) IssueCredit(credit uint32) error

IssueCredit mocks base method.

func (*MockAMQPReceiver) LinkName 

func (m *MockAMQPReceiver) LinkName() string

LinkName mocks base method.

func (*MockAMQPReceiver) LinkSourceFilterValue 

func (m *MockAMQPReceiver) LinkSourceFilterValue(name string) any

LinkSourceFilterValue mocks base method.

func (*MockAMQPReceiver) ModifyMessage 

func (m *MockAMQPReceiver) ModifyMessage(ctx context.Context, msg *amqp.Message, options *amqp.ModifyMessageOptions) error

ModifyMessage mocks base method.

func (*MockAMQPReceiver) Prefetched 

func (m *MockAMQPReceiver) Prefetched() *amqp.Message

Prefetched mocks base method.

func (*MockAMQPReceiver) Receive 

func (m *MockAMQPReceiver) Receive(ctx context.Context, o *amqp.ReceiveOptions) (*amqp.Message, error)

Receive mocks base method.

func (*MockAMQPReceiver) RejectMessage 

func (m *MockAMQPReceiver) RejectMessage(ctx context.Context, msg *amqp.Message, e *amqp.Error) error

RejectMessage mocks base method.

func (*MockAMQPReceiver) ReleaseMessage 

func (m *MockAMQPReceiver) ReleaseMessage(ctx context.Context, msg *amqp.Message) error

ReleaseMessage mocks base method.

type MockAMQPReceiverCloser 

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

MockAMQPReceiverCloser is a mock of AMQPReceiverCloser interface.

func NewMockAMQPReceiverCloser 

func NewMockAMQPReceiverCloser(ctrl *gomock.Controller) *MockAMQPReceiverCloser

NewMockAMQPReceiverCloser creates a new mock instance.

func (*MockAMQPReceiverCloser) AcceptMessage 

func (m *MockAMQPReceiverCloser) AcceptMessage(ctx context.Context, msg *amqp.Message) error

AcceptMessage mocks base method.

func (*MockAMQPReceiverCloser) Close 

func (m *MockAMQPReceiverCloser) Close(ctx context.Context) error

Close mocks base method.

func (*MockAMQPReceiverCloser) ConnID added in v1.0.1 

func (m *MockAMQPReceiverCloser) ConnID() uint64

ConnID mocks base method.

func (*MockAMQPReceiverCloser) Credits 

func (m *MockAMQPReceiverCloser) Credits() uint32

Credits mocks base method.

func (*MockAMQPReceiverCloser) EXPECT 

func (m *MockAMQPReceiverCloser) EXPECT() *MockAMQPReceiverCloserMockRecorder

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

func (*MockAMQPReceiverCloser) IssueCredit 

func (m *MockAMQPReceiverCloser) IssueCredit(credit uint32) error

IssueCredit mocks base method.

func (*MockAMQPReceiverCloser) LinkName 

func (m *MockAMQPReceiverCloser) LinkName() string

LinkName mocks base method.

func (*MockAMQPReceiverCloser) LinkSourceFilterValue 

func (m *MockAMQPReceiverCloser) LinkSourceFilterValue(name string) any

LinkSourceFilterValue mocks base method.

func (*MockAMQPReceiverCloser) ModifyMessage 

func (m *MockAMQPReceiverCloser) ModifyMessage(ctx context.Context, msg *amqp.Message, options *amqp.ModifyMessageOptions) error

ModifyMessage mocks base method.

func (*MockAMQPReceiverCloser) Prefetched 

func (m *MockAMQPReceiverCloser) Prefetched() *amqp.Message

Prefetched mocks base method.

func (*MockAMQPReceiverCloser) Receive 

func (m *MockAMQPReceiverCloser) Receive(ctx context.Context, o *amqp.ReceiveOptions) (*amqp.Message, error)

Receive mocks base method.

func (*MockAMQPReceiverCloser) RejectMessage 

func (m *MockAMQPReceiverCloser) RejectMessage(ctx context.Context, msg *amqp.Message, e *amqp.Error) error

RejectMessage mocks base method.

func (*MockAMQPReceiverCloser) ReleaseMessage 

func (m *MockAMQPReceiverCloser) ReleaseMessage(ctx context.Context, msg *amqp.Message) error

ReleaseMessage mocks base method.

type MockAMQPReceiverCloserMockRecorder 

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

MockAMQPReceiverCloserMockRecorder is the mock recorder for MockAMQPReceiverCloser.

func (*MockAMQPReceiverCloserMockRecorder) AcceptMessage 

func (mr *MockAMQPReceiverCloserMockRecorder) AcceptMessage(ctx, msg interface{}) *gomock.Call

AcceptMessage indicates an expected call of AcceptMessage.

func (*MockAMQPReceiverCloserMockRecorder) Close 

func (mr *MockAMQPReceiverCloserMockRecorder) Close(ctx interface{}) *gomock.Call

Close indicates an expected call of Close.

func (*MockAMQPReceiverCloserMockRecorder) ConnID added in v1.0.1 

func (mr *MockAMQPReceiverCloserMockRecorder) ConnID() *gomock.Call

ConnID indicates an expected call of ConnID.

func (*MockAMQPReceiverCloserMockRecorder) Credits 

func (mr *MockAMQPReceiverCloserMockRecorder) Credits() *gomock.Call

Credits indicates an expected call of Credits.

func (*MockAMQPReceiverCloserMockRecorder) IssueCredit 

func (mr *MockAMQPReceiverCloserMockRecorder) IssueCredit(credit interface{}) *gomock.Call

IssueCredit indicates an expected call of IssueCredit.

func (*MockAMQPReceiverCloserMockRecorder) LinkName 

func (mr *MockAMQPReceiverCloserMockRecorder) LinkName() *gomock.Call

LinkName indicates an expected call of LinkName.

func (*MockAMQPReceiverCloserMockRecorder) LinkSourceFilterValue 

func (mr *MockAMQPReceiverCloserMockRecorder) LinkSourceFilterValue(name interface{}) *gomock.Call

LinkSourceFilterValue indicates an expected call of LinkSourceFilterValue.

func (*MockAMQPReceiverCloserMockRecorder) ModifyMessage 

func (mr *MockAMQPReceiverCloserMockRecorder) ModifyMessage(ctx, msg, options interface{}) *gomock.Call

ModifyMessage indicates an expected call of ModifyMessage.

func (*MockAMQPReceiverCloserMockRecorder) Prefetched 

func (mr *MockAMQPReceiverCloserMockRecorder) Prefetched() *gomock.Call

Prefetched indicates an expected call of Prefetched.

func (*MockAMQPReceiverCloserMockRecorder) Receive 

func (mr *MockAMQPReceiverCloserMockRecorder) Receive(ctx, o interface{}) *gomock.Call

Receive indicates an expected call of Receive.

func (*MockAMQPReceiverCloserMockRecorder) RejectMessage 

func (mr *MockAMQPReceiverCloserMockRecorder) RejectMessage(ctx, msg, e interface{}) *gomock.Call

RejectMessage indicates an expected call of RejectMessage.

func (*MockAMQPReceiverCloserMockRecorder) ReleaseMessage 

func (mr *MockAMQPReceiverCloserMockRecorder) ReleaseMessage(ctx, msg interface{}) *gomock.Call

ReleaseMessage indicates an expected call of ReleaseMessage.

type MockAMQPReceiverMockRecorder 

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

MockAMQPReceiverMockRecorder is the mock recorder for MockAMQPReceiver.

func (*MockAMQPReceiverMockRecorder) AcceptMessage 

func (mr *MockAMQPReceiverMockRecorder) AcceptMessage(ctx, msg interface{}) *gomock.Call

AcceptMessage indicates an expected call of AcceptMessage.

func (*MockAMQPReceiverMockRecorder) ConnID added in v1.0.1 

func (mr *MockAMQPReceiverMockRecorder) ConnID() *gomock.Call

ConnID indicates an expected call of ConnID.

func (*MockAMQPReceiverMockRecorder) Credits 

func (mr *MockAMQPReceiverMockRecorder) Credits() *gomock.Call

Credits indicates an expected call of Credits.

func (*MockAMQPReceiverMockRecorder) IssueCredit 

func (mr *MockAMQPReceiverMockRecorder) IssueCredit(credit interface{}) *gomock.Call

IssueCredit indicates an expected call of IssueCredit.

func (*MockAMQPReceiverMockRecorder) LinkName 

func (mr *MockAMQPReceiverMockRecorder) LinkName() *gomock.Call

LinkName indicates an expected call of LinkName.

func (*MockAMQPReceiverMockRecorder) LinkSourceFilterValue 

func (mr *MockAMQPReceiverMockRecorder) LinkSourceFilterValue(name interface{}) *gomock.Call

LinkSourceFilterValue indicates an expected call of LinkSourceFilterValue.

func (*MockAMQPReceiverMockRecorder) ModifyMessage 

func (mr *MockAMQPReceiverMockRecorder) ModifyMessage(ctx, msg, options interface{}) *gomock.Call

ModifyMessage indicates an expected call of ModifyMessage.

func (*MockAMQPReceiverMockRecorder) Prefetched 

func (mr *MockAMQPReceiverMockRecorder) Prefetched() *gomock.Call

Prefetched indicates an expected call of Prefetched.

func (*MockAMQPReceiverMockRecorder) Receive 

func (mr *MockAMQPReceiverMockRecorder) Receive(ctx, o interface{}) *gomock.Call

Receive indicates an expected call of Receive.

func (*MockAMQPReceiverMockRecorder) RejectMessage 

func (mr *MockAMQPReceiverMockRecorder) RejectMessage(ctx, msg, e interface{}) *gomock.Call

RejectMessage indicates an expected call of RejectMessage.

func (*MockAMQPReceiverMockRecorder) ReleaseMessage 

func (mr *MockAMQPReceiverMockRecorder) ReleaseMessage(ctx, msg interface{}) *gomock.Call

ReleaseMessage indicates an expected call of ReleaseMessage.

type MockAMQPSender 

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

MockAMQPSender is a mock of AMQPSender interface.

func NewMockAMQPSender 

func NewMockAMQPSender(ctrl *gomock.Controller) *MockAMQPSender

NewMockAMQPSender creates a new mock instance.

func (*MockAMQPSender) ConnID added in v1.0.1 

func (m *MockAMQPSender) ConnID() uint64

ConnID mocks base method.

func (*MockAMQPSender) EXPECT 

func (m *MockAMQPSender) EXPECT() *MockAMQPSenderMockRecorder

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

func (*MockAMQPSender) LinkName 

func (m *MockAMQPSender) LinkName() string

LinkName mocks base method.

func (*MockAMQPSender) MaxMessageSize 

func (m *MockAMQPSender) MaxMessageSize() uint64

MaxMessageSize mocks base method.

func (*MockAMQPSender) Send 

func (m *MockAMQPSender) Send(ctx context.Context, msg *amqp.Message, o *amqp.SendOptions) error

Send mocks base method.

type MockAMQPSenderCloser 

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

MockAMQPSenderCloser is a mock of AMQPSenderCloser interface.

func NewMockAMQPSenderCloser 

func NewMockAMQPSenderCloser(ctrl *gomock.Controller) *MockAMQPSenderCloser

NewMockAMQPSenderCloser creates a new mock instance.

func (*MockAMQPSenderCloser) Close 

func (m *MockAMQPSenderCloser) Close(ctx context.Context) error

Close mocks base method.

func (*MockAMQPSenderCloser) ConnID added in v1.0.1 

func (m *MockAMQPSenderCloser) ConnID() uint64

ConnID mocks base method.

func (*MockAMQPSenderCloser) EXPECT 

func (m *MockAMQPSenderCloser) EXPECT() *MockAMQPSenderCloserMockRecorder

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

func (*MockAMQPSenderCloser) LinkName 

func (m *MockAMQPSenderCloser) LinkName() string

LinkName mocks base method.

func (*MockAMQPSenderCloser) MaxMessageSize 

func (m *MockAMQPSenderCloser) MaxMessageSize() uint64

MaxMessageSize mocks base method.

func (*MockAMQPSenderCloser) Send 

func (m *MockAMQPSenderCloser) Send(ctx context.Context, msg *amqp.Message, o *amqp.SendOptions) error

Send mocks base method.

type MockAMQPSenderCloserMockRecorder 

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

MockAMQPSenderCloserMockRecorder is the mock recorder for MockAMQPSenderCloser.

func (*MockAMQPSenderCloserMockRecorder) Close 

func (mr *MockAMQPSenderCloserMockRecorder) Close(ctx interface{}) *gomock.Call

Close indicates an expected call of Close.

func (*MockAMQPSenderCloserMockRecorder) ConnID added in v1.0.1 

func (mr *MockAMQPSenderCloserMockRecorder) ConnID() *gomock.Call

ConnID indicates an expected call of ConnID.

func (*MockAMQPSenderCloserMockRecorder) LinkName 

func (mr *MockAMQPSenderCloserMockRecorder) LinkName() *gomock.Call

LinkName indicates an expected call of LinkName.

func (*MockAMQPSenderCloserMockRecorder) MaxMessageSize 

func (mr *MockAMQPSenderCloserMockRecorder) MaxMessageSize() *gomock.Call

MaxMessageSize indicates an expected call of MaxMessageSize.

func (*MockAMQPSenderCloserMockRecorder) Send 

func (mr *MockAMQPSenderCloserMockRecorder) Send(ctx, msg, o interface{}) *gomock.Call

Send indicates an expected call of Send.

type MockAMQPSenderMockRecorder 

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

MockAMQPSenderMockRecorder is the mock recorder for MockAMQPSender.

func (*MockAMQPSenderMockRecorder) ConnID added in v1.0.1 

func (mr *MockAMQPSenderMockRecorder) ConnID() *gomock.Call

ConnID indicates an expected call of ConnID.

func (*MockAMQPSenderMockRecorder) LinkName 

func (mr *MockAMQPSenderMockRecorder) LinkName() *gomock.Call

LinkName indicates an expected call of LinkName.

func (*MockAMQPSenderMockRecorder) MaxMessageSize 

func (mr *MockAMQPSenderMockRecorder) MaxMessageSize() *gomock.Call

MaxMessageSize indicates an expected call of MaxMessageSize.

func (*MockAMQPSenderMockRecorder) Send 

func (mr *MockAMQPSenderMockRecorder) Send(ctx, msg, o interface{}) *gomock.Call

Send indicates an expected call of Send.

type MockAMQPSession 

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

MockAMQPSession is a mock of AMQPSession interface.

func NewMockAMQPSession 

func NewMockAMQPSession(ctrl *gomock.Controller) *MockAMQPSession

NewMockAMQPSession creates a new mock instance.

func (*MockAMQPSession) Close 

func (m *MockAMQPSession) Close(ctx context.Context) error

Close mocks base method.

func (*MockAMQPSession) ConnID added in v1.0.1 

func (m *MockAMQPSession) ConnID() uint64

ConnID mocks base method.

func (*MockAMQPSession) EXPECT 

func (m *MockAMQPSession) EXPECT() *MockAMQPSessionMockRecorder

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

func (*MockAMQPSession) NewReceiver 

func (m *MockAMQPSession) NewReceiver(ctx context.Context, source, partitionID string, opts *amqp.ReceiverOptions) (amqpwrap.AMQPReceiverCloser, error)

NewReceiver mocks base method.

func (*MockAMQPSession) NewSender 

func (m *MockAMQPSession) NewSender(ctx context.Context, target, partitionID string, opts *amqp.SenderOptions) (amqpwrap.AMQPSenderCloser, error)

NewSender mocks base method.

type MockAMQPSessionMockRecorder 

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

MockAMQPSessionMockRecorder is the mock recorder for MockAMQPSession.

func (*MockAMQPSessionMockRecorder) Close 

func (mr *MockAMQPSessionMockRecorder) Close(ctx interface{}) *gomock.Call

Close indicates an expected call of Close.

func (*MockAMQPSessionMockRecorder) ConnID added in v1.0.1 

func (mr *MockAMQPSessionMockRecorder) ConnID() *gomock.Call

ConnID indicates an expected call of ConnID.

func (*MockAMQPSessionMockRecorder) NewReceiver 

func (mr *MockAMQPSessionMockRecorder) NewReceiver(ctx, source, partitionID, opts interface{}) *gomock.Call

NewReceiver indicates an expected call of NewReceiver.

func (*MockAMQPSessionMockRecorder) NewSender 

func (mr *MockAMQPSessionMockRecorder) NewSender(ctx, target, partitionID, opts interface{}) *gomock.Call

NewSender indicates an expected call of NewSender. 

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

MockNamespaceForAMQPLinks is a mock of NamespaceForAMQPLinks interface. 

func NewMockNamespaceForAMQPLinks(ctrl *gomock.Controller) *MockNamespaceForAMQPLinks

NewMockNamespaceForAMQPLinks creates a new mock instance.

func (*MockNamespaceForAMQPLinks) Close 

func (m *MockNamespaceForAMQPLinks) Close(ctx context.Context, permanently bool) error

Close mocks base method.

func (*MockNamespaceForAMQPLinks) EXPECT 

func (m *MockNamespaceForAMQPLinks) EXPECT() *MockNamespaceForAMQPLinksMockRecorder

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

func (*MockNamespaceForAMQPLinks) GetEntityAudience 

func (m *MockNamespaceForAMQPLinks) GetEntityAudience(entityPath string) string

GetEntityAudience mocks base method.

func (*MockNamespaceForAMQPLinks) NegotiateClaim 

func (m *MockNamespaceForAMQPLinks) NegotiateClaim(ctx context.Context, entityPath string) (context.CancelFunc, <-chan struct{}, error)

NegotiateClaim mocks base method.

func (*MockNamespaceForAMQPLinks) NewAMQPSession 

func (m *MockNamespaceForAMQPLinks) NewAMQPSession(ctx context.Context) (amqpwrap.AMQPSession, uint64, error)

NewAMQPSession mocks base method. 

func (m *MockNamespaceForAMQPLinks) NewRPCLink(ctx context.Context, managementPath string) (amqpwrap.RPCLink, uint64, error)

NewRPCLink mocks base method.

func (*MockNamespaceForAMQPLinks) Recover 

func (m *MockNamespaceForAMQPLinks) Recover(ctx context.Context, clientRevision uint64) error

Recover mocks base method.

type MockNamespaceForAMQPLinksMockRecorder 

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

MockNamespaceForAMQPLinksMockRecorder is the mock recorder for MockNamespaceForAMQPLinks.

func (*MockNamespaceForAMQPLinksMockRecorder) Close 

func (mr *MockNamespaceForAMQPLinksMockRecorder) Close(ctx, permanently interface{}) *gomock.Call

Close indicates an expected call of Close.

func (*MockNamespaceForAMQPLinksMockRecorder) GetEntityAudience 

func (mr *MockNamespaceForAMQPLinksMockRecorder) GetEntityAudience(entityPath interface{}) *gomock.Call

GetEntityAudience indicates an expected call of GetEntityAudience.

func (*MockNamespaceForAMQPLinksMockRecorder) NegotiateClaim 

func (mr *MockNamespaceForAMQPLinksMockRecorder) NegotiateClaim(ctx, entityPath interface{}) *gomock.Call

NegotiateClaim indicates an expected call of NegotiateClaim.

func (*MockNamespaceForAMQPLinksMockRecorder) NewAMQPSession 

func (mr *MockNamespaceForAMQPLinksMockRecorder) NewAMQPSession(ctx interface{}) *gomock.Call

NewAMQPSession indicates an expected call of NewAMQPSession. 

func (mr *MockNamespaceForAMQPLinksMockRecorder) NewRPCLink(ctx, managementPath interface{}) *gomock.Call

NewRPCLink indicates an expected call of NewRPCLink.

func (*MockNamespaceForAMQPLinksMockRecorder) Recover 

func (mr *MockNamespaceForAMQPLinksMockRecorder) Recover(ctx, clientRevision interface{}) *gomock.Call

Recover indicates an expected call of Recover. 

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

MockNamespaceWithNewAMQPLinks is a mock of NamespaceWithNewAMQPLinks interface. 

func NewMockNamespaceWithNewAMQPLinks(ctrl *gomock.Controller) *MockNamespaceWithNewAMQPLinks

NewMockNamespaceWithNewAMQPLinks creates a new mock instance.

func (*MockNamespaceWithNewAMQPLinks) Check 

func (m *MockNamespaceWithNewAMQPLinks) Check() error

Check mocks base method.

func (*MockNamespaceWithNewAMQPLinks) EXPECT 

func (m *MockNamespaceWithNewAMQPLinks) EXPECT() *MockNamespaceWithNewAMQPLinksMockRecorder

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

type MockNamespaceWithNewAMQPLinksMockRecorder 

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

MockNamespaceWithNewAMQPLinksMockRecorder is the mock recorder for MockNamespaceWithNewAMQPLinks.

func (*MockNamespaceWithNewAMQPLinksMockRecorder) Check 

func (mr *MockNamespaceWithNewAMQPLinksMockRecorder) Check() *gomock.Call

Check indicates an expected call of Check.

type MockTokenCredential 

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

MockTokenCredential is a mock of TokenCredential interface.

func NewMockTokenCredential 

func NewMockTokenCredential(ctrl *gomock.Controller) *MockTokenCredential

NewMockTokenCredential creates a new mock instance.

func (*MockTokenCredential) EXPECT 

func (m *MockTokenCredential) EXPECT() *MockTokenCredentialMockRecorder

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

func (*MockTokenCredential) GetToken 

func (m *MockTokenCredential) GetToken(ctx context.Context, options policy.TokenRequestOptions) (azcore.AccessToken, error)

GetToken mocks base method.

type MockTokenCredentialMockRecorder 

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

MockTokenCredentialMockRecorder is the mock recorder for MockTokenCredential.

func (*MockTokenCredentialMockRecorder) GetToken 

func (mr *MockTokenCredentialMockRecorder) GetToken(ctx, options interface{}) *gomock.Call

GetToken indicates an expected call of GetToken.

type MockTokenProvider 

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

MockTokenProvider is a mock of TokenProvider interface.

func NewMockTokenProvider 

func NewMockTokenProvider(ctrl *gomock.Controller) *MockTokenProvider

NewMockTokenProvider creates a new mock instance.

func (*MockTokenProvider) EXPECT 

func (m *MockTokenProvider) EXPECT() *MockTokenProviderMockRecorder

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

func (*MockTokenProvider) GetToken 

func (m *MockTokenProvider) GetToken(uri string) (*auth.Token, error)

GetToken mocks base method.

type MockTokenProviderMockRecorder 

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

MockTokenProviderMockRecorder is the mock recorder for MockTokenProvider.

func (*MockTokenProviderMockRecorder) GetToken 

func (mr *MockTokenProviderMockRecorder) GetToken(uri interface{}) *gomock.Call

GetToken indicates an expected call of GetToken.

type MockgoamqpConn added in v1.0.1 

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

MockgoamqpConn is a mock of goamqpConn interface.

func NewMockgoamqpConn added in v1.0.1 

func NewMockgoamqpConn(ctrl *gomock.Controller) *MockgoamqpConn

NewMockgoamqpConn creates a new mock instance.

func (*MockgoamqpConn) Close added in v1.0.1 

func (m *MockgoamqpConn) Close() error

Close mocks base method.

func (*MockgoamqpConn) EXPECT added in v1.0.1 

func (m *MockgoamqpConn) EXPECT() *MockgoamqpConnMockRecorder

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

func (*MockgoamqpConn) NewSession added in v1.0.1 

func (m *MockgoamqpConn) NewSession(ctx context.Context, opts *amqp.SessionOptions) (*amqp.Session, error)

NewSession mocks base method.

type MockgoamqpConnMockRecorder added in v1.0.1 

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

MockgoamqpConnMockRecorder is the mock recorder for MockgoamqpConn.

func (*MockgoamqpConnMockRecorder) Close added in v1.0.1 

func (mr *MockgoamqpConnMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockgoamqpConnMockRecorder) NewSession added in v1.0.1 

func (mr *MockgoamqpConnMockRecorder) NewSession(ctx, opts interface{}) *gomock.Call

NewSession indicates an expected call of NewSession.

type MockgoamqpReceiver added in v1.0.1 

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

MockgoamqpReceiver is a mock of goamqpReceiver interface.

func NewMockgoamqpReceiver added in v1.0.1 

func NewMockgoamqpReceiver(ctrl *gomock.Controller) *MockgoamqpReceiver

NewMockgoamqpReceiver creates a new mock instance.

func (*MockgoamqpReceiver) AcceptMessage added in v1.0.1 

func (m *MockgoamqpReceiver) AcceptMessage(ctx context.Context, msg *amqp.Message) error

AcceptMessage mocks base method.

func (*MockgoamqpReceiver) Close added in v1.0.1 

func (m *MockgoamqpReceiver) Close(ctx context.Context) error

Close mocks base method.

func (*MockgoamqpReceiver) EXPECT added in v1.0.1 

func (m *MockgoamqpReceiver) EXPECT() *MockgoamqpReceiverMockRecorder

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

func (*MockgoamqpReceiver) IssueCredit added in v1.0.1 

func (m *MockgoamqpReceiver) IssueCredit(credit uint32) error

IssueCredit mocks base method.

func (*MockgoamqpReceiver) LinkName added in v1.0.1 

func (m *MockgoamqpReceiver) LinkName() string

LinkName mocks base method.

func (*MockgoamqpReceiver) LinkSourceFilterValue added in v1.0.1 

func (m *MockgoamqpReceiver) LinkSourceFilterValue(name string) any

LinkSourceFilterValue mocks base method.

func (*MockgoamqpReceiver) ModifyMessage added in v1.0.1 

func (m *MockgoamqpReceiver) ModifyMessage(ctx context.Context, msg *amqp.Message, options *amqp.ModifyMessageOptions) error

ModifyMessage mocks base method.

func (*MockgoamqpReceiver) Prefetched added in v1.0.1 

func (m *MockgoamqpReceiver) Prefetched() *amqp.Message

Prefetched mocks base method.

func (*MockgoamqpReceiver) Receive added in v1.0.1 

func (m *MockgoamqpReceiver) Receive(ctx context.Context, o *amqp.ReceiveOptions) (*amqp.Message, error)

Receive mocks base method.

func (*MockgoamqpReceiver) RejectMessage added in v1.0.1 

func (m *MockgoamqpReceiver) RejectMessage(ctx context.Context, msg *amqp.Message, e *amqp.Error) error

RejectMessage mocks base method.

func (*MockgoamqpReceiver) ReleaseMessage added in v1.0.1 

func (m *MockgoamqpReceiver) ReleaseMessage(ctx context.Context, msg *amqp.Message) error

ReleaseMessage mocks base method.

type MockgoamqpReceiverMockRecorder added in v1.0.1 

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

MockgoamqpReceiverMockRecorder is the mock recorder for MockgoamqpReceiver.

func (*MockgoamqpReceiverMockRecorder) AcceptMessage added in v1.0.1 

func (mr *MockgoamqpReceiverMockRecorder) AcceptMessage(ctx, msg interface{}) *gomock.Call

AcceptMessage indicates an expected call of AcceptMessage.

func (*MockgoamqpReceiverMockRecorder) Close added in v1.0.1 

func (mr *MockgoamqpReceiverMockRecorder) Close(ctx interface{}) *gomock.Call

Close indicates an expected call of Close.

func (*MockgoamqpReceiverMockRecorder) IssueCredit added in v1.0.1 

func (mr *MockgoamqpReceiverMockRecorder) IssueCredit(credit interface{}) *gomock.Call

IssueCredit indicates an expected call of IssueCredit.

func (*MockgoamqpReceiverMockRecorder) LinkName added in v1.0.1 

func (mr *MockgoamqpReceiverMockRecorder) LinkName() *gomock.Call

LinkName indicates an expected call of LinkName.

func (*MockgoamqpReceiverMockRecorder) LinkSourceFilterValue added in v1.0.1 

func (mr *MockgoamqpReceiverMockRecorder) LinkSourceFilterValue(name interface{}) *gomock.Call

LinkSourceFilterValue indicates an expected call of LinkSourceFilterValue.

func (*MockgoamqpReceiverMockRecorder) ModifyMessage added in v1.0.1 

func (mr *MockgoamqpReceiverMockRecorder) ModifyMessage(ctx, msg, options interface{}) *gomock.Call

ModifyMessage indicates an expected call of ModifyMessage.

func (*MockgoamqpReceiverMockRecorder) Prefetched added in v1.0.1 

func (mr *MockgoamqpReceiverMockRecorder) Prefetched() *gomock.Call

Prefetched indicates an expected call of Prefetched.

func (*MockgoamqpReceiverMockRecorder) Receive added in v1.0.1 

func (mr *MockgoamqpReceiverMockRecorder) Receive(ctx, o interface{}) *gomock.Call

Receive indicates an expected call of Receive.

func (*MockgoamqpReceiverMockRecorder) RejectMessage added in v1.0.1 

func (mr *MockgoamqpReceiverMockRecorder) RejectMessage(ctx, msg, e interface{}) *gomock.Call

RejectMessage indicates an expected call of RejectMessage.

func (*MockgoamqpReceiverMockRecorder) ReleaseMessage added in v1.0.1 

func (mr *MockgoamqpReceiverMockRecorder) ReleaseMessage(ctx, msg interface{}) *gomock.Call

ReleaseMessage indicates an expected call of ReleaseMessage.

type MockgoamqpSender added in v1.0.1 

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

MockgoamqpSender is a mock of goamqpSender interface.

func NewMockgoamqpSender added in v1.0.1 

func NewMockgoamqpSender(ctrl *gomock.Controller) *MockgoamqpSender

NewMockgoamqpSender creates a new mock instance.

func (*MockgoamqpSender) Close added in v1.0.1 

func (m *MockgoamqpSender) Close(ctx context.Context) error

Close mocks base method.

func (*MockgoamqpSender) EXPECT added in v1.0.1 

func (m *MockgoamqpSender) EXPECT() *MockgoamqpSenderMockRecorder

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

func (*MockgoamqpSender) LinkName added in v1.0.1 

func (m *MockgoamqpSender) LinkName() string

LinkName mocks base method.

func (*MockgoamqpSender) MaxMessageSize added in v1.0.1 

func (m *MockgoamqpSender) MaxMessageSize() uint64

MaxMessageSize mocks base method.

func (*MockgoamqpSender) Send added in v1.0.1 

func (m *MockgoamqpSender) Send(ctx context.Context, msg *amqp.Message, o *amqp.SendOptions) error

Send mocks base method.

type MockgoamqpSenderMockRecorder added in v1.0.1 

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

MockgoamqpSenderMockRecorder is the mock recorder for MockgoamqpSender.

func (*MockgoamqpSenderMockRecorder) Close added in v1.0.1 

func (mr *MockgoamqpSenderMockRecorder) Close(ctx interface{}) *gomock.Call

Close indicates an expected call of Close.

func (*MockgoamqpSenderMockRecorder) LinkName added in v1.0.1 

func (mr *MockgoamqpSenderMockRecorder) LinkName() *gomock.Call

LinkName indicates an expected call of LinkName.

func (*MockgoamqpSenderMockRecorder) MaxMessageSize added in v1.0.1 

func (mr *MockgoamqpSenderMockRecorder) MaxMessageSize() *gomock.Call

MaxMessageSize indicates an expected call of MaxMessageSize.

func (*MockgoamqpSenderMockRecorder) Send added in v1.0.1 

func (mr *MockgoamqpSenderMockRecorder) Send(ctx, msg, o interface{}) *gomock.Call

Send indicates an expected call of Send.

type MockgoamqpSession added in v1.0.1 

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

MockgoamqpSession is a mock of goamqpSession interface.

func NewMockgoamqpSession added in v1.0.1 

func NewMockgoamqpSession(ctrl *gomock.Controller) *MockgoamqpSession

NewMockgoamqpSession creates a new mock instance.

func (*MockgoamqpSession) Close added in v1.0.1 

func (m *MockgoamqpSession) Close(ctx context.Context) error

Close mocks base method.

func (*MockgoamqpSession) EXPECT added in v1.0.1 

func (m *MockgoamqpSession) EXPECT() *MockgoamqpSessionMockRecorder

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

func (*MockgoamqpSession) NewReceiver added in v1.0.1 

func (m *MockgoamqpSession) NewReceiver(ctx context.Context, source string, opts *amqp.ReceiverOptions) (*amqp.Receiver, error)

NewReceiver mocks base method.

func (*MockgoamqpSession) NewSender added in v1.0.1 

func (m *MockgoamqpSession) NewSender(ctx context.Context, target string, opts *amqp.SenderOptions) (*amqp.Sender, error)

NewSender mocks base method.

type MockgoamqpSessionMockRecorder added in v1.0.1 

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

MockgoamqpSessionMockRecorder is the mock recorder for MockgoamqpSession.

func (*MockgoamqpSessionMockRecorder) Close added in v1.0.1 

func (mr *MockgoamqpSessionMockRecorder) Close(ctx interface{}) *gomock.Call

Close indicates an expected call of Close.

func (*MockgoamqpSessionMockRecorder) NewReceiver added in v1.0.1 

func (mr *MockgoamqpSessionMockRecorder) NewReceiver(ctx, source, opts interface{}) *gomock.Call

NewReceiver indicates an expected call of NewReceiver.

func (*MockgoamqpSessionMockRecorder) NewSender added in v1.0.1 

func (mr *MockgoamqpSessionMockRecorder) NewSender(ctx, target, opts interface{}) *gomock.Call

NewSender indicates an expected call of NewSender.

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.