emulation

package

Go to main page

Versions in this module

v1

v1.8.0-beta.1

May 1, 2024

v1.7.1

May 20, 2024

v1.7.0

Apr 2, 2024

v1.6.1

Mar 4, 2024

Changes in this version

type DispositionType

+ const DispositionTypeModify

v1.6.0

Jan 17, 2024

v1.5.0

Oct 2, 2023

v1.4.1

Sep 6, 2023

v1.4.0

Jun 6, 2023

v1.3.0

May 8, 2023

v1.2.1

Mar 7, 2023

Changes in this version

type MockReceiver

+ InternalIssueCredit func(credit uint32) error

v1.2.0

Feb 7, 2023

Changes in this version

+ const EventEmulator

+ func RequireNoLeaks(t *testing.T, events *Events)

+ type CreditEvent struct

+ Credit uint32

+ type DispositionEvent struct

+ DispType DispositionType

+ type DispositionType string

+ const DispositionTypeAccept

+ const DispositionTypeReject

+ const DispositionTypeRelease

+ type Event struct

+ Data any

+ Type EventType

+ type EventType string

+ const EventTypeConnClose

+ const EventTypeConnOpen

+ const EventTypeLinkClose

+ const EventTypeLinkCredit

+ const EventTypeLinkDisposition

+ const EventTypeLinkOpen

+ const EventTypeReceive

+ const EventTypeSend

+ type Events struct

+ func NewEvents() *Events

+ func (e *Events) All() []Event

+ func (e *Events) Chan() <-chan Event

+ func (e *Events) Clear()

+ func (e *Events) CloseConnection(name string)

+ func (e *Events) CloseLink(args LinkEvent)

+ func (e *Events) Custom(name string, data any)

+ func (e *Events) Disposition(args DispositionEvent)

+ func (e *Events) GetOpenConns() []string

+ func (e *Events) GetOpenLinks() []string

+ func (e *Events) IssueCredit(args CreditEvent)

+ func (e *Events) OpenConnection(name string)

+ func (e *Events) OpenLink(args LinkEvent)

+ func (e *Events) Receive(args ReceiveEvent)

+ func (e *Events) Send(args SendEvent)

+ type LinkEvent struct

+ ConnID string

+ Entity string

+ Name string

+ Role LinkRole

+ SessID string

+ TargetAddress string

+ type LinkRole string

+ const LinkRoleReceiver

+ const LinkRoleSender

+ type MockConnection struct

+ Status *Status

+ type MockData struct

+ Ctrl *gomock.Controller

+ Events *Events

+ func NewMockData(t *testing.T, options *MockDataOptions) *MockData

+ func (md *MockData) AllQueues() map[string]*Queue

+ func (md *MockData) Close()

+ func (md *MockData) DetachReceivers(entityName string)

+ func (md *MockData) DetachSenders(entityName string)

+ func (md *MockData) NewConnection(ctx context.Context) (amqpwrap.AMQPClient, error)

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

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

+ func (md *MockData) NewTokenProvider() auth.TokenProvider

+ type MockDataOptions struct

+ NewConnectionFn func(orig *mock.MockAMQPClient, ctx context.Context) error

+ PreReceiverMock func(mr *MockReceiver, ctx context.Context) error

+ PreSenderMock func(ms *MockSender, ctx context.Context) error

+ PreSessionMock func(msess *MockSession, ctx context.Context, opts *amqp.SessionOptions) error

+ type MockReceiver struct

+ InternalReceive func(ctx context.Context) (*amqp.Message, error)

+ Opts *amqp.ReceiverOptions

+ Session *MockSession

+ Source string

+ Status *Status

+ TargetAddress string

+ func (rcvr *MockReceiver) Done() <-chan error

+ func (rcvr *MockReceiver) LinkEvent() LinkEvent

+ type MockSender struct

+ Opts *amqp.SenderOptions

+ Session *MockSession

+ Status *Status

+ Target string

+ func (m *MockSender) LinkEvent() LinkEvent

+ type MockSession struct

+ Conn *MockConnection

+ ID string

+ Status *Status

+ func (sess *MockSession) Done() <-chan error

+ type Operation struct

+ Credits uint32

+ Entity string

+ LinkName string

+ M *amqp.Message

+ Op string

+ Role string

+ func (op *Operation) String() string

+ type Queue struct

+ func NewQueue(name string, events *Events) *Queue

+ func (q *Queue) AcceptMessage(ctx context.Context, msg *amqp.Message, evt LinkEvent, status *Status) error

+ func (q *Queue) Close()

+ func (q *Queue) IssueCredit(credit uint32, evt LinkEvent, status *Status) error

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

+ func (q *Queue) Receive(ctx context.Context, evt LinkEvent, status *Status) (*amqp.Message, error)

+ func (q *Queue) RejectMessage(ctx context.Context, msg *amqp.Message, e *amqp.Error, evt LinkEvent, ...) error

+ func (q *Queue) ReleaseMessage(ctx context.Context, msg *amqp.Message, evt LinkEvent) error

+ func (q *Queue) Send(ctx context.Context, tempMsg *amqp.Message, evt LinkEvent, status *Status) error

+ type ReceiveEvent struct

+ type SendEvent struct

+ type Status struct

+ func NewStatus(parent *Status) *Status

+ func (s *Status) CloseWithError(err error)

+ func (s *Status) Done() <-chan struct{}

+ func (s *Status) Err() error

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