recordchecker

Documentation

Index

• func RecordFromLRegisterRequest(msg rms.LRegisterRequest) rms.BasicRecord
• type Builder
  • func NewChecker(t minimock.Tester) Builder
• type ChainBuilder
• type ChainValidator
• type ChainValidatorList
• type CheckMessageFunc
• type ProduceResponseFunc
  • func ProduceResponse(ctx context.Context, sender publisher.Sender) ProduceResponseFunc

Functions

func RecordFromLRegisterRequest

func RecordFromLRegisterRequest(msg rms.LRegisterRequest) rms.BasicRecord

Types

type Builder

type Builder interface {
	// Add new chainItem of expected messages
	CreateChainFromReference(objectRef rms.Reference) ChainBuilder
	CreateChainFromRLifeline(msg rms.LRegisterRequest, responseProducer ProduceResponseFunc, checkFuncs ...CheckMessageFunc) ChainBuilder

	GetChainValidatorList() ChainValidatorList
}

func NewChecker

func NewChecker(t minimock.Tester) Builder

type ChainBuilder

type ChainBuilder interface {
	AddMessage(msg rms.LRegisterRequest, responseProducer ProduceResponseFunc, constraints ...CheckMessageFunc) ChainBuilder
	GetValidator() ChainValidator
	// GetReference returns reference that can be accessed only AFTER we've obtained message
	GetReference() rmsbox.ReferenceProvider
}

type ChainValidator

type ChainValidator interface {
	Feed(msg rms.LRegisterRequest) (ChainValidator, error)
	GetProduceResponseFunc() ProduceResponseFunc
	GetCheckMessageFuncs() []CheckMessageFunc
	IsFinished() bool
}

type ChainValidatorList

type ChainValidatorList interface {
	// Mocker describes common interface for all mocks generated by minimock
	minimock.Mocker

	IsFinished() bool
	GetChainValidatorByReference(objectRef reference.Global) ChainValidator
	GetChainValidatorByRLifeline(p pulse.Number, msg rms.LRegisterRequest) ChainValidator
}

type CheckMessageFunc

type CheckMessageFunc func(actualMsg rms.LRegisterRequest) error

type ProduceResponseFunc

type ProduceResponseFunc func(message rms.LRegisterRequest)

func ProduceResponse

func ProduceResponse(ctx context.Context, sender publisher.Sender) ProduceResponseFunc