vnlmn

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

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CounterAwaitZero 

func CounterAwaitZero(ctx smachine.ExecutionContext, link smachine.SharedDataLink) smachine.StateUpdate

func CounterDecrement 

func CounterDecrement(ctx smachine.ExecutionContext, link smachine.SharedDataLink) smachine.StateUpdate

func CounterIncrement 

func CounterIncrement(ctx smachine.ExecutionContext, link smachine.SharedDataLink, count int) smachine.StateUpdate

func GetLifelineAnticipatedReference 

func GetLifelineAnticipatedReference(
	digester cryptkit.DataDigester,
	request *rms.VCallRequest,
	_ pulse.Number,
) reference.Global

func GetOutgoingAnticipatedReference 

func GetOutgoingAnticipatedReference(
	digester cryptkit.DataDigester,
	request *rms.VCallRequest,
	previousRef reference.Global,
	pn pulse.Number,
) reference.Global

func LRegisterRequestInterceptor 

func LRegisterRequestInterceptor(record rmsreg.GoGoSerializable) ([]rmsreg.GoGoSerializable, bool)

func MustRecordToAnyRecordLazy 

func MustRecordToAnyRecordLazy(rec SerializableReferencableBasicRecord) rms.AnyRecordLazy

Types

type DefaultRecordReferenceBuilder 

type DefaultRecordReferenceBuilder struct {
	RecordScheme   crypto.RecordScheme
	ProducerSigner cryptkit.DataSigner
	LocalNodeRef   reference.Holder
}

func NewRecordReferenceBuilder 

func NewRecordReferenceBuilder(rs crypto.RecordScheme, localNodeRef reference.Holder) *DefaultRecordReferenceBuilder

func (DefaultRecordReferenceBuilder) AnticipatedRefFromBytes 

func (s DefaultRecordReferenceBuilder) AnticipatedRefFromBytes(object reference.Global, pn pulse.Number, data []byte) reference.Global

func (DefaultRecordReferenceBuilder) AnticipatedRefFromRecord 

func (s DefaultRecordReferenceBuilder) AnticipatedRefFromRecord(object reference.Global, pn pulse.Number, record rms.BasicRecord) reference.Global

func (DefaultRecordReferenceBuilder) AnticipatedRefFromWriterTo 

func (s DefaultRecordReferenceBuilder) AnticipatedRefFromWriterTo(object reference.Global, pn pulse.Number, w io.WriterTo) reference.Global

type IncomingRegistrationStatus 

type IncomingRegistrationStatus int8
const (
	RegistrationNot IncomingRegistrationStatus = iota
	RegistrationPrepared
	RegistrationOk
	RegistrationFail
)

type ReceivedType 

type ReceivedType int
const (
	ReceivedNothing ReceivedType = iota
	ReceivedLRegisterResponse
	ReceivedLStateVerifyResponse
)

type RecordReferenceBuilder 

type RecordReferenceBuilder interface {
	AnticipatedRefFromWriterTo(reference.Global, pulse.Number, io.WriterTo) reference.Global
	AnticipatedRefFromBytes(reference.Global, pulse.Number, []byte) reference.Global
	AnticipatedRefFromRecord(reference.Global, pulse.Number, rms.BasicRecord) reference.Global
}

type RegisterRecordBuilder 

type RegisterRecordBuilder struct {
	// input arguments
	Incoming          *rms.VCallRequest
	Outgoing          *rms.VCallRequest
	OutgoingRepeat    bool
	OutgoingResult    *rms.VCallResult
	IncomingResult    *execution.Update
	Interference      isolation.InterferenceFlag
	ObjectSharedState object.SharedStateAccessor

	Object      reference.Global
	PulseNumber pulse.Number

	// output arguments
	Context *RegistrationCtx

	Messages []SerializableBasicMessage

	// DI
	PulseGetter  func() pulse.Number
	DataDigester cryptkit.DataDigester
	// contains filtered or unexported fields
}

func (*RegisterRecordBuilder) BuildLifeline 

func (s *RegisterRecordBuilder) BuildLifeline() error

func (*RegisterRecordBuilder) BuildRegisterIncomingResult 

func (s *RegisterRecordBuilder) BuildRegisterIncomingResult() error

func (*RegisterRecordBuilder) BuildRegisterOutgoingRequest 

func (s *RegisterRecordBuilder) BuildRegisterOutgoingRequest() error

func (*RegisterRecordBuilder) BuildRegisterOutgoingResult 

func (s *RegisterRecordBuilder) BuildRegisterOutgoingResult() error

func (*RegisterRecordBuilder) Finalize 

func (s *RegisterRecordBuilder) Finalize() error

