logicrunner

package
v0.9.10 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2019 License: Apache-2.0 Imports: 44 Imported by: 0

Documentation

Overview

Package logicrunner - infrastructure for executing smartcontracts

Index

Constants

View Source 
const MaxFetchCount = 20

Variables

View Source 
var (
	ErrNotInPending     = errors.New("state is not in pending")
	ErrAlreadyExecuting = errors.New("already executing")
)
View Source 
var ErrCantExecute = errors.New("can't executeAndReply this object")
View Source 
var OutgoingRequestSenderDefaultGoroutineLimit = int32(5000)
View Source 
var OutgoingRequestSenderDefaultQueueLimit = 1000

Functions

func ProcessLogicalError added in v0.9.1 

func ProcessLogicalError(err error) bool

Types

type AddFreshRequest added in v0.9.0 

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

func (*AddFreshRequest) Proceed added in v0.9.0 

func (c *AddFreshRequest) Proceed(ctx context.Context) error

type AdditionalCallFromPreviousExecutor added in v0.9.0 

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

func (*AdditionalCallFromPreviousExecutor) Proceed added in v0.9.0 

func (p *AdditionalCallFromPreviousExecutor) Proceed(ctx context.Context) error

type CheckOurRole added in v0.9.0 

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

func (*CheckOurRole) Proceed added in v0.9.0 

func (ch *CheckOurRole) Proceed(ctx context.Context) error

type Dependencies added in v0.9.0 

type Dependencies struct {
	ArtifactManager  artifacts.Client
	Publisher        message.Publisher
	StateStorage     StateStorage
	ResultsMatcher   ResultMatcher
	Sender           bus.Sender
	JetStorage       jet.Storage
	JetCoordinator   jet.Coordinator
	WriteAccessor    writecontroller.Accessor
	OutgoingSender   OutgoingRequestSender
	RequestsExecutor RequestsExecutor
	PulseAccessor    pulse.Accessor
}

type ExecutionBroker added in v0.9.0 

type ExecutionBroker struct {
	Ref insolar.Reference

	PendingConfirmed     bool
	HasPendingCheckMutex sync.Mutex
	// contains filtered or unexported fields
}

func NewExecutionBroker added in v0.9.0 

func NewExecutionBroker(
	ref insolar.Reference,
	publisher watermillMsg.Publisher,
	requestsExecutor RequestsExecutor,
	sender bus.Sender,
	artifactsManager artifacts.Client,
	executionRegistry executionregistry.ExecutionRegistry,
	outgoingSender OutgoingRequestSender,
	pulseAccessor pulse.Accessor,
) *ExecutionBroker

func (*ExecutionBroker) AbandonedRequestsOnLedger added in v0.9.0 

func (q *ExecutionBroker) AbandonedRequestsOnLedger(ctx context.Context)

func (*ExecutionBroker) AddAdditionalRequestFromPrevExecutor added in v0.9.0 

func (q *ExecutionBroker) AddAdditionalRequestFromPrevExecutor(
	ctx context.Context, tr *common.Transcript,
)

func (*ExecutionBroker) AddFreshRequest added in v0.9.0 

func (q *ExecutionBroker) AddFreshRequest(
	ctx context.Context, tr *common.Transcript,
)

func (*ExecutionBroker) AddRequestsFromLedger added in v0.9.0 

func (q *ExecutionBroker) AddRequestsFromLedger(ctx context.Context, transcripts ...*common.Transcript)

func (*ExecutionBroker) AddRequestsFromPrevExecutor added in v0.9.0 

func (q *ExecutionBroker) AddRequestsFromPrevExecutor(ctx context.Context, transcripts ...*common.Transcript)

func (*ExecutionBroker) IsKnownRequest added in v0.9.0 

func (q *ExecutionBroker) IsKnownRequest(ctx context.Context, req insolar.Reference) bool

func (*ExecutionBroker) MoreRequestsOnLedger added in v0.9.0 

func (q *ExecutionBroker) MoreRequestsOnLedger(ctx context.Context)

func (*ExecutionBroker) NoMoreRequestsOnLedger added in v0.9.0 

func (q *ExecutionBroker) NoMoreRequestsOnLedger(ctx context.Context)

func (*ExecutionBroker) OnPulse added in v0.9.0 

func (q *ExecutionBroker) OnPulse(ctx context.Context) []payload.Payload

func (*ExecutionBroker) PendingState added in v0.9.0 

func (q *ExecutionBroker) PendingState() insolar.PendingState

func (*ExecutionBroker) PrevExecutorPendingResult added in v0.9.0 

func (q *ExecutionBroker) PrevExecutorPendingResult(ctx context.Context, prevExecState insolar.PendingState)

func (*ExecutionBroker) PrevExecutorSentPendingFinished added in v0.9.0 

func (q *ExecutionBroker) PrevExecutorSentPendingFinished(ctx context.Context) error

func (*ExecutionBroker) PrevExecutorStillExecuting added in v0.9.0 

func (q *ExecutionBroker) PrevExecutorStillExecuting(ctx context.Context) error

func (*ExecutionBroker) SetNotPending added in v0.9.0 

func (q *ExecutionBroker) SetNotPending(ctx context.Context)

type ExecutionBrokerI added in v0.9.0 

type ExecutionBrokerI interface {
	AddFreshRequest(ctx context.Context, transcript *common.Transcript)
	AddRequestsFromPrevExecutor(ctx context.Context, transcripts ...*common.Transcript)
	AddRequestsFromLedger(ctx context.Context, transcripts ...*common.Transcript)
	AddAdditionalRequestFromPrevExecutor(ctx context.Context, transcript *common.Transcript)

	PendingState() insolar.PendingState
	PrevExecutorStillExecuting(ctx context.Context) error
	PrevExecutorPendingResult(ctx context.Context, prevExecState insolar.PendingState)
	PrevExecutorSentPendingFinished(ctx context.Context) error
	SetNotPending(ctx context.Context)

	IsKnownRequest(ctx context.Context, req insolar.Reference) bool

	AbandonedRequestsOnLedger(ctx context.Context)
	MoreRequestsOnLedger(ctx context.Context)
	NoMoreRequestsOnLedger(ctx context.Context)

	OnPulse(ctx context.Context) []payload.Payload
}

type ExecutionBrokerIMock added in v0.9.0 

type ExecutionBrokerIMock struct {
	AbandonedRequestsOnLedgerMock mExecutionBrokerIMockAbandonedRequestsOnLedger

	AddAdditionalRequestFromPrevExecutorMock mExecutionBrokerIMockAddAdditionalRequestFromPrevExecutor

	AddFreshRequestMock mExecutionBrokerIMockAddFreshRequest

	AddRequestsFromLedgerMock mExecutionBrokerIMockAddRequestsFromLedger

	AddRequestsFromPrevExecutorMock mExecutionBrokerIMockAddRequestsFromPrevExecutor

	IsKnownRequestMock mExecutionBrokerIMockIsKnownRequest

	MoreRequestsOnLedgerMock mExecutionBrokerIMockMoreRequestsOnLedger

	NoMoreRequestsOnLedgerMock mExecutionBrokerIMockNoMoreRequestsOnLedger

	OnPulseMock mExecutionBrokerIMockOnPulse

	PendingStateMock mExecutionBrokerIMockPendingState

	PrevExecutorPendingResultMock mExecutionBrokerIMockPrevExecutorPendingResult

	PrevExecutorSentPendingFinishedMock mExecutionBrokerIMockPrevExecutorSentPendingFinished

	PrevExecutorStillExecutingMock mExecutionBrokerIMockPrevExecutorStillExecuting

	SetNotPendingMock mExecutionBrokerIMockSetNotPending
	// contains filtered or unexported fields
}

ExecutionBrokerIMock implements ExecutionBrokerI

func NewExecutionBrokerIMock added in v0.9.0 

func NewExecutionBrokerIMock(t minimock.Tester) *ExecutionBrokerIMock

NewExecutionBrokerIMock returns a mock for ExecutionBrokerI

func (*ExecutionBrokerIMock) AbandonedRequestsOnLedger added in v0.9.0 

func (mmAbandonedRequestsOnLedger *ExecutionBrokerIMock) AbandonedRequestsOnLedger(ctx context.Context)

AbandonedRequestsOnLedger implements ExecutionBrokerI

func (*ExecutionBrokerIMock) AbandonedRequestsOnLedgerAfterCounter added in v0.9.0 

func (mmAbandonedRequestsOnLedger *ExecutionBrokerIMock) AbandonedRequestsOnLedgerAfterCounter() uint64

AbandonedRequestsOnLedgerAfterCounter returns a count of finished ExecutionBrokerIMock.AbandonedRequestsOnLedger invocations

func (*ExecutionBrokerIMock) AbandonedRequestsOnLedgerBeforeCounter added in v0.9.0 

func (mmAbandonedRequestsOnLedger *ExecutionBrokerIMock) AbandonedRequestsOnLedgerBeforeCounter() uint64

AbandonedRequestsOnLedgerBeforeCounter returns a count of ExecutionBrokerIMock.AbandonedRequestsOnLedger invocations

func (*ExecutionBrokerIMock) AddAdditionalRequestFromPrevExecutor added in v0.9.0 

func (mmAddAdditionalRequestFromPrevExecutor *ExecutionBrokerIMock) AddAdditionalRequestFromPrevExecutor(ctx context.Context, transcript *common.Transcript)

AddAdditionalRequestFromPrevExecutor implements ExecutionBrokerI

func (*ExecutionBrokerIMock) AddAdditionalRequestFromPrevExecutorAfterCounter added in v0.9.0 

func (mmAddAdditionalRequestFromPrevExecutor *ExecutionBrokerIMock) AddAdditionalRequestFromPrevExecutorAfterCounter() uint64

AddAdditionalRequestFromPrevExecutorAfterCounter returns a count of finished ExecutionBrokerIMock.AddAdditionalRequestFromPrevExecutor invocations

func (*ExecutionBrokerIMock) AddAdditionalRequestFromPrevExecutorBeforeCounter added in v0.9.0 

func (mmAddAdditionalRequestFromPrevExecutor *ExecutionBrokerIMock) AddAdditionalRequestFromPrevExecutorBeforeCounter() uint64

AddAdditionalRequestFromPrevExecutorBeforeCounter returns a count of ExecutionBrokerIMock.AddAdditionalRequestFromPrevExecutor invocations

func (*ExecutionBrokerIMock) AddFreshRequest added in v0.9.0 

func (mmAddFreshRequest *ExecutionBrokerIMock) AddFreshRequest(ctx context.Context, transcript *common.Transcript)

AddFreshRequest implements ExecutionBrokerI

func (*ExecutionBrokerIMock) AddFreshRequestAfterCounter added in v0.9.0 

func (mmAddFreshRequest *ExecutionBrokerIMock) AddFreshRequestAfterCounter() uint64

AddFreshRequestAfterCounter returns a count of finished ExecutionBrokerIMock.AddFreshRequest invocations

func (*ExecutionBrokerIMock) AddFreshRequestBeforeCounter added in v0.9.0 

func (mmAddFreshRequest *ExecutionBrokerIMock) AddFreshRequestBeforeCounter() uint64

AddFreshRequestBeforeCounter returns a count of ExecutionBrokerIMock.AddFreshRequest invocations

func (*ExecutionBrokerIMock) AddRequestsFromLedger added in v0.9.0 

func (mmAddRequestsFromLedger *ExecutionBrokerIMock) AddRequestsFromLedger(ctx context.Context, transcripts ...*common.Transcript)

AddRequestsFromLedger implements ExecutionBrokerI

func (*ExecutionBrokerIMock) AddRequestsFromLedgerAfterCounter added in v0.9.0 

func (mmAddRequestsFromLedger *ExecutionBrokerIMock) AddRequestsFromLedgerAfterCounter() uint64

AddRequestsFromLedgerAfterCounter returns a count of finished ExecutionBrokerIMock.AddRequestsFromLedger invocations

func (*ExecutionBrokerIMock) AddRequestsFromLedgerBeforeCounter added in v0.9.0 

func (mmAddRequestsFromLedger *ExecutionBrokerIMock) AddRequestsFromLedgerBeforeCounter() uint64

AddRequestsFromLedgerBeforeCounter returns a count of ExecutionBrokerIMock.AddRequestsFromLedger invocations

