mock

package

Go to main page

Versions in this module

v1

v1.3.0-beta.1

Jan 13, 2025

v1.2.3

Oct 11, 2024

v1.2.2

Aug 15, 2024

v1.2.1

May 20, 2024

v1.2.0

May 7, 2024

v1.1.0

Apr 2, 2024

v1.0.4

Mar 4, 2024

v1.0.3

Jan 8, 2024

v1.0.2

Nov 7, 2023

v1.0.1

Jun 6, 2023

Changes in this version

type MockAMQPClient

+ func (m *MockAMQPClient) ID() uint64

type MockAMQPClientMockRecorder

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

type MockAMQPReceiver

+ func (m *MockAMQPReceiver) ConnID() uint64

type MockAMQPReceiverCloser

+ func (m *MockAMQPReceiverCloser) ConnID() uint64

type MockAMQPReceiverCloserMockRecorder

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

type MockAMQPReceiverMockRecorder

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

type MockAMQPSender

+ func (m *MockAMQPSender) ConnID() uint64

type MockAMQPSenderCloser

+ func (m *MockAMQPSenderCloser) ConnID() uint64

type MockAMQPSenderCloserMockRecorder

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

type MockAMQPSenderMockRecorder

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

type MockAMQPSession

+ func (m *MockAMQPSession) ConnID() uint64

type MockAMQPSessionMockRecorder

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

+ type MockgoamqpConn struct

+ func NewMockgoamqpConn(ctrl *gomock.Controller) *MockgoamqpConn

+ func (m *MockgoamqpConn) Close() error

+ func (m *MockgoamqpConn) EXPECT() *MockgoamqpConnMockRecorder

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

+ type MockgoamqpConnMockRecorder struct

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

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

+ type MockgoamqpReceiver struct

+ func NewMockgoamqpReceiver(ctrl *gomock.Controller) *MockgoamqpReceiver

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

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

+ func (m *MockgoamqpReceiver) EXPECT() *MockgoamqpReceiverMockRecorder

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

+ func (m *MockgoamqpReceiver) LinkName() string

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

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

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

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

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

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

+ type MockgoamqpReceiverMockRecorder struct

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

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

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

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

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

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

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

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

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

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

+ type MockgoamqpSender struct

+ func NewMockgoamqpSender(ctrl *gomock.Controller) *MockgoamqpSender

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

+ func (m *MockgoamqpSender) EXPECT() *MockgoamqpSenderMockRecorder

+ func (m *MockgoamqpSender) LinkName() string

+ func (m *MockgoamqpSender) MaxMessageSize() uint64

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

+ type MockgoamqpSenderMockRecorder struct

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

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

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

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

+ type MockgoamqpSession struct

+ func NewMockgoamqpSession(ctrl *gomock.Controller) *MockgoamqpSession

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

+ func (m *MockgoamqpSession) EXPECT() *MockgoamqpSessionMockRecorder

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

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

+ type MockgoamqpSessionMockRecorder struct

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

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

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

v1.0.0

May 8, 2023

v0

v0.6.0

Mar 7, 2023

v0.5.0

Feb 8, 2023

v0.4.0

Jan 5, 2023

Changes in this version

+ var Cancelled gomock.Matcher = ContextCancelledMatcher

+ var CancelledAndHasTimeout gomock.Matcher = gomock.All(ContextCancelledMatcher{ ... }, ContextHasTestValueMatcher{})

+ var NotCancelled gomock.Matcher = ContextCancelledMatcher

+ var NotCancelledAndHasTimeout gomock.Matcher = gomock.All(ContextCancelledMatcher{ ... }, ContextHasTestValueMatcher{})

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

+ func SetupRPC(sender *MockAMQPSenderCloser, receiver *MockAMQPReceiverCloser, ...)

+ type ContextCancelledMatcher struct

+ WantCancelled bool

+ func (m ContextCancelledMatcher) Matches(x interface{}) bool

+ func (m ContextCancelledMatcher) String() string

+ type ContextHasTestValueMatcher struct

+ func (m ContextHasTestValueMatcher) Matches(x interface{}) bool

+ func (m ContextHasTestValueMatcher) String() string

+ type MockAMQPClient struct

+ func NewMockAMQPClient(ctrl *gomock.Controller) *MockAMQPClient

+ func (m *MockAMQPClient) Close() error

+ func (m *MockAMQPClient) EXPECT() *MockAMQPClientMockRecorder

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

+ type MockAMQPClientMockRecorder struct

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

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

