transport

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

Documentation

Index

Constants

View Source 
const PrepareWithIntro = PacketPrepareOptions(TargetNeedsIntro)
View Source 
const PrepareWithoutPulseData = PacketPrepareOptions(SendWithoutPulseData)
View Source 
const SharedPrepareSendOptionsMask = SendWithoutPulseData | TargetNeedsIntro

Variables

This section is empty.

Functions

This section is empty.

Types

type AnnouncementPacketReader 

type AnnouncementPacketReader interface {
	ExtendedIntroReader
	GetAnnouncementReader() MembershipAnnouncementReader
}

type BriefIntroductionReader 

type BriefIntroductionReader interface {
	profiles.BriefCandidateProfile
}

type CloudIntroductionReader 

type CloudIntroductionReader interface {
	GetLastCloudStateHash() cryptkit.DigestHolder
	// GetAnnouncedJoinerSecret() cryptkit.DigestHolder
	GetCloudIdentity() cryptkit.DigestHolder
}

type ConsensusDigestFactory 

type ConsensusDigestFactory interface {
	cryptkit.DigestFactory
	CreateAnnouncementDigester() cryptkit.ForkingDigester
	CreateGlobulaStateDigester() StateDigester
}

type CryptographyAssistant 

type CryptographyAssistant interface {
	cryptkit.SignatureVerifierFactory
	cryptkit.KeyStoreFactory
	GetDigestFactory() ConsensusDigestFactory
	CreateNodeSigner(sks cryptkit.SecretKeyStore) cryptkit.DigestSigner
}

type ExtendedIntroReader 

type ExtendedIntroReader interface {
	HasFullIntro() bool
	GetFullIntroduction() FullIntroductionReader

	HasCloudIntro() bool
	GetCloudIntroduction() CloudIntroductionReader

	HasJoinerSecret() bool
	GetJoinerSecret() cryptkit.DigestHolder
}

type Factory 

type Factory interface {
	GetPacketSender() PacketSender
	GetPacketBuilder(signer cryptkit.DigestSigner) PacketBuilder
	GetCryptographyFactory() CryptographyAssistant
}

type FullIntroductionReader 

type FullIntroductionReader interface {
	profiles.CandidateProfile
}

type FullIntroductionReaderMock 

type FullIntroductionReaderMock struct {
	GetBriefIntroSignedDigestMock mFullIntroductionReaderMockGetBriefIntroSignedDigest

	GetDefaultEndpointMock mFullIntroductionReaderMockGetDefaultEndpoint

	GetExtraEndpointsMock mFullIntroductionReaderMockGetExtraEndpoints

	GetIssuedAtPulseMock mFullIntroductionReaderMockGetIssuedAtPulse

	GetIssuedAtTimeMock mFullIntroductionReaderMockGetIssuedAtTime

	GetIssuerIDMock mFullIntroductionReaderMockGetIssuerID

	GetIssuerSignatureMock mFullIntroductionReaderMockGetIssuerSignature

	GetNodePublicKeyMock mFullIntroductionReaderMockGetNodePublicKey

	GetPowerLevelsMock mFullIntroductionReaderMockGetPowerLevels

	GetPrimaryRoleMock mFullIntroductionReaderMockGetPrimaryRole

	GetReferenceMock mFullIntroductionReaderMockGetReference

	GetSpecialRolesMock mFullIntroductionReaderMockGetSpecialRoles

	GetStartPowerMock mFullIntroductionReaderMockGetStartPower

	GetStaticNodeIDMock mFullIntroductionReaderMockGetStaticNodeID
	// contains filtered or unexported fields
}

FullIntroductionReaderMock implements FullIntroductionReader

func NewFullIntroductionReaderMock 

func NewFullIntroductionReaderMock(t minimock.Tester) *FullIntroductionReaderMock

NewFullIntroductionReaderMock returns a mock for FullIntroductionReader

func (*FullIntroductionReaderMock) GetBriefIntroSignedDigest 

func (mmGetBriefIntroSignedDigest *FullIntroductionReaderMock) GetBriefIntroSignedDigest() (s1 cryptkit.SignedDigestHolder)

GetBriefIntroSignedDigest implements FullIntroductionReader

func (*FullIntroductionReaderMock) GetBriefIntroSignedDigestAfterCounter 

func (mmGetBriefIntroSignedDigest *FullIntroductionReaderMock) GetBriefIntroSignedDigestAfterCounter() uint64

GetBriefIntroSignedDigestAfterCounter returns a count of finished FullIntroductionReaderMock.GetBriefIntroSignedDigest invocations

func (*FullIntroductionReaderMock) GetBriefIntroSignedDigestBeforeCounter 

func (mmGetBriefIntroSignedDigest *FullIntroductionReaderMock) GetBriefIntroSignedDigestBeforeCounter() uint64

GetBriefIntroSignedDigestBeforeCounter returns a count of FullIntroductionReaderMock.GetBriefIntroSignedDigest invocations

func (*FullIntroductionReaderMock) GetDefaultEndpoint 

func (mmGetDefaultEndpoint *FullIntroductionReaderMock) GetDefaultEndpoint() (o1 endpoints.Outbound)

GetDefaultEndpoint implements FullIntroductionReader

func (*FullIntroductionReaderMock) GetDefaultEndpointAfterCounter 

func (mmGetDefaultEndpoint *FullIntroductionReaderMock) GetDefaultEndpointAfterCounter() uint64

GetDefaultEndpointAfterCounter returns a count of finished FullIntroductionReaderMock.GetDefaultEndpoint invocations

func (*FullIntroductionReaderMock) GetDefaultEndpointBeforeCounter 

func (mmGetDefaultEndpoint *FullIntroductionReaderMock) GetDefaultEndpointBeforeCounter() uint64

GetDefaultEndpointBeforeCounter returns a count of FullIntroductionReaderMock.GetDefaultEndpoint invocations

func (*FullIntroductionReaderMock) GetExtraEndpoints 

func (mmGetExtraEndpoints *FullIntroductionReaderMock) GetExtraEndpoints() (oa1 []endpoints.Outbound)

GetExtraEndpoints implements FullIntroductionReader

func (*FullIntroductionReaderMock) GetExtraEndpointsAfterCounter 

func (mmGetExtraEndpoints *FullIntroductionReaderMock) GetExtraEndpointsAfterCounter() uint64

GetExtraEndpointsAfterCounter returns a count of finished FullIntroductionReaderMock.GetExtraEndpoints invocations

func (*FullIntroductionReaderMock) GetExtraEndpointsBeforeCounter 

func (mmGetExtraEndpoints *FullIntroductionReaderMock) GetExtraEndpointsBeforeCounter() uint64

GetExtraEndpointsBeforeCounter returns a count of FullIntroductionReaderMock.GetExtraEndpoints invocations

func (*FullIntroductionReaderMock) GetIssuedAtPulse 

func (mmGetIssuedAtPulse *FullIntroductionReaderMock) GetIssuedAtPulse() (n1 pulse.Number)

GetIssuedAtPulse implements FullIntroductionReader

func (*FullIntroductionReaderMock) GetIssuedAtPulseAfterCounter 

func (mmGetIssuedAtPulse *FullIntroductionReaderMock) GetIssuedAtPulseAfterCounter() uint64