func (*ExecutionBrokerIMock) AddRequestsFromPrevExecutor added in v0.9.0 

func (mmAddRequestsFromPrevExecutor *ExecutionBrokerIMock) AddRequestsFromPrevExecutor(ctx context.Context, transcripts ...*common.Transcript)

AddRequestsFromPrevExecutor implements ExecutionBrokerI

func (*ExecutionBrokerIMock) AddRequestsFromPrevExecutorAfterCounter added in v0.9.0 

func (mmAddRequestsFromPrevExecutor *ExecutionBrokerIMock) AddRequestsFromPrevExecutorAfterCounter() uint64

AddRequestsFromPrevExecutorAfterCounter returns a count of finished ExecutionBrokerIMock.AddRequestsFromPrevExecutor invocations

func (*ExecutionBrokerIMock) AddRequestsFromPrevExecutorBeforeCounter added in v0.9.0 

func (mmAddRequestsFromPrevExecutor *ExecutionBrokerIMock) AddRequestsFromPrevExecutorBeforeCounter() uint64

AddRequestsFromPrevExecutorBeforeCounter returns a count of ExecutionBrokerIMock.AddRequestsFromPrevExecutor invocations

func (*ExecutionBrokerIMock) IsKnownRequest added in v0.9.0 

func (mmIsKnownRequest *ExecutionBrokerIMock) IsKnownRequest(ctx context.Context, req insolar.Reference) (b1 bool)

IsKnownRequest implements ExecutionBrokerI

func (*ExecutionBrokerIMock) IsKnownRequestAfterCounter added in v0.9.0 

func (mmIsKnownRequest *ExecutionBrokerIMock) IsKnownRequestAfterCounter() uint64

IsKnownRequestAfterCounter returns a count of finished ExecutionBrokerIMock.IsKnownRequest invocations

func (*ExecutionBrokerIMock) IsKnownRequestBeforeCounter added in v0.9.0 

func (mmIsKnownRequest *ExecutionBrokerIMock) IsKnownRequestBeforeCounter() uint64

IsKnownRequestBeforeCounter returns a count of ExecutionBrokerIMock.IsKnownRequest invocations

func (*ExecutionBrokerIMock) MinimockAbandonedRequestsOnLedgerDone added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockAbandonedRequestsOnLedgerDone() bool

MinimockAbandonedRequestsOnLedgerDone returns true if the count of the AbandonedRequestsOnLedger invocations corresponds the number of defined expectations

func (*ExecutionBrokerIMock) MinimockAbandonedRequestsOnLedgerInspect added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockAbandonedRequestsOnLedgerInspect()

MinimockAbandonedRequestsOnLedgerInspect logs each unmet expectation

func (*ExecutionBrokerIMock) MinimockAddAdditionalRequestFromPrevExecutorDone added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockAddAdditionalRequestFromPrevExecutorDone() bool

MinimockAddAdditionalRequestFromPrevExecutorDone returns true if the count of the AddAdditionalRequestFromPrevExecutor invocations corresponds the number of defined expectations

func (*ExecutionBrokerIMock) MinimockAddAdditionalRequestFromPrevExecutorInspect added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockAddAdditionalRequestFromPrevExecutorInspect()

MinimockAddAdditionalRequestFromPrevExecutorInspect logs each unmet expectation

func (*ExecutionBrokerIMock) MinimockAddFreshRequestDone added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockAddFreshRequestDone() bool

MinimockAddFreshRequestDone returns true if the count of the AddFreshRequest invocations corresponds the number of defined expectations

func (*ExecutionBrokerIMock) MinimockAddFreshRequestInspect added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockAddFreshRequestInspect()

MinimockAddFreshRequestInspect logs each unmet expectation

func (*ExecutionBrokerIMock) MinimockAddRequestsFromLedgerDone added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockAddRequestsFromLedgerDone() bool

MinimockAddRequestsFromLedgerDone returns true if the count of the AddRequestsFromLedger invocations corresponds the number of defined expectations

func (*ExecutionBrokerIMock) MinimockAddRequestsFromLedgerInspect added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockAddRequestsFromLedgerInspect()

MinimockAddRequestsFromLedgerInspect logs each unmet expectation

func (*ExecutionBrokerIMock) MinimockAddRequestsFromPrevExecutorDone added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockAddRequestsFromPrevExecutorDone() bool

MinimockAddRequestsFromPrevExecutorDone returns true if the count of the AddRequestsFromPrevExecutor invocations corresponds the number of defined expectations

func (*ExecutionBrokerIMock) MinimockAddRequestsFromPrevExecutorInspect added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockAddRequestsFromPrevExecutorInspect()

MinimockAddRequestsFromPrevExecutorInspect logs each unmet expectation

func (*ExecutionBrokerIMock) MinimockFinish added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockFinish()

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

func (*ExecutionBrokerIMock) MinimockIsKnownRequestDone added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockIsKnownRequestDone() bool

MinimockIsKnownRequestDone returns true if the count of the IsKnownRequest invocations corresponds the number of defined expectations

func (*ExecutionBrokerIMock) MinimockIsKnownRequestInspect added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockIsKnownRequestInspect()

MinimockIsKnownRequestInspect logs each unmet expectation

func (*ExecutionBrokerIMock) MinimockMoreRequestsOnLedgerDone added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockMoreRequestsOnLedgerDone() bool

MinimockMoreRequestsOnLedgerDone returns true if the count of the MoreRequestsOnLedger invocations corresponds the number of defined expectations

func (*ExecutionBrokerIMock) MinimockMoreRequestsOnLedgerInspect added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockMoreRequestsOnLedgerInspect()

MinimockMoreRequestsOnLedgerInspect logs each unmet expectation

func (*ExecutionBrokerIMock) MinimockNoMoreRequestsOnLedgerDone added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockNoMoreRequestsOnLedgerDone() bool

MinimockNoMoreRequestsOnLedgerDone returns true if the count of the NoMoreRequestsOnLedger invocations corresponds the number of defined expectations

func (*ExecutionBrokerIMock) MinimockNoMoreRequestsOnLedgerInspect added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockNoMoreRequestsOnLedgerInspect()

MinimockNoMoreRequestsOnLedgerInspect logs each unmet expectation

func (*ExecutionBrokerIMock) MinimockOnPulseDone added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockOnPulseDone() bool

MinimockOnPulseDone returns true if the count of the OnPulse invocations corresponds the number of defined expectations

func (*ExecutionBrokerIMock) MinimockOnPulseInspect added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockOnPulseInspect()

MinimockOnPulseInspect logs each unmet expectation

func (*ExecutionBrokerIMock) MinimockPendingStateDone added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockPendingStateDone() bool

MinimockPendingStateDone returns true if the count of the PendingState invocations corresponds the number of defined expectations

func (*ExecutionBrokerIMock) MinimockPendingStateInspect added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockPendingStateInspect()

MinimockPendingStateInspect logs each unmet expectation

func (*ExecutionBrokerIMock) MinimockPrevExecutorPendingResultDone added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockPrevExecutorPendingResultDone() bool

MinimockPrevExecutorPendingResultDone returns true if the count of the PrevExecutorPendingResult invocations corresponds the number of defined expectations

func (*ExecutionBrokerIMock) MinimockPrevExecutorPendingResultInspect added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockPrevExecutorPendingResultInspect()

MinimockPrevExecutorPendingResultInspect logs each unmet expectation

func (*ExecutionBrokerIMock) MinimockPrevExecutorSentPendingFinishedDone added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockPrevExecutorSentPendingFinishedDone() bool

MinimockPrevExecutorSentPendingFinishedDone returns true if the count of the PrevExecutorSentPendingFinished invocations corresponds the number of defined expectations

func (*ExecutionBrokerIMock) MinimockPrevExecutorSentPendingFinishedInspect added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockPrevExecutorSentPendingFinishedInspect()

MinimockPrevExecutorSentPendingFinishedInspect logs each unmet expectation

func (*ExecutionBrokerIMock) MinimockPrevExecutorStillExecutingDone added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockPrevExecutorStillExecutingDone() bool

MinimockPrevExecutorStillExecutingDone returns true if the count of the PrevExecutorStillExecuting invocations corresponds the number of defined expectations

func (*ExecutionBrokerIMock) MinimockPrevExecutorStillExecutingInspect added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockPrevExecutorStillExecutingInspect()

MinimockPrevExecutorStillExecutingInspect logs each unmet expectation

func (*ExecutionBrokerIMock) MinimockSetNotPendingDone added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockSetNotPendingDone() bool

MinimockSetNotPendingDone returns true if the count of the SetNotPending invocations corresponds the number of defined expectations

func (*ExecutionBrokerIMock) MinimockSetNotPendingInspect added in v0.9.0 

func (m *ExecutionBrokerIMock) MinimockSetNotPendingInspect()

MinimockSetNotPendingInspect logs each unmet expectation

func (*ExecutionBrokerIMock) MinimockWait added in v0.9.0 

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

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

func (*ExecutionBrokerIMock) MoreRequestsOnLedger added in v0.9.0 

func (mmMoreRequestsOnLedger *ExecutionBrokerIMock) MoreRequestsOnLedger(ctx context.Context)

MoreRequestsOnLedger implements ExecutionBrokerI

func (*ExecutionBrokerIMock) MoreRequestsOnLedgerAfterCounter added in v0.9.0 

func (mmMoreRequestsOnLedger *ExecutionBrokerIMock) MoreRequestsOnLedgerAfterCounter() uint64

MoreRequestsOnLedgerAfterCounter returns a count of finished ExecutionBrokerIMock.MoreRequestsOnLedger invocations

func (*ExecutionBrokerIMock) MoreRequestsOnLedgerBeforeCounter added in v0.9.0 

func (mmMoreRequestsOnLedger *ExecutionBrokerIMock) MoreRequestsOnLedgerBeforeCounter() uint64

MoreRequestsOnLedgerBeforeCounter returns a count of ExecutionBrokerIMock.MoreRequestsOnLedger invocations

func (*ExecutionBrokerIMock) NoMoreRequestsOnLedger added in v0.9.0 

func (mmNoMoreRequestsOnLedger *ExecutionBrokerIMock) NoMoreRequestsOnLedger(ctx context.Context)

NoMoreRequestsOnLedger implements ExecutionBrokerI

func (*ExecutionBrokerIMock) NoMoreRequestsOnLedgerAfterCounter added in v0.9.0 

func (mmNoMoreRequestsOnLedger *ExecutionBrokerIMock) NoMoreRequestsOnLedgerAfterCounter() uint64

NoMoreRequestsOnLedgerAfterCounter returns a count of finished ExecutionBrokerIMock.NoMoreRequestsOnLedger invocations

func (*ExecutionBrokerIMock) NoMoreRequestsOnLedgerBeforeCounter added in v0.9.0 

func (mmNoMoreRequestsOnLedger *ExecutionBrokerIMock) NoMoreRequestsOnLedgerBeforeCounter() uint64

NoMoreRequestsOnLedgerBeforeCounter returns a count of ExecutionBrokerIMock.NoMoreRequestsOnLedger invocations

func (*ExecutionBrokerIMock) OnPulse added in v0.9.0 

func (mmOnPulse *ExecutionBrokerIMock) OnPulse(ctx context.Context) (pa1 []payload.Payload)

OnPulse implements ExecutionBrokerI

func (*ExecutionBrokerIMock) OnPulseAfterCounter added in v0.9.0 

func (mmOnPulse *ExecutionBrokerIMock) OnPulseAfterCounter() uint64

OnPulseAfterCounter returns a count of finished ExecutionBrokerIMock.OnPulse invocations

func (*ExecutionBrokerIMock) OnPulseBeforeCounter added in v0.9.0 

func (mmOnPulse *ExecutionBrokerIMock) OnPulseBeforeCounter() uint64

OnPulseBeforeCounter returns a count of ExecutionBrokerIMock.OnPulse invocations

func (*ExecutionBrokerIMock) PendingState added in v0.9.0 

func (mmPendingState *ExecutionBrokerIMock) PendingState() (p1 insolar.PendingState)

PendingState implements ExecutionBrokerI

func (*ExecutionBrokerIMock) PendingStateAfterCounter added in v0.9.0 

