logicrunner

package

Go to main page

Versions in this module

v1

v1.5.2

Apr 30, 2020

v1.3.3

Jan 29, 2020

v1.3.2

Jan 27, 2020

v1.3.1

Jan 27, 2020

v1.3.0

Jan 14, 2020

v1.1.3

Dec 16, 2019

v1.1.2

Dec 13, 2019

v1.1.1

Dec 12, 2019

v1.1.0

Dec 9, 2019

v1.0.0

Nov 26, 2019

v0

v0.9.20

Nov 26, 2019

Changes in this version

+ type LedgerHasMore int

+ const LedgerHasMoreKnown

+ const LedgerHasMoreUnknown

+ const LedgerIsEmpty

v0.9.19

Nov 20, 2019

v0.9.18

Nov 15, 2019

v0.9.17

Nov 15, 2019

v0.9.16

Oct 18, 2019

Changes in this version

type ExecutionBroker

+ func (q *ExecutionBroker) HasMoreRequests(ctx context.Context)

type ExecutionBrokerI

+ HasMoreRequests func(ctx context.Context)

type ExecutionBrokerIMock

+ HasMoreRequestsMock mExecutionBrokerIMockHasMoreRequests

+ func (m *ExecutionBrokerIMock) MinimockHasMoreRequestsDone() bool

+ func (m *ExecutionBrokerIMock) MinimockHasMoreRequestsInspect()

+ func (mmHasMoreRequests *ExecutionBrokerIMock) HasMoreRequests(ctx context.Context)

+ func (mmHasMoreRequests *ExecutionBrokerIMock) HasMoreRequestsAfterCounter() uint64

+ func (mmHasMoreRequests *ExecutionBrokerIMock) HasMoreRequestsBeforeCounter() uint64

+ type ExecutionBrokerIMockHasMoreRequestsExpectation struct

+ Counter uint64

+ type ExecutionBrokerIMockHasMoreRequestsParams struct

type RequestFetcherMockFetchPendingsExpectation

+ func (e *RequestFetcherMockFetchPendingsExpectation) Then(ch1 <-chan *common.Transcript) *RequestFetcherMock

+ type RequestFetcherMockFetchPendingsResults struct

v0.9.15

Oct 1, 2019

v0.9.14

Oct 1, 2019

v0.9.13

Sep 30, 2019

v0.9.12

Sep 30, 2019

v0.9.11

Sep 29, 2019

Changes in this version

+ const ImmutableQueueName

+ const MutableQueueName

v0.9.10

Sep 27, 2019

v0.9.9

Sep 27, 2019

v0.9.8

Sep 26, 2019

v0.9.7

Sep 20, 2019

v0.9.6

Sep 17, 2019

v0.9.5

Sep 13, 2019

Changes in this version

+ var ErrAlreadyExecuting = errors.New("already executing")

+ var ErrNotInPending = errors.New("state is not in pending")

type ExecutionBrokerIMockPrevExecutorStillExecutingExpectation

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

+ type ExecutionBrokerIMockPrevExecutorStillExecutingResults struct

+ type RequestFetcher interface

+ Abort func(ctx context.Context)

+ FetchPendings func(ctx context.Context)

+ type RequestFetcherMock struct

+ AbortMock mRequestFetcherMockAbort

+ FetchPendingsMock mRequestFetcherMockFetchPendings

+ func NewRequestFetcherMock(t minimock.Tester) *RequestFetcherMock

+ func (m *RequestFetcherMock) MinimockAbortDone() bool

+ func (m *RequestFetcherMock) MinimockAbortInspect()

+ func (m *RequestFetcherMock) MinimockFetchPendingsDone() bool

+ func (m *RequestFetcherMock) MinimockFetchPendingsInspect()

+ func (m *RequestFetcherMock) MinimockFinish()

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

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

+ func (mmAbort *RequestFetcherMock) AbortAfterCounter() uint64

+ func (mmAbort *RequestFetcherMock) AbortBeforeCounter() uint64

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

+ func (mmFetchPendings *RequestFetcherMock) FetchPendingsAfterCounter() uint64

+ func (mmFetchPendings *RequestFetcherMock) FetchPendingsBeforeCounter() uint64

+ type RequestFetcherMockAbortExpectation struct

+ Counter uint64

+ type RequestFetcherMockAbortParams struct

+ type RequestFetcherMockFetchPendingsExpectation struct

+ Counter uint64

+ type RequestFetcherMockFetchPendingsParams struct

v0.9.4

Sep 12, 2019

v0.9.3

Sep 11, 2019

Changes in this version

+ const MaxFetchCount

v0.9.2

Sep 10, 2019

v0.9.1

Sep 5, 2019

Changes in this version

+ func ProcessLogicalError(err error) bool

v0.9.1-rc1

Sep 5, 2019

v0.9.0

Aug 30, 2019

Changes in this version

+ const InnerMsgTopic

+ var ErrCantExecute = errors.New("can't executeAndReply this object")

+ var OutgoingRequestSenderDefaultGoroutineLimit = int32(5000)

+ var OutgoingRequestSenderDefaultQueueLimit = 1000

+ type AddFreshRequest struct

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

+ type AdditionalCallFromPreviousExecutor struct

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

+ type CheckOurRole struct

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

+ type Dependencies struct

+ ArtifactManager artifacts.Client

+ JetCoordinator jet.Coordinator

+ JetStorage jet.Storage

+ OutgoingSender OutgoingRequestSender

+ Publisher message.Publisher

+ PulseAccessor pulse.Accessor

+ RequestsExecutor RequestsExecutor

+ ResultsMatcher ResultMatcher

+ Sender bus.Sender

+ StateStorage StateStorage

+ WriteAccessor writecontroller.Accessor

+ type ExecutionBroker struct

+ HasPendingCheckMutex sync.Mutex

+ PendingConfirmed bool

+ Ref insolar.Reference

+ func NewExecutionBroker(ref insolar.Reference, publisher watermillMsg.Publisher, ...) *ExecutionBroker

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type ExecutionBrokerI interface

+ AbandonedRequestsOnLedger func(ctx context.Context)

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

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

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

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

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

+ MoreRequestsOnLedger func(ctx context.Context)

+ NoMoreRequestsOnLedger func(ctx context.Context)

+ OnPulse func(ctx context.Context) []payload.Payload

+ PendingState func() insolar.PendingState

+ PrevExecutorPendingResult func(ctx context.Context, prevExecState insolar.PendingState)

