mock

package
v1.7.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: 10 Imported by: 0

Documentation

Overview

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var Cancelled gomock.Matcher = ContextCancelledMatcher{true}

Cancelled matches context.Context instances that are cancelled.

View Source 
var CancelledAndHasTimeout gomock.Matcher = gomock.All(ContextCancelledMatcher{true}, ContextCreatedForTest{})

CancelledAndHasTimeout matches context.Context instances that are cancelled AND were also created from NewContextForTest.

View Source 
var NotCancelled gomock.Matcher = ContextCancelledMatcher{false}

NotCancelled matches context.Context instances that are not cancelled.

View Source 
var NotCancelledAndHasTimeout gomock.Matcher = gomock.All(ContextCancelledMatcher{false}, ContextCreatedForTest{})

NotCancelledAndHasTimeout matches context.Context instances that are not cancelled AND were also created from NewContextForTest.

Functions

func CancelTestContext 

func CancelTestContext(ctx context.Context) context.CancelFunc

func NewContextWithTimeoutForTests 

func NewContextWithTimeoutForTests(parent context.Context, timeout time.Duration) (context.Context, context.CancelFunc)

NewContextWithTimeoutForTests creates a context with a lower timeout than requested just to keep unit test times reasonable.

It validates that the passed in timeout is the actual defaultCloseTimeout and also adds in a testContextKey(0) as a value which contains a pointer to a context.CancelFunc.

func SetupRPC 

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

Types

type ContextCancelledMatcher 

type ContextCancelledMatcher struct {
	// WantCancelled should be set if we expect the context should
	// be cancelled. If true, we check if Err() != nil, if false we check
	// that it's nil.
	WantCancelled bool
}

func (ContextCancelledMatcher) Matches 

func (m ContextCancelledMatcher) Matches(x any) bool

Matches returns whether x is a match.

func (ContextCancelledMatcher) String 

func (m ContextCancelledMatcher) String() string

String describes what the matcher matches.

type ContextCreatedForTest 

type ContextCreatedForTest struct{}

func (ContextCreatedForTest) Matches 

func (m ContextCreatedForTest) Matches(x any) bool

func (ContextCreatedForTest) String 

func (m ContextCreatedForTest) String() string

type ContextWithValueMatcher added in v1.2.1 

type ContextWithValueMatcher[KT comparable, VT comparable] struct {
	Key   KT
	Value VT
}

func NewContextWithValueMatcher added in v1.2.1 

func NewContextWithValueMatcher[KT comparable, VT comparable](key KT, value VT) ContextWithValueMatcher[KT, VT]

func (ContextWithValueMatcher[KT, VT]) Matches added in v1.2.1 

func (m ContextWithValueMatcher[KT, VT]) Matches(x any) bool

func (ContextWithValueMatcher[KT, VT]) String added in v1.2.1 

func (m ContextWithValueMatcher[KT, VT]) String() string

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

func (m *MockAMQPClient) Name() string

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

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

Name indicates an expected call of Name.

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) 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) 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) 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) 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) 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) 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) 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) 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) 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 string, opts *amqp.ReceiverOptions) (amqpwrap.AMQPReceiverCloser, error)

NewReceiver mocks base method.

func (*MockAMQPSession) NewSender 

func (m *MockAMQPSession) NewSender(ctx context.Context, target 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) NewReceiver 

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

NewReceiver indicates an expected call of NewReceiver.

func (*MockAMQPSessionMockRecorder) NewSender 

func (mr *MockAMQPSessionMockRecorder) NewSender(ctx, target, 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) Check 

func (m *MockNamespaceForAMQPLinks) Check() error

Check mocks base method.

func (*MockNamespaceForAMQPLinks) Close 

func (m *MockNamespaceForAMQPLinks) Close(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, error)

NewRPCLink mocks base method.

func (*MockNamespaceForAMQPLinks) Recover 

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

Recover mocks base method.

type MockNamespaceForAMQPLinksMockRecorder 

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

MockNamespaceForAMQPLinksMockRecorder is the mock recorder for MockNamespaceForAMQPLinks.

func (*MockNamespaceForAMQPLinksMockRecorder) Check 

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

Check indicates an expected call of Check.

func (*MockNamespaceForAMQPLinksMockRecorder) Close 