func (mmPendingState *ExecutionBrokerIMock) PendingStateAfterCounter() uint64

PendingStateAfterCounter returns a count of finished ExecutionBrokerIMock.PendingState invocations

func (*ExecutionBrokerIMock) PendingStateBeforeCounter added in v0.9.0 

func (mmPendingState *ExecutionBrokerIMock) PendingStateBeforeCounter() uint64

PendingStateBeforeCounter returns a count of ExecutionBrokerIMock.PendingState invocations

func (*ExecutionBrokerIMock) PrevExecutorPendingResult added in v0.9.0 

func (mmPrevExecutorPendingResult *ExecutionBrokerIMock) PrevExecutorPendingResult(ctx context.Context, prevExecState insolar.PendingState)

PrevExecutorPendingResult implements ExecutionBrokerI

func (*ExecutionBrokerIMock) PrevExecutorPendingResultAfterCounter added in v0.9.0 

func (mmPrevExecutorPendingResult *ExecutionBrokerIMock) PrevExecutorPendingResultAfterCounter() uint64

PrevExecutorPendingResultAfterCounter returns a count of finished ExecutionBrokerIMock.PrevExecutorPendingResult invocations

func (*ExecutionBrokerIMock) PrevExecutorPendingResultBeforeCounter added in v0.9.0 

func (mmPrevExecutorPendingResult *ExecutionBrokerIMock) PrevExecutorPendingResultBeforeCounter() uint64

PrevExecutorPendingResultBeforeCounter returns a count of ExecutionBrokerIMock.PrevExecutorPendingResult invocations

func (*ExecutionBrokerIMock) PrevExecutorSentPendingFinished added in v0.9.0 

func (mmPrevExecutorSentPendingFinished *ExecutionBrokerIMock) PrevExecutorSentPendingFinished(ctx context.Context) (err error)

PrevExecutorSentPendingFinished implements ExecutionBrokerI

func (*ExecutionBrokerIMock) PrevExecutorSentPendingFinishedAfterCounter added in v0.9.0 

func (mmPrevExecutorSentPendingFinished *ExecutionBrokerIMock) PrevExecutorSentPendingFinishedAfterCounter() uint64

PrevExecutorSentPendingFinishedAfterCounter returns a count of finished ExecutionBrokerIMock.PrevExecutorSentPendingFinished invocations

func (*ExecutionBrokerIMock) PrevExecutorSentPendingFinishedBeforeCounter added in v0.9.0 

func (mmPrevExecutorSentPendingFinished *ExecutionBrokerIMock) PrevExecutorSentPendingFinishedBeforeCounter() uint64

PrevExecutorSentPendingFinishedBeforeCounter returns a count of ExecutionBrokerIMock.PrevExecutorSentPendingFinished invocations

func (*ExecutionBrokerIMock) PrevExecutorStillExecuting added in v0.9.0 

func (mmPrevExecutorStillExecuting *ExecutionBrokerIMock) PrevExecutorStillExecuting(ctx context.Context) (err error)

PrevExecutorStillExecuting implements ExecutionBrokerI

func (*ExecutionBrokerIMock) PrevExecutorStillExecutingAfterCounter added in v0.9.0 

func (mmPrevExecutorStillExecuting *ExecutionBrokerIMock) PrevExecutorStillExecutingAfterCounter() uint64

PrevExecutorStillExecutingAfterCounter returns a count of finished ExecutionBrokerIMock.PrevExecutorStillExecuting invocations

func (*ExecutionBrokerIMock) PrevExecutorStillExecutingBeforeCounter added in v0.9.0 

func (mmPrevExecutorStillExecuting *ExecutionBrokerIMock) PrevExecutorStillExecutingBeforeCounter() uint64

PrevExecutorStillExecutingBeforeCounter returns a count of ExecutionBrokerIMock.PrevExecutorStillExecuting invocations

func (*ExecutionBrokerIMock) SetNotPending added in v0.9.0 

func (mmSetNotPending *ExecutionBrokerIMock) SetNotPending(ctx context.Context)

SetNotPending implements ExecutionBrokerI

func (*ExecutionBrokerIMock) SetNotPendingAfterCounter added in v0.9.0 

func (mmSetNotPending *ExecutionBrokerIMock) SetNotPendingAfterCounter() uint64

SetNotPendingAfterCounter returns a count of finished ExecutionBrokerIMock.SetNotPending invocations

func (*ExecutionBrokerIMock) SetNotPendingBeforeCounter added in v0.9.0 

func (mmSetNotPending *ExecutionBrokerIMock) SetNotPendingBeforeCounter() uint64

SetNotPendingBeforeCounter returns a count of ExecutionBrokerIMock.SetNotPending invocations

type ExecutionBrokerIMockAbandonedRequestsOnLedgerExpectation added in v0.9.0 

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

ExecutionBrokerIMockAbandonedRequestsOnLedgerExpectation specifies expectation struct of the ExecutionBrokerI.AbandonedRequestsOnLedger

type ExecutionBrokerIMockAbandonedRequestsOnLedgerParams added in v0.9.0 

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

ExecutionBrokerIMockAbandonedRequestsOnLedgerParams contains parameters of the ExecutionBrokerI.AbandonedRequestsOnLedger

type ExecutionBrokerIMockAddAdditionalRequestFromPrevExecutorExpectation added in v0.9.0 

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

ExecutionBrokerIMockAddAdditionalRequestFromPrevExecutorExpectation specifies expectation struct of the ExecutionBrokerI.AddAdditionalRequestFromPrevExecutor

type ExecutionBrokerIMockAddAdditionalRequestFromPrevExecutorParams added in v0.9.0 

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

ExecutionBrokerIMockAddAdditionalRequestFromPrevExecutorParams contains parameters of the ExecutionBrokerI.AddAdditionalRequestFromPrevExecutor

type ExecutionBrokerIMockAddFreshRequestExpectation added in v0.9.0 

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

ExecutionBrokerIMockAddFreshRequestExpectation specifies expectation struct of the ExecutionBrokerI.AddFreshRequest

type ExecutionBrokerIMockAddFreshRequestParams added in v0.9.0 

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

ExecutionBrokerIMockAddFreshRequestParams contains parameters of the ExecutionBrokerI.AddFreshRequest

type ExecutionBrokerIMockAddRequestsFromLedgerExpectation added in v0.9.0 

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

ExecutionBrokerIMockAddRequestsFromLedgerExpectation specifies expectation struct of the ExecutionBrokerI.AddRequestsFromLedger

type ExecutionBrokerIMockAddRequestsFromLedgerParams added in v0.9.0 

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

ExecutionBrokerIMockAddRequestsFromLedgerParams contains parameters of the ExecutionBrokerI.AddRequestsFromLedger

type ExecutionBrokerIMockAddRequestsFromPrevExecutorExpectation added in v0.9.0 

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

ExecutionBrokerIMockAddRequestsFromPrevExecutorExpectation specifies expectation struct of the ExecutionBrokerI.AddRequestsFromPrevExecutor

type ExecutionBrokerIMockAddRequestsFromPrevExecutorParams added in v0.9.0 

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

ExecutionBrokerIMockAddRequestsFromPrevExecutorParams contains parameters of the ExecutionBrokerI.AddRequestsFromPrevExecutor

type ExecutionBrokerIMockIsKnownRequestExpectation added in v0.9.0 

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

ExecutionBrokerIMockIsKnownRequestExpectation specifies expectation struct of the ExecutionBrokerI.IsKnownRequest

func (*ExecutionBrokerIMockIsKnownRequestExpectation) Then added in v0.9.0 

func (e *ExecutionBrokerIMockIsKnownRequestExpectation) Then(b1 bool) *ExecutionBrokerIMock

Then sets up ExecutionBrokerI.IsKnownRequest return parameters for the expectation previously defined by the When method

type ExecutionBrokerIMockIsKnownRequestParams added in v0.9.0 

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

ExecutionBrokerIMockIsKnownRequestParams contains parameters of the ExecutionBrokerI.IsKnownRequest

type ExecutionBrokerIMockIsKnownRequestResults added in v0.9.0 

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

ExecutionBrokerIMockIsKnownRequestResults contains results of the ExecutionBrokerI.IsKnownRequest

type ExecutionBrokerIMockMoreRequestsOnLedgerExpectation added in v0.9.0 

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

ExecutionBrokerIMockMoreRequestsOnLedgerExpectation specifies expectation struct of the ExecutionBrokerI.MoreRequestsOnLedger

type ExecutionBrokerIMockMoreRequestsOnLedgerParams added in v0.9.0 

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

ExecutionBrokerIMockMoreRequestsOnLedgerParams contains parameters of the ExecutionBrokerI.MoreRequestsOnLedger

type ExecutionBrokerIMockNoMoreRequestsOnLedgerExpectation added in v0.9.0 

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

ExecutionBrokerIMockNoMoreRequestsOnLedgerExpectation specifies expectation struct of the ExecutionBrokerI.NoMoreRequestsOnLedger

type ExecutionBrokerIMockNoMoreRequestsOnLedgerParams added in v0.9.0 

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

ExecutionBrokerIMockNoMoreRequestsOnLedgerParams contains parameters of the ExecutionBrokerI.NoMoreRequestsOnLedger

type ExecutionBrokerIMockOnPulseExpectation added in v0.9.0 

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

ExecutionBrokerIMockOnPulseExpectation specifies expectation struct of the ExecutionBrokerI.OnPulse

func (*ExecutionBrokerIMockOnPulseExpectation) Then added in v0.9.0 

func (e *ExecutionBrokerIMockOnPulseExpectation) Then(pa1 []payload.Payload) *ExecutionBrokerIMock

Then sets up ExecutionBrokerI.OnPulse return parameters for the expectation previously defined by the When method

type ExecutionBrokerIMockOnPulseParams added in v0.9.0 

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

ExecutionBrokerIMockOnPulseParams contains parameters of the ExecutionBrokerI.OnPulse

type ExecutionBrokerIMockOnPulseResults added in v0.9.0 

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

ExecutionBrokerIMockOnPulseResults contains results of the ExecutionBrokerI.OnPulse

type ExecutionBrokerIMockPendingStateExpectation added in v0.9.0 

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

ExecutionBrokerIMockPendingStateExpectation specifies expectation struct of the ExecutionBrokerI.PendingState

type ExecutionBrokerIMockPendingStateResults added in v0.9.0 

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

ExecutionBrokerIMockPendingStateResults contains results of the ExecutionBrokerI.PendingState

type ExecutionBrokerIMockPrevExecutorPendingResultExpectation added in v0.9.0 

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

ExecutionBrokerIMockPrevExecutorPendingResultExpectation specifies expectation struct of the ExecutionBrokerI.PrevExecutorPendingResult

type ExecutionBrokerIMockPrevExecutorPendingResultParams added in v0.9.0 

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

ExecutionBrokerIMockPrevExecutorPendingResultParams contains parameters of the ExecutionBrokerI.PrevExecutorPendingResult

type ExecutionBrokerIMockPrevExecutorSentPendingFinishedExpectation added in v0.9.0 

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

ExecutionBrokerIMockPrevExecutorSentPendingFinishedExpectation specifies expectation struct of the ExecutionBrokerI.PrevExecutorSentPendingFinished

func (*ExecutionBrokerIMockPrevExecutorSentPendingFinishedExpectation) Then added in v0.9.0 

func (e *ExecutionBrokerIMockPrevExecutorSentPendingFinishedExpectation) Then(err error) *ExecutionBrokerIMock

Then sets up ExecutionBrokerI.PrevExecutorSentPendingFinished return parameters for the expectation previously defined by the When method

type ExecutionBrokerIMockPrevExecutorSentPendingFinishedParams added in v0.9.0 

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

ExecutionBrokerIMockPrevExecutorSentPendingFinishedParams contains parameters of the ExecutionBrokerI.PrevExecutorSentPendingFinished

type ExecutionBrokerIMockPrevExecutorSentPendingFinishedResults added in v0.9.0 

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

ExecutionBrokerIMockPrevExecutorSentPendingFinishedResults contains results of the ExecutionBrokerI.PrevExecutorSentPendingFinished

type ExecutionBrokerIMockPrevExecutorStillExecutingExpectation added in v0.9.0 

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