+ PrevExecutorSentPendingFinished func(ctx context.Context) error

+ PrevExecutorStillExecuting func(ctx context.Context)

+ SetNotPending func(ctx context.Context)

+ 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

+ func NewExecutionBrokerIMock(t minimock.Tester) *ExecutionBrokerIMock

+ func (m *ExecutionBrokerIMock) MinimockAbandonedRequestsOnLedgerDone() bool

+ func (m *ExecutionBrokerIMock) MinimockAbandonedRequestsOnLedgerInspect()

+ func (m *ExecutionBrokerIMock) MinimockAddAdditionalRequestFromPrevExecutorDone() bool

+ func (m *ExecutionBrokerIMock) MinimockAddAdditionalRequestFromPrevExecutorInspect()

+ func (m *ExecutionBrokerIMock) MinimockAddFreshRequestDone() bool

+ func (m *ExecutionBrokerIMock) MinimockAddFreshRequestInspect()

+ func (m *ExecutionBrokerIMock) MinimockAddRequestsFromLedgerDone() bool

+ func (m *ExecutionBrokerIMock) MinimockAddRequestsFromLedgerInspect()

+ func (m *ExecutionBrokerIMock) MinimockAddRequestsFromPrevExecutorDone() bool

+ func (m *ExecutionBrokerIMock) MinimockAddRequestsFromPrevExecutorInspect()

+ func (m *ExecutionBrokerIMock) MinimockFinish()

+ func (m *ExecutionBrokerIMock) MinimockIsKnownRequestDone() bool

+ func (m *ExecutionBrokerIMock) MinimockIsKnownRequestInspect()

+ func (m *ExecutionBrokerIMock) MinimockMoreRequestsOnLedgerDone() bool

+ func (m *ExecutionBrokerIMock) MinimockMoreRequestsOnLedgerInspect()

+ func (m *ExecutionBrokerIMock) MinimockNoMoreRequestsOnLedgerDone() bool

+ func (m *ExecutionBrokerIMock) MinimockNoMoreRequestsOnLedgerInspect()

+ func (m *ExecutionBrokerIMock) MinimockOnPulseDone() bool

+ func (m *ExecutionBrokerIMock) MinimockOnPulseInspect()

+ func (m *ExecutionBrokerIMock) MinimockPendingStateDone() bool

+ func (m *ExecutionBrokerIMock) MinimockPendingStateInspect()

+ func (m *ExecutionBrokerIMock) MinimockPrevExecutorPendingResultDone() bool

+ func (m *ExecutionBrokerIMock) MinimockPrevExecutorPendingResultInspect()

+ func (m *ExecutionBrokerIMock) MinimockPrevExecutorSentPendingFinishedDone() bool

+ func (m *ExecutionBrokerIMock) MinimockPrevExecutorSentPendingFinishedInspect()

+ func (m *ExecutionBrokerIMock) MinimockPrevExecutorStillExecutingDone() bool

+ func (m *ExecutionBrokerIMock) MinimockPrevExecutorStillExecutingInspect()

+ func (m *ExecutionBrokerIMock) MinimockSetNotPendingDone() bool

+ func (m *ExecutionBrokerIMock) MinimockSetNotPendingInspect()

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

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

+ func (mmAbandonedRequestsOnLedger *ExecutionBrokerIMock) AbandonedRequestsOnLedgerAfterCounter() uint64

+ func (mmAbandonedRequestsOnLedger *ExecutionBrokerIMock) AbandonedRequestsOnLedgerBeforeCounter() uint64

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

+ func (mmAddAdditionalRequestFromPrevExecutor *ExecutionBrokerIMock) AddAdditionalRequestFromPrevExecutorAfterCounter() uint64

+ func (mmAddAdditionalRequestFromPrevExecutor *ExecutionBrokerIMock) AddAdditionalRequestFromPrevExecutorBeforeCounter() uint64

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

+ func (mmAddFreshRequest *ExecutionBrokerIMock) AddFreshRequestAfterCounter() uint64

+ func (mmAddFreshRequest *ExecutionBrokerIMock) AddFreshRequestBeforeCounter() uint64

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

+ func (mmAddRequestsFromLedger *ExecutionBrokerIMock) AddRequestsFromLedgerAfterCounter() uint64

+ func (mmAddRequestsFromLedger *ExecutionBrokerIMock) AddRequestsFromLedgerBeforeCounter() uint64

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

+ func (mmAddRequestsFromPrevExecutor *ExecutionBrokerIMock) AddRequestsFromPrevExecutorAfterCounter() uint64

+ func (mmAddRequestsFromPrevExecutor *ExecutionBrokerIMock) AddRequestsFromPrevExecutorBeforeCounter() uint64

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

+ func (mmIsKnownRequest *ExecutionBrokerIMock) IsKnownRequestAfterCounter() uint64

+ func (mmIsKnownRequest *ExecutionBrokerIMock) IsKnownRequestBeforeCounter() uint64

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

+ func (mmMoreRequestsOnLedger *ExecutionBrokerIMock) MoreRequestsOnLedgerAfterCounter() uint64

+ func (mmMoreRequestsOnLedger *ExecutionBrokerIMock) MoreRequestsOnLedgerBeforeCounter() uint64

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

+ func (mmNoMoreRequestsOnLedger *ExecutionBrokerIMock) NoMoreRequestsOnLedgerAfterCounter() uint64

+ func (mmNoMoreRequestsOnLedger *ExecutionBrokerIMock) NoMoreRequestsOnLedgerBeforeCounter() uint64

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

+ func (mmOnPulse *ExecutionBrokerIMock) OnPulseAfterCounter() uint64

+ func (mmOnPulse *ExecutionBrokerIMock) OnPulseBeforeCounter() uint64

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

+ func (mmPendingState *ExecutionBrokerIMock) PendingStateAfterCounter() uint64

+ func (mmPendingState *ExecutionBrokerIMock) PendingStateBeforeCounter() uint64

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

+ func (mmPrevExecutorPendingResult *ExecutionBrokerIMock) PrevExecutorPendingResultAfterCounter() uint64

+ func (mmPrevExecutorPendingResult *ExecutionBrokerIMock) PrevExecutorPendingResultBeforeCounter() uint64

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

+ func (mmPrevExecutorSentPendingFinished *ExecutionBrokerIMock) PrevExecutorSentPendingFinishedAfterCounter() uint64