func (*RegisterRecordBuilder) GetOutboundRecord 

func (s *RegisterRecordBuilder) GetOutboundRecord() *rms.ROutboundRequest

type RegistrationCtx 

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

func NewDummyRegistrationCtx 

func NewDummyRegistrationCtx(trunk reference.Global) *RegistrationCtx

func NewRegistrationCtx 

func NewRegistrationCtx(ctx smachine.InitializationContext) *RegistrationCtx

func (*RegistrationCtx) BranchRef 

func (c *RegistrationCtx) BranchRef() rmsbox.ReferenceProvider

func (*RegistrationCtx) DecrementSafeResponse 

func (c *RegistrationCtx) DecrementSafeResponse(ctx smachine.ExecutionContext) smachine.StateUpdate

func (*RegistrationCtx) IncomingRegisterNext 

func (c *RegistrationCtx) IncomingRegisterNext()

func (*RegistrationCtx) IncomingRegisterOverride 

func (c *RegistrationCtx) IncomingRegisterOverride()

func (*RegistrationCtx) IncomingRegisterRollback 

func (c *RegistrationCtx) IncomingRegisterRollback()

func (*RegistrationCtx) IncomingRegistered 

func (c *RegistrationCtx) IncomingRegistered() bool

func (*RegistrationCtx) IncomingRegistrationInProgress 

func (c *RegistrationCtx) IncomingRegistrationInProgress() bool

func (*RegistrationCtx) IncrementSafeResponse 

func (c *RegistrationCtx) IncrementSafeResponse(ctx smachine.ExecutionContext) smachine.StateUpdate

func (*RegistrationCtx) Init 

func (c *RegistrationCtx) Init(object reference.Global, trunk reference.Global)

func (*RegistrationCtx) Rollback 

func (c *RegistrationCtx) Rollback()

func (*RegistrationCtx) SetNewReferences 

func (c *RegistrationCtx) SetNewReferences(trunk rmsbox.ReferenceProvider, branch rmsbox.ReferenceProvider)

func (*RegistrationCtx) TrunkRef 

func (c *RegistrationCtx) TrunkRef() rmsbox.ReferenceProvider

func (*RegistrationCtx) WaitForAllSafeResponses 

func (c *RegistrationCtx) WaitForAllSafeResponses(ctx smachine.ExecutionContext) smachine.StateUpdate

type ResultAwaitKey 

type ResultAwaitKey struct {
	AnticipatedRef rms.Reference
	RequiredFlag   rms.RegistrationFlags
}

func NewResultAwaitKey 

func NewResultAwaitKey(ref rms.Reference, requiredFlag rms.RegistrationFlags) ResultAwaitKey

func (*ResultAwaitKey) String 

func (k *ResultAwaitKey) String() string

type SMWaitSafeResponse 

type SMWaitSafeResponse struct {
	ObjectSharedState   object.SharedStateAccessor
	ExpectedKey         ResultAwaitKey
	SafeResponseCounter smachine.SharedDataLink
	LMNContext          *RegistrationCtx
	// contains filtered or unexported fields
}

func (*SMWaitSafeResponse) GetStateMachineDeclaration 

func (s *SMWaitSafeResponse) GetStateMachineDeclaration() smachine.StateMachineDeclaration

func (*SMWaitSafeResponse) Init 

func (s *SMWaitSafeResponse) Init(ctx smachine.InitializationContext) smachine.StateUpdate

type SafeResponseCounter 

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

type SerializableBasicMessage 

type SerializableBasicMessage interface {
	rmsreg.GoGoSerializable
	rms.BasicMessage
}

type SerializableReferencableBasicRecord 

type SerializableReferencableBasicRecord interface {
	rmsreg.GoGoSerializable
	rms.BasicRecord
	rmsbox.Referencable
}

type SubSMRegisterRecordSend 

type SubSMRegisterRecordSend struct {
	Messages          []SerializableBasicMessage
	Object            reference.Global
	ObjectSharedState object.SharedStateAccessor
	LMNContext        *RegistrationCtx
	// contains filtered or unexported fields
}

func (*SubSMRegisterRecordSend) GetStateMachineDeclaration 

func (s *SubSMRegisterRecordSend) GetStateMachineDeclaration() smachine.StateMachineDeclaration

func (*SubSMRegisterRecordSend) GetSubroutineInitState 

func (s *SubSMRegisterRecordSend) GetSubroutineInitState(ctx smachine.SubroutineStartContext) smachine.InitFunc

func (*SubSMRegisterRecordSend) Init 

func (s *SubSMRegisterRecordSend) Init(ctx smachine.InitializationContext) smachine.StateUpdate

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.