ExecutionBrokerIMockPrevExecutorStillExecutingExpectation specifies expectation struct of the ExecutionBrokerI.PrevExecutorStillExecuting

func (*ExecutionBrokerIMockPrevExecutorStillExecutingExpectation) Then added in v0.9.5 

func (e *ExecutionBrokerIMockPrevExecutorStillExecutingExpectation) Then(err error) *ExecutionBrokerIMock

Then sets up ExecutionBrokerI.PrevExecutorStillExecuting return parameters for the expectation previously defined by the When method

type ExecutionBrokerIMockPrevExecutorStillExecutingParams added in v0.9.0 

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

ExecutionBrokerIMockPrevExecutorStillExecutingParams contains parameters of the ExecutionBrokerI.PrevExecutorStillExecuting

type ExecutionBrokerIMockPrevExecutorStillExecutingResults added in v0.9.5 

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

ExecutionBrokerIMockPrevExecutorStillExecutingResults contains results of the ExecutionBrokerI.PrevExecutorStillExecuting

type ExecutionBrokerIMockSetNotPendingExpectation added in v0.9.0 

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

ExecutionBrokerIMockSetNotPendingExpectation specifies expectation struct of the ExecutionBrokerI.SetNotPending

type ExecutionBrokerIMockSetNotPendingParams added in v0.9.0 

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

ExecutionBrokerIMockSetNotPendingParams contains parameters of the ExecutionBrokerI.SetNotPending

type HandleAbandonedRequestsNotification added in v0.9.0 

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

func (*HandleAbandonedRequestsNotification) Present added in v0.9.0 

func (h *HandleAbandonedRequestsNotification) Present(ctx context.Context, f flow.Flow) error

type HandleAdditionalCallFromPreviousExecutor added in v0.9.0 

type HandleAdditionalCallFromPreviousExecutor struct {
	Message payload.Meta
	// contains filtered or unexported fields
}

func (*HandleAdditionalCallFromPreviousExecutor) Present added in v0.9.0 

func (h *HandleAdditionalCallFromPreviousExecutor) Present(ctx context.Context, f flow.Flow) error

Please note that currently we lack any fraud detection here. Ideally we should check that the previous executor was really an executor during previous pulse, that the request was really registered, etc. Also we don't handle case when pulse changes during execution of this handle. In this scenario user is in a bad luck. The request will be lost and user will have to re-send it after some timeout.

type HandleCall added in v0.9.0 

type HandleCall struct {
	Message payload.Meta
	// contains filtered or unexported fields
}

func (*HandleCall) Present added in v0.9.0 

func (h *HandleCall) Present(ctx context.Context, f flow.Flow) error

type HandleExecutorResults added in v0.9.0 

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

func (*HandleExecutorResults) Present added in v0.9.0 

func (h *HandleExecutorResults) Present(ctx context.Context, f flow.Flow) error

type HandlePendingFinished added in v0.9.0 

type HandlePendingFinished struct {
	Message payload.Meta
	// contains filtered or unexported fields
}

func (*HandlePendingFinished) Present added in v0.9.0 

func (h *HandlePendingFinished) Present(ctx context.Context, _ flow.Flow) error

type HandleSagaCallAcceptNotification added in v0.9.0 

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

func (*HandleSagaCallAcceptNotification) Present added in v0.9.0 

func (h *HandleSagaCallAcceptNotification) Present(ctx context.Context, f flow.Flow) error

type HandleStillExecuting added in v0.9.0 

type HandleStillExecuting struct {
	Message payload.Meta
	// contains filtered or unexported fields
}

func (*HandleStillExecuting) Present added in v0.9.0 

func (h *HandleStillExecuting) Present(ctx context.Context, f flow.Flow) error

type HandleUpdateJet added in v0.9.0 

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

func (*HandleUpdateJet) Present added in v0.9.0 

func (h *HandleUpdateJet) Present(ctx context.Context, _ flow.Flow) error

type Init added in v0.9.0 

type Init struct {
	Message *message.Message
	// contains filtered or unexported fields
}

func (*Init) Future added in v0.9.0 

func (s *Init) Future(ctx context.Context, f flow.Flow) error

func (*Init) Past added in v0.9.0 

func (s *Init) Past(ctx context.Context, f flow.Flow) error

func (*Init) Present added in v0.9.0 

func (s *Init) Present(ctx context.Context, f flow.Flow) error

type LogicRunner 

type LogicRunner struct {
	ContractRequester          insolar.ContractRequester          `inject:""`
	PlatformCryptographyScheme insolar.PlatformCryptographyScheme `inject:""`
	PulseAccessor              insolarPulse.Accessor              `inject:""`
	ArtifactManager            artifacts.Client                   `inject:""`
	DescriptorsCache           artifacts.DescriptorsCache         `inject:""`
	JetCoordinator             jet.Coordinator                    `inject:""`
	RequestsExecutor           RequestsExecutor                   `inject:""`
	MachinesManager            machinesmanager.MachinesManager    `inject:""`
	JetStorage                 jet.Storage                        `inject:""`
	Publisher                  watermillMsg.Publisher
	Sender                     bus.Sender
	SenderWithRetry            *bus.WaitOKSender
	StateStorage               StateStorage
	ResultsMatcher             ResultMatcher
	OutgoingSender             OutgoingRequestSender
	WriteController            writecontroller.WriteController
	FlowDispatcher             dispatcher.Dispatcher
	ShutdownFlag               shutdown.Flag

	Cfg *configuration.LogicRunner
	// contains filtered or unexported fields
}

LogicRunner is a general interface of contract executor

func NewLogicRunner added in v0.0.3 

func NewLogicRunner(cfg *configuration.LogicRunner, publisher watermillMsg.Publisher, sender bus.Sender) (*LogicRunner, error)

NewLogicRunner is constructor for LogicRunner

func (*LogicRunner) AddUnwantedResponse added in v0.9.0 

func (lr *LogicRunner) AddUnwantedResponse(ctx context.Context, msg insolar.Payload) error

func (*LogicRunner) GracefulStop added in v0.9.0 

func (lr *LogicRunner) GracefulStop(ctx context.Context) error

func (*LogicRunner) Init added in v0.9.0 

func (lr *LogicRunner) Init(ctx context.Context) error

func (*LogicRunner) LRI added in v0.9.0 

func (lr *LogicRunner) LRI()

func (*LogicRunner) OnPulse added in v0.4.0 

func (lr *LogicRunner) OnPulse(ctx context.Context, oldPulse insolar.Pulse, newPulse insolar.Pulse) error

func (*LogicRunner) Start 

func (lr *LogicRunner) Start(ctx context.Context) error

Start starts logic runner component

func (*LogicRunner) Stop 

func (lr *LogicRunner) Stop(ctx context.Context) error

Stop stops logic runner component and its executors

type OutgoingRequestSender added in v0.9.0 

type OutgoingRequestSender interface {
	SendOutgoingRequest(ctx context.Context, reqRef insolar.Reference, req *record.OutgoingRequest) (*insolar.Reference, insolar.Arguments, *record.IncomingRequest, error)
	SendAbandonedOutgoingRequest(ctx context.Context, reqRef insolar.Reference, req *record.OutgoingRequest)
	Stop(ctx context.Context)
}

OutgoingRequestSender is a type-safe wrapper for an actor implementation. Currently OutgoingRequestSender is implemented as a pair of actors. OutgoingSenderActor is responsible for sending regular outgoing requests and AbandonedSenderActor is responsible for sending abandoned requests. Generally we want to limit the number of outgoing requests, i.e. use some sort of queue. While this is easy for abandoned requests it's a bit tricky for regular requests (see comments below). Also generally speaking a synchronous abandoned request can create new outgoing requests which may cause a deadlock situation when a single actor is responsible for both types of messages. This is why two actors are used with two independent queues and their logic differs a little.

func NewOutgoingRequestSender added in v0.9.0 

func NewOutgoingRequestSender(as actor.System, cr insolar.ContractRequester, am artifacts.Client, pa pulse.Accessor) OutgoingRequestSender

type OutgoingRequestSenderMock added in v0.9.0 

type OutgoingRequestSenderMock struct {
	SendAbandonedOutgoingRequestMock mOutgoingRequestSenderMockSendAbandonedOutgoingRequest

	SendOutgoingRequestMock mOutgoingRequestSenderMockSendOutgoingRequest

	StopMock mOutgoingRequestSenderMockStop
	// contains filtered or unexported fields
}

OutgoingRequestSenderMock implements OutgoingRequestSender

func NewOutgoingRequestSenderMock added in v0.9.0 

func NewOutgoingRequestSenderMock(t minimock.Tester) *OutgoingRequestSenderMock

NewOutgoingRequestSenderMock returns a mock for OutgoingRequestSender

func (*OutgoingRequestSenderMock) MinimockFinish added in v0.9.0 

func (m *OutgoingRequestSenderMock) MinimockFinish()

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

func (*OutgoingRequestSenderMock) MinimockSendAbandonedOutgoingRequestDone added in v0.9.0 

func (m *OutgoingRequestSenderMock) MinimockSendAbandonedOutgoingRequestDone() bool

MinimockSendAbandonedOutgoingRequestDone returns true if the count of the SendAbandonedOutgoingRequest invocations corresponds the number of defined expectations

func (*OutgoingRequestSenderMock) MinimockSendAbandonedOutgoingRequestInspect added in v0.9.0 

func (m *OutgoingRequestSenderMock) MinimockSendAbandonedOutgoingRequestInspect()

MinimockSendAbandonedOutgoingRequestInspect logs each unmet expectation

func (*OutgoingRequestSenderMock) MinimockSendOutgoingRequestDone added in v0.9.0 

func (m *OutgoingRequestSenderMock) MinimockSendOutgoingRequestDone() bool

MinimockSendOutgoingRequestDone returns true if the count of the SendOutgoingRequest invocations corresponds the number of defined expectations

func (*OutgoingRequestSenderMock) MinimockSendOutgoingRequestInspect added in v0.9.0 

func (m *OutgoingRequestSenderMock) MinimockSendOutgoingRequestInspect()

MinimockSendOutgoingRequestInspect logs each unmet expectation

func (*OutgoingRequestSenderMock) MinimockStopDone added in v0.9.0 

func (m *OutgoingRequestSenderMock) MinimockStopDone() bool

MinimockStopDone returns true if the count of the Stop invocations corresponds the number of defined expectations

func (*OutgoingRequestSenderMock) MinimockStopInspect added in v0.9.0 

func (m *OutgoingRequestSenderMock) MinimockStopInspect()

MinimockStopInspect logs each unmet expectation

func (*OutgoingRequestSenderMock) MinimockWait added in v0.9.0 

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

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

func (*OutgoingRequestSenderMock) SendAbandonedOutgoingRequest added in v0.9.0 

func (mmSendAbandonedOutgoingRequest *OutgoingRequestSenderMock) SendAbandonedOutgoingRequest(ctx context.Context, reqRef insolar.Reference, req *record.OutgoingRequest)

SendAbandonedOutgoingRequest implements OutgoingRequestSender

func (*OutgoingRequestSenderMock) SendAbandonedOutgoingRequestAfterCounter added in v0.9.0 

func (mmSendAbandonedOutgoingRequest *OutgoingRequestSenderMock) SendAbandonedOutgoingRequestAfterCounter() uint64

SendAbandonedOutgoingRequestAfterCounter returns a count of finished OutgoingRequestSenderMock.SendAbandonedOutgoingRequest invocations

func (*OutgoingRequestSenderMock) SendAbandonedOutgoingRequestBeforeCounter added in v0.9.0 

func (mmSendAbandonedOutgoingRequest *OutgoingRequestSenderMock) SendAbandonedOutgoingRequestBeforeCounter() uint64

SendAbandonedOutgoingRequestBeforeCounter returns a count of OutgoingRequestSenderMock.SendAbandonedOutgoingRequest invocations

func (*OutgoingRequestSenderMock) SendOutgoingRequest added in v0.9.0 

func (mmSendOutgoingRequest *OutgoingRequestSenderMock) SendOutgoingRequest(ctx context.Context, reqRef insolar.Reference, req *record.OutgoingRequest) (rp1 *insolar.Reference, a1 insolar.Arguments, ip1 *record.IncomingRequest, err error)

SendOutgoingRequest implements OutgoingRequestSender