+ func (mmPrevExecutorSentPendingFinished *ExecutionBrokerIMock) PrevExecutorSentPendingFinishedBeforeCounter() uint64

+ func (mmPrevExecutorStillExecuting *ExecutionBrokerIMock) PrevExecutorStillExecuting(ctx context.Context)

+ func (mmPrevExecutorStillExecuting *ExecutionBrokerIMock) PrevExecutorStillExecutingAfterCounter() uint64

+ func (mmPrevExecutorStillExecuting *ExecutionBrokerIMock) PrevExecutorStillExecutingBeforeCounter() uint64

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

+ func (mmSetNotPending *ExecutionBrokerIMock) SetNotPendingAfterCounter() uint64

+ func (mmSetNotPending *ExecutionBrokerIMock) SetNotPendingBeforeCounter() uint64

+ type ExecutionBrokerIMockAbandonedRequestsOnLedgerExpectation struct

+ Counter uint64

+ type ExecutionBrokerIMockAbandonedRequestsOnLedgerParams struct

+ type ExecutionBrokerIMockAddAdditionalRequestFromPrevExecutorExpectation struct

+ Counter uint64

+ type ExecutionBrokerIMockAddAdditionalRequestFromPrevExecutorParams struct

+ type ExecutionBrokerIMockAddFreshRequestExpectation struct

+ Counter uint64

+ type ExecutionBrokerIMockAddFreshRequestParams struct

+ type ExecutionBrokerIMockAddRequestsFromLedgerExpectation struct

+ Counter uint64

+ type ExecutionBrokerIMockAddRequestsFromLedgerParams struct

+ type ExecutionBrokerIMockAddRequestsFromPrevExecutorExpectation struct

+ Counter uint64

+ type ExecutionBrokerIMockAddRequestsFromPrevExecutorParams struct

+ type ExecutionBrokerIMockIsKnownRequestExpectation struct

+ Counter uint64

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

+ type ExecutionBrokerIMockIsKnownRequestParams struct

+ type ExecutionBrokerIMockIsKnownRequestResults struct

+ type ExecutionBrokerIMockMoreRequestsOnLedgerExpectation struct

+ Counter uint64

+ type ExecutionBrokerIMockMoreRequestsOnLedgerParams struct

+ type ExecutionBrokerIMockNoMoreRequestsOnLedgerExpectation struct

+ Counter uint64

+ type ExecutionBrokerIMockNoMoreRequestsOnLedgerParams struct

+ type ExecutionBrokerIMockOnPulseExpectation struct

+ Counter uint64

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

+ type ExecutionBrokerIMockOnPulseParams struct

+ type ExecutionBrokerIMockOnPulseResults struct

+ type ExecutionBrokerIMockPendingStateExpectation struct

+ Counter uint64

+ type ExecutionBrokerIMockPendingStateResults struct

+ type ExecutionBrokerIMockPrevExecutorPendingResultExpectation struct

+ Counter uint64

+ type ExecutionBrokerIMockPrevExecutorPendingResultParams struct

+ type ExecutionBrokerIMockPrevExecutorSentPendingFinishedExpectation struct

+ Counter uint64

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

+ type ExecutionBrokerIMockPrevExecutorSentPendingFinishedParams struct

+ type ExecutionBrokerIMockPrevExecutorSentPendingFinishedResults struct

+ type ExecutionBrokerIMockPrevExecutorStillExecutingExpectation struct

+ Counter uint64

+ type ExecutionBrokerIMockPrevExecutorStillExecutingParams struct

+ type ExecutionBrokerIMockSetNotPendingExpectation struct

+ Counter uint64

+ type ExecutionBrokerIMockSetNotPendingParams struct

+ type HandleAbandonedRequestsNotification struct

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

+ type HandleAdditionalCallFromPreviousExecutor struct

+ Message payload.Meta

+ Parcel insolar.Parcel

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

+ type HandleCall struct

+ Message payload.Meta

+ Parcel insolar.Parcel

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

+ type HandleExecutorResults struct

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

+ type HandlePendingFinished struct

+ Message payload.Meta

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

+ type HandleSagaCallAcceptNotification struct

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

+ type HandleStillExecuting struct

+ Message payload.Meta

+ Parcel insolar.Parcel

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

+ type HandleUpdateJet struct

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

+ type Init struct

+ Message *message.Message

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

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

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

type LogicRunner

+ DescriptorsCache artifacts.DescriptorsCache

+ FlowDispatcher dispatcher.Dispatcher

+ JetStorage jet.Storage

+ MachinesManager machinesmanager.MachinesManager

+ OutgoingSender OutgoingRequestSender

+ Publisher watermillMsg.Publisher

+ PulseAccessor insolarPulse.Accessor

+ RequestsExecutor RequestsExecutor

+ ResultsMatcher ResultMatcher

+ Sender bus.Sender

+ SenderWithRetry *bus.WaitOKSender

+ ShutdownFlag shutdown.Flag

+ StateStorage StateStorage

+ WriteController writecontroller.WriteController

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

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

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

+ func (lr *LogicRunner) LRI()

+ type OutgoingRequestSender interface

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

+ SendOutgoingRequest func(ctx context.Context, reqRef insolar.Reference, req *record.OutgoingRequest) (*insolar.Reference, insolar.Arguments, *record.IncomingRequest, error)

+ Stop func(ctx context.Context)

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

+ type OutgoingRequestSenderMock struct

+ SendAbandonedOutgoingRequestMock mOutgoingRequestSenderMockSendAbandonedOutgoingRequest

+ SendOutgoingRequestMock mOutgoingRequestSenderMockSendOutgoingRequest

+ StopMock mOutgoingRequestSenderMockStop

+ func NewOutgoingRequestSenderMock(t minimock.Tester) *OutgoingRequestSenderMock

+ func (m *OutgoingRequestSenderMock) MinimockFinish()

+ func (m *OutgoingRequestSenderMock) MinimockSendAbandonedOutgoingRequestDone() bool

+ func (m *OutgoingRequestSenderMock) MinimockSendAbandonedOutgoingRequestInspect()

+ func (m *OutgoingRequestSenderMock) MinimockSendOutgoingRequestDone() bool

+ func (m *OutgoingRequestSenderMock) MinimockSendOutgoingRequestInspect()

+ func (m *OutgoingRequestSenderMock) MinimockStopDone() bool

+ func (m *OutgoingRequestSenderMock) MinimockStopInspect()

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

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