GetIssuedAtPulseAfterCounter returns a count of finished FullIntroductionReaderMock.GetIssuedAtPulse invocations

func (*FullIntroductionReaderMock) GetIssuedAtPulseBeforeCounter 

func (mmGetIssuedAtPulse *FullIntroductionReaderMock) GetIssuedAtPulseBeforeCounter() uint64

GetIssuedAtPulseBeforeCounter returns a count of FullIntroductionReaderMock.GetIssuedAtPulse invocations

func (*FullIntroductionReaderMock) GetIssuedAtTime 

func (mmGetIssuedAtTime *FullIntroductionReaderMock) GetIssuedAtTime() (t1 time.Time)

GetIssuedAtTime implements FullIntroductionReader

func (*FullIntroductionReaderMock) GetIssuedAtTimeAfterCounter 

func (mmGetIssuedAtTime *FullIntroductionReaderMock) GetIssuedAtTimeAfterCounter() uint64

GetIssuedAtTimeAfterCounter returns a count of finished FullIntroductionReaderMock.GetIssuedAtTime invocations

func (*FullIntroductionReaderMock) GetIssuedAtTimeBeforeCounter 

func (mmGetIssuedAtTime *FullIntroductionReaderMock) GetIssuedAtTimeBeforeCounter() uint64

GetIssuedAtTimeBeforeCounter returns a count of FullIntroductionReaderMock.GetIssuedAtTime invocations

func (*FullIntroductionReaderMock) GetIssuerID 

func (mmGetIssuerID *FullIntroductionReaderMock) GetIssuerID() (s1 node.ShortNodeID)

GetIssuerID implements FullIntroductionReader

func (*FullIntroductionReaderMock) GetIssuerIDAfterCounter 

func (mmGetIssuerID *FullIntroductionReaderMock) GetIssuerIDAfterCounter() uint64

GetIssuerIDAfterCounter returns a count of finished FullIntroductionReaderMock.GetIssuerID invocations

func (*FullIntroductionReaderMock) GetIssuerIDBeforeCounter 

func (mmGetIssuerID *FullIntroductionReaderMock) GetIssuerIDBeforeCounter() uint64

GetIssuerIDBeforeCounter returns a count of FullIntroductionReaderMock.GetIssuerID invocations

func (*FullIntroductionReaderMock) GetIssuerSignature 

func (mmGetIssuerSignature *FullIntroductionReaderMock) GetIssuerSignature() (s1 cryptkit.SignatureHolder)

GetIssuerSignature implements FullIntroductionReader

func (*FullIntroductionReaderMock) GetIssuerSignatureAfterCounter 

func (mmGetIssuerSignature *FullIntroductionReaderMock) GetIssuerSignatureAfterCounter() uint64

GetIssuerSignatureAfterCounter returns a count of finished FullIntroductionReaderMock.GetIssuerSignature invocations

func (*FullIntroductionReaderMock) GetIssuerSignatureBeforeCounter 

func (mmGetIssuerSignature *FullIntroductionReaderMock) GetIssuerSignatureBeforeCounter() uint64

GetIssuerSignatureBeforeCounter returns a count of FullIntroductionReaderMock.GetIssuerSignature invocations

func (*FullIntroductionReaderMock) GetNodePublicKey 

func (mmGetNodePublicKey *FullIntroductionReaderMock) GetNodePublicKey() (s1 cryptkit.SigningKeyHolder)

GetNodePublicKey implements FullIntroductionReader

func (*FullIntroductionReaderMock) GetNodePublicKeyAfterCounter 

func (mmGetNodePublicKey *FullIntroductionReaderMock) GetNodePublicKeyAfterCounter() uint64

GetNodePublicKeyAfterCounter returns a count of finished FullIntroductionReaderMock.GetNodePublicKey invocations

func (*FullIntroductionReaderMock) GetNodePublicKeyBeforeCounter 

func (mmGetNodePublicKey *FullIntroductionReaderMock) GetNodePublicKeyBeforeCounter() uint64

GetNodePublicKeyBeforeCounter returns a count of FullIntroductionReaderMock.GetNodePublicKey invocations

func (*FullIntroductionReaderMock) GetPowerLevels 

func (mmGetPowerLevels *FullIntroductionReaderMock) GetPowerLevels() (p1 member.PowerSet)

GetPowerLevels implements FullIntroductionReader

func (*FullIntroductionReaderMock) GetPowerLevelsAfterCounter 

func (mmGetPowerLevels *FullIntroductionReaderMock) GetPowerLevelsAfterCounter() uint64

GetPowerLevelsAfterCounter returns a count of finished FullIntroductionReaderMock.GetPowerLevels invocations

func (*FullIntroductionReaderMock) GetPowerLevelsBeforeCounter 

func (mmGetPowerLevels *FullIntroductionReaderMock) GetPowerLevelsBeforeCounter() uint64

GetPowerLevelsBeforeCounter returns a count of FullIntroductionReaderMock.GetPowerLevels invocations

func (*FullIntroductionReaderMock) GetPrimaryRole 

func (mmGetPrimaryRole *FullIntroductionReaderMock) GetPrimaryRole() (p1 member.PrimaryRole)

GetPrimaryRole implements FullIntroductionReader

func (*FullIntroductionReaderMock) GetPrimaryRoleAfterCounter 

func (mmGetPrimaryRole *FullIntroductionReaderMock) GetPrimaryRoleAfterCounter() uint64

GetPrimaryRoleAfterCounter returns a count of finished FullIntroductionReaderMock.GetPrimaryRole invocations

func (*FullIntroductionReaderMock) GetPrimaryRoleBeforeCounter 

func (mmGetPrimaryRole *FullIntroductionReaderMock) GetPrimaryRoleBeforeCounter() uint64

GetPrimaryRoleBeforeCounter returns a count of FullIntroductionReaderMock.GetPrimaryRole invocations

func (*FullIntroductionReaderMock) GetReference 

func (mmGetReference *FullIntroductionReaderMock) GetReference() (g1 reference.Global)

GetReference implements FullIntroductionReader

func (*FullIntroductionReaderMock) GetReferenceAfterCounter 

func (mmGetReference *FullIntroductionReaderMock) GetReferenceAfterCounter() uint64

GetReferenceAfterCounter returns a count of finished FullIntroductionReaderMock.GetReference invocations

func (*FullIntroductionReaderMock) GetReferenceBeforeCounter 

func (mmGetReference *FullIntroductionReaderMock) GetReferenceBeforeCounter() uint64

GetReferenceBeforeCounter returns a count of FullIntroductionReaderMock.GetReference invocations

func (*FullIntroductionReaderMock) GetSpecialRoles 

func (mmGetSpecialRoles *FullIntroductionReaderMock) GetSpecialRoles() (s1 member.SpecialRole)

GetSpecialRoles implements FullIntroductionReader

func (*FullIntroductionReaderMock) GetSpecialRolesAfterCounter 

func (mmGetSpecialRoles *FullIntroductionReaderMock) GetSpecialRolesAfterCounter() uint64

GetSpecialRolesAfterCounter returns a count of finished FullIntroductionReaderMock.GetSpecialRoles invocations

func (*FullIntroductionReaderMock) GetSpecialRolesBeforeCounter 