func (*OutgoingRequestSenderMock) SendOutgoingRequestAfterCounter added in v0.9.0 

func (mmSendOutgoingRequest *OutgoingRequestSenderMock) SendOutgoingRequestAfterCounter() uint64

SendOutgoingRequestAfterCounter returns a count of finished OutgoingRequestSenderMock.SendOutgoingRequest invocations

func (*OutgoingRequestSenderMock) SendOutgoingRequestBeforeCounter added in v0.9.0 

func (mmSendOutgoingRequest *OutgoingRequestSenderMock) SendOutgoingRequestBeforeCounter() uint64

SendOutgoingRequestBeforeCounter returns a count of OutgoingRequestSenderMock.SendOutgoingRequest invocations

func (*OutgoingRequestSenderMock) Stop added in v0.9.0 

func (mmStop *OutgoingRequestSenderMock) Stop(ctx context.Context)

Stop implements OutgoingRequestSender

func (*OutgoingRequestSenderMock) StopAfterCounter added in v0.9.0 

func (mmStop *OutgoingRequestSenderMock) StopAfterCounter() uint64

StopAfterCounter returns a count of finished OutgoingRequestSenderMock.Stop invocations

func (*OutgoingRequestSenderMock) StopBeforeCounter added in v0.9.0 

func (mmStop *OutgoingRequestSenderMock) StopBeforeCounter() uint64

StopBeforeCounter returns a count of OutgoingRequestSenderMock.Stop invocations

type OutgoingRequestSenderMockSendAbandonedOutgoingRequestExpectation added in v0.9.0 

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

OutgoingRequestSenderMockSendAbandonedOutgoingRequestExpectation specifies expectation struct of the OutgoingRequestSender.SendAbandonedOutgoingRequest

type OutgoingRequestSenderMockSendAbandonedOutgoingRequestParams added in v0.9.0 

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

OutgoingRequestSenderMockSendAbandonedOutgoingRequestParams contains parameters of the OutgoingRequestSender.SendAbandonedOutgoingRequest

type OutgoingRequestSenderMockSendOutgoingRequestExpectation added in v0.9.0 

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

OutgoingRequestSenderMockSendOutgoingRequestExpectation specifies expectation struct of the OutgoingRequestSender.SendOutgoingRequest

func (*OutgoingRequestSenderMockSendOutgoingRequestExpectation) Then added in v0.9.0 

func (e *OutgoingRequestSenderMockSendOutgoingRequestExpectation) Then(rp1 *insolar.Reference, a1 insolar.Arguments, ip1 *record.IncomingRequest, err error) *OutgoingRequestSenderMock

Then sets up OutgoingRequestSender.SendOutgoingRequest return parameters for the expectation previously defined by the When method

type OutgoingRequestSenderMockSendOutgoingRequestParams added in v0.9.0 

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

OutgoingRequestSenderMockSendOutgoingRequestParams contains parameters of the OutgoingRequestSender.SendOutgoingRequest

type OutgoingRequestSenderMockSendOutgoingRequestResults added in v0.9.0 

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

OutgoingRequestSenderMockSendOutgoingRequestResults contains results of the OutgoingRequestSender.SendOutgoingRequest

type OutgoingRequestSenderMockStopExpectation added in v0.9.0 

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

OutgoingRequestSenderMockStopExpectation specifies expectation struct of the OutgoingRequestSender.Stop

type OutgoingRequestSenderMockStopParams added in v0.9.0 

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

OutgoingRequestSenderMockStopParams contains parameters of the OutgoingRequestSender.Stop

type ProxyImplementation added in v0.9.0 

type ProxyImplementation interface {
	GetCode(context.Context, *common.Transcript, rpctypes.UpGetCodeReq, *rpctypes.UpGetCodeResp) error
	RouteCall(context.Context, *common.Transcript, rpctypes.UpRouteReq, *rpctypes.UpRouteResp) error
	SaveAsChild(context.Context, *common.Transcript, rpctypes.UpSaveAsChildReq, *rpctypes.UpSaveAsChildResp) error
	DeactivateObject(context.Context, *common.Transcript, rpctypes.UpDeactivateObjectReq, *rpctypes.UpDeactivateObjectResp) error
}

func NewExecutionProxyImplementation added in v0.9.0 

func NewExecutionProxyImplementation(
	dc artifacts.DescriptorsCache,
	cr insolar.ContractRequester,
	am artifacts.Client,
	outgoingSender OutgoingRequestSender,
) ProxyImplementation

func NewValidationProxyImplementation added in v0.9.0 

func NewValidationProxyImplementation(
	dc artifacts.DescriptorsCache,
) ProxyImplementation

type ProxyImplementationMock added in v0.9.0 

type ProxyImplementationMock struct {
	DeactivateObjectMock mProxyImplementationMockDeactivateObject

	GetCodeMock mProxyImplementationMockGetCode

	RouteCallMock mProxyImplementationMockRouteCall

	SaveAsChildMock mProxyImplementationMockSaveAsChild
	// contains filtered or unexported fields
}

ProxyImplementationMock implements ProxyImplementation

func NewProxyImplementationMock added in v0.9.0 

func NewProxyImplementationMock(t minimock.Tester) *ProxyImplementationMock

NewProxyImplementationMock returns a mock for ProxyImplementation

func (*ProxyImplementationMock) DeactivateObject added in v0.9.0 

func (mmDeactivateObject *ProxyImplementationMock) DeactivateObject(ctx context.Context, tp1 *common.Transcript, u1 rpctypes.UpDeactivateObjectReq, up1 *rpctypes.UpDeactivateObjectResp) (err error)

DeactivateObject implements ProxyImplementation

func (*ProxyImplementationMock) DeactivateObjectAfterCounter added in v0.9.0 

func (mmDeactivateObject *ProxyImplementationMock) DeactivateObjectAfterCounter() uint64

DeactivateObjectAfterCounter returns a count of finished ProxyImplementationMock.DeactivateObject invocations

func (*ProxyImplementationMock) DeactivateObjectBeforeCounter added in v0.9.0 

func (mmDeactivateObject *ProxyImplementationMock) DeactivateObjectBeforeCounter() uint64

DeactivateObjectBeforeCounter returns a count of ProxyImplementationMock.DeactivateObject invocations

func (*ProxyImplementationMock) GetCode added in v0.9.0 

func (mmGetCode *ProxyImplementationMock) GetCode(ctx context.Context, tp1 *common.Transcript, u1 rpctypes.UpGetCodeReq, up1 *rpctypes.UpGetCodeResp) (err error)

GetCode implements ProxyImplementation

func (*ProxyImplementationMock) GetCodeAfterCounter added in v0.9.0 

func (mmGetCode *ProxyImplementationMock) GetCodeAfterCounter() uint64

GetCodeAfterCounter returns a count of finished ProxyImplementationMock.GetCode invocations

func (*ProxyImplementationMock) GetCodeBeforeCounter added in v0.9.0 

func (mmGetCode *ProxyImplementationMock) GetCodeBeforeCounter() uint64

GetCodeBeforeCounter returns a count of ProxyImplementationMock.GetCode invocations

func (*ProxyImplementationMock) MinimockDeactivateObjectDone added in v0.9.0 

func (m *ProxyImplementationMock) MinimockDeactivateObjectDone() bool

MinimockDeactivateObjectDone returns true if the count of the DeactivateObject invocations corresponds the number of defined expectations

func (*ProxyImplementationMock) MinimockDeactivateObjectInspect added in v0.9.0 

func (m *ProxyImplementationMock) MinimockDeactivateObjectInspect()

MinimockDeactivateObjectInspect logs each unmet expectation

func (*ProxyImplementationMock) MinimockFinish added in v0.9.0 

func (m *ProxyImplementationMock) MinimockFinish()

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

func (*ProxyImplementationMock) MinimockGetCodeDone added in v0.9.0 

func (m *ProxyImplementationMock) MinimockGetCodeDone() bool

MinimockGetCodeDone returns true if the count of the GetCode invocations corresponds the number of defined expectations

func (*ProxyImplementationMock) MinimockGetCodeInspect added in v0.9.0 

func (m *ProxyImplementationMock) MinimockGetCodeInspect()

MinimockGetCodeInspect logs each unmet expectation

func (*ProxyImplementationMock) MinimockRouteCallDone added in v0.9.0 

func (m *ProxyImplementationMock) MinimockRouteCallDone() bool

MinimockRouteCallDone returns true if the count of the RouteCall invocations corresponds the number of defined expectations

func (*ProxyImplementationMock) MinimockRouteCallInspect added in v0.9.0 

func (m *ProxyImplementationMock) MinimockRouteCallInspect()

MinimockRouteCallInspect logs each unmet expectation

func (*ProxyImplementationMock) MinimockSaveAsChildDone added in v0.9.0 

func (m *ProxyImplementationMock) MinimockSaveAsChildDone() bool

MinimockSaveAsChildDone returns true if the count of the SaveAsChild invocations corresponds the number of defined expectations

func (*ProxyImplementationMock) MinimockSaveAsChildInspect added in v0.9.0 

func (m *ProxyImplementationMock) MinimockSaveAsChildInspect()

MinimockSaveAsChildInspect logs each unmet expectation

func (*ProxyImplementationMock) MinimockWait added in v0.9.0 

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

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

func (*ProxyImplementationMock) RouteCall added in v0.9.0 

func (mmRouteCall *ProxyImplementationMock) RouteCall(ctx context.Context, tp1 *common.Transcript, u1 rpctypes.UpRouteReq, up1 *rpctypes.UpRouteResp) (err error)

RouteCall implements ProxyImplementation

func (*ProxyImplementationMock) RouteCallAfterCounter added in v0.9.0 

func (mmRouteCall *ProxyImplementationMock) RouteCallAfterCounter() uint64

RouteCallAfterCounter returns a count of finished ProxyImplementationMock.RouteCall invocations

func (*ProxyImplementationMock) RouteCallBeforeCounter added in v0.9.0 

func (mmRouteCall *ProxyImplementationMock) RouteCallBeforeCounter() uint64

RouteCallBeforeCounter returns a count of ProxyImplementationMock.RouteCall invocations

func (*ProxyImplementationMock) SaveAsChild added in v0.9.0 

func (mmSaveAsChild *ProxyImplementationMock) SaveAsChild(ctx context.Context, tp1 *common.Transcript, u1 rpctypes.UpSaveAsChildReq, up1 *rpctypes.UpSaveAsChildResp) (err error)

SaveAsChild implements ProxyImplementation

func (*ProxyImplementationMock) SaveAsChildAfterCounter added in v0.9.0 

func (mmSaveAsChild *ProxyImplementationMock) SaveAsChildAfterCounter() uint64

SaveAsChildAfterCounter returns a count of finished ProxyImplementationMock.SaveAsChild invocations

func (*ProxyImplementationMock) SaveAsChildBeforeCounter added in v0.9.0 

func (mmSaveAsChild *ProxyImplementationMock) SaveAsChildBeforeCounter() uint64

SaveAsChildBeforeCounter returns a count of ProxyImplementationMock.SaveAsChild invocations

type ProxyImplementationMockDeactivateObjectExpectation added in v0.9.0 

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

ProxyImplementationMockDeactivateObjectExpectation specifies expectation struct of the ProxyImplementation.DeactivateObject

func (*ProxyImplementationMockDeactivateObjectExpectation) Then added in v0.9.0 

func (e *ProxyImplementationMockDeactivateObjectExpectation) Then(err error) *ProxyImplementationMock

Then sets up ProxyImplementation.DeactivateObject return parameters for the expectation previously defined by the When method

type ProxyImplementationMockDeactivateObjectParams added in v0.9.0 

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

ProxyImplementationMockDeactivateObjectParams contains parameters of the ProxyImplementation.DeactivateObject

type ProxyImplementationMockDeactivateObjectResults added in v0.9.0 

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

ProxyImplementationMockDeactivateObjectResults contains results of the ProxyImplementation.DeactivateObject

type ProxyImplementationMockGetCodeExpectation added in v0.9.0 

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

ProxyImplementationMockGetCodeExpectation specifies expectation struct of the ProxyImplementation.GetCode

func (*ProxyImplementationMockGetCodeExpectation) Then added in v0.9.0 

func (e *ProxyImplementationMockGetCodeExpectation) Then(err error) *ProxyImplementationMock