func (mr *MockNamespaceForAMQPLinksMockRecorder) Close(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 MockRPCLink struct {
	// contains filtered or unexported fields
}

MockRPCLink is a mock of RPCLink interface. 

func NewMockRPCLink(ctrl *gomock.Controller) *MockRPCLink

NewMockRPCLink creates a new mock instance.

func (*MockRPCLink) Close 

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

Close mocks base method.

func (*MockRPCLink) EXPECT 

func (m *MockRPCLink) EXPECT() *MockRPCLinkMockRecorder

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

func (*MockRPCLink) RPC 

func (m *MockRPCLink) RPC(ctx context.Context, msg *amqp.Message) (*amqpwrap.RPCResponse, error)

RPC mocks base method.

type MockRPCLinkMockRecorder 

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

MockRPCLinkMockRecorder is the mock recorder for MockRPCLink.

func (*MockRPCLinkMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockRPCLinkMockRecorder) RPC 

func (mr *MockRPCLinkMockRecorder) RPC(ctx, msg interface{}) *gomock.Call

RPC indicates an expected call of RPC.

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.3.0 

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

MockgoamqpConn is a mock of goamqpConn interface.

func NewMockgoamqpConn added in v1.3.0 

func NewMockgoamqpConn(ctrl *gomock.Controller) *MockgoamqpConn

NewMockgoamqpConn creates a new mock instance.

func (*MockgoamqpConn) Close added in v1.3.0 

func (m *MockgoamqpConn) Close() error

Close mocks base method.

func (*MockgoamqpConn) EXPECT added in v1.3.0 

func (m *MockgoamqpConn) EXPECT() *MockgoamqpConnMockRecorder

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

func (*MockgoamqpConn) NewSession added in v1.3.0 

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

NewSession mocks base method.

type MockgoamqpConnMockRecorder added in v1.3.0 

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

MockgoamqpConnMockRecorder is the mock recorder for MockgoamqpConn.

func (*MockgoamqpConnMockRecorder) Close added in v1.3.0 

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

Close indicates an expected call of Close.

func (*MockgoamqpConnMockRecorder) NewSession added in v1.3.0 

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

NewSession indicates an expected call of NewSession.

type MockgoamqpReceiver added in v1.3.0 

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

MockgoamqpReceiver is a mock of goamqpReceiver interface.

func NewMockgoamqpReceiver added in v1.3.0 

func NewMockgoamqpReceiver(ctrl *gomock.Controller) *MockgoamqpReceiver

NewMockgoamqpReceiver creates a new mock instance.

func (*MockgoamqpReceiver) AcceptMessage added in v1.3.0 

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

AcceptMessage mocks base method.

func (*MockgoamqpReceiver) Close added in v1.3.0 

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

Close mocks base method.

func (*MockgoamqpReceiver) EXPECT added in v1.3.0 

func (m *MockgoamqpReceiver) EXPECT() *MockgoamqpReceiverMockRecorder

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

func (*MockgoamqpReceiver) IssueCredit added in v1.3.0 

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

IssueCredit mocks base method.

func (*MockgoamqpReceiver) LinkName added in v1.3.0 

func (m *MockgoamqpReceiver) LinkName() string

LinkName mocks base method.

func (*MockgoamqpReceiver) LinkSourceFilterValue added in v1.3.0 

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

LinkSourceFilterValue mocks base method.

func (*MockgoamqpReceiver) ModifyMessage added in v1.3.0 

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

ModifyMessage mocks base method.

func (*MockgoamqpReceiver) Prefetched added in v1.3.0 

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

Prefetched mocks base method.

func (*MockgoamqpReceiver) Receive added in v1.3.0 

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

Receive mocks base method.

func (*MockgoamqpReceiver) RejectMessage added in v1.3.0 

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

RejectMessage mocks base method.

func (*MockgoamqpReceiver) ReleaseMessage added in v1.3.0 

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

ReleaseMessage mocks base method.

type MockgoamqpReceiverMockRecorder added in v1.3.0 

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

MockgoamqpReceiverMockRecorder is the mock recorder for MockgoamqpReceiver.

func (*MockgoamqpReceiverMockRecorder) AcceptMessage added in v1.3.0 

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

AcceptMessage indicates an expected call of AcceptMessage.

func (*MockgoamqpReceiverMockRecorder) Close added in v1.3.0 

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

Close indicates an expected call of Close.

func (*MockgoamqpReceiverMockRecorder) IssueCredit added in v1.3.0 

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

IssueCredit indicates an expected call of IssueCredit.

func (*MockgoamqpReceiverMockRecorder) LinkName added in v1.3.0 

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

LinkName indicates an expected call of LinkName.

func (*MockgoamqpReceiverMockRecorder) LinkSourceFilterValue added in v1.3.0 

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

LinkSourceFilterValue indicates an expected call of LinkSourceFilterValue.

func (*MockgoamqpReceiverMockRecorder) ModifyMessage added in v1.3.0 

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

ModifyMessage indicates an expected call of ModifyMessage.

func (*MockgoamqpReceiverMockRecorder) Prefetched added in v1.3.0 

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

Prefetched indicates an expected call of Prefetched.

func (*MockgoamqpReceiverMockRecorder) Receive added in v1.3.0 

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

Receive indicates an expected call of Receive.

func (*MockgoamqpReceiverMockRecorder) RejectMessage added in v1.3.0 

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

RejectMessage indicates an expected call of RejectMessage.

func (*MockgoamqpReceiverMockRecorder) ReleaseMessage added in v1.3.0 

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

ReleaseMessage indicates an expected call of ReleaseMessage.

type MockgoamqpSession added in v1.3.0 

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

MockgoamqpSession is a mock of goamqpSession interface.

func NewMockgoamqpSession added in v1.3.0 

func NewMockgoamqpSession(ctrl *gomock.Controller) *MockgoamqpSession

NewMockgoamqpSession creates a new mock instance.

func (*MockgoamqpSession) Close added in v1.3.0 

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

Close mocks base method.

func (*MockgoamqpSession) EXPECT added in v1.3.0 

func (m *MockgoamqpSession) EXPECT() *MockgoamqpSessionMockRecorder

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

func (*MockgoamqpSession) NewReceiver added in v1.3.0 

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.3.0 

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

NewSender mocks base method.

type MockgoamqpSessionMockRecorder added in v1.3.0 

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

MockgoamqpSessionMockRecorder is the mock recorder for MockgoamqpSession.

func (*MockgoamqpSessionMockRecorder) Close added in v1.3.0 

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

Close indicates an expected call of Close.

func (*MockgoamqpSessionMockRecorder) NewReceiver added in v1.3.0 

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

NewReceiver indicates an expected call of NewReceiver.

func (*MockgoamqpSessionMockRecorder) NewSender added in v1.3.0 

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

NewSender indicates an expected call of NewSender.

Source Files

View all Source files

Directories

Path Synopsis

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.