+ func (mmSendAbandonedOutgoingRequest *OutgoingRequestSenderMock) SendAbandonedOutgoingRequestAfterCounter() uint64

+ func (mmSendAbandonedOutgoingRequest *OutgoingRequestSenderMock) SendAbandonedOutgoingRequestBeforeCounter() uint64

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

+ func (mmSendOutgoingRequest *OutgoingRequestSenderMock) SendOutgoingRequestAfterCounter() uint64

+ func (mmSendOutgoingRequest *OutgoingRequestSenderMock) SendOutgoingRequestBeforeCounter() uint64

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

+ func (mmStop *OutgoingRequestSenderMock) StopAfterCounter() uint64

+ func (mmStop *OutgoingRequestSenderMock) StopBeforeCounter() uint64

+ type OutgoingRequestSenderMockSendAbandonedOutgoingRequestExpectation struct

+ Counter uint64

+ type OutgoingRequestSenderMockSendAbandonedOutgoingRequestParams struct

+ type OutgoingRequestSenderMockSendOutgoingRequestExpectation struct

+ Counter uint64

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

+ type OutgoingRequestSenderMockSendOutgoingRequestParams struct

+ type OutgoingRequestSenderMockSendOutgoingRequestResults struct

+ type OutgoingRequestSenderMockStopExpectation struct

+ Counter uint64

+ type OutgoingRequestSenderMockStopParams struct

+ type ProxyImplementation interface

+ DeactivateObject func(context.Context, *common.Transcript, rpctypes.UpDeactivateObjectReq, ...) error

+ GetCode func(context.Context, *common.Transcript, rpctypes.UpGetCodeReq, ...) error

+ RouteCall func(context.Context, *common.Transcript, rpctypes.UpRouteReq, ...) error

+ SaveAsChild func(context.Context, *common.Transcript, rpctypes.UpSaveAsChildReq, ...) error

+ func NewExecutionProxyImplementation(dc artifacts.DescriptorsCache, cr insolar.ContractRequester, ...) ProxyImplementation

+ func NewValidationProxyImplementation(dc artifacts.DescriptorsCache) ProxyImplementation

+ type ProxyImplementationMock struct

+ DeactivateObjectMock mProxyImplementationMockDeactivateObject

+ GetCodeMock mProxyImplementationMockGetCode

+ RouteCallMock mProxyImplementationMockRouteCall

+ SaveAsChildMock mProxyImplementationMockSaveAsChild

+ func NewProxyImplementationMock(t minimock.Tester) *ProxyImplementationMock

+ func (m *ProxyImplementationMock) MinimockDeactivateObjectDone() bool

+ func (m *ProxyImplementationMock) MinimockDeactivateObjectInspect()

+ func (m *ProxyImplementationMock) MinimockFinish()

+ func (m *ProxyImplementationMock) MinimockGetCodeDone() bool

+ func (m *ProxyImplementationMock) MinimockGetCodeInspect()

+ func (m *ProxyImplementationMock) MinimockRouteCallDone() bool

+ func (m *ProxyImplementationMock) MinimockRouteCallInspect()

+ func (m *ProxyImplementationMock) MinimockSaveAsChildDone() bool

+ func (m *ProxyImplementationMock) MinimockSaveAsChildInspect()

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

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

+ func (mmDeactivateObject *ProxyImplementationMock) DeactivateObjectAfterCounter() uint64

+ func (mmDeactivateObject *ProxyImplementationMock) DeactivateObjectBeforeCounter() uint64

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

+ func (mmGetCode *ProxyImplementationMock) GetCodeAfterCounter() uint64

+ func (mmGetCode *ProxyImplementationMock) GetCodeBeforeCounter() uint64

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

+ func (mmRouteCall *ProxyImplementationMock) RouteCallAfterCounter() uint64

+ func (mmRouteCall *ProxyImplementationMock) RouteCallBeforeCounter() uint64

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

+ func (mmSaveAsChild *ProxyImplementationMock) SaveAsChildAfterCounter() uint64

+ func (mmSaveAsChild *ProxyImplementationMock) SaveAsChildBeforeCounter() uint64

+ type ProxyImplementationMockDeactivateObjectExpectation struct

+ Counter uint64

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

+ type ProxyImplementationMockDeactivateObjectParams struct

+ type ProxyImplementationMockDeactivateObjectResults struct

+ type ProxyImplementationMockGetCodeExpectation struct

+ Counter uint64

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

+ type ProxyImplementationMockGetCodeParams struct

+ type ProxyImplementationMockGetCodeResults struct

+ type ProxyImplementationMockRouteCallExpectation struct

+ Counter uint64

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

+ type ProxyImplementationMockRouteCallParams struct

+ type ProxyImplementationMockRouteCallResults struct

+ type ProxyImplementationMockSaveAsChildExpectation struct

+ Counter uint64

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

+ type ProxyImplementationMockSaveAsChildParams struct

+ type ProxyImplementationMockSaveAsChildResults struct

+ type RPCMethods struct

+ func NewRPCMethods(am artifacts.Client, dc artifacts.DescriptorsCache, ...) *RPCMethods

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

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

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

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

+ type RecordErrorResult struct

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

+ type RegisterIncomingRequest struct

+ ArtifactManager artifacts.Client

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

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

+ type RequestsExecutor interface

+ Execute func(ctx context.Context, current *common.Transcript) (artifacts.RequestResult, error)

+ ExecuteAndSave func(ctx context.Context, current *common.Transcript) (insolar.Reply, error)

+ Save func(ctx context.Context, current *common.Transcript, res artifacts.RequestResult) (insolar.Reply, error)

+ SendReply func(ctx context.Context, reqRef insolar.Reference, req record.IncomingRequest, ...)

+ func NewRequestsExecutor() RequestsExecutor

+ type RequestsExecutorMock struct

+ ExecuteAndSaveMock mRequestsExecutorMockExecuteAndSave

+ ExecuteMock mRequestsExecutorMockExecute

+ SaveMock mRequestsExecutorMockSave

+ SendReplyMock mRequestsExecutorMockSendReply

+ func NewRequestsExecutorMock(t minimock.Tester) *RequestsExecutorMock

+ func (m *RequestsExecutorMock) MinimockExecuteAndSaveDone() bool

+ func (m *RequestsExecutorMock) MinimockExecuteAndSaveInspect()

+ func (m *RequestsExecutorMock) MinimockExecuteDone() bool

+ func (m *RequestsExecutorMock) MinimockExecuteInspect()