Then sets up ProxyImplementation.GetCode return parameters for the expectation previously defined by the When method

type ProxyImplementationMockGetCodeParams added in v0.9.0 

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

ProxyImplementationMockGetCodeParams contains parameters of the ProxyImplementation.GetCode

type ProxyImplementationMockGetCodeResults added in v0.9.0 

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

ProxyImplementationMockGetCodeResults contains results of the ProxyImplementation.GetCode

type ProxyImplementationMockRouteCallExpectation added in v0.9.0 

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

ProxyImplementationMockRouteCallExpectation specifies expectation struct of the ProxyImplementation.RouteCall

func (*ProxyImplementationMockRouteCallExpectation) Then added in v0.9.0 

func (e *ProxyImplementationMockRouteCallExpectation) Then(err error) *ProxyImplementationMock

Then sets up ProxyImplementation.RouteCall return parameters for the expectation previously defined by the When method

type ProxyImplementationMockRouteCallParams added in v0.9.0 

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

ProxyImplementationMockRouteCallParams contains parameters of the ProxyImplementation.RouteCall

type ProxyImplementationMockRouteCallResults added in v0.9.0 

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

ProxyImplementationMockRouteCallResults contains results of the ProxyImplementation.RouteCall

type ProxyImplementationMockSaveAsChildExpectation added in v0.9.0 

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

ProxyImplementationMockSaveAsChildExpectation specifies expectation struct of the ProxyImplementation.SaveAsChild

func (*ProxyImplementationMockSaveAsChildExpectation) Then added in v0.9.0 

func (e *ProxyImplementationMockSaveAsChildExpectation) Then(err error) *ProxyImplementationMock

Then sets up ProxyImplementation.SaveAsChild return parameters for the expectation previously defined by the When method

type ProxyImplementationMockSaveAsChildParams added in v0.9.0 

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

ProxyImplementationMockSaveAsChildParams contains parameters of the ProxyImplementation.SaveAsChild

type ProxyImplementationMockSaveAsChildResults added in v0.9.0 

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

ProxyImplementationMockSaveAsChildResults contains results of the ProxyImplementation.SaveAsChild

type RPCMethods added in v0.9.0 

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

func NewRPCMethods added in v0.9.0 

func NewRPCMethods(
	am artifacts.Client,
	dc artifacts.DescriptorsCache,
	cr insolar.ContractRequester,
	ss StateStorage,
	outgoingSender OutgoingRequestSender,
) *RPCMethods

func (*RPCMethods) DeactivateObject added in v0.9.0 

func (m *RPCMethods) DeactivateObject(req rpctypes.UpDeactivateObjectReq, rep *rpctypes.UpDeactivateObjectResp) error

DeactivateObject is an RPC saving data as memory of a contract as child a parent

func (*RPCMethods) GetCode added in v0.9.0 

func (m *RPCMethods) GetCode(req rpctypes.UpGetCodeReq, rep *rpctypes.UpGetCodeResp) error

GetCode is an RPC retrieving a code by its reference

func (*RPCMethods) RouteCall added in v0.9.0 

func (m *RPCMethods) RouteCall(req rpctypes.UpRouteReq, rep *rpctypes.UpRouteResp) error

RouteCall routes call from a contract to a contract through event bus.

func (*RPCMethods) SaveAsChild added in v0.9.0 

func (m *RPCMethods) SaveAsChild(req rpctypes.UpSaveAsChildReq, rep *rpctypes.UpSaveAsChildResp) error

SaveAsChild is an RPC saving data as memory of a contract as child a parent

type RecordErrorResult added in v0.9.0 

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

func (*RecordErrorResult) Proceed added in v0.9.0 

func (r *RecordErrorResult) Proceed(ctx context.Context) error

type RegisterIncomingRequest added in v0.9.0 

type RegisterIncomingRequest struct {
	ArtifactManager artifacts.Client
	// contains filtered or unexported fields
}

func NewRegisterIncomingRequest added in v0.9.0 

func NewRegisterIncomingRequest(request record.IncomingRequest, dep *Dependencies) *RegisterIncomingRequest

func (*RegisterIncomingRequest) Proceed added in v0.9.0 

func (r *RegisterIncomingRequest) Proceed(ctx context.Context) error

type RequestFetcher added in v0.9.5 

type RequestFetcher interface {
	FetchPendings(ctx context.Context)
	Abort(ctx context.Context)
}

func NewRequestsFetcher added in v0.9.0 

func NewRequestsFetcher(
	obj insolar.Reference, am artifacts.Client, br ExecutionBrokerI, os OutgoingRequestSender,
) RequestFetcher

type RequestFetcherMock added in v0.9.5 

type RequestFetcherMock struct {
	AbortMock mRequestFetcherMockAbort

	FetchPendingsMock mRequestFetcherMockFetchPendings
	// contains filtered or unexported fields
}

RequestFetcherMock implements RequestFetcher

func NewRequestFetcherMock added in v0.9.5 

func NewRequestFetcherMock(t minimock.Tester) *RequestFetcherMock

NewRequestFetcherMock returns a mock for RequestFetcher

func (*RequestFetcherMock) Abort added in v0.9.5 

func (mmAbort *RequestFetcherMock) Abort(ctx context.Context)

Abort implements RequestFetcher

func (*RequestFetcherMock) AbortAfterCounter added in v0.9.5 

func (mmAbort *RequestFetcherMock) AbortAfterCounter() uint64

AbortAfterCounter returns a count of finished RequestFetcherMock.Abort invocations

func (*RequestFetcherMock) AbortBeforeCounter added in v0.9.5 

func (mmAbort *RequestFetcherMock) AbortBeforeCounter() uint64

AbortBeforeCounter returns a count of RequestFetcherMock.Abort invocations

func (*RequestFetcherMock) FetchPendings added in v0.9.5 

func (mmFetchPendings *RequestFetcherMock) FetchPendings(ctx context.Context)

FetchPendings implements RequestFetcher

func (*RequestFetcherMock) FetchPendingsAfterCounter added in v0.9.5 

func (mmFetchPendings *RequestFetcherMock) FetchPendingsAfterCounter() uint64

FetchPendingsAfterCounter returns a count of finished RequestFetcherMock.FetchPendings invocations

func (*RequestFetcherMock) FetchPendingsBeforeCounter added in v0.9.5 

func (mmFetchPendings *RequestFetcherMock) FetchPendingsBeforeCounter() uint64

FetchPendingsBeforeCounter returns a count of RequestFetcherMock.FetchPendings invocations

func (*RequestFetcherMock) MinimockAbortDone added in v0.9.5 

func (m *RequestFetcherMock) MinimockAbortDone() bool

MinimockAbortDone returns true if the count of the Abort invocations corresponds the number of defined expectations

func (*RequestFetcherMock) MinimockAbortInspect added in v0.9.5 

func (m *RequestFetcherMock) MinimockAbortInspect()

MinimockAbortInspect logs each unmet expectation

func (*RequestFetcherMock) MinimockFetchPendingsDone added in v0.9.5 

func (m *RequestFetcherMock) MinimockFetchPendingsDone() bool

MinimockFetchPendingsDone returns true if the count of the FetchPendings invocations corresponds the number of defined expectations

func (*RequestFetcherMock) MinimockFetchPendingsInspect added in v0.9.5 

func (m *RequestFetcherMock) MinimockFetchPendingsInspect()

MinimockFetchPendingsInspect logs each unmet expectation

func (*RequestFetcherMock) MinimockFinish added in v0.9.5 

func (m *RequestFetcherMock) MinimockFinish()

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

func (*RequestFetcherMock) MinimockWait added in v0.9.5 

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

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

type RequestFetcherMockAbortExpectation added in v0.9.5 

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

RequestFetcherMockAbortExpectation specifies expectation struct of the RequestFetcher.Abort

type RequestFetcherMockAbortParams added in v0.9.5 

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

RequestFetcherMockAbortParams contains parameters of the RequestFetcher.Abort

type RequestFetcherMockFetchPendingsExpectation added in v0.9.5 

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

RequestFetcherMockFetchPendingsExpectation specifies expectation struct of the RequestFetcher.FetchPendings

type RequestFetcherMockFetchPendingsParams added in v0.9.5 

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

RequestFetcherMockFetchPendingsParams contains parameters of the RequestFetcher.FetchPendings

type RequestsExecutor added in v0.9.0 

type RequestsExecutor interface {
	ExecuteAndSave(ctx context.Context, current *common.Transcript) (insolar.Reply, error)
	Execute(ctx context.Context, current *common.Transcript) (artifacts.RequestResult, error)
	Save(ctx context.Context, current *common.Transcript, res artifacts.RequestResult) (insolar.Reply, error)
	SendReply(ctx context.Context, reqRef insolar.Reference, req record.IncomingRequest, re insolar.Reply, err error)
}

func NewRequestsExecutor added in v0.9.0 

func NewRequestsExecutor() RequestsExecutor

type RequestsExecutorMock added in v0.9.0 

type RequestsExecutorMock struct {
	ExecuteMock mRequestsExecutorMockExecute

	ExecuteAndSaveMock mRequestsExecutorMockExecuteAndSave

	SaveMock mRequestsExecutorMockSave

	SendReplyMock mRequestsExecutorMockSendReply
	// contains filtered or unexported fields
}

RequestsExecutorMock implements RequestsExecutor

func NewRequestsExecutorMock added in v0.9.0 

func NewRequestsExecutorMock(t minimock.Tester) *RequestsExecutorMock

NewRequestsExecutorMock returns a mock for RequestsExecutor

func (*RequestsExecutorMock) Execute added in v0.9.0 

func (mmExecute *RequestsExecutorMock) Execute(ctx context.Context, current *common.Transcript) (r1 artifacts.RequestResult, err error)

Execute implements RequestsExecutor

func (*RequestsExecutorMock) ExecuteAfterCounter added in v0.9.0 

func (mmExecute *RequestsExecutorMock) ExecuteAfterCounter() uint64

ExecuteAfterCounter returns a count of finished RequestsExecutorMock.Execute invocations

func (*RequestsExecutorMock) ExecuteAndSave added in v0.9.0 

func (mmExecuteAndSave *RequestsExecutorMock) ExecuteAndSave(ctx context.Context, current *common.Transcript) (r1 insolar.Reply, err error)

ExecuteAndSave implements RequestsExecutor

func (*RequestsExecutorMock) ExecuteAndSaveAfterCounter added in v0.9.0 

func (mmExecuteAndSave *RequestsExecutorMock) ExecuteAndSaveAfterCounter() uint64

ExecuteAndSaveAfterCounter returns a count of finished RequestsExecutorMock.ExecuteAndSave invocations

func (*RequestsExecutorMock) ExecuteAndSaveBeforeCounter added in v0.9.0 

func (mmExecuteAndSave *RequestsExecutorMock) ExecuteAndSaveBeforeCounter() uint64

ExecuteAndSaveBeforeCounter returns a count of RequestsExecutorMock.ExecuteAndSave invocations

func (*RequestsExecutorMock) ExecuteBeforeCounter added in v0.9.0 

func (mmExecute *RequestsExecutorMock) ExecuteBeforeCounter() uint64

ExecuteBeforeCounter returns a count of RequestsExecutorMock.Execute invocations

func (*RequestsExecutorMock) MinimockExecuteAndSaveDone added in v0.9.0 

func (m *RequestsExecutorMock) MinimockExecuteAndSaveDone() bool

MinimockExecuteAndSaveDone returns true if the count of the ExecuteAndSave invocations corresponds the number of defined expectations

func (*RequestsExecutorMock) MinimockExecuteAndSaveInspect added in v0.9.0 

func (m *RequestsExecutorMock) MinimockExecuteAndSaveInspect()

MinimockExecuteAndSaveInspect logs each unmet expectation

func (*RequestsExecutorMock) MinimockExecuteDone added in v0.9.0 

func (m *RequestsExecutorMock) MinimockExecuteDone() bool

MinimockExecuteDone returns true if the count of the Execute invocations corresponds the number of defined expectations

func (*RequestsExecutorMock) MinimockExecuteInspect added in v0.9.0 

func (m *RequestsExecutorMock) MinimockExecuteInspect()

MinimockExecuteInspect logs each unmet expectation

