adapter

package
v0.0.0-...-05bc493 Latest Latest
Warning

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

 Go to latest Published: Sep 20, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AsyncCallFunc 

type AsyncCallFunc func(ctx context.Context, svc messagesender.Service) smachine.AsyncResultFunc

type CallFunc 

type CallFunc func(ctx context.Context, svc messagesender.Service)

type MessageSender 

type MessageSender interface {
	PrepareSync(ctx smachine.ExecutionContext, fn CallFunc) smachine.SyncCallRequester
	PrepareAsync(ctx smachine.ExecutionContext, fn AsyncCallFunc) smachine.AsyncCallRequester
	PrepareNotify(ctx smachine.ExecutionContext, fn CallFunc) smachine.NotifyRequester
}

type MessageSenderMock 

type MessageSenderMock struct {
	PrepareAsyncMock mMessageSenderMockPrepareAsync

	PrepareNotifyMock mMessageSenderMockPrepareNotify

	PrepareSyncMock mMessageSenderMockPrepareSync
	// contains filtered or unexported fields
}

MessageSenderMock implements MessageSender

func NewMessageSenderMock 

func NewMessageSenderMock(t minimock.Tester) *MessageSenderMock

NewMessageSenderMock returns a mock for MessageSender

func (*MessageSenderMock) MinimockFinish 

func (m *MessageSenderMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*MessageSenderMock) MinimockPrepareAsyncDone 

func (m *MessageSenderMock) MinimockPrepareAsyncDone() bool

MinimockPrepareAsyncDone returns true if the count of the PrepareAsync invocations corresponds the number of defined expectations

func (*MessageSenderMock) MinimockPrepareAsyncInspect 

func (m *MessageSenderMock) MinimockPrepareAsyncInspect()

MinimockPrepareAsyncInspect logs each unmet expectation

func (*MessageSenderMock) MinimockPrepareNotifyDone 

func (m *MessageSenderMock) MinimockPrepareNotifyDone() bool

MinimockPrepareNotifyDone returns true if the count of the PrepareNotify invocations corresponds the number of defined expectations

func (*MessageSenderMock) MinimockPrepareNotifyInspect 

func (m *MessageSenderMock) MinimockPrepareNotifyInspect()

MinimockPrepareNotifyInspect logs each unmet expectation

func (*MessageSenderMock) MinimockPrepareSyncDone 

func (m *MessageSenderMock) MinimockPrepareSyncDone() bool

MinimockPrepareSyncDone returns true if the count of the PrepareSync invocations corresponds the number of defined expectations

func (*MessageSenderMock) MinimockPrepareSyncInspect 

func (m *MessageSenderMock) MinimockPrepareSyncInspect()

MinimockPrepareSyncInspect logs each unmet expectation

func (*MessageSenderMock) MinimockWait 