+ type MockAMQPReceiver struct

+ func NewMockAMQPReceiver(ctrl *gomock.Controller) *MockAMQPReceiver

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

+ func (m *MockAMQPReceiver) Credits() uint32

+ func (m *MockAMQPReceiver) EXPECT() *MockAMQPReceiverMockRecorder

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

+ func (m *MockAMQPReceiver) LinkName() string

+ func (m *MockAMQPReceiver) LinkSourceFilterValue(name string) interface{}

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

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

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

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

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

+ type MockAMQPReceiverCloser struct

+ func NewMockAMQPReceiverCloser(ctrl *gomock.Controller) *MockAMQPReceiverCloser

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

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

+ func (m *MockAMQPReceiverCloser) Credits() uint32

+ func (m *MockAMQPReceiverCloser) EXPECT() *MockAMQPReceiverCloserMockRecorder

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

+ func (m *MockAMQPReceiverCloser) LinkName() string

+ func (m *MockAMQPReceiverCloser) LinkSourceFilterValue(name string) interface{}

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

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

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

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

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

+ type MockAMQPReceiverCloserMockRecorder struct

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

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

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

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

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

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

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

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

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

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

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

+ type MockAMQPReceiverMockRecorder struct

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

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

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

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

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

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

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

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

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

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

+ type MockAMQPSender struct

+ func NewMockAMQPSender(ctrl *gomock.Controller) *MockAMQPSender

+ func (m *MockAMQPSender) EXPECT() *MockAMQPSenderMockRecorder

+ func (m *MockAMQPSender) LinkName() string

+ func (m *MockAMQPSender) MaxMessageSize() uint64

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

+ type MockAMQPSenderCloser struct

+ func NewMockAMQPSenderCloser(ctrl *gomock.Controller) *MockAMQPSenderCloser

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

+ func (m *MockAMQPSenderCloser) EXPECT() *MockAMQPSenderCloserMockRecorder

+ func (m *MockAMQPSenderCloser) LinkName() string

+ func (m *MockAMQPSenderCloser) MaxMessageSize() uint64

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

+ type MockAMQPSenderCloserMockRecorder struct

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

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

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

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

+ type MockAMQPSenderMockRecorder struct

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

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

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

+ type MockAMQPSession struct

+ func NewMockAMQPSession(ctrl *gomock.Controller) *MockAMQPSession

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

+ func (m *MockAMQPSession) EXPECT() *MockAMQPSessionMockRecorder

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

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

+ type MockAMQPSessionMockRecorder struct

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

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

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

+ type MockNamespaceForAMQPLinks struct

+ func NewMockNamespaceForAMQPLinks(ctrl *gomock.Controller) *MockNamespaceForAMQPLinks

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

+ func (m *MockNamespaceForAMQPLinks) EXPECT() *MockNamespaceForAMQPLinksMockRecorder

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

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

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

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

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

+ type MockNamespaceForAMQPLinksMockRecorder struct

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

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

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

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

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

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

+ type MockNamespaceWithNewAMQPLinks struct

+ func NewMockNamespaceWithNewAMQPLinks(ctrl *gomock.Controller) *MockNamespaceWithNewAMQPLinks

+ func (m *MockNamespaceWithNewAMQPLinks) Check() error

+ func (m *MockNamespaceWithNewAMQPLinks) EXPECT() *MockNamespaceWithNewAMQPLinksMockRecorder

+ type MockNamespaceWithNewAMQPLinksMockRecorder struct

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

+ type MockRPCLink struct

+ func NewMockRPCLink(ctrl *gomock.Controller) *MockRPCLink

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

+ func (m *MockRPCLink) EXPECT() *MockRPCLinkMockRecorder

+ func (m *MockRPCLink) LinkName() string

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

+ type MockRPCLinkMockRecorder struct

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

+ func (mr *MockRPCLinkMockRecorder) LinkName() *gomock.Call

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

+ type MockTokenCredential struct

+ func NewMockTokenCredential(ctrl *gomock.Controller) *MockTokenCredential

+ func (m *MockTokenCredential) EXPECT() *MockTokenCredentialMockRecorder

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

+ type MockTokenCredentialMockRecorder struct

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

+ type MockTokenProvider struct

+ func NewMockTokenProvider(ctrl *gomock.Controller) *MockTokenProvider

+ func (m *MockTokenProvider) EXPECT() *MockTokenProviderMockRecorder

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

+ type MockTokenProviderMockRecorder struct

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL