checker

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: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CallbackFn 

type CallbackFn func(topic string, messages ...*message.Message) error

type Checker 

type Checker interface {
	CheckMessages(topic string, messages ...*message.Message) error
}

type Default 

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

func NewDefault 

func NewDefault(fn CallbackFn) *Default

func NewResend 

func NewResend(ctx context.Context, sender Sender) *Default

func (*Default) CheckMessages 

func (p *Default) CheckMessages(topic string, messages ...*message.Message) error

type LRegisterRequestDefinition 

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

type LRegisterRequestHandler 

type LRegisterRequestHandler func(*rms.LRegisterRequest) bool

type LRegisterResponseDefinition 

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

type LRegisterResponseHandler 

type LRegisterResponseHandler func(*rms.LRegisterResponse) bool

type PubLRegisterRequestMock 

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

func (PubLRegisterRequestMock) Count 

func (p PubLRegisterRequestMock) Count() int

func (PubLRegisterRequestMock) CountBefore 

func (p PubLRegisterRequestMock) CountBefore() int

func (PubLRegisterRequestMock) ExpectedCount 

func (p PubLRegisterRequestMock) ExpectedCount(count int) PubLRegisterRequestMock

func (PubLRegisterRequestMock) Set 

func (p PubLRegisterRequestMock) Set(handler LRegisterRequestHandler) PubLRegisterRequestMock

func (PubLRegisterRequestMock) SetResend 

func (p PubLRegisterRequestMock) SetResend(resend bool) PubLRegisterRequestMock

func (PubLRegisterRequestMock) Wait 

func (p PubLRegisterRequestMock) Wait(ctx context.Context, count int) synckit.SignalChannel

type PubLRegisterResponseMock 

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

func (PubLRegisterResponseMock) Count 

func (p PubLRegisterResponseMock) Count() int

func (PubLRegisterResponseMock) CountBefore 

func (p PubLRegisterResponseMock) CountBefore() int

func (PubLRegisterResponseMock) ExpectedCount 

func (p PubLRegisterResponseMock) ExpectedCount(count int) PubLRegisterResponseMock

func (PubLRegisterResponseMock) Set 

func (p PubLRegisterResponseMock) Set(handler LRegisterResponseHandler) PubLRegisterResponseMock

func (PubLRegisterResponseMock) SetResend 

func (p PubLRegisterResponseMock) SetResend(resend bool) PubLRegisterResponseMock

func (PubLRegisterResponseMock) Wait 

func (p PubLRegisterResponseMock) Wait(ctx context.Context, count int) synckit.SignalChannel

type PubVCachedMemoryRequestMock 

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

func (PubVCachedMemoryRequestMock) Count 

func (p PubVCachedMemoryRequestMock) Count() int

func (PubVCachedMemoryRequestMock) CountBefore 

func (p PubVCachedMemoryRequestMock) CountBefore() int

func (PubVCachedMemoryRequestMock) ExpectedCount 

func (p PubVCachedMemoryRequestMock) ExpectedCount(count int) PubVCachedMemoryRequestMock

func (PubVCachedMemoryRequestMock) Set 

func (p PubVCachedMemoryRequestMock) Set(handler VCachedMemoryRequestHandler) PubVCachedMemoryRequestMock

func (PubVCachedMemoryRequestMock) SetResend 

func (p PubVCachedMemoryRequestMock) SetResend(resend bool) PubVCachedMemoryRequestMock

func (PubVCachedMemoryRequestMock) Wait 

func (p PubVCachedMemoryRequestMock) Wait(ctx context.Context, count int) synckit.SignalChannel

type PubVCachedMemoryResponseMock 

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

func (PubVCachedMemoryResponseMock) Count 

func (p PubVCachedMemoryResponseMock) Count() int

func (PubVCachedMemoryResponseMock) CountBefore 

func (p PubVCachedMemoryResponseMock) CountBefore() int