func (m *MessageSenderMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

func (*MessageSenderMock) PrepareAsync 

func (mmPrepareAsync *MessageSenderMock) PrepareAsync(e1 smachine.ExecutionContext, fn AsyncCallFunc) (a1 smachine.AsyncCallRequester)

PrepareAsync implements MessageSender

func (*MessageSenderMock) PrepareAsyncAfterCounter 

func (mmPrepareAsync *MessageSenderMock) PrepareAsyncAfterCounter() uint64

PrepareAsyncAfterCounter returns a count of finished MessageSenderMock.PrepareAsync invocations

func (*MessageSenderMock) PrepareAsyncBeforeCounter 

func (mmPrepareAsync *MessageSenderMock) PrepareAsyncBeforeCounter() uint64

PrepareAsyncBeforeCounter returns a count of MessageSenderMock.PrepareAsync invocations

func (*MessageSenderMock) PrepareNotify 

func (mmPrepareNotify *MessageSenderMock) PrepareNotify(e1 smachine.ExecutionContext, fn CallFunc) (n1 smachine.NotifyRequester)

PrepareNotify implements MessageSender

func (*MessageSenderMock) PrepareNotifyAfterCounter 

func (mmPrepareNotify *MessageSenderMock) PrepareNotifyAfterCounter() uint64

PrepareNotifyAfterCounter returns a count of finished MessageSenderMock.PrepareNotify invocations

func (*MessageSenderMock) PrepareNotifyBeforeCounter 

func (mmPrepareNotify *MessageSenderMock) PrepareNotifyBeforeCounter() uint64

PrepareNotifyBeforeCounter returns a count of MessageSenderMock.PrepareNotify invocations

func (*MessageSenderMock) PrepareSync 

func (mmPrepareSync *MessageSenderMock) PrepareSync(e1 smachine.ExecutionContext, fn CallFunc) (s1 smachine.SyncCallRequester)

PrepareSync implements MessageSender

func (*MessageSenderMock) PrepareSyncAfterCounter 

func (mmPrepareSync *MessageSenderMock) PrepareSyncAfterCounter() uint64

PrepareSyncAfterCounter returns a count of finished MessageSenderMock.PrepareSync invocations

func (*MessageSenderMock) PrepareSyncBeforeCounter 

func (mmPrepareSync *MessageSenderMock) PrepareSyncBeforeCounter() uint64

PrepareSyncBeforeCounter returns a count of MessageSenderMock.PrepareSync invocations

type MessageSenderMockPrepareAsyncExpectation 

type MessageSenderMockPrepareAsyncExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

MessageSenderMockPrepareAsyncExpectation specifies expectation struct of the MessageSender.PrepareAsync

func (*MessageSenderMockPrepareAsyncExpectation) Then 

func (e *MessageSenderMockPrepareAsyncExpectation) Then(a1 smachine.AsyncCallRequester) *MessageSenderMock

Then sets up MessageSender.PrepareAsync return parameters for the expectation previously defined by the When method

type MessageSenderMockPrepareAsyncParams 

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

MessageSenderMockPrepareAsyncParams contains parameters of the MessageSender.PrepareAsync

type MessageSenderMockPrepareAsyncResults 

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

MessageSenderMockPrepareAsyncResults contains results of the MessageSender.PrepareAsync

type MessageSenderMockPrepareNotifyExpectation 

type MessageSenderMockPrepareNotifyExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

MessageSenderMockPrepareNotifyExpectation specifies expectation struct of the MessageSender.PrepareNotify

func (*MessageSenderMockPrepareNotifyExpectation) Then 

func (e *MessageSenderMockPrepareNotifyExpectation) Then(n1 smachine.NotifyRequester) *MessageSenderMock

Then sets up MessageSender.PrepareNotify return parameters for the expectation previously defined by the When method

type MessageSenderMockPrepareNotifyParams 

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

MessageSenderMockPrepareNotifyParams contains parameters of the MessageSender.PrepareNotify

type MessageSenderMockPrepareNotifyResults 

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

MessageSenderMockPrepareNotifyResults contains results of the MessageSender.PrepareNotify

type MessageSenderMockPrepareSyncExpectation 

type MessageSenderMockPrepareSyncExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

MessageSenderMockPrepareSyncExpectation specifies expectation struct of the MessageSender.PrepareSync

func (*MessageSenderMockPrepareSyncExpectation) Then 

func (e *MessageSenderMockPrepareSyncExpectation) Then(s1 smachine.SyncCallRequester) *MessageSenderMock

Then sets up MessageSender.PrepareSync return parameters for the expectation previously defined by the When method

type MessageSenderMockPrepareSyncParams 

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

MessageSenderMockPrepareSyncParams contains parameters of the MessageSender.PrepareSync

type MessageSenderMockPrepareSyncResults 

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

MessageSenderMockPrepareSyncResults contains results of the MessageSender.PrepareSync

type ParallelMessageSender 

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

func CreateMessageSendService 

func CreateMessageSendService(ctx context.Context, svc messagesender.Service) *ParallelMessageSender

func (*ParallelMessageSender) PrepareAsync 

func (a *ParallelMessageSender) PrepareAsync(ctx smachine.ExecutionContext, fn AsyncCallFunc) smachine.AsyncCallRequester

func (*ParallelMessageSender) PrepareNotify 

func (a *ParallelMessageSender) PrepareNotify(ctx smachine.ExecutionContext, fn CallFunc) smachine.NotifyRequester

func (*ParallelMessageSender) PrepareSync 

func (a *ParallelMessageSender) PrepareSync(ctx smachine.ExecutionContext, fn CallFunc) smachine.SyncCallRequester

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.