func (mmGetSpecialRoles *FullIntroductionReaderMock) GetSpecialRolesBeforeCounter() uint64

GetSpecialRolesBeforeCounter returns a count of FullIntroductionReaderMock.GetSpecialRoles invocations

func (*FullIntroductionReaderMock) GetStartPower 

func (mmGetStartPower *FullIntroductionReaderMock) GetStartPower() (p1 member.Power)

GetStartPower implements FullIntroductionReader

func (*FullIntroductionReaderMock) GetStartPowerAfterCounter 

func (mmGetStartPower *FullIntroductionReaderMock) GetStartPowerAfterCounter() uint64

GetStartPowerAfterCounter returns a count of finished FullIntroductionReaderMock.GetStartPower invocations

func (*FullIntroductionReaderMock) GetStartPowerBeforeCounter 

func (mmGetStartPower *FullIntroductionReaderMock) GetStartPowerBeforeCounter() uint64

GetStartPowerBeforeCounter returns a count of FullIntroductionReaderMock.GetStartPower invocations

func (*FullIntroductionReaderMock) GetStaticNodeID 

func (mmGetStaticNodeID *FullIntroductionReaderMock) GetStaticNodeID() (s1 node.ShortNodeID)

GetStaticNodeID implements FullIntroductionReader

func (*FullIntroductionReaderMock) GetStaticNodeIDAfterCounter 

func (mmGetStaticNodeID *FullIntroductionReaderMock) GetStaticNodeIDAfterCounter() uint64

GetStaticNodeIDAfterCounter returns a count of finished FullIntroductionReaderMock.GetStaticNodeID invocations

func (*FullIntroductionReaderMock) GetStaticNodeIDBeforeCounter 

func (mmGetStaticNodeID *FullIntroductionReaderMock) GetStaticNodeIDBeforeCounter() uint64

GetStaticNodeIDBeforeCounter returns a count of FullIntroductionReaderMock.GetStaticNodeID invocations

func (*FullIntroductionReaderMock) MinimockFinish 

func (m *FullIntroductionReaderMock) MinimockFinish()

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

func (*FullIntroductionReaderMock) MinimockGetBriefIntroSignedDigestDone 

func (m *FullIntroductionReaderMock) MinimockGetBriefIntroSignedDigestDone() bool

MinimockGetBriefIntroSignedDigestDone returns true if the count of the GetBriefIntroSignedDigest invocations corresponds the number of defined expectations

func (*FullIntroductionReaderMock) MinimockGetBriefIntroSignedDigestInspect 

func (m *FullIntroductionReaderMock) MinimockGetBriefIntroSignedDigestInspect()

MinimockGetBriefIntroSignedDigestInspect logs each unmet expectation

func (*FullIntroductionReaderMock) MinimockGetDefaultEndpointDone 

func (m *FullIntroductionReaderMock) MinimockGetDefaultEndpointDone() bool

MinimockGetDefaultEndpointDone returns true if the count of the GetDefaultEndpoint invocations corresponds the number of defined expectations

func (*FullIntroductionReaderMock) MinimockGetDefaultEndpointInspect 

func (m *FullIntroductionReaderMock) MinimockGetDefaultEndpointInspect()

MinimockGetDefaultEndpointInspect logs each unmet expectation

func (*FullIntroductionReaderMock) MinimockGetExtraEndpointsDone 

func (m *FullIntroductionReaderMock) MinimockGetExtraEndpointsDone() bool

MinimockGetExtraEndpointsDone returns true if the count of the GetExtraEndpoints invocations corresponds the number of defined expectations

func (*FullIntroductionReaderMock) MinimockGetExtraEndpointsInspect 

func (m *FullIntroductionReaderMock) MinimockGetExtraEndpointsInspect()

MinimockGetExtraEndpointsInspect logs each unmet expectation

func (*FullIntroductionReaderMock) MinimockGetIssuedAtPulseDone 

func (m *FullIntroductionReaderMock) MinimockGetIssuedAtPulseDone() bool

MinimockGetIssuedAtPulseDone returns true if the count of the GetIssuedAtPulse invocations corresponds the number of defined expectations

func (*FullIntroductionReaderMock) MinimockGetIssuedAtPulseInspect 

func (m *FullIntroductionReaderMock) MinimockGetIssuedAtPulseInspect()

MinimockGetIssuedAtPulseInspect logs each unmet expectation

func (*FullIntroductionReaderMock) MinimockGetIssuedAtTimeDone 

func (m *FullIntroductionReaderMock) MinimockGetIssuedAtTimeDone() bool

MinimockGetIssuedAtTimeDone returns true if the count of the GetIssuedAtTime invocations corresponds the number of defined expectations

func (*FullIntroductionReaderMock) MinimockGetIssuedAtTimeInspect 

func (m *FullIntroductionReaderMock) MinimockGetIssuedAtTimeInspect()

MinimockGetIssuedAtTimeInspect logs each unmet expectation

func (*FullIntroductionReaderMock) MinimockGetIssuerIDDone 

func (m *FullIntroductionReaderMock) MinimockGetIssuerIDDone() bool

MinimockGetIssuerIDDone returns true if the count of the GetIssuerID invocations corresponds the number of defined expectations

func (*FullIntroductionReaderMock) MinimockGetIssuerIDInspect 

func (m *FullIntroductionReaderMock) MinimockGetIssuerIDInspect()

MinimockGetIssuerIDInspect logs each unmet expectation

func (*FullIntroductionReaderMock) MinimockGetIssuerSignatureDone 

func (m *FullIntroductionReaderMock) MinimockGetIssuerSignatureDone() bool

MinimockGetIssuerSignatureDone returns true if the count of the GetIssuerSignature invocations corresponds the number of defined expectations

func (*FullIntroductionReaderMock) MinimockGetIssuerSignatureInspect 

func (m *FullIntroductionReaderMock) MinimockGetIssuerSignatureInspect()

MinimockGetIssuerSignatureInspect logs each unmet expectation

func (*FullIntroductionReaderMock) MinimockGetNodePublicKeyDone 

func (m *FullIntroductionReaderMock) MinimockGetNodePublicKeyDone() bool

MinimockGetNodePublicKeyDone returns true if the count of the GetNodePublicKey invocations corresponds the number of defined expectations

func (*FullIntroductionReaderMock) MinimockGetNodePublicKeyInspect 

func (m *FullIntroductionReaderMock) MinimockGetNodePublicKeyInspect()

MinimockGetNodePublicKeyInspect logs each unmet expectation

func (*FullIntroductionReaderMock) MinimockGetPowerLevelsDone 

func (m *FullIntroductionReaderMock) MinimockGetPowerLevelsDone() bool

MinimockGetPowerLevelsDone returns true if the count of the GetPowerLevels invocations corresponds the number of defined expectations

func (*FullIntroductionReaderMock) MinimockGetPowerLevelsInspect 

func (m *FullIntroductionReaderMock) MinimockGetPowerLevelsInspect()

MinimockGetPowerLevelsInspect logs each unmet expectation

func (*FullIntroductionReaderMock) MinimockGetPrimaryRoleDone 

func (m *FullIntroductionReaderMock) MinimockGetPrimaryRoleDone() bool