func (PubVCachedMemoryResponseMock) ExpectedCount 

func (p PubVCachedMemoryResponseMock) ExpectedCount(count int) PubVCachedMemoryResponseMock

func (PubVCachedMemoryResponseMock) Set 

func (p PubVCachedMemoryResponseMock) Set(handler VCachedMemoryResponseHandler) PubVCachedMemoryResponseMock

func (PubVCachedMemoryResponseMock) SetResend 

func (p PubVCachedMemoryResponseMock) SetResend(resend bool) PubVCachedMemoryResponseMock

func (PubVCachedMemoryResponseMock) Wait 

func (p PubVCachedMemoryResponseMock) Wait(ctx context.Context, count int) synckit.SignalChannel

type PubVCallRequestMock 

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

func (PubVCallRequestMock) Count 

func (p PubVCallRequestMock) Count() int

func (PubVCallRequestMock) CountBefore 

func (p PubVCallRequestMock) CountBefore() int

func (PubVCallRequestMock) ExpectedCount 

func (p PubVCallRequestMock) ExpectedCount(count int) PubVCallRequestMock

func (PubVCallRequestMock) Set 

func (p PubVCallRequestMock) Set(handler VCallRequestHandler) PubVCallRequestMock

func (PubVCallRequestMock) SetResend 

func (p PubVCallRequestMock) SetResend(resend bool) PubVCallRequestMock

func (PubVCallRequestMock) Wait 

func (p PubVCallRequestMock) Wait(ctx context.Context, count int) synckit.SignalChannel

type PubVCallResultMock 

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

func (PubVCallResultMock) Count 

func (p PubVCallResultMock) Count() int

func (PubVCallResultMock) CountBefore 

func (p PubVCallResultMock) CountBefore() int

func (PubVCallResultMock) ExpectedCount 

func (p PubVCallResultMock) ExpectedCount(count int) PubVCallResultMock

func (PubVCallResultMock) Set 

func (p PubVCallResultMock) Set(handler VCallResultHandler) PubVCallResultMock

func (PubVCallResultMock) SetResend 

func (p PubVCallResultMock) SetResend(resend bool) PubVCallResultMock

func (PubVCallResultMock) Wait 

func (p PubVCallResultMock) Wait(ctx context.Context, count int) synckit.SignalChannel

type PubVDelegatedCallRequestMock 

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

func (PubVDelegatedCallRequestMock) Count 

func (p PubVDelegatedCallRequestMock) Count() int

func (PubVDelegatedCallRequestMock) CountBefore 

func (p PubVDelegatedCallRequestMock) CountBefore() int

func (PubVDelegatedCallRequestMock) ExpectedCount 

func (p PubVDelegatedCallRequestMock) ExpectedCount(count int) PubVDelegatedCallRequestMock

func (PubVDelegatedCallRequestMock) Set 

func (p PubVDelegatedCallRequestMock) Set(handler VDelegatedCallRequestHandler) PubVDelegatedCallRequestMock

func (PubVDelegatedCallRequestMock) SetResend 

func (p PubVDelegatedCallRequestMock) SetResend(resend bool) PubVDelegatedCallRequestMock

func (PubVDelegatedCallRequestMock) Wait 

func (p PubVDelegatedCallRequestMock) Wait(ctx context.Context, count int) synckit.SignalChannel

type PubVDelegatedCallResponseMock 

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

func (PubVDelegatedCallResponseMock) Count 

func (p PubVDelegatedCallResponseMock) Count() int

func (PubVDelegatedCallResponseMock) CountBefore 

func (p PubVDelegatedCallResponseMock) CountBefore() int

func (PubVDelegatedCallResponseMock) ExpectedCount 

func (p PubVDelegatedCallResponseMock) ExpectedCount(count int) PubVDelegatedCallResponseMock

func (PubVDelegatedCallResponseMock) Set 