+ func (m *RequestsExecutorMock) MinimockFinish()

+ func (m *RequestsExecutorMock) MinimockSaveDone() bool

+ func (m *RequestsExecutorMock) MinimockSaveInspect()

+ func (m *RequestsExecutorMock) MinimockSendReplyDone() bool

+ func (m *RequestsExecutorMock) MinimockSendReplyInspect()

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

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

+ func (mmExecute *RequestsExecutorMock) ExecuteAfterCounter() uint64

+ func (mmExecute *RequestsExecutorMock) ExecuteBeforeCounter() uint64

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

+ func (mmExecuteAndSave *RequestsExecutorMock) ExecuteAndSaveAfterCounter() uint64

+ func (mmExecuteAndSave *RequestsExecutorMock) ExecuteAndSaveBeforeCounter() uint64

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

+ func (mmSave *RequestsExecutorMock) SaveAfterCounter() uint64

+ func (mmSave *RequestsExecutorMock) SaveBeforeCounter() uint64

+ func (mmSendReply *RequestsExecutorMock) SendReply(ctx context.Context, reqRef insolar.Reference, req record.IncomingRequest, ...)

+ func (mmSendReply *RequestsExecutorMock) SendReplyAfterCounter() uint64

+ func (mmSendReply *RequestsExecutorMock) SendReplyBeforeCounter() uint64

+ type RequestsExecutorMockExecuteAndSaveExpectation struct

+ Counter uint64

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

+ type RequestsExecutorMockExecuteAndSaveParams struct

+ type RequestsExecutorMockExecuteAndSaveResults struct

+ type RequestsExecutorMockExecuteExpectation struct

+ Counter uint64

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

+ type RequestsExecutorMockExecuteParams struct

+ type RequestsExecutorMockExecuteResults struct

+ type RequestsExecutorMockSaveExpectation struct

+ Counter uint64

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

+ type RequestsExecutorMockSaveParams struct

+ type RequestsExecutorMockSaveResults struct

+ type RequestsExecutorMockSendReplyExpectation struct

+ Counter uint64

+ type RequestsExecutorMockSendReplyParams struct

+ type RequestsFetcher interface

+ Abort func(ctx context.Context)

+ FetchPendings func(ctx context.Context)

+ func NewRequestsFetcher(obj insolar.Reference, am artifacts.Client, br ExecutionBrokerI, ...) RequestsFetcher

+ type RequestsFetcherMock struct

+ AbortMock mRequestsFetcherMockAbort

+ FetchPendingsMock mRequestsFetcherMockFetchPendings

+ func NewRequestsFetcherMock(t minimock.Tester) *RequestsFetcherMock

+ func (m *RequestsFetcherMock) MinimockAbortDone() bool

+ func (m *RequestsFetcherMock) MinimockAbortInspect()

+ func (m *RequestsFetcherMock) MinimockFetchPendingsDone() bool

+ func (m *RequestsFetcherMock) MinimockFetchPendingsInspect()

+ func (m *RequestsFetcherMock) MinimockFinish()

+ func (m *RequestsFetcherMock) MinimockWait(timeout mm_time.Duration)

+ func (mmAbort *RequestsFetcherMock) Abort(ctx context.Context)

+ func (mmAbort *RequestsFetcherMock) AbortAfterCounter() uint64

+ func (mmAbort *RequestsFetcherMock) AbortBeforeCounter() uint64

+ func (mmFetchPendings *RequestsFetcherMock) FetchPendings(ctx context.Context)

+ func (mmFetchPendings *RequestsFetcherMock) FetchPendingsAfterCounter() uint64

+ func (mmFetchPendings *RequestsFetcherMock) FetchPendingsBeforeCounter() uint64

+ type RequestsFetcherMockAbortExpectation struct

+ Counter uint64

+ type RequestsFetcherMockAbortParams struct

+ type RequestsFetcherMockFetchPendingsExpectation struct

+ Counter uint64

+ type RequestsFetcherMockFetchPendingsParams struct

+ type ResultMatcher interface

+ AddStillExecution func(ctx context.Context, msg payload.StillExecuting)

+ AddUnwantedResponse func(ctx context.Context, msg payload.ReturnResults)

+ Clear func(ctx context.Context)

+ type ResultMatcherMock struct

+ AddStillExecutionMock mResultMatcherMockAddStillExecution

+ AddUnwantedResponseMock mResultMatcherMockAddUnwantedResponse

+ ClearMock mResultMatcherMockClear

+ func NewResultMatcherMock(t minimock.Tester) *ResultMatcherMock

+ func (m *ResultMatcherMock) MinimockAddStillExecutionDone() bool

+ func (m *ResultMatcherMock) MinimockAddStillExecutionInspect()

+ func (m *ResultMatcherMock) MinimockAddUnwantedResponseDone() bool

+ func (m *ResultMatcherMock) MinimockAddUnwantedResponseInspect()

+ func (m *ResultMatcherMock) MinimockClearDone() bool

+ func (m *ResultMatcherMock) MinimockClearInspect()

+ func (m *ResultMatcherMock) MinimockFinish()

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

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

+ func (mmAddStillExecution *ResultMatcherMock) AddStillExecutionAfterCounter() uint64

+ func (mmAddStillExecution *ResultMatcherMock) AddStillExecutionBeforeCounter() uint64

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

+ func (mmAddUnwantedResponse *ResultMatcherMock) AddUnwantedResponseAfterCounter() uint64

+ func (mmAddUnwantedResponse *ResultMatcherMock) AddUnwantedResponseBeforeCounter() uint64

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

+ func (mmClear *ResultMatcherMock) ClearAfterCounter() uint64

+ func (mmClear *ResultMatcherMock) ClearBeforeCounter() uint64

+ type ResultMatcherMockAddStillExecutionExpectation struct

+ Counter uint64

+ type ResultMatcherMockAddStillExecutionParams struct

+ type ResultMatcherMockAddUnwantedResponseExpectation struct

+ Counter uint64

+ type ResultMatcherMockAddUnwantedResponseParams struct

+ type ResultMatcherMockClearExpectation struct

+ Counter uint64

+ type ResultMatcherMockClearParams struct

+ type StateStorage interface

+ GetExecutionRegistry func(ref insolar.Reference) executionregistry.ExecutionRegistry

+ GetExecutionState func(ref insolar.Reference) ExecutionBrokerI

+ IsEmpty func() bool