func (*RequestsExecutorMock) MinimockFinish added in v0.9.0 

func (m *RequestsExecutorMock) MinimockFinish()

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

func (*RequestsExecutorMock) MinimockSaveDone added in v0.9.0 

func (m *RequestsExecutorMock) MinimockSaveDone() bool

MinimockSaveDone returns true if the count of the Save invocations corresponds the number of defined expectations

func (*RequestsExecutorMock) MinimockSaveInspect added in v0.9.0 

func (m *RequestsExecutorMock) MinimockSaveInspect()

MinimockSaveInspect logs each unmet expectation

func (*RequestsExecutorMock) MinimockSendReplyDone added in v0.9.0 

func (m *RequestsExecutorMock) MinimockSendReplyDone() bool

MinimockSendReplyDone returns true if the count of the SendReply invocations corresponds the number of defined expectations

func (*RequestsExecutorMock) MinimockSendReplyInspect added in v0.9.0 

func (m *RequestsExecutorMock) MinimockSendReplyInspect()

MinimockSendReplyInspect logs each unmet expectation

func (*RequestsExecutorMock) MinimockWait added in v0.9.0 

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

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

func (*RequestsExecutorMock) Save added in v0.9.0 

func (mmSave *RequestsExecutorMock) Save(ctx context.Context, current *common.Transcript, res artifacts.RequestResult) (r1 insolar.Reply, err error)

Save implements RequestsExecutor

func (*RequestsExecutorMock) SaveAfterCounter added in v0.9.0 

func (mmSave *RequestsExecutorMock) SaveAfterCounter() uint64

SaveAfterCounter returns a count of finished RequestsExecutorMock.Save invocations

func (*RequestsExecutorMock) SaveBeforeCounter added in v0.9.0 

func (mmSave *RequestsExecutorMock) SaveBeforeCounter() uint64

SaveBeforeCounter returns a count of RequestsExecutorMock.Save invocations

func (*RequestsExecutorMock) SendReply added in v0.9.0 

func (mmSendReply *RequestsExecutorMock) SendReply(ctx context.Context, reqRef insolar.Reference, req record.IncomingRequest, re insolar.Reply, err error)

SendReply implements RequestsExecutor

func (*RequestsExecutorMock) SendReplyAfterCounter added in v0.9.0 

func (mmSendReply *RequestsExecutorMock) SendReplyAfterCounter() uint64

SendReplyAfterCounter returns a count of finished RequestsExecutorMock.SendReply invocations

func (*RequestsExecutorMock) SendReplyBeforeCounter added in v0.9.0 

func (mmSendReply *RequestsExecutorMock) SendReplyBeforeCounter() uint64

SendReplyBeforeCounter returns a count of RequestsExecutorMock.SendReply invocations

type RequestsExecutorMockExecuteAndSaveExpectation added in v0.9.0 

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

RequestsExecutorMockExecuteAndSaveExpectation specifies expectation struct of the RequestsExecutor.ExecuteAndSave

func (*RequestsExecutorMockExecuteAndSaveExpectation) Then added in v0.9.0 

func (e *RequestsExecutorMockExecuteAndSaveExpectation) Then(r1 insolar.Reply, err error) *RequestsExecutorMock

Then sets up RequestsExecutor.ExecuteAndSave return parameters for the expectation previously defined by the When method

type RequestsExecutorMockExecuteAndSaveParams added in v0.9.0 

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

RequestsExecutorMockExecuteAndSaveParams contains parameters of the RequestsExecutor.ExecuteAndSave

type RequestsExecutorMockExecuteAndSaveResults added in v0.9.0 

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

RequestsExecutorMockExecuteAndSaveResults contains results of the RequestsExecutor.ExecuteAndSave

type RequestsExecutorMockExecuteExpectation added in v0.9.0 

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

RequestsExecutorMockExecuteExpectation specifies expectation struct of the RequestsExecutor.Execute

func (*RequestsExecutorMockExecuteExpectation) Then added in v0.9.0 

func (e *RequestsExecutorMockExecuteExpectation) Then(r1 artifacts.RequestResult, err error) *RequestsExecutorMock

Then sets up RequestsExecutor.Execute return parameters for the expectation previously defined by the When method

type RequestsExecutorMockExecuteParams added in v0.9.0 

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

RequestsExecutorMockExecuteParams contains parameters of the RequestsExecutor.Execute

type RequestsExecutorMockExecuteResults added in v0.9.0 

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

RequestsExecutorMockExecuteResults contains results of the RequestsExecutor.Execute

type RequestsExecutorMockSaveExpectation added in v0.9.0 

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

RequestsExecutorMockSaveExpectation specifies expectation struct of the RequestsExecutor.Save

func (*RequestsExecutorMockSaveExpectation) Then added in v0.9.0 

func (e *RequestsExecutorMockSaveExpectation) Then(r1 insolar.Reply, err error) *RequestsExecutorMock

Then sets up RequestsExecutor.Save return parameters for the expectation previously defined by the When method

type RequestsExecutorMockSaveParams added in v0.9.0 

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

RequestsExecutorMockSaveParams contains parameters of the RequestsExecutor.Save

type RequestsExecutorMockSaveResults added in v0.9.0 

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

RequestsExecutorMockSaveResults contains results of the RequestsExecutor.Save

type RequestsExecutorMockSendReplyExpectation added in v0.9.0 

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

RequestsExecutorMockSendReplyExpectation specifies expectation struct of the RequestsExecutor.SendReply

type RequestsExecutorMockSendReplyParams added in v0.9.0 

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

RequestsExecutorMockSendReplyParams contains parameters of the RequestsExecutor.SendReply

type ResultMatcher added in v0.9.0 

type ResultMatcher interface {
	AddStillExecution(ctx context.Context, msg payload.StillExecuting)
	AddUnwantedResponse(ctx context.Context, msg payload.ReturnResults)
	Clear(ctx context.Context)
}

type ResultMatcherMock added in v0.9.0 

type ResultMatcherMock struct {
	AddStillExecutionMock mResultMatcherMockAddStillExecution

	AddUnwantedResponseMock mResultMatcherMockAddUnwantedResponse

	ClearMock mResultMatcherMockClear
	// contains filtered or unexported fields
}

ResultMatcherMock implements ResultMatcher

func NewResultMatcherMock added in v0.9.0 

func NewResultMatcherMock(t minimock.Tester) *ResultMatcherMock

NewResultMatcherMock returns a mock for ResultMatcher

func (*ResultMatcherMock) AddStillExecution added in v0.9.0 

func (mmAddStillExecution *ResultMatcherMock) AddStillExecution(ctx context.Context, msg payload.StillExecuting)

AddStillExecution implements ResultMatcher

func (*ResultMatcherMock) AddStillExecutionAfterCounter added in v0.9.0 

func (mmAddStillExecution *ResultMatcherMock) AddStillExecutionAfterCounter() uint64

AddStillExecutionAfterCounter returns a count of finished ResultMatcherMock.AddStillExecution invocations

func (*ResultMatcherMock) AddStillExecutionBeforeCounter added in v0.9.0 

func (mmAddStillExecution *ResultMatcherMock) AddStillExecutionBeforeCounter() uint64

AddStillExecutionBeforeCounter returns a count of ResultMatcherMock.AddStillExecution invocations

func (*ResultMatcherMock) AddUnwantedResponse added in v0.9.0 

func (mmAddUnwantedResponse *ResultMatcherMock) AddUnwantedResponse(ctx context.Context, msg payload.ReturnResults)

AddUnwantedResponse implements ResultMatcher

func (*ResultMatcherMock) AddUnwantedResponseAfterCounter added in v0.9.0 

func (mmAddUnwantedResponse *ResultMatcherMock) AddUnwantedResponseAfterCounter() uint64

AddUnwantedResponseAfterCounter returns a count of finished ResultMatcherMock.AddUnwantedResponse invocations

func (*ResultMatcherMock) AddUnwantedResponseBeforeCounter added in v0.9.0 

func (mmAddUnwantedResponse *ResultMatcherMock) AddUnwantedResponseBeforeCounter() uint64

AddUnwantedResponseBeforeCounter returns a count of ResultMatcherMock.AddUnwantedResponse invocations

func (*ResultMatcherMock) Clear added in v0.9.0 

func (mmClear *ResultMatcherMock) Clear(ctx context.Context)

Clear implements ResultMatcher

func (*ResultMatcherMock) ClearAfterCounter added in v0.9.0 

func (mmClear *ResultMatcherMock) ClearAfterCounter() uint64

ClearAfterCounter returns a count of finished ResultMatcherMock.Clear invocations

func (*ResultMatcherMock) ClearBeforeCounter added in v0.9.0 

func (mmClear *ResultMatcherMock) ClearBeforeCounter() uint64

ClearBeforeCounter returns a count of ResultMatcherMock.Clear invocations

func (*ResultMatcherMock) MinimockAddStillExecutionDone added in v0.9.0 

func (m *ResultMatcherMock) MinimockAddStillExecutionDone() bool

MinimockAddStillExecutionDone returns true if the count of the AddStillExecution invocations corresponds the number of defined expectations

func (*ResultMatcherMock) MinimockAddStillExecutionInspect added in v0.9.0 

func (m *ResultMatcherMock) MinimockAddStillExecutionInspect()

MinimockAddStillExecutionInspect logs each unmet expectation

func (*ResultMatcherMock) MinimockAddUnwantedResponseDone added in v0.9.0 

func (m *ResultMatcherMock) MinimockAddUnwantedResponseDone() bool

MinimockAddUnwantedResponseDone returns true if the count of the AddUnwantedResponse invocations corresponds the number of defined expectations

func (*ResultMatcherMock) MinimockAddUnwantedResponseInspect added in v0.9.0 

func (m *ResultMatcherMock) MinimockAddUnwantedResponseInspect()

MinimockAddUnwantedResponseInspect logs each unmet expectation

func (*ResultMatcherMock) MinimockClearDone added in v0.9.0 

func (m *ResultMatcherMock) MinimockClearDone() bool

MinimockClearDone returns true if the count of the Clear invocations corresponds the number of defined expectations

func (*ResultMatcherMock) MinimockClearInspect added in v0.9.0 

func (m *ResultMatcherMock) MinimockClearInspect()

MinimockClearInspect logs each unmet expectation

func (*ResultMatcherMock) MinimockFinish added in v0.9.0 

func (m *ResultMatcherMock) MinimockFinish()

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

func (*ResultMatcherMock) MinimockWait added in v0.9.0 

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

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

type ResultMatcherMockAddStillExecutionExpectation added in v0.9.0 

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

ResultMatcherMockAddStillExecutionExpectation specifies expectation struct of the ResultMatcher.AddStillExecution

type ResultMatcherMockAddStillExecutionParams added in v0.9.0 

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

ResultMatcherMockAddStillExecutionParams contains parameters of the ResultMatcher.AddStillExecution

type ResultMatcherMockAddUnwantedResponseExpectation added in v0.9.0 

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

ResultMatcherMockAddUnwantedResponseExpectation specifies expectation struct of the ResultMatcher.AddUnwantedResponse

type ResultMatcherMockAddUnwantedResponseParams added in v0.9.0 

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

ResultMatcherMockAddUnwantedResponseParams contains parameters of the ResultMatcher.AddUnwantedResponse

type ResultMatcherMockClearExpectation added in v0.9.0 

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

ResultMatcherMockClearExpectation specifies expectation struct of the ResultMatcher.Clear

type ResultMatcherMockClearParams added in v0.9.0 

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

ResultMatcherMockClearParams contains parameters of the ResultMatcher.Clear

type StateStorage added in v0.9.0 

type StateStorage interface {
	UpsertExecutionState(ref insolar.Reference) ExecutionBrokerI
	GetExecutionState(ref insolar.Reference) ExecutionBrokerI
	GetExecutionRegistry(ref insolar.Reference) executionregistry.ExecutionRegistry

	IsEmpty() bool
	OnPulse(ctx context.Context, pulse insolar.Pulse) map[insolar.Reference][]payload.Payload
}

func NewStateStorage added in v0.9.0 

func NewStateStorage(
	publisher watermillMsg.Publisher,
	requestsExecutor RequestsExecutor,
	sender bus.Sender,
	jetCoordinator jet.Coordinator,
	pulseAccessor pulse.Accessor,
	artifactsManager artifacts.Client,
	outgoingSender OutgoingRequestSender,
	shutdownFlag shutdown.Flag,
) StateStorage