MinimockGetPrimaryRoleDone returns true if the count of the GetPrimaryRole invocations corresponds the number of defined expectations

func (*FullIntroductionReaderMock) MinimockGetPrimaryRoleInspect 

func (m *FullIntroductionReaderMock) MinimockGetPrimaryRoleInspect()

MinimockGetPrimaryRoleInspect logs each unmet expectation

func (*FullIntroductionReaderMock) MinimockGetReferenceDone 

func (m *FullIntroductionReaderMock) MinimockGetReferenceDone() bool

MinimockGetReferenceDone returns true if the count of the GetReference invocations corresponds the number of defined expectations

func (*FullIntroductionReaderMock) MinimockGetReferenceInspect 

func (m *FullIntroductionReaderMock) MinimockGetReferenceInspect()

MinimockGetReferenceInspect logs each unmet expectation

func (*FullIntroductionReaderMock) MinimockGetSpecialRolesDone 

func (m *FullIntroductionReaderMock) MinimockGetSpecialRolesDone() bool

MinimockGetSpecialRolesDone returns true if the count of the GetSpecialRoles invocations corresponds the number of defined expectations

func (*FullIntroductionReaderMock) MinimockGetSpecialRolesInspect 

func (m *FullIntroductionReaderMock) MinimockGetSpecialRolesInspect()

MinimockGetSpecialRolesInspect logs each unmet expectation

func (*FullIntroductionReaderMock) MinimockGetStartPowerDone 

func (m *FullIntroductionReaderMock) MinimockGetStartPowerDone() bool

MinimockGetStartPowerDone returns true if the count of the GetStartPower invocations corresponds the number of defined expectations

func (*FullIntroductionReaderMock) MinimockGetStartPowerInspect 

func (m *FullIntroductionReaderMock) MinimockGetStartPowerInspect()

MinimockGetStartPowerInspect logs each unmet expectation

func (*FullIntroductionReaderMock) MinimockGetStaticNodeIDDone 

func (m *FullIntroductionReaderMock) MinimockGetStaticNodeIDDone() bool

MinimockGetStaticNodeIDDone returns true if the count of the GetStaticNodeID invocations corresponds the number of defined expectations

func (*FullIntroductionReaderMock) MinimockGetStaticNodeIDInspect 

func (m *FullIntroductionReaderMock) MinimockGetStaticNodeIDInspect()

MinimockGetStaticNodeIDInspect logs each unmet expectation

func (*FullIntroductionReaderMock) MinimockWait 

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

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

type FullIntroductionReaderMockGetBriefIntroSignedDigestExpectation 

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

FullIntroductionReaderMockGetBriefIntroSignedDigestExpectation specifies expectation struct of the FullIntroductionReader.GetBriefIntroSignedDigest

type FullIntroductionReaderMockGetBriefIntroSignedDigestResults 

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

FullIntroductionReaderMockGetBriefIntroSignedDigestResults contains results of the FullIntroductionReader.GetBriefIntroSignedDigest

type FullIntroductionReaderMockGetDefaultEndpointExpectation 

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

FullIntroductionReaderMockGetDefaultEndpointExpectation specifies expectation struct of the FullIntroductionReader.GetDefaultEndpoint

type FullIntroductionReaderMockGetDefaultEndpointResults 

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

FullIntroductionReaderMockGetDefaultEndpointResults contains results of the FullIntroductionReader.GetDefaultEndpoint

type FullIntroductionReaderMockGetExtraEndpointsExpectation 

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

FullIntroductionReaderMockGetExtraEndpointsExpectation specifies expectation struct of the FullIntroductionReader.GetExtraEndpoints

type FullIntroductionReaderMockGetExtraEndpointsResults 

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

FullIntroductionReaderMockGetExtraEndpointsResults contains results of the FullIntroductionReader.GetExtraEndpoints

type FullIntroductionReaderMockGetIssuedAtPulseExpectation 

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

FullIntroductionReaderMockGetIssuedAtPulseExpectation specifies expectation struct of the FullIntroductionReader.GetIssuedAtPulse

type FullIntroductionReaderMockGetIssuedAtPulseResults 

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

FullIntroductionReaderMockGetIssuedAtPulseResults contains results of the FullIntroductionReader.GetIssuedAtPulse

type FullIntroductionReaderMockGetIssuedAtTimeExpectation 

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

FullIntroductionReaderMockGetIssuedAtTimeExpectation specifies expectation struct of the FullIntroductionReader.GetIssuedAtTime

type FullIntroductionReaderMockGetIssuedAtTimeResults 

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

FullIntroductionReaderMockGetIssuedAtTimeResults contains results of the FullIntroductionReader.GetIssuedAtTime

type FullIntroductionReaderMockGetIssuerIDExpectation 

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

FullIntroductionReaderMockGetIssuerIDExpectation specifies expectation struct of the FullIntroductionReader.GetIssuerID

type FullIntroductionReaderMockGetIssuerIDResults 

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

FullIntroductionReaderMockGetIssuerIDResults contains results of the FullIntroductionReader.GetIssuerID

type FullIntroductionReaderMockGetIssuerSignatureExpectation 

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

FullIntroductionReaderMockGetIssuerSignatureExpectation specifies expectation struct of the FullIntroductionReader.GetIssuerSignature

type FullIntroductionReaderMockGetIssuerSignatureResults 

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

FullIntroductionReaderMockGetIssuerSignatureResults contains results of the FullIntroductionReader.GetIssuerSignature

type FullIntroductionReaderMockGetNodePublicKeyExpectation 

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

FullIntroductionReaderMockGetNodePublicKeyExpectation specifies expectation struct of the FullIntroductionReader.GetNodePublicKey

type FullIntroductionReaderMockGetNodePublicKeyResults 

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

FullIntroductionReaderMockGetNodePublicKeyResults contains results of the FullIntroductionReader.GetNodePublicKey

type FullIntroductionReaderMockGetPowerLevelsExpectation 

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

FullIntroductionReaderMockGetPowerLevelsExpectation specifies expectation struct of the FullIntroductionReader.GetPowerLevels

type FullIntroductionReaderMockGetPowerLevelsResults 

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

FullIntroductionReaderMockGetPowerLevelsResults contains results of the FullIntroductionReader.GetPowerLevels

type FullIntroductionReaderMockGetPrimaryRoleExpectation 

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

FullIntroductionReaderMockGetPrimaryRoleExpectation specifies expectation struct of the FullIntroductionReader.GetPrimaryRole

type FullIntroductionReaderMockGetPrimaryRoleResults 

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

FullIntroductionReaderMockGetPrimaryRoleResults contains results of the FullIntroductionReader.GetPrimaryRole

type FullIntroductionReaderMockGetReferenceExpectation 

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

FullIntroductionReaderMockGetReferenceExpectation specifies expectation struct of the FullIntroductionReader.GetReference

type FullIntroductionReaderMockGetReferenceResults 

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

FullIntroductionReaderMockGetReferenceResults contains results of the FullIntroductionReader.GetReference

type FullIntroductionReaderMockGetSpecialRolesExpectation 

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

FullIntroductionReaderMockGetSpecialRolesExpectation specifies expectation struct of the FullIntroductionReader.GetSpecialRoles