+ OnPulse func(ctx context.Context, pulse insolar.Pulse) map[insolar.Reference][]payload.Payload

+ UpsertExecutionState func(ref insolar.Reference) ExecutionBrokerI

+ func NewStateStorage(publisher watermillMsg.Publisher, requestsExecutor RequestsExecutor, ...) StateStorage

+ type StateStorageMock struct

+ GetExecutionRegistryMock mStateStorageMockGetExecutionRegistry

+ GetExecutionStateMock mStateStorageMockGetExecutionState

+ IsEmptyMock mStateStorageMockIsEmpty

+ OnPulseMock mStateStorageMockOnPulse

+ UpsertExecutionStateMock mStateStorageMockUpsertExecutionState

+ func NewStateStorageMock(t minimock.Tester) *StateStorageMock

+ func (m *StateStorageMock) MinimockFinish()

+ func (m *StateStorageMock) MinimockGetExecutionRegistryDone() bool

+ func (m *StateStorageMock) MinimockGetExecutionRegistryInspect()

+ func (m *StateStorageMock) MinimockGetExecutionStateDone() bool

+ func (m *StateStorageMock) MinimockGetExecutionStateInspect()

+ func (m *StateStorageMock) MinimockIsEmptyDone() bool

+ func (m *StateStorageMock) MinimockIsEmptyInspect()

+ func (m *StateStorageMock) MinimockOnPulseDone() bool

+ func (m *StateStorageMock) MinimockOnPulseInspect()

+ func (m *StateStorageMock) MinimockUpsertExecutionStateDone() bool

+ func (m *StateStorageMock) MinimockUpsertExecutionStateInspect()

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

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

+ func (mmGetExecutionRegistry *StateStorageMock) GetExecutionRegistryAfterCounter() uint64

+ func (mmGetExecutionRegistry *StateStorageMock) GetExecutionRegistryBeforeCounter() uint64

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

+ func (mmGetExecutionState *StateStorageMock) GetExecutionStateAfterCounter() uint64

+ func (mmGetExecutionState *StateStorageMock) GetExecutionStateBeforeCounter() uint64

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

+ func (mmIsEmpty *StateStorageMock) IsEmptyAfterCounter() uint64

+ func (mmIsEmpty *StateStorageMock) IsEmptyBeforeCounter() uint64

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

+ func (mmOnPulse *StateStorageMock) OnPulseAfterCounter() uint64

+ func (mmOnPulse *StateStorageMock) OnPulseBeforeCounter() uint64

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

+ func (mmUpsertExecutionState *StateStorageMock) UpsertExecutionStateAfterCounter() uint64

+ func (mmUpsertExecutionState *StateStorageMock) UpsertExecutionStateBeforeCounter() uint64

+ type StateStorageMockGetExecutionRegistryExpectation struct

+ Counter uint64

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

+ type StateStorageMockGetExecutionRegistryParams struct

+ type StateStorageMockGetExecutionRegistryResults struct

+ type StateStorageMockGetExecutionStateExpectation struct

+ Counter uint64

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

+ type StateStorageMockGetExecutionStateParams struct

+ type StateStorageMockGetExecutionStateResults struct

+ type StateStorageMockIsEmptyExpectation struct

+ Counter uint64

+ type StateStorageMockIsEmptyResults struct

+ type StateStorageMockOnPulseExpectation struct

+ Counter uint64

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

+ type StateStorageMockOnPulseParams struct

+ type StateStorageMockOnPulseResults struct

+ type StateStorageMockUpsertExecutionStateExpectation struct

+ Counter uint64

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

+ type StateStorageMockUpsertExecutionStateParams struct

+ type StateStorageMockUpsertExecutionStateResults struct

v0.9.0-rc4

Aug 30, 2019

v0.9.0-rc3

Aug 29, 2019

v0.9.0-rc2

Aug 28, 2019

v0.9.0-rc1

Aug 20, 2019

v0.8.7

Apr 23, 2019

v0.8.6

Mar 22, 2019

v0.8.5

Mar 12, 2019

v0.8.4

Feb 26, 2019

v0.8.3

Feb 22, 2019

v0.8.2

Feb 21, 2019

v0.8.1

Feb 21, 2019

v0.8.0

Feb 20, 2019

Changes in this version

type ExecutionState

+ HasPendingCheckMutex sync.Mutex

+ LedgerHasMoreRequests bool

+ LedgerQueueElement *ExecutionQueueElement

type LogicRunner

+ func (lr *LogicRunner) ClarifyPendingState(ctx context.Context, es *ExecutionState, parcel core.Parcel) error

+ func (lr *LogicRunner) HandleAbandonedRequestsNotificationMessage(ctx context.Context, parcel core.Parcel) (core.Reply, error)

v0.7.6

Jan 29, 2019

v0.7.5

Jan 29, 2019

Changes in this version

type CaseBind

+ Requests []CaseRequest

+ func NewCaseBind() *CaseBind

+ func NewCaseBindFromExecutorResultsMessage(msg *message.ExecutorResults) *CaseBind

+ func NewCaseBindFromValidateMessage(ctx context.Context, mb core.MessageBus, msg *message.ValidateCaseBind) *CaseBind

+ func (cb *CaseBind) NewRequest(p core.Parcel, request Ref, mb core.MessageBus) *CaseRequest

+ func (cb *CaseBind) ToValidateMessage(ctx context.Context, ref Ref, pulse core.Pulse) *message.ValidateCaseBind

+ type CaseBindReplay struct

+ CaseBind CaseBind

+ Fail int

+ Pulse core.Pulse

+ Record int

+ Request int

+ Steps int

+ func NewCaseBindReplay(cb CaseBind) *CaseBindReplay

+ func (r *CaseBindReplay) NextRequest() *CaseRequest

+ type CaseRequest struct

+ Error string

+ MessageBus core.MessageBus

+ Parcel core.Parcel

+ Reply core.Reply

+ Request core.RecordRef

+ type CurrentExecution struct

+ Context context.Context

+ LogicContext *core.LogicCallContext

+ Request *Ref

+ RequesterNode *Ref

+ ReturnMode message.MethodReturnMode

+ SentResult bool

+ Sequence uint64

+ type ExecutionQueueElement struct

+ type ExecutionQueueResult struct

type ExecutionState

+ ArtifactManager core.ArtifactManager

+ Behaviour ValidationBehaviour

+ Current *CurrentExecution

+ PendingConfirmed bool

+ Queue []ExecutionQueueElement