func (p PubVDelegatedCallResponseMock) Set(handler VDelegatedCallResponseHandler) PubVDelegatedCallResponseMock

func (PubVDelegatedCallResponseMock) SetResend 

func (p PubVDelegatedCallResponseMock) SetResend(resend bool) PubVDelegatedCallResponseMock

func (PubVDelegatedCallResponseMock) Wait 

func (p PubVDelegatedCallResponseMock) Wait(ctx context.Context, count int) synckit.SignalChannel

type PubVDelegatedRequestFinishedMock 

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

func (PubVDelegatedRequestFinishedMock) Count 

func (p PubVDelegatedRequestFinishedMock) Count() int

func (PubVDelegatedRequestFinishedMock) CountBefore 

func (p PubVDelegatedRequestFinishedMock) CountBefore() int

func (PubVDelegatedRequestFinishedMock) ExpectedCount 

func (p PubVDelegatedRequestFinishedMock) ExpectedCount(count int) PubVDelegatedRequestFinishedMock

func (PubVDelegatedRequestFinishedMock) Set 

func (p PubVDelegatedRequestFinishedMock) Set(handler VDelegatedRequestFinishedHandler) PubVDelegatedRequestFinishedMock

func (PubVDelegatedRequestFinishedMock) SetResend 

func (p PubVDelegatedRequestFinishedMock) SetResend(resend bool) PubVDelegatedRequestFinishedMock

func (PubVDelegatedRequestFinishedMock) Wait 

func (p PubVDelegatedRequestFinishedMock) Wait(ctx context.Context, count int) synckit.SignalChannel

type PubVFindCallRequestMock 

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

func (PubVFindCallRequestMock) Count 

func (p PubVFindCallRequestMock) Count() int

func (PubVFindCallRequestMock) CountBefore 

func (p PubVFindCallRequestMock) CountBefore() int

func (PubVFindCallRequestMock) ExpectedCount 

func (p PubVFindCallRequestMock) ExpectedCount(count int) PubVFindCallRequestMock

func (PubVFindCallRequestMock) Set 

func (p PubVFindCallRequestMock) Set(handler VFindCallRequestHandler) PubVFindCallRequestMock

func (PubVFindCallRequestMock) SetResend 

func (p PubVFindCallRequestMock) SetResend(resend bool) PubVFindCallRequestMock

func (PubVFindCallRequestMock) Wait 

func (p PubVFindCallRequestMock) Wait(ctx context.Context, count int) synckit.SignalChannel

type PubVFindCallResponseMock 

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

func (PubVFindCallResponseMock) Count 

func (p PubVFindCallResponseMock) Count() int

func (PubVFindCallResponseMock) CountBefore 

func (p PubVFindCallResponseMock) CountBefore() int

func (PubVFindCallResponseMock) ExpectedCount 

func (p PubVFindCallResponseMock) ExpectedCount(count int) PubVFindCallResponseMock

func (PubVFindCallResponseMock) Set 

func (p PubVFindCallResponseMock) Set(handler VFindCallResponseHandler) PubVFindCallResponseMock

func (PubVFindCallResponseMock) SetResend 

func (p PubVFindCallResponseMock) SetResend(resend bool) PubVFindCallResponseMock

func (PubVFindCallResponseMock) Wait 

func (p PubVFindCallResponseMock) Wait(ctx context.Context, count int) synckit.SignalChannel

type PubVObjectTranscriptReportMock 

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

func (PubVObjectTranscriptReportMock) Count 

func (p PubVObjectTranscriptReportMock) Count() int

func (PubVObjectTranscriptReportMock) CountBefore 

func (p PubVObjectTranscriptReportMock) CountBefore() int

func (PubVObjectTranscriptReportMock) ExpectedCount 

func (p PubVObjectTranscriptReportMock) ExpectedCount(count int) PubVObjectTranscriptReportMock

func (PubVObjectTranscriptReportMock) Set 