type FullIntroductionReaderMockGetSpecialRolesResults 

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

FullIntroductionReaderMockGetSpecialRolesResults contains results of the FullIntroductionReader.GetSpecialRoles

type FullIntroductionReaderMockGetStartPowerExpectation 

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

FullIntroductionReaderMockGetStartPowerExpectation specifies expectation struct of the FullIntroductionReader.GetStartPower

type FullIntroductionReaderMockGetStartPowerResults 

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

FullIntroductionReaderMockGetStartPowerResults contains results of the FullIntroductionReader.GetStartPower

type FullIntroductionReaderMockGetStaticNodeIDExpectation 

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

FullIntroductionReaderMockGetStaticNodeIDExpectation specifies expectation struct of the FullIntroductionReader.GetStaticNodeID

type FullIntroductionReaderMockGetStaticNodeIDResults 

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

FullIntroductionReaderMockGetStaticNodeIDResults contains results of the FullIntroductionReader.GetStaticNodeID

type HashedVectorReader 

type HashedVectorReader interface {
	GetBitset() member.StateBitset

	GetTrustedGlobulaAnnouncementHash() proofs.GlobulaAnnouncementHash
	GetTrustedGlobulaStateSignature() proofs.GlobulaStateSignature
	GetTrustedExpectedRank() member.Rank

	GetDoubtedGlobulaAnnouncementHash() proofs.GlobulaAnnouncementHash
	GetDoubtedGlobulaStateSignature() proofs.GlobulaStateSignature
	GetDoubtedExpectedRank() member.Rank
}

type JoinerAnnouncement 

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

func NewAnyJoinerAnnouncement 

func NewAnyJoinerAnnouncement(np profiles.StaticProfile, announcerID node.ShortNodeID, joinerSecret cryptkit.DigestHolder) *JoinerAnnouncement

func NewBriefJoinerAnnouncement 

func NewBriefJoinerAnnouncement(np profiles.StaticProfile, announcerID node.ShortNodeID, joinerSecret cryptkit.DigestHolder) *JoinerAnnouncement

func NewFullJoinerAnnouncement 

func NewFullJoinerAnnouncement(np profiles.StaticProfile, announcerID node.ShortNodeID, joinerSecret cryptkit.DigestHolder) *JoinerAnnouncement

func (*JoinerAnnouncement) GetBriefIntroduction 

func (p *JoinerAnnouncement) GetBriefIntroduction() BriefIntroductionReader

func (*JoinerAnnouncement) GetDecryptedSecret 

func (p *JoinerAnnouncement) GetDecryptedSecret() cryptkit.DigestHolder

func (*JoinerAnnouncement) GetFullIntroduction 

func (p *JoinerAnnouncement) GetFullIntroduction() FullIntroductionReader

func (*JoinerAnnouncement) GetJoinerIntroducedByID 

func (p *JoinerAnnouncement) GetJoinerIntroducedByID() node.ShortNodeID

func (*JoinerAnnouncement) HasFullIntro 

func (p *JoinerAnnouncement) HasFullIntro() bool

type JoinerAnnouncementReader 

type JoinerAnnouncementReader interface {
	GetJoinerIntroducedByID() node.ShortNodeID
	GetBriefIntroduction() BriefIntroductionReader

	HasFullIntro() bool
	GetFullIntroduction() FullIntroductionReader
}

func NewBriefJoinerAnnouncementByFull 

func NewBriefJoinerAnnouncementByFull(fp JoinerAnnouncementReader) JoinerAnnouncementReader

type MemberPacketReader 

type MemberPacketReader interface {
	GetPacketType() phases.PacketType

	AsPhase0Packet() Phase0PacketReader
	AsPhase1Packet() Phase1PacketReader
	AsPhase2Packet() Phase2PacketReader
	AsPhase3Packet() Phase3PacketReader

	GetPacketSignature() cryptkit.SignedDigest
}

type MembershipAnnouncementReader 

type MembershipAnnouncementReader interface {
	GetNodeID() node.ShortNodeID
	GetNodeRank() member.Rank
	GetRequestedPower() member.Power
	GetNodeStateHashEvidence() proofs.NodeStateHashEvidence
	GetAnnouncementSignature() proofs.MemberAnnouncementSignature

	// Methods below are not applicable when GetNodeRank().IsJoiner()
	IsLeaving() bool
	GetLeaveReason() uint32

	/*
		If GetJoinerID() == 0 then there is no joiner announced by the member
		If this reader is part of Neighbourhood then nonzero GetJoinerID() will be equal to GetNodeID()
	*/
	GetJoinerID() node.ShortNodeID

	/* Can be nil when this reader is part of Neighbourhood - then joiner data is in the sender's announcement */
	GetJoinerAnnouncement() JoinerAnnouncementReader
}

type NeighbourhoodSizes 

type NeighbourhoodSizes struct {
	NeighbourhoodSize           int
	NeighbourhoodTrustThreshold int
	JoinersPerNeighbourhood     int
	JoinersBoost                int
	ExtendingNeighbourhoodLimit uint8
}

func (*NeighbourhoodSizes) VerifySizes 

func (sizes *NeighbourhoodSizes) VerifySizes()

type NodeAnnouncementProfile 

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

func NewNodeAnnouncement 

func NewNodeAnnouncement(np profiles.ActiveNode, ma profiles.MembershipAnnouncement, nodeCount int,
	pn pulse.Number, joiner *JoinerAnnouncement) *NodeAnnouncementProfile

func (*NodeAnnouncementProfile) GetAnnouncementSignature 

func (c *NodeAnnouncementProfile) GetAnnouncementSignature() proofs.MemberAnnouncementSignature

func (*NodeAnnouncementProfile) GetJoinerAnnouncement 

func (c *NodeAnnouncementProfile) GetJoinerAnnouncement() JoinerAnnouncementReader

func (*NodeAnnouncementProfile) GetJoinerID 

func (c *NodeAnnouncementProfile) GetJoinerID() node.ShortNodeID

func (*NodeAnnouncementProfile) GetLeaveReason 

func (c *NodeAnnouncementProfile) GetLeaveReason() uint32

func (*NodeAnnouncementProfile) GetMembershipProfile 

func (c *NodeAnnouncementProfile) GetMembershipProfile() profiles.MembershipProfile

func (*NodeAnnouncementProfile) GetNodeCount 

func (c *NodeAnnouncementProfile) GetNodeCount() uint16

func (*NodeAnnouncementProfile) GetNodeID 

func (c *NodeAnnouncementProfile) GetNodeID() node.ShortNodeID

func (*NodeAnnouncementProfile) GetNodeRank 

func (c *NodeAnnouncementProfile) GetNodeRank() member.Rank

func (*NodeAnnouncementProfile) GetNodeStateHashEvidence 

func (c *NodeAnnouncementProfile) GetNodeStateHashEvidence() proofs.NodeStateHashEvidence

func (*NodeAnnouncementProfile) GetPulseNumber 

func (c *NodeAnnouncementProfile) GetPulseNumber() pulse.Number

func (*NodeAnnouncementProfile) GetRequestedPower 

func (c *NodeAnnouncementProfile) GetRequestedPower() member.Power

func (*NodeAnnouncementProfile) GetStatic 