type StateStorageMock added in v0.9.0 

type StateStorageMock struct {
	GetExecutionRegistryMock mStateStorageMockGetExecutionRegistry

	GetExecutionStateMock mStateStorageMockGetExecutionState

	IsEmptyMock mStateStorageMockIsEmpty

	OnPulseMock mStateStorageMockOnPulse

	UpsertExecutionStateMock mStateStorageMockUpsertExecutionState
	// contains filtered or unexported fields
}

StateStorageMock implements StateStorage

func NewStateStorageMock added in v0.9.0 

func NewStateStorageMock(t minimock.Tester) *StateStorageMock

NewStateStorageMock returns a mock for StateStorage

func (*StateStorageMock) GetExecutionRegistry added in v0.9.0 

func (mmGetExecutionRegistry *StateStorageMock) GetExecutionRegistry(ref insolar.Reference) (e1 executionregistry.ExecutionRegistry)

GetExecutionRegistry implements StateStorage

func (*StateStorageMock) GetExecutionRegistryAfterCounter added in v0.9.0 

func (mmGetExecutionRegistry *StateStorageMock) GetExecutionRegistryAfterCounter() uint64

GetExecutionRegistryAfterCounter returns a count of finished StateStorageMock.GetExecutionRegistry invocations

func (*StateStorageMock) GetExecutionRegistryBeforeCounter added in v0.9.0 

func (mmGetExecutionRegistry *StateStorageMock) GetExecutionRegistryBeforeCounter() uint64

GetExecutionRegistryBeforeCounter returns a count of StateStorageMock.GetExecutionRegistry invocations

func (*StateStorageMock) GetExecutionState added in v0.9.0 

func (mmGetExecutionState *StateStorageMock) GetExecutionState(ref insolar.Reference) (e1 ExecutionBrokerI)

GetExecutionState implements StateStorage

func (*StateStorageMock) GetExecutionStateAfterCounter added in v0.9.0 

func (mmGetExecutionState *StateStorageMock) GetExecutionStateAfterCounter() uint64

GetExecutionStateAfterCounter returns a count of finished StateStorageMock.GetExecutionState invocations

func (*StateStorageMock) GetExecutionStateBeforeCounter added in v0.9.0 

func (mmGetExecutionState *StateStorageMock) GetExecutionStateBeforeCounter() uint64

GetExecutionStateBeforeCounter returns a count of StateStorageMock.GetExecutionState invocations

func (*StateStorageMock) IsEmpty added in v0.9.0 

func (mmIsEmpty *StateStorageMock) IsEmpty() (b1 bool)

IsEmpty implements StateStorage

func (*StateStorageMock) IsEmptyAfterCounter added in v0.9.0 

func (mmIsEmpty *StateStorageMock) IsEmptyAfterCounter() uint64

IsEmptyAfterCounter returns a count of finished StateStorageMock.IsEmpty invocations

func (*StateStorageMock) IsEmptyBeforeCounter added in v0.9.0 

func (mmIsEmpty *StateStorageMock) IsEmptyBeforeCounter() uint64

IsEmptyBeforeCounter returns a count of StateStorageMock.IsEmpty invocations

func (*StateStorageMock) MinimockFinish added in v0.9.0 

func (m *StateStorageMock) MinimockFinish()

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

func (*StateStorageMock) MinimockGetExecutionRegistryDone added in v0.9.0 

func (m *StateStorageMock) MinimockGetExecutionRegistryDone() bool

MinimockGetExecutionRegistryDone returns true if the count of the GetExecutionRegistry invocations corresponds the number of defined expectations

func (*StateStorageMock) MinimockGetExecutionRegistryInspect added in v0.9.0 

func (m *StateStorageMock) MinimockGetExecutionRegistryInspect()

MinimockGetExecutionRegistryInspect logs each unmet expectation

func (*StateStorageMock) MinimockGetExecutionStateDone added in v0.9.0 

func (m *StateStorageMock) MinimockGetExecutionStateDone() bool

MinimockGetExecutionStateDone returns true if the count of the GetExecutionState invocations corresponds the number of defined expectations

func (*StateStorageMock) MinimockGetExecutionStateInspect added in v0.9.0 

func (m *StateStorageMock) MinimockGetExecutionStateInspect()

MinimockGetExecutionStateInspect logs each unmet expectation

func (*StateStorageMock) MinimockIsEmptyDone added in v0.9.0 

func (m *StateStorageMock) MinimockIsEmptyDone() bool

MinimockIsEmptyDone returns true if the count of the IsEmpty invocations corresponds the number of defined expectations

func (*StateStorageMock) MinimockIsEmptyInspect added in v0.9.0 

func (m *StateStorageMock) MinimockIsEmptyInspect()

MinimockIsEmptyInspect logs each unmet expectation

func (*StateStorageMock) MinimockOnPulseDone added in v0.9.0 

func (m *StateStorageMock) MinimockOnPulseDone() bool

MinimockOnPulseDone returns true if the count of the OnPulse invocations corresponds the number of defined expectations

func (*StateStorageMock) MinimockOnPulseInspect added in v0.9.0 

func (m *StateStorageMock) MinimockOnPulseInspect()

MinimockOnPulseInspect logs each unmet expectation

func (*StateStorageMock) MinimockUpsertExecutionStateDone added in v0.9.0 

func (m *StateStorageMock) MinimockUpsertExecutionStateDone() bool

MinimockUpsertExecutionStateDone returns true if the count of the UpsertExecutionState invocations corresponds the number of defined expectations

func (*StateStorageMock) MinimockUpsertExecutionStateInspect added in v0.9.0 

func (m *StateStorageMock) MinimockUpsertExecutionStateInspect()

MinimockUpsertExecutionStateInspect logs each unmet expectation

func (*StateStorageMock) MinimockWait added in v0.9.0 

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

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

func (*StateStorageMock) OnPulse added in v0.9.0 

func (mmOnPulse *StateStorageMock) OnPulse(ctx context.Context, pulse insolar.Pulse) (m1 map[insolar.Reference][]payload.Payload)

OnPulse implements StateStorage

func (*StateStorageMock) OnPulseAfterCounter added in v0.9.0 

func (mmOnPulse *StateStorageMock) OnPulseAfterCounter() uint64

OnPulseAfterCounter returns a count of finished StateStorageMock.OnPulse invocations

func (*StateStorageMock) OnPulseBeforeCounter added in v0.9.0 

func (mmOnPulse *StateStorageMock) OnPulseBeforeCounter() uint64

OnPulseBeforeCounter returns a count of StateStorageMock.OnPulse invocations

func (*StateStorageMock) UpsertExecutionState added in v0.9.0 

func (mmUpsertExecutionState *StateStorageMock) UpsertExecutionState(ref insolar.Reference) (e1 ExecutionBrokerI)

UpsertExecutionState implements StateStorage

func (*StateStorageMock) UpsertExecutionStateAfterCounter added in v0.9.0 

func (mmUpsertExecutionState *StateStorageMock) UpsertExecutionStateAfterCounter() uint64

UpsertExecutionStateAfterCounter returns a count of finished StateStorageMock.UpsertExecutionState invocations

func (*StateStorageMock) UpsertExecutionStateBeforeCounter added in v0.9.0 

func (mmUpsertExecutionState *StateStorageMock) UpsertExecutionStateBeforeCounter() uint64

UpsertExecutionStateBeforeCounter returns a count of StateStorageMock.UpsertExecutionState invocations

type StateStorageMockGetExecutionRegistryExpectation added in v0.9.0 

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

StateStorageMockGetExecutionRegistryExpectation specifies expectation struct of the StateStorage.GetExecutionRegistry

func (*StateStorageMockGetExecutionRegistryExpectation) Then added in v0.9.0 

func (e *StateStorageMockGetExecutionRegistryExpectation) Then(e1 executionregistry.ExecutionRegistry) *StateStorageMock

Then sets up StateStorage.GetExecutionRegistry return parameters for the expectation previously defined by the When method

type StateStorageMockGetExecutionRegistryParams added in v0.9.0 

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

StateStorageMockGetExecutionRegistryParams contains parameters of the StateStorage.GetExecutionRegistry

type StateStorageMockGetExecutionRegistryResults added in v0.9.0 

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

StateStorageMockGetExecutionRegistryResults contains results of the StateStorage.GetExecutionRegistry

type StateStorageMockGetExecutionStateExpectation added in v0.9.0 

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

StateStorageMockGetExecutionStateExpectation specifies expectation struct of the StateStorage.GetExecutionState

func (*StateStorageMockGetExecutionStateExpectation) Then added in v0.9.0 

func (e *StateStorageMockGetExecutionStateExpectation) Then(e1 ExecutionBrokerI) *StateStorageMock

Then sets up StateStorage.GetExecutionState return parameters for the expectation previously defined by the When method

type StateStorageMockGetExecutionStateParams added in v0.9.0 

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

StateStorageMockGetExecutionStateParams contains parameters of the StateStorage.GetExecutionState

type StateStorageMockGetExecutionStateResults added in v0.9.0 

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

StateStorageMockGetExecutionStateResults contains results of the StateStorage.GetExecutionState

type StateStorageMockIsEmptyExpectation added in v0.9.0 

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

StateStorageMockIsEmptyExpectation specifies expectation struct of the StateStorage.IsEmpty

type StateStorageMockIsEmptyResults added in v0.9.0 

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

StateStorageMockIsEmptyResults contains results of the StateStorage.IsEmpty

type StateStorageMockOnPulseExpectation added in v0.9.0 

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

StateStorageMockOnPulseExpectation specifies expectation struct of the StateStorage.OnPulse

func (*StateStorageMockOnPulseExpectation) Then added in v0.9.0 

func (e *StateStorageMockOnPulseExpectation) Then(m1 map[insolar.Reference][]payload.Payload) *StateStorageMock

Then sets up StateStorage.OnPulse return parameters for the expectation previously defined by the When method

type StateStorageMockOnPulseParams added in v0.9.0 

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

StateStorageMockOnPulseParams contains parameters of the StateStorage.OnPulse

type StateStorageMockOnPulseResults added in v0.9.0 

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

StateStorageMockOnPulseResults contains results of the StateStorage.OnPulse

type StateStorageMockUpsertExecutionStateExpectation added in v0.9.0 

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

StateStorageMockUpsertExecutionStateExpectation specifies expectation struct of the StateStorage.UpsertExecutionState

func (*StateStorageMockUpsertExecutionStateExpectation) Then added in v0.9.0 

func (e *StateStorageMockUpsertExecutionStateExpectation) Then(e1 ExecutionBrokerI) *StateStorageMock

Then sets up StateStorage.UpsertExecutionState return parameters for the expectation previously defined by the When method

type StateStorageMockUpsertExecutionStateParams added in v0.9.0 

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

StateStorageMockUpsertExecutionStateParams contains parameters of the StateStorage.UpsertExecutionState

type StateStorageMockUpsertExecutionStateResults added in v0.9.0 

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

StateStorageMockUpsertExecutionStateResults contains results of the StateStorage.UpsertExecutionState

Source Files

View all Source files

Directories

Path Synopsis
Package builtin is implementation of builtin contracts engine
 Package builtin is implementation of builtin contracts engine
contract/account
contract/costcenter
contract/deposit
contract/helloworld
contract/member
contract/member/signer
contract/migrationadmin
contract/migrationdaemon
contract/migrationshard
contract/nodedomain
contract/noderecord
contract/pkshard
contract/rootdomain
contract/wallet
foundation
Package foundation server implementation of smartcontract functions
 Package foundation server implementation of smartcontract functions
foundation/safemath
proxy/account
proxy/costcenter
proxy/deposit
proxy/helloworld
proxy/member
proxy/migrationadmin
proxy/migrationdaemon
proxy/migrationshard
proxy/nodedomain
proxy/noderecord
proxy/pkshard
proxy/rootdomain
proxy/wallet
Package goplugin - golang plugin in docker runner
 Package goplugin - golang plugin in docker runner
ginsider
ginsider/healthcheck
goplugintestutils
rpctypes
Package pulsemanager is responsible for all pulse operations.
 Package pulsemanager is responsible for all pulse operations.

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.