func (p PubVObjectTranscriptReportMock) Set(handler VObjectTranscriptReportHandler) PubVObjectTranscriptReportMock

func (PubVObjectTranscriptReportMock) SetResend 

func (p PubVObjectTranscriptReportMock) SetResend(resend bool) PubVObjectTranscriptReportMock

func (PubVObjectTranscriptReportMock) Wait 

func (p PubVObjectTranscriptReportMock) Wait(ctx context.Context, count int) synckit.SignalChannel

type PubVObjectValidationReportMock 

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

func (PubVObjectValidationReportMock) Count 

func (p PubVObjectValidationReportMock) Count() int

func (PubVObjectValidationReportMock) CountBefore 

func (p PubVObjectValidationReportMock) CountBefore() int

func (PubVObjectValidationReportMock) ExpectedCount 

func (p PubVObjectValidationReportMock) ExpectedCount(count int) PubVObjectValidationReportMock

func (PubVObjectValidationReportMock) Set 

func (p PubVObjectValidationReportMock) Set(handler VObjectValidationReportHandler) PubVObjectValidationReportMock

func (PubVObjectValidationReportMock) SetResend 

func (p PubVObjectValidationReportMock) SetResend(resend bool) PubVObjectValidationReportMock

func (PubVObjectValidationReportMock) Wait 

func (p PubVObjectValidationReportMock) Wait(ctx context.Context, count int) synckit.SignalChannel

type PubVStateReportMock 

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

func (PubVStateReportMock) Count 

func (p PubVStateReportMock) Count() int

func (PubVStateReportMock) CountBefore 

func (p PubVStateReportMock) CountBefore() int

func (PubVStateReportMock) ExpectedCount 

func (p PubVStateReportMock) ExpectedCount(count int) PubVStateReportMock

func (PubVStateReportMock) Set 

func (p PubVStateReportMock) Set(handler VStateReportHandler) PubVStateReportMock

func (PubVStateReportMock) SetResend 

func (p PubVStateReportMock) SetResend(resend bool) PubVStateReportMock

func (PubVStateReportMock) Wait 

func (p PubVStateReportMock) Wait(ctx context.Context, count int) synckit.SignalChannel

type PubVStateRequestMock 

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

func (PubVStateRequestMock) Count 

func (p PubVStateRequestMock) Count() int

func (PubVStateRequestMock) CountBefore 

func (p PubVStateRequestMock) CountBefore() int

func (PubVStateRequestMock) ExpectedCount 

func (p PubVStateRequestMock) ExpectedCount(count int) PubVStateRequestMock

func (PubVStateRequestMock) Set 

func (p PubVStateRequestMock) Set(handler VStateRequestHandler) PubVStateRequestMock

func (PubVStateRequestMock) SetResend 

func (p PubVStateRequestMock) SetResend(resend bool) PubVStateRequestMock

func (PubVStateRequestMock) Wait 

func (p PubVStateRequestMock) Wait(ctx context.Context, count int) synckit.SignalChannel

type Sender 

type Sender interface {
	SendMessage(context.Context, *message.Message)
}

type Typed 

type Typed struct {
	Handlers TypedHandlers

	LRegisterRequest          PubLRegisterRequestMock
	LRegisterResponse         PubLRegisterResponseMock
	VCachedMemoryRequest      PubVCachedMemoryRequestMock
	VCachedMemoryResponse     PubVCachedMemoryResponseMock
	VCallRequest              PubVCallRequestMock
	VCallResult               PubVCallResultMock
	VDelegatedCallRequest     PubVDelegatedCallRequestMock
	VDelegatedCallResponse    PubVDelegatedCallResponseMock
	VDelegatedRequestFinished PubVDelegatedRequestFinishedMock
	VFindCallRequest          PubVFindCallRequestMock
	VFindCallResponse         PubVFindCallResponseMock
	VObjectTranscriptReport   PubVObjectTranscriptReportMock
	VObjectValidationReport   PubVObjectValidationReportMock
	VStateReport              PubVStateReportMock
	VStateRequest             PubVStateRequestMock
	// contains filtered or unexported fields
}