func (c *NodeAnnouncementProfile) GetStatic() profiles.StaticProfile

func (*NodeAnnouncementProfile) IsLeaving 

func (c *NodeAnnouncementProfile) IsLeaving() bool

func (NodeAnnouncementProfile) String 

func (c NodeAnnouncementProfile) String() string

type PacketBuilder 

type PacketBuilder interface {
	GetNeighbourhoodSize() NeighbourhoodSizes

	PreparePhase0Packet(sender *NodeAnnouncementProfile, pulsarPacket proofs.OriginalPulsarPacket,
		options PacketPrepareOptions) PreparedPacketSender
	PreparePhase1Packet(sender *NodeAnnouncementProfile, pulsarPacket proofs.OriginalPulsarPacket,
		welcome *proofs.NodeWelcomePackage, options PacketPrepareOptions) PreparedPacketSender

	/* Prepare receives all introductions at once, but PreparedSendPacket.SendTo MUST:
	1. exclude all intros when target is not joiner
	2. exclude the intro of the target
	*/
	PreparePhase2Packet(sender *NodeAnnouncementProfile, welcome *proofs.NodeWelcomePackage,
		neighbourhood []MembershipAnnouncementReader, options PacketPrepareOptions) PreparedPacketSender

	PreparePhase3Packet(sender *NodeAnnouncementProfile, vectors statevector.Vector,
		options PacketPrepareOptions) PreparedPacketSender
}

type PacketParser 

type PacketParser interface {
	GetPacketType() phases.PacketType
	/* Should return Unknown when it is not possible to identify it for a packet */
	GetPulseNumber() pulse.Number

	GetSourceID() node.ShortNodeID
	GetReceiverID() node.ShortNodeID
	GetTargetID() node.ShortNodeID
	IsRelayForbidden() bool

	GetPacketSignature() cryptkit.SignedDigest
	ParsePacketBody() (PacketParser, error) // enables lazy parsing / parsing only after packet validation

	GetPulsePacket() PulsePacketReader
	GetMemberPacket() MemberPacketReader
}

type PacketParserMock 

type PacketParserMock struct {
	GetMemberPacketMock mPacketParserMockGetMemberPacket

	GetPacketSignatureMock mPacketParserMockGetPacketSignature

	GetPacketTypeMock mPacketParserMockGetPacketType

	GetPulseNumberMock mPacketParserMockGetPulseNumber

	GetPulsePacketMock mPacketParserMockGetPulsePacket

	GetReceiverIDMock mPacketParserMockGetReceiverID

	GetSourceIDMock mPacketParserMockGetSourceID

	GetTargetIDMock mPacketParserMockGetTargetID

	IsRelayForbiddenMock mPacketParserMockIsRelayForbidden

	ParsePacketBodyMock mPacketParserMockParsePacketBody
	// contains filtered or unexported fields
}

PacketParserMock implements PacketParser

func NewPacketParserMock 

func NewPacketParserMock(t minimock.Tester) *PacketParserMock

NewPacketParserMock returns a mock for PacketParser

func (*PacketParserMock) GetMemberPacket 

func (mmGetMemberPacket *PacketParserMock) GetMemberPacket() (m1 MemberPacketReader)

GetMemberPacket implements PacketParser

func (*PacketParserMock) GetMemberPacketAfterCounter 

func (mmGetMemberPacket *PacketParserMock) GetMemberPacketAfterCounter() uint64

GetMemberPacketAfterCounter returns a count of finished PacketParserMock.GetMemberPacket invocations

func (*PacketParserMock) GetMemberPacketBeforeCounter 

func (mmGetMemberPacket *PacketParserMock) GetMemberPacketBeforeCounter() uint64

GetMemberPacketBeforeCounter returns a count of PacketParserMock.GetMemberPacket invocations

func (*PacketParserMock) GetPacketSignature 

func (mmGetPacketSignature *PacketParserMock) GetPacketSignature() (s1 cryptkit.SignedDigest)

GetPacketSignature implements PacketParser

func (*PacketParserMock) GetPacketSignatureAfterCounter 

func (mmGetPacketSignature *PacketParserMock) GetPacketSignatureAfterCounter() uint64

GetPacketSignatureAfterCounter returns a count of finished PacketParserMock.GetPacketSignature invocations

func (*PacketParserMock) GetPacketSignatureBeforeCounter 

func (mmGetPacketSignature *PacketParserMock) GetPacketSignatureBeforeCounter() uint64

GetPacketSignatureBeforeCounter returns a count of PacketParserMock.GetPacketSignature invocations

func (*PacketParserMock) GetPacketType 

func (mmGetPacketType *PacketParserMock) GetPacketType() (p1 phases.PacketType)

GetPacketType implements PacketParser

func (*PacketParserMock) GetPacketTypeAfterCounter 

func (mmGetPacketType *PacketParserMock) GetPacketTypeAfterCounter() uint64

GetPacketTypeAfterCounter returns a count of finished PacketParserMock.GetPacketType invocations

func (*PacketParserMock) GetPacketTypeBeforeCounter 

func (mmGetPacketType *PacketParserMock) GetPacketTypeBeforeCounter() uint64

GetPacketTypeBeforeCounter returns a count of PacketParserMock.GetPacketType invocations

func (*PacketParserMock) GetPulseNumber 

func (mmGetPulseNumber *PacketParserMock) GetPulseNumber() (n1 pulse.Number)

GetPulseNumber implements PacketParser

func (*PacketParserMock) GetPulseNumberAfterCounter 

func (mmGetPulseNumber *PacketParserMock) GetPulseNumberAfterCounter() uint64

GetPulseNumberAfterCounter returns a count of finished PacketParserMock.GetPulseNumber invocations

func (*PacketParserMock) GetPulseNumberBeforeCounter 

func (mmGetPulseNumber *PacketParserMock) GetPulseNumberBeforeCounter() uint64

GetPulseNumberBeforeCounter returns a count of PacketParserMock.GetPulseNumber invocations

func (*PacketParserMock) GetPulsePacket 

func (mmGetPulsePacket *PacketParserMock) GetPulsePacket() (p1 PulsePacketReader)

GetPulsePacket implements PacketParser

func (*PacketParserMock) GetPulsePacketAfterCounter 

func (mmGetPulsePacket *PacketParserMock) GetPulsePacketAfterCounter() uint64

GetPulsePacketAfterCounter returns a count of finished PacketParserMock.GetPulsePacket invocations

func (*PacketParserMock) GetPulsePacketBeforeCounter 

func (mmGetPulsePacket *PacketParserMock) GetPulsePacketBeforeCounter() uint64

GetPulsePacketBeforeCounter returns a count of PacketParserMock.GetPulsePacket invocations

func (*PacketParserMock) GetReceiverID 

func (mmGetReceiverID *PacketParserMock) GetReceiverID() (s1 node.ShortNodeID)

GetReceiverID implements PacketParser

func (*PacketParserMock) GetReceiverIDAfterCounter 

func (mmGetReceiverID *PacketParserMock) GetReceiverIDAfterCounter() uint64

GetReceiverIDAfterCounter returns a count of finished PacketParserMock.GetReceiverID invocations

func (*PacketParserMock) GetReceiverIDBeforeCounter 