+ QueueProcessorActive bool

+ func (es *ExecutionState) CheckPendingRequests(ctx context.Context, inMsg core.Message) (message.PendingState, error)

+ func (es *ExecutionState) WrapError(err error, message string) error

type LogicRunner

+ ContractRequester core.ContractRequester

+ NodeNetwork core.NodeNetwork

+ PulseStorage core.PulseStorage

+ func (lr *LogicRunner) CheckExecutionLoop(ctx context.Context, es *ExecutionState, parcel core.Parcel) bool

+ func (lr *LogicRunner) GetObjectState(ref Ref) *ObjectState

+ func (lr *LogicRunner) HandleExecutorResultsMessage(ctx context.Context, inmsg core.Parcel) (core.Reply, error)

+ func (lr *LogicRunner) HandlePendingFinishedMessage(ctx context.Context, parcel core.Parcel) (core.Reply, error)

+ func (lr *LogicRunner) HandleStillExecutingMessage(ctx context.Context, parcel core.Parcel) (core.Reply, error)

+ func (lr *LogicRunner) HandleValidateCaseBindMessage(ctx context.Context, inmsg core.Parcel) (core.Reply, error)

+ func (lr *LogicRunner) HandleValidationResultsMessage(ctx context.Context, inmsg core.Parcel) (core.Reply, error)

+ func (lr *LogicRunner) MustObjectState(ref Ref) *ObjectState

+ func (lr *LogicRunner) ProcessExecutionQueue(ctx context.Context, es *ExecutionState)

+ func (lr *LogicRunner) RegisterRequest(ctx context.Context, parcel core.Parcel) (*Ref, error)

+ func (lr *LogicRunner) StartQueueProcessorIfNeeded(ctx context.Context, es *ExecutionState, msg core.Message) error

+ func (lr *LogicRunner) UpsertObjectState(ref Ref) *ObjectState

type ObjectBody

+ Prototype *Ref

+ type ObjectState struct

+ Consensus *Consensus

+ ExecutionState *ExecutionState

+ Ref *Ref

+ Validation *ExecutionState

+ func (st *ObjectState) MustModeState(mode string) (res *ExecutionState)

+ func (st *ObjectState) RefreshConsensus()

+ func (st *ObjectState) StartValidation() *ExecutionState

+ func (st *ObjectState) WrapError(err error, message string) error

type RPC

+ func (gpr *RPC) GetObjChildrenIterator(req rpctypes.UpGetObjChildrenIteratorReq, ...) (err error)

type ValidationBehaviour

+ Mode func() string

+ Result func(reply core.Reply, err error) error

type ValidationChecker

+ func (vb *ValidationChecker) Mode() string

+ func (vb *ValidationChecker) NextRequest() *CaseRequest

+ func (vb *ValidationChecker) Result(reply core.Reply, err error) error

type ValidationSaver

+ func (vb *ValidationSaver) Mode() string

+ func (vb *ValidationSaver) NewRequest(p core.Parcel, request Ref, mb core.MessageBus)

+ func (vb *ValidationSaver) Result(reply core.Reply, err error) error

v0.7.4-alpha

Jan 28, 2019

v0.7.3-alpha

Jan 24, 2019

v0.7.2-alpha

Jan 22, 2019

v0.7.1-alpha

Jan 21, 2019

v0.7.0-alpha

Jan 21, 2019

v0.6.3

Nov 30, 2018

Changes in this version

type Consensus

+ CaseBind core.CaseBind

+ type Error struct

+ Contract *Ref

+ Err error

+ Method string

+ Request *Ref

+ func (lre Error) Error() string

type ExecutionState

+ Method string

+ Ref *Ref

+ func (es *ExecutionState) AddCaseRecord(record core.CaseRecord)

+ func (es *ExecutionState) AddCaseRequest(record core.CaseRecord)

+ func (es *ExecutionState) ErrorWrap(err error, message string) error

+ func (es *ExecutionState) Lock()

+ func (es *ExecutionState) ReleaseQueue()

+ func (es *ExecutionState) Unlock()

type LogicRunner

+ JetCoordinator core.JetCoordinator

+ ParcelFactory message.ParcelFactory

+ PlatformCryptographyScheme core.PlatformCryptographyScheme

+ PulseManager core.PulseManager

+ func (lr *LogicRunner) CheckOurRole(ctx context.Context, msg core.Message, role core.DynamicRole) error

+ func (lr *LogicRunner) MustExecutionState(ref Ref) *ExecutionState

+ func (lr *LogicRunner) RegisterHandlers()

type ObjectBody

+ Parent *Ref

v0.6.2

Nov 1, 2018

Changes in this version

type Consensus

+ Message core.SignedMessage

+ func (c *Consensus) FindRequestBefore(steps int) *core.RecordID

+ func (c *Consensus) GetReference() Ref

+ func (c *Consensus) GetValidatorSignatures() (messages []core.Message)

type ConsensusRecord

+ Message core.SignedMessage

type LogicRunner

+ func (lr *LogicRunner) GetExecution(ref Ref) *ExecutionState

+ func (lr *LogicRunner) RefreshConsensus()

+ type ObjectBody struct

+ ClassHeadRef *Ref

+ CodeMachineType core.MachineType

+ CodeRef *Ref

+ Object []byte

type ValidationBehaviour

+ GetRole func() core.JetRole

type ValidationChecker

+ func (vb ValidationChecker) GetRole() core.JetRole

type ValidationSaver

+ func (vb ValidationSaver) GetRole() core.JetRole

v0.6.1

Oct 23, 2018

Changes in this version

+ type Consensus struct

+ CaseRecords []core.CaseRecord

+ Have int

+ Need int

+ Results map[Ref]ConsensusRecord

+ Total int

+ func (c *Consensus) AddExecutor(m *message.ExecutorResults)

+ func (c *Consensus) AddValidated(m *message.ValidationResults)

+ func (c *Consensus) CheckReady()

+ type ConsensusRecord struct

+ Error error

+ Steps int

+ type ExecutionState struct

type LogicRunner

+ Ledger core.Ledger

+ Network core.Network

+ Pulse core.Pulse

+ func (lr *LogicRunner) GetConsensus(r Ref) (*Consensus, bool)

+ func (lr *LogicRunner) UpsertExecution(ref Ref) *ExecutionState

type ValidationBehaviour

+ RegisterRequest func(m message.IBaseLogicMessage) (*Ref, error)

type ValidationChecker