func NewTyped 

func NewTyped(ctx context.Context, t minimock.Tester, sender Sender) *Typed

func (*Typed) CheckMessages 

func (p *Typed) CheckMessages(topic string, messages ...*message.Message) error

func (*Typed) MinimockFinish 

func (p *Typed) MinimockFinish()

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

func (*Typed) MinimockWait 

func (p *Typed) MinimockWait(timeout time.Duration)

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

func (*Typed) SetDefaultResend 

func (p *Typed) SetDefaultResend(flag bool) *Typed

type TypedHandlers 

type TypedHandlers struct {
	LRegisterRequest          LRegisterRequestDefinition
	LRegisterResponse         LRegisterResponseDefinition
	VCachedMemoryRequest      VCachedMemoryRequestDefinition
	VCachedMemoryResponse     VCachedMemoryResponseDefinition
	VCallRequest              VCallRequestDefinition
	VCallResult               VCallResultDefinition
	VDelegatedCallRequest     VDelegatedCallRequestDefinition
	VDelegatedCallResponse    VDelegatedCallResponseDefinition
	VDelegatedRequestFinished VDelegatedRequestFinishedDefinition
	VFindCallRequest          VFindCallRequestDefinition
	VFindCallResponse         VFindCallResponseDefinition
	VObjectTranscriptReport   VObjectTranscriptReportDefinition
	VObjectValidationReport   VObjectValidationReportDefinition
	VStateReport              VStateReportDefinition
	VStateRequest             VStateRequestDefinition

	BaseMessage struct {
		// contains filtered or unexported fields
	}
}

type VCachedMemoryRequestDefinition 

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

type VCachedMemoryRequestHandler 

type VCachedMemoryRequestHandler func(*rms.VCachedMemoryRequest) bool

type VCachedMemoryResponseDefinition 

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

type VCachedMemoryResponseHandler 

type VCachedMemoryResponseHandler func(*rms.VCachedMemoryResponse) bool

type VCallRequestDefinition 

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

type VCallRequestHandler 

type VCallRequestHandler func(*rms.VCallRequest) bool

type VCallResultDefinition 

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

type VCallResultHandler 

type VCallResultHandler func(*rms.VCallResult) bool

type VDelegatedCallRequestDefinition 

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

type VDelegatedCallRequestHandler 

type VDelegatedCallRequestHandler func(*rms.VDelegatedCallRequest) bool

type VDelegatedCallResponseDefinition 

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

type VDelegatedCallResponseHandler 

type VDelegatedCallResponseHandler func(*rms.VDelegatedCallResponse) bool

type VDelegatedRequestFinishedDefinition 

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

type VDelegatedRequestFinishedHandler 

type VDelegatedRequestFinishedHandler func(*rms.VDelegatedRequestFinished) bool

type VFindCallRequestDefinition 

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

type VFindCallRequestHandler 

type VFindCallRequestHandler func(*rms.VFindCallRequest) bool

type VFindCallResponseDefinition 

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

type VFindCallResponseHandler 

type VFindCallResponseHandler func(*rms.VFindCallResponse) bool

type VObjectTranscriptReportDefinition 

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

type VObjectTranscriptReportHandler 

type VObjectTranscriptReportHandler func(*rms.VObjectTranscriptReport) bool

type VObjectValidationReportDefinition 

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

type VObjectValidationReportHandler 

type VObjectValidationReportHandler func(*rms.VObjectValidationReport) bool

type VStateReportDefinition 

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

type VStateReportHandler 

type VStateReportHandler func(*rms.VStateReport) bool

type VStateRequestDefinition 

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

type VStateRequestHandler 

type VStateRequestHandler func(*rms.VStateRequest) bool

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.