func (mmGetReceiverID *PacketParserMock) GetReceiverIDBeforeCounter() uint64

GetReceiverIDBeforeCounter returns a count of PacketParserMock.GetReceiverID invocations

func (*PacketParserMock) GetSourceID 

func (mmGetSourceID *PacketParserMock) GetSourceID() (s1 node.ShortNodeID)

GetSourceID implements PacketParser

func (*PacketParserMock) GetSourceIDAfterCounter 

func (mmGetSourceID *PacketParserMock) GetSourceIDAfterCounter() uint64

GetSourceIDAfterCounter returns a count of finished PacketParserMock.GetSourceID invocations

func (*PacketParserMock) GetSourceIDBeforeCounter 

func (mmGetSourceID *PacketParserMock) GetSourceIDBeforeCounter() uint64

GetSourceIDBeforeCounter returns a count of PacketParserMock.GetSourceID invocations

func (*PacketParserMock) GetTargetID 

func (mmGetTargetID *PacketParserMock) GetTargetID() (s1 node.ShortNodeID)

GetTargetID implements PacketParser

func (*PacketParserMock) GetTargetIDAfterCounter 

func (mmGetTargetID *PacketParserMock) GetTargetIDAfterCounter() uint64

GetTargetIDAfterCounter returns a count of finished PacketParserMock.GetTargetID invocations

func (*PacketParserMock) GetTargetIDBeforeCounter 

func (mmGetTargetID *PacketParserMock) GetTargetIDBeforeCounter() uint64

GetTargetIDBeforeCounter returns a count of PacketParserMock.GetTargetID invocations

func (*PacketParserMock) IsRelayForbidden 

func (mmIsRelayForbidden *PacketParserMock) IsRelayForbidden() (b1 bool)

IsRelayForbidden implements PacketParser

func (*PacketParserMock) IsRelayForbiddenAfterCounter 

func (mmIsRelayForbidden *PacketParserMock) IsRelayForbiddenAfterCounter() uint64

IsRelayForbiddenAfterCounter returns a count of finished PacketParserMock.IsRelayForbidden invocations

func (*PacketParserMock) IsRelayForbiddenBeforeCounter 

func (mmIsRelayForbidden *PacketParserMock) IsRelayForbiddenBeforeCounter() uint64

IsRelayForbiddenBeforeCounter returns a count of PacketParserMock.IsRelayForbidden invocations

func (*PacketParserMock) MinimockFinish 

func (m *PacketParserMock) MinimockFinish()

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

func (*PacketParserMock) MinimockGetMemberPacketDone 

func (m *PacketParserMock) MinimockGetMemberPacketDone() bool

MinimockGetMemberPacketDone returns true if the count of the GetMemberPacket invocations corresponds the number of defined expectations

func (*PacketParserMock) MinimockGetMemberPacketInspect 

func (m *PacketParserMock) MinimockGetMemberPacketInspect()

MinimockGetMemberPacketInspect logs each unmet expectation

func (*PacketParserMock) MinimockGetPacketSignatureDone 

func (m *PacketParserMock) MinimockGetPacketSignatureDone() bool

MinimockGetPacketSignatureDone returns true if the count of the GetPacketSignature invocations corresponds the number of defined expectations

func (*PacketParserMock) MinimockGetPacketSignatureInspect 

func (m *PacketParserMock) MinimockGetPacketSignatureInspect()

MinimockGetPacketSignatureInspect logs each unmet expectation

func (*PacketParserMock) MinimockGetPacketTypeDone 

func (m *PacketParserMock) MinimockGetPacketTypeDone() bool

MinimockGetPacketTypeDone returns true if the count of the GetPacketType invocations corresponds the number of defined expectations

func (*PacketParserMock) MinimockGetPacketTypeInspect 

func (m *PacketParserMock) MinimockGetPacketTypeInspect()

MinimockGetPacketTypeInspect logs each unmet expectation

func (*PacketParserMock) MinimockGetPulseNumberDone 

func (m *PacketParserMock) MinimockGetPulseNumberDone() bool

MinimockGetPulseNumberDone returns true if the count of the GetPulseNumber invocations corresponds the number of defined expectations

func (*PacketParserMock) MinimockGetPulseNumberInspect 

func (m *PacketParserMock) MinimockGetPulseNumberInspect()

MinimockGetPulseNumberInspect logs each unmet expectation

func (*PacketParserMock) MinimockGetPulsePacketDone 

func (m *PacketParserMock) MinimockGetPulsePacketDone() bool

MinimockGetPulsePacketDone returns true if the count of the GetPulsePacket invocations corresponds the number of defined expectations

func (*PacketParserMock) MinimockGetPulsePacketInspect 

func (m *PacketParserMock) MinimockGetPulsePacketInspect()

MinimockGetPulsePacketInspect logs each unmet expectation

func (*PacketParserMock) MinimockGetReceiverIDDone 

func (m *PacketParserMock) MinimockGetReceiverIDDone() bool

MinimockGetReceiverIDDone returns true if the count of the GetReceiverID invocations corresponds the number of defined expectations

func (*PacketParserMock) MinimockGetReceiverIDInspect 

func (m *PacketParserMock) MinimockGetReceiverIDInspect()

MinimockGetReceiverIDInspect logs each unmet expectation

func (*PacketParserMock) MinimockGetSourceIDDone 

func (m *PacketParserMock) MinimockGetSourceIDDone() bool

MinimockGetSourceIDDone returns true if the count of the GetSourceID invocations corresponds the number of defined expectations

func (*PacketParserMock) MinimockGetSourceIDInspect 

func (m *PacketParserMock) MinimockGetSourceIDInspect()

MinimockGetSourceIDInspect logs each unmet expectation

func (*PacketParserMock) MinimockGetTargetIDDone 

func (m *PacketParserMock) MinimockGetTargetIDDone() bool

MinimockGetTargetIDDone returns true if the count of the GetTargetID invocations corresponds the number of defined expectations

func (*PacketParserMock) MinimockGetTargetIDInspect 

func (m *PacketParserMock) MinimockGetTargetIDInspect()

MinimockGetTargetIDInspect logs each unmet expectation

func (*PacketParserMock) MinimockIsRelayForbiddenDone 

func (m *PacketParserMock) MinimockIsRelayForbiddenDone() bool

MinimockIsRelayForbiddenDone returns true if the count of the IsRelayForbidden invocations corresponds the number of defined expectations

func (*PacketParserMock) MinimockIsRelayForbiddenInspect 

func (m *PacketParserMock) MinimockIsRelayForbiddenInspect()

MinimockIsRelayForbiddenInspect logs each unmet expectation

func (*PacketParserMock) MinimockParsePacketBodyDone 

func (m *PacketParserMock) MinimockParsePacketBodyDone() bool

MinimockParsePacketBodyDone returns true if the count of the ParsePacketBody invocations corresponds the number of defined expectations

func (*PacketParserMock) MinimockParsePacketBodyInspect 

func (m *PacketParserMock) MinimockParsePacketBodyInspect()

MinimockParsePacketBodyInspect logs each unmet expectation

func (*PacketParserMock) MinimockWait 

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

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

func (*PacketParserMock) ParsePacketBody 

func (mmParsePacketBody *PacketParserMock) ParsePacketBody() (p1 PacketParser, err error)