+ func (vb ValidationChecker) RegisterRequest(m message.IBaseLogicMessage) (*Ref, error)

type ValidationSaver

+ func (vb ValidationSaver) RegisterRequest(m message.IBaseLogicMessage) (*Ref, error)

v0.6.0

Oct 16, 2018

Changes in this version

+ type ExecutionContext struct

+ Pending bool

+ Queue []core.Message

+ TraceID []byte

type LogicRunner

+ func (lr *LogicRunner) ExecutorResults(inmsg core.Message) (core.Reply, error)

+ func (lr *LogicRunner) GetContext(ref Ref) (ExecutionContext, bool)

+ func (lr *LogicRunner) ProcessValidationResults(inmsg core.Message) (core.Reply, error)

+ func (lr *LogicRunner) SetContext(ref Ref, ec ExecutionContext) bool

+ func (lr *LogicRunner) ValidateCaseBind(inmsg core.Message) (core.Reply, error)

type RPC

+ func (gpr *RPC) DeactivateObject(req rpctypes.UpDeactivateObjectReq, rep *rpctypes.UpDeactivateObjectResp) error

+ type Ref = core.RecordRef

v0.5.0

Oct 9, 2018

Changes in this version

+ func MakeBaseMessage(req rpctypes.UpBaseReq) message.BaseLogicMessage

type LogicRunner

+ func (lr *LogicRunner) Validate(ref core.RecordRef, p core.Pulse, cr []core.CaseRecord) (int, error)

+ type ValidationBehaviour interface

+ Begin func(refs core.RecordRef, record core.CaseRecord)

+ End func(refs core.RecordRef, record core.CaseRecord)

+ ModifyContext func(ctx *core.LogicCallContext)

+ NeedSave func() bool

+ type ValidationChecker struct

+ func (vb ValidationChecker) Begin(refs core.RecordRef, record core.CaseRecord)

+ func (vb ValidationChecker) End(refs core.RecordRef, record core.CaseRecord)

+ func (vb ValidationChecker) ModifyContext(ctx *core.LogicCallContext)

+ func (vb ValidationChecker) NeedSave() bool

+ type ValidationSaver struct

+ func (vb ValidationSaver) Begin(refs core.RecordRef, record core.CaseRecord)

+ func (vb ValidationSaver) End(refs core.RecordRef, record core.CaseRecord)

+ func (vb ValidationSaver) ModifyContext(ctx *core.LogicCallContext)

+ func (vb ValidationSaver) NeedSave() bool

v0.4.1

Oct 3, 2018

v0.4.0

Oct 3, 2018

Changes in this version

+ func HashInterface(in interface{}) []byte

+ func MakeBaseEvent(req rpctypes.UpBaseReq) message.BaseLogicEvent

+ type CaseBind struct

+ P core.Pulse

+ R map[trf][]CaseRecord

+ type CaseRecord struct

+ ReqSig []byte

+ Resp rpctypes.UpRespIface

+ Type CaseRecordType

+ type CaseRecordType int

+ const CaseRecordTypeConstructorCall

+ const CaseRecordTypeConstructorCallResult

+ const CaseRecordTypeGetDelegate

+ const CaseRecordTypeGetObjChildren

+ const CaseRecordTypeMethodCall

+ const CaseRecordTypeMethodCallResult

+ const CaseRecordTypeRouteCall

+ const CaseRecordTypeSaveAsChild

+ const CaseRecordTypeSaveAsDelegate

type LogicRunner

+ MessageBus core.MessageBus

+ func (lr *LogicRunner) OnPulse(pulse core.Pulse) error

+ type RPC struct

+ func StartRPC(lr *LogicRunner) *RPC

+ func (gpr *RPC) GetCode(req rpctypes.UpGetCodeReq, reply *rpctypes.UpGetCodeResp) error

+ func (gpr *RPC) GetDelegate(req rpctypes.UpGetDelegateReq, reply *rpctypes.UpGetDelegateResp) error

+ func (gpr *RPC) GetObjChildren(req rpctypes.UpGetObjChildrenReq, reply *rpctypes.UpGetObjChildrenResp) error

+ func (gpr *RPC) RouteCall(req rpctypes.UpRouteReq, rep *rpctypes.UpRouteResp) error

+ func (gpr *RPC) RouteConstructorCall(req rpctypes.UpRouteConstructorReq, rep *rpctypes.UpRouteConstructorResp) error

+ func (gpr *RPC) SaveAsChild(req rpctypes.UpSaveAsChildReq, reply *rpctypes.UpSaveAsChildResp) error

+ func (gpr *RPC) SaveAsDelegate(req rpctypes.UpSaveAsDelegateReq, reply *rpctypes.UpSaveAsDelegateResp) error

v0.3.0

Sep 25, 2018

Changes in this version

type LogicRunner

+ EventBus core.EventBus

v0.2.0

Sep 18, 2018

Changes in this version

type LogicRunner

+ MessageRouter core.MessageRouter

v0.0.6

Sep 13, 2018

v0.0.5

Sep 4, 2018

Changes in this version

type LogicRunner

+ Cfg configuration.LogicRunner

v0.0.4

Aug 28, 2018

v0.0.3

Aug 20, 2018

Changes in this version

+ type ArtifactManager interface

+ Get func(ref string) (data []byte, codeRef Reference, err error)

+ type Executor interface

+ Exec func(codeRef Reference, data []byte, method string, args Arguments) (newObjectState []byte, methodResults Arguments, err error)

type LogicRunner

+ ArtifactManager ArtifactManager

+ Executors [MachineTypesTotalCount]Executor

+ func NewLogicRunner(am ArtifactManager) (*LogicRunner, error)

+ func (r *LogicRunner) Execute(ref string, method string, args Arguments) ([]byte, []byte, error)

+ func (r *LogicRunner) GetExecutor(t MachineType) (Executor, error)

+ func (r *LogicRunner) RegisterExecutor(t MachineType, e Executor) error

type MachineType

+ const MachineTypesTotalCount

v0.0.2

Aug 14, 2018

Changes in this version

+ type Arguments []byte

+ type LogicRunner interface

+ Exec func(object Object, method string, args Arguments) (ret Arguments, err error)

+ Start func()

+ Stop func()

+ type MachineType int

+ const MachineTypeBuiltin

+ const MachineTypeGoPlugin

+ type Object struct

+ Data []byte

+ MachineType MachineType

+ Reference Reference

+ type Reference string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL