messagesender

Documentation

Index

• type AdapterMockWrapper
  • func NewAdapterMockWrapper(t *minimock.Controller, svc messageSender.Service) *AdapterMockWrapper
  • func (m *AdapterMockWrapper) Mock() *messageSenderAdapter.MessageSenderMock
  • func (m *AdapterMockWrapper) SetDefaultPrepareAsyncCall(ctx context.Context) *AdapterMockWrapper
• type AsyncCallRequesterMock
  • func NewAsyncCallRequesterMock(t *minimock.Controller) *AsyncCallRequesterMock
  • func (m *AsyncCallRequesterMock) Mock() *smachine.AsyncCallRequesterMock
  • func (m *AsyncCallRequesterMock) SetStart() *AsyncCallRequesterMock
  • func (m *AsyncCallRequesterMock) SetWithoutAutoWakeUp() *AsyncCallRequesterMock
• type AsyncCallRequesterSendRoleMock
  • func NewAsyncCallRequesterSendRoleMock(parent *ServiceMockWrapper) *AsyncCallRequesterSendRoleMock
  • func (m *AsyncCallRequesterSendRoleMock) Set(fn SendRoleFn) *AsyncCallRequesterSendRoleMock
  • func (m *AsyncCallRequesterSendRoleMock) SetCheckMessage(fn func(rmsreg.GoGoSerializable)) *AsyncCallRequesterSendRoleMock
  • func (m *AsyncCallRequesterSendRoleMock) SetCheckObject(fn func(reference.Global)) *AsyncCallRequesterSendRoleMock
  • func (m *AsyncCallRequesterSendRoleMock) SetCheckPulseNumber(fn func(pulse.Number)) *AsyncCallRequesterSendRoleMock
  • func (m *AsyncCallRequesterSendRoleMock) SetCheckRole(fn func(affinity.DynamicRole)) *AsyncCallRequesterSendRoleMock
• type AsyncCallRequesterSendTargetMock
  • func NewAsyncCallRequesterSendTargetMock(parent *ServiceMockWrapper) *AsyncCallRequesterSendTargetMock
  • func (m *AsyncCallRequesterSendTargetMock) Set(fn SendTargetFn) *AsyncCallRequesterSendTargetMock
  • func (m *AsyncCallRequesterSendTargetMock) SetCheckMessage(fn func(rmsreg.GoGoSerializable)) *AsyncCallRequesterSendTargetMock
  • func (m *AsyncCallRequesterSendTargetMock) SetCheckTarget(fn func(reference.Global)) *AsyncCallRequesterSendTargetMock
• type SendRoleFn
• type SendTargetFn
• type ServiceMockWrapper
  • func NewServiceMockWrapper(t *minimock.Controller) *ServiceMockWrapper
  • func (m *ServiceMockWrapper) Mock() *messageSender.ServiceMock
  • func (m *ServiceMockWrapper) NewAdapterMock() *AdapterMockWrapper

Types

type AdapterMockWrapper

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

func NewAdapterMockWrapper

func NewAdapterMockWrapper(t *minimock.Controller, svc messageSender.Service) *AdapterMockWrapper

func (*AdapterMockWrapper) Mock

func (m *AdapterMockWrapper) Mock() *messageSenderAdapter.MessageSenderMock

func (*AdapterMockWrapper) SetDefaultPrepareAsyncCall

func (m *AdapterMockWrapper) SetDefaultPrepareAsyncCall(ctx context.Context) *AdapterMockWrapper

type AsyncCallRequesterMock

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

func NewAsyncCallRequesterMock

func NewAsyncCallRequesterMock(t *minimock.Controller) *AsyncCallRequesterMock

func (*AsyncCallRequesterMock) Mock

func (m *AsyncCallRequesterMock) Mock() *smachine.AsyncCallRequesterMock

func (*AsyncCallRequesterMock) SetStart

func (m *AsyncCallRequesterMock) SetStart() *AsyncCallRequesterMock

func (*AsyncCallRequesterMock) SetWithoutAutoWakeUp

func (m *AsyncCallRequesterMock) SetWithoutAutoWakeUp() *AsyncCallRequesterMock

type AsyncCallRequesterSendRoleMock

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

func NewAsyncCallRequesterSendRoleMock

func NewAsyncCallRequesterSendRoleMock(parent *ServiceMockWrapper) *AsyncCallRequesterSendRoleMock

func (*AsyncCallRequesterSendRoleMock) Set

func (m *AsyncCallRequesterSendRoleMock) Set(fn SendRoleFn) *AsyncCallRequesterSendRoleMock

func (*AsyncCallRequesterSendRoleMock) SetCheckMessage

func (m *AsyncCallRequesterSendRoleMock) SetCheckMessage(fn func(rmsreg.GoGoSerializable)) *AsyncCallRequesterSendRoleMock

func (*AsyncCallRequesterSendRoleMock) SetCheckObject

func (m *AsyncCallRequesterSendRoleMock) SetCheckObject(fn func(reference.Global)) *AsyncCallRequesterSendRoleMock

func (*AsyncCallRequesterSendRoleMock) SetCheckPulseNumber

func (m *AsyncCallRequesterSendRoleMock) SetCheckPulseNumber(fn func(pulse.Number)) *AsyncCallRequesterSendRoleMock

func (*AsyncCallRequesterSendRoleMock) SetCheckRole

func (m *AsyncCallRequesterSendRoleMock) SetCheckRole(fn func(affinity.DynamicRole)) *AsyncCallRequesterSendRoleMock

type AsyncCallRequesterSendTargetMock

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

func NewAsyncCallRequesterSendTargetMock

func NewAsyncCallRequesterSendTargetMock(parent *ServiceMockWrapper) *AsyncCallRequesterSendTargetMock

func (*AsyncCallRequesterSendTargetMock) Set

func (m *AsyncCallRequesterSendTargetMock) Set(fn SendTargetFn) *AsyncCallRequesterSendTargetMock

func (*AsyncCallRequesterSendTargetMock) SetCheckMessage

func (m *AsyncCallRequesterSendTargetMock) SetCheckMessage(fn func(rmsreg.GoGoSerializable)) *AsyncCallRequesterSendTargetMock

func (*AsyncCallRequesterSendTargetMock) SetCheckTarget

func (m *AsyncCallRequesterSendTargetMock) SetCheckTarget(fn func(reference.Global)) *AsyncCallRequesterSendTargetMock

type SendRoleFn

type SendRoleFn func(
	_ context.Context,
	msg rmsreg.GoGoSerializable,
	role affinity.DynamicRole,
	object reference.Global,
	pn pulse.Number,
	_ ...messageSender.SendOption,
) error

type SendTargetFn

type SendTargetFn func(
	_ context.Context,
	msg rmsreg.GoGoSerializable,
	target reference.Global,
	_ ...messageSender.SendOption,
) error

type ServiceMockWrapper

type ServiceMockWrapper struct {
	SendRole   *AsyncCallRequesterSendRoleMock
	SendTarget *AsyncCallRequesterSendTargetMock
	// contains filtered or unexported fields
}

func NewServiceMockWrapper

func NewServiceMockWrapper(t *minimock.Controller) *ServiceMockWrapper

func (*ServiceMockWrapper) Mock

func (m *ServiceMockWrapper) Mock() *messageSender.ServiceMock

func (*ServiceMockWrapper) NewAdapterMock

func (m *ServiceMockWrapper) NewAdapterMock() *AdapterMockWrapper