ParsePacketBody implements PacketParser

func (*PacketParserMock) ParsePacketBodyAfterCounter 

func (mmParsePacketBody *PacketParserMock) ParsePacketBodyAfterCounter() uint64

ParsePacketBodyAfterCounter returns a count of finished PacketParserMock.ParsePacketBody invocations

func (*PacketParserMock) ParsePacketBodyBeforeCounter 

func (mmParsePacketBody *PacketParserMock) ParsePacketBodyBeforeCounter() uint64

ParsePacketBodyBeforeCounter returns a count of PacketParserMock.ParsePacketBody invocations

type PacketParserMockGetMemberPacketExpectation 

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

PacketParserMockGetMemberPacketExpectation specifies expectation struct of the PacketParser.GetMemberPacket

type PacketParserMockGetMemberPacketResults 

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

PacketParserMockGetMemberPacketResults contains results of the PacketParser.GetMemberPacket

type PacketParserMockGetPacketSignatureExpectation 

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

PacketParserMockGetPacketSignatureExpectation specifies expectation struct of the PacketParser.GetPacketSignature

type PacketParserMockGetPacketSignatureResults 

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

PacketParserMockGetPacketSignatureResults contains results of the PacketParser.GetPacketSignature

type PacketParserMockGetPacketTypeExpectation 

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

PacketParserMockGetPacketTypeExpectation specifies expectation struct of the PacketParser.GetPacketType

type PacketParserMockGetPacketTypeResults 

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

PacketParserMockGetPacketTypeResults contains results of the PacketParser.GetPacketType

type PacketParserMockGetPulseNumberExpectation 

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

PacketParserMockGetPulseNumberExpectation specifies expectation struct of the PacketParser.GetPulseNumber

type PacketParserMockGetPulseNumberResults 

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

PacketParserMockGetPulseNumberResults contains results of the PacketParser.GetPulseNumber

type PacketParserMockGetPulsePacketExpectation 

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

PacketParserMockGetPulsePacketExpectation specifies expectation struct of the PacketParser.GetPulsePacket

type PacketParserMockGetPulsePacketResults 

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

PacketParserMockGetPulsePacketResults contains results of the PacketParser.GetPulsePacket

type PacketParserMockGetReceiverIDExpectation 

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

PacketParserMockGetReceiverIDExpectation specifies expectation struct of the PacketParser.GetReceiverID

type PacketParserMockGetReceiverIDResults 

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

PacketParserMockGetReceiverIDResults contains results of the PacketParser.GetReceiverID

type PacketParserMockGetSourceIDExpectation 

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

PacketParserMockGetSourceIDExpectation specifies expectation struct of the PacketParser.GetSourceID

type PacketParserMockGetSourceIDResults 

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

PacketParserMockGetSourceIDResults contains results of the PacketParser.GetSourceID

type PacketParserMockGetTargetIDExpectation 

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

PacketParserMockGetTargetIDExpectation specifies expectation struct of the PacketParser.GetTargetID

type PacketParserMockGetTargetIDResults 

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

PacketParserMockGetTargetIDResults contains results of the PacketParser.GetTargetID

type PacketParserMockIsRelayForbiddenExpectation 

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

PacketParserMockIsRelayForbiddenExpectation specifies expectation struct of the PacketParser.IsRelayForbidden

type PacketParserMockIsRelayForbiddenResults 

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

PacketParserMockIsRelayForbiddenResults contains results of the PacketParser.IsRelayForbidden

type PacketParserMockParsePacketBodyExpectation 

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

PacketParserMockParsePacketBodyExpectation specifies expectation struct of the PacketParser.ParsePacketBody

type PacketParserMockParsePacketBodyResults 

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

PacketParserMockParsePacketBodyResults contains results of the PacketParser.ParsePacketBody

type PacketPrepareOptions 

type PacketPrepareOptions uint32
const (
	AlternativePhasePacket PacketPrepareOptions = 1 << (16 + iota)
	OnlyBriefIntroAboutJoiner
)

func (PacketPrepareOptions) AsSendOptions 

func (o PacketPrepareOptions) AsSendOptions() PacketSendOptions

func (PacketPrepareOptions) HasAll 

func (o PacketPrepareOptions) HasAll(mask PacketPrepareOptions) bool

func (PacketPrepareOptions) HasAny 

func (o PacketPrepareOptions) HasAny(mask PacketPrepareOptions) bool

type PacketSendOptions 

type PacketSendOptions uint32
const (
	SendWithoutPulseData PacketSendOptions = 1 << iota
	TargetNeedsIntro
)

func (PacketSendOptions) HasAll 

func (o PacketSendOptions) HasAll(mask PacketSendOptions) bool

func (PacketSendOptions) HasAny 

func (o PacketSendOptions) HasAny(mask PacketSendOptions) bool

type PacketSender 

type PacketSender interface {
	SendPacketToTransport(ctx context.Context, t TargetProfile, sendOptions PacketSendOptions, payload interface{})
}

type Phase0PacketReader 

type Phase0PacketReader interface {
	PhasePacketReader

	GetNodeRank() member.Rank
	GetEmbeddedPulsePacket() PulsePacketReader
}

type Phase1PacketReader 

type Phase1PacketReader interface {
	PhasePacketReader
	AnnouncementPacketReader

	HasPulseData() bool /* PulseData/PulsarData is optional for Phase1 */
	GetEmbeddedPulsePacket() PulsePacketReader
}

type Phase2PacketReader 

type Phase2PacketReader interface {
	PhasePacketReader
	AnnouncementPacketReader

	GetBriefIntroduction() BriefIntroductionReader
	GetNeighbourhood() []MembershipAnnouncementReader
}

type Phase3PacketReader 

type Phase3PacketReader interface {
	PhasePacketReader
	HashedVectorReader
}

type PhasePacketReader 

type PhasePacketReader interface {
	GetPulseNumber() pulse.Number
}

type PreparedPacketSender 

type PreparedPacketSender interface {
	SendTo(ctx context.Context, target TargetProfile, sendOptions PacketSendOptions, sender PacketSender)

	/* Allows to control parallelism. Can return nil to skip a target */
	SendToMany(ctx context.Context, targetCount int, sender PacketSender, filter ProfileFilter)
}

type ProfileFilter 

type ProfileFilter func(ctx context.Context, targetIndex int) (TargetProfile, PacketSendOptions)

type PulsePacketReader 

type PulsePacketReader interface {
	// GetPulsarId() PulsarId
	GetPulseData() pulse.Data
	GetPulseDataEvidence() proofs.OriginalPulsarPacket
}

type StateDigester 

type StateDigester interface {
	AddNext(digest longbits.FoldableReader, fullRank member.FullRank)
	GetDigestMethod() cryptkit.DigestMethod
	/* deprecated */
	ForkSequence() StateDigester

	FinishSequence() cryptkit.Digest
}

type TargetProfile 

type TargetProfile interface {
	GetNodeID() node.ShortNodeID
	GetStatic() profiles.StaticProfile
	IsJoiner() bool
	// GetOpMode() member.OpMode
	EncryptJoinerSecret(joinerSecret cryptkit.DigestHolder) cryptkit.DigestHolder
}

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.