censusimpl

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ActiveCensusTemplate 

type ActiveCensusTemplate struct {
	CensusTemplate
	// contains filtered or unexported fields
}

func (*ActiveCensusTemplate) CreateBuilder 

func (c *ActiveCensusTemplate) CreateBuilder(ctx context.Context, pn pulse.Number) census.Builder

func (*ActiveCensusTemplate) GetCensusState 

func (*ActiveCensusTemplate) GetCensusState() census.State

func (*ActiveCensusTemplate) GetCloudStateHash 

func (c *ActiveCensusTemplate) GetCloudStateHash() proofs.CloudStateHash

func (*ActiveCensusTemplate) GetExpectedPulseNumber 

func (c *ActiveCensusTemplate) GetExpectedPulseNumber() pulse.Number

func (*ActiveCensusTemplate) GetGlobulaStateHash 

func (c *ActiveCensusTemplate) GetGlobulaStateHash() proofs.GlobulaStateHash

func (*ActiveCensusTemplate) GetPulseData 

func (c *ActiveCensusTemplate) GetPulseData() pulse.Data

func (*ActiveCensusTemplate) GetPulseNumber 

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

func (*ActiveCensusTemplate) IsActive 

func (c *ActiveCensusTemplate) IsActive() bool

func (ActiveCensusTemplate) String 

func (c ActiveCensusTemplate) String() string

type BuiltCensusTemplate 

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

func (*BuiltCensusTemplate) GetCloudStateHash 

func (b *BuiltCensusTemplate) GetCloudStateHash() proofs.CloudStateHash

func (*BuiltCensusTemplate) GetEvictedPopulation 

func (b *BuiltCensusTemplate) GetEvictedPopulation() census.EvictedPopulation

func (*BuiltCensusTemplate) GetGlobulaStateHash 

func (b *BuiltCensusTemplate) GetGlobulaStateHash() proofs.GlobulaStateHash

func (*BuiltCensusTemplate) GetNearestPulseData 

func (b *BuiltCensusTemplate) GetNearestPulseData() (bool, pulse.Data)

func (*BuiltCensusTemplate) GetOnlinePopulation 

func (b *BuiltCensusTemplate) GetOnlinePopulation() census.OnlinePopulation

func (*BuiltCensusTemplate) MakeExpected 

func (b *BuiltCensusTemplate) MakeExpected() census.Expected

func (BuiltCensusTemplate) String 

func (b BuiltCensusTemplate) String() string

func (*BuiltCensusTemplate) Update 

func (b *BuiltCensusTemplate) Update(csh proofs.CloudStateHash, gsh proofs.GlobulaStateHash) census.Built

type CensusTemplate 

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

func (*CensusTemplate) GetEvictedPopulation 

func (c *CensusTemplate) GetEvictedPopulation() census.EvictedPopulation

func (*CensusTemplate) GetMandateRegistry 

func (c *CensusTemplate) GetMandateRegistry() census.MandateRegistry

func (*CensusTemplate) GetMisbehaviorRegistry 

func (c *CensusTemplate) GetMisbehaviorRegistry() census.MisbehaviorRegistry

func (*CensusTemplate) GetNearestPulseData 

func (c *CensusTemplate) GetNearestPulseData() (bool, pulse.Data)

func (*CensusTemplate) GetOfflinePopulation 

func (c *CensusTemplate) GetOfflinePopulation() census.OfflinePopulation

func (*CensusTemplate) GetOnlinePopulation 

func (c *CensusTemplate) GetOnlinePopulation() census.OnlinePopulation

func (*CensusTemplate) GetProfileFactory 

func (c *CensusTemplate) GetProfileFactory(ksf cryptkit.KeyStoreFactory) profiles.Factory

func (CensusTemplate) String 

func (c CensusTemplate) String() string

type DynamicPopulation 

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

func NewDynamicPopulationCopySelf 

func NewDynamicPopulationCopySelf(src copyToPopulation) DynamicPopulation

func (*DynamicPopulation) AddProfile 

func (c *DynamicPopulation) AddProfile(n profiles.StaticProfile) profiles.Updatable

func (*DynamicPopulation) CopyAndSeparate 

func (c *DynamicPopulation) CopyAndSeparate(forceInvalid bool, report RecoverableReport) (*ManyNodePopulation, census.EvictedPopulation)

func (*DynamicPopulation) FindProfile 

func (c *DynamicPopulation) FindProfile(nodeID node.ShortNodeID) profiles.ActiveNode

func (*DynamicPopulation) FindUpdatableProfile 

func (c *DynamicPopulation) FindUpdatableProfile(nodeID node.ShortNodeID) profiles.Updatable

func (*DynamicPopulation) GetCount 

func (c *DynamicPopulation) GetCount() int

func (*DynamicPopulation) GetLocalProfile 

func (c *DynamicPopulation) GetLocalProfile() profiles.LocalNode

func (*DynamicPopulation) GetProfiles 

func (c *DynamicPopulation) GetProfiles() []profiles.ActiveNode

func (*DynamicPopulation) GetUnorderedProfiles 

func (c *DynamicPopulation) GetUnorderedProfiles() []profiles.Updatable

func (*DynamicPopulation) RemoveOthers 

func (c *DynamicPopulation) RemoveOthers()

func (*DynamicPopulation) RemoveProfile 

func (c *DynamicPopulation) RemoveProfile(id node.ShortNodeID)

type DynamicPopulationBuilder 

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

func (*DynamicPopulationBuilder) AddProfile 

func (c *DynamicPopulationBuilder) AddProfile(intro profiles.StaticProfile) profiles.Updatable

func (*DynamicPopulationBuilder) FindProfile 

func (c *DynamicPopulationBuilder) FindProfile(nodeID node.ShortNodeID) profiles.Updatable

func (*DynamicPopulationBuilder) GetCount 

func (c *DynamicPopulationBuilder) GetCount() int

func (*DynamicPopulationBuilder) GetLocalProfile 

func (c *DynamicPopulationBuilder) GetLocalProfile() profiles.Updatable

func (*DynamicPopulationBuilder) GetUnorderedProfiles 

func (c *DynamicPopulationBuilder) GetUnorderedProfiles() []profiles.Updatable

func (*DynamicPopulationBuilder) RemoveOthers 

func (c *DynamicPopulationBuilder) RemoveOthers()

func (*DynamicPopulationBuilder) RemoveProfile 

func (c *DynamicPopulationBuilder) RemoveProfile(nodeID node.ShortNodeID)

type ExpectedCensusTemplate 

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

func (*ExpectedCensusTemplate) CreateBuilder 

func (c *ExpectedCensusTemplate) CreateBuilder(ctx context.Context, pn pulse.Number) census.Builder

func (*ExpectedCensusTemplate) GetCensusState 

func (c *ExpectedCensusTemplate) GetCensusState() census.State

func (*ExpectedCensusTemplate) GetCloudStateHash 

func (c *ExpectedCensusTemplate) GetCloudStateHash() proofs.CloudStateHash

func (*ExpectedCensusTemplate) GetEvictedPopulation 

func (c *ExpectedCensusTemplate) GetEvictedPopulation() census.EvictedPopulation

func (*ExpectedCensusTemplate) GetExpectedPulseNumber 

func (c *ExpectedCensusTemplate) GetExpectedPulseNumber() pulse.Number

func (*ExpectedCensusTemplate) GetGlobulaStateHash 

func (c *ExpectedCensusTemplate) GetGlobulaStateHash() proofs.GlobulaStateHash

func (*ExpectedCensusTemplate) GetMandateRegistry 

func (c *ExpectedCensusTemplate) GetMandateRegistry() census.MandateRegistry

func (*ExpectedCensusTemplate) GetMisbehaviorRegistry 

func (c *ExpectedCensusTemplate) GetMisbehaviorRegistry() census.MisbehaviorRegistry

func (*ExpectedCensusTemplate) GetNearestPulseData 

func (c *ExpectedCensusTemplate) GetNearestPulseData() (bool, pulse.Data)

func (*ExpectedCensusTemplate) GetOfflinePopulation 

func (c *ExpectedCensusTemplate) GetOfflinePopulation() census.OfflinePopulation

func (*ExpectedCensusTemplate) GetOnlinePopulation 

func (c *ExpectedCensusTemplate) GetOnlinePopulation() census.OnlinePopulation

func (*ExpectedCensusTemplate) GetPrevious 

func (c *ExpectedCensusTemplate) GetPrevious() census.Active

func (*ExpectedCensusTemplate) GetProfileFactory 

func (c *ExpectedCensusTemplate) GetProfileFactory(ksf cryptkit.KeyStoreFactory) profiles.Factory

func (*ExpectedCensusTemplate) GetPulseNumber 

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

func (*ExpectedCensusTemplate) IsActive 

func (c *ExpectedCensusTemplate) IsActive() bool

func (*ExpectedCensusTemplate) MakeActive 

func (c *ExpectedCensusTemplate) MakeActive(pd pulse.Data) census.Active

func (*ExpectedCensusTemplate) Rebuild 

func (c *ExpectedCensusTemplate) Rebuild(pn pulse.Number) census.Built

func (ExpectedCensusTemplate) String 

func (c ExpectedCensusTemplate) String() string

type LessFunc 

type LessFunc func(c profiles.ActiveNode, o profiles.ActiveNode) bool

type LocalCensusBuilder 

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

func (*LocalCensusBuilder) Build 

func (c *LocalCensusBuilder) Build(csh proofs.CloudStateHash) census.Built

func (*LocalCensusBuilder) BuildAsBroken 

func (c *LocalCensusBuilder) BuildAsBroken(csh proofs.CloudStateHash) census.Built

func (*LocalCensusBuilder) GetCensusState 

func (c *LocalCensusBuilder) GetCensusState() census.State

func (*LocalCensusBuilder) GetGlobulaStateHash 

func (c *LocalCensusBuilder) GetGlobulaStateHash() proofs.GlobulaStateHash

func (*LocalCensusBuilder) GetPopulationBuilder 

func (c *LocalCensusBuilder) GetPopulationBuilder() census.PopulationBuilder

func (*LocalCensusBuilder) GetPulseNumber 

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

func (*LocalCensusBuilder) IsSealed 

func (c *LocalCensusBuilder) IsSealed() bool

func (*LocalCensusBuilder) SealCensus 

func (c *LocalCensusBuilder) SealCensus()

func (*LocalCensusBuilder) SetGlobulaStateHash 

func (c *LocalCensusBuilder) SetGlobulaStateHash(gsh proofs.GlobulaStateHash)

type LocalConsensusChronicles 

type LocalConsensusChronicles interface {
	api.ConsensusChronicles
	// contains filtered or unexported methods
}

func NewLocalChronicles 

func NewLocalChronicles(profileFactory profiles.Factory) LocalConsensusChronicles

type ManyNodePopulation 

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

func CopySelfNodePopulation 

func CopySelfNodePopulation(pop census.OnlinePopulation) ManyNodePopulation

func NewManyNodePopulation 

func NewManyNodePopulation(nodes []profiles.StaticProfile, localID node.ShortNodeID,
	vf cryptkit.SignatureVerifierFactory) ManyNodePopulation

func (*ManyNodePopulation) FindProfile 

func (c *ManyNodePopulation) FindProfile(nodeID node.ShortNodeID) profiles.ActiveNode

func (*ManyNodePopulation) GetIdleCount 

func (c *ManyNodePopulation) GetIdleCount() int

func (*ManyNodePopulation) GetIdleProfiles 

func (c *ManyNodePopulation) GetIdleProfiles() []profiles.ActiveNode

func (*ManyNodePopulation) GetIndexedCapacity 

func (c *ManyNodePopulation) GetIndexedCapacity() int

func (*ManyNodePopulation) GetIndexedCount 

func (c *ManyNodePopulation) GetIndexedCount() int

func (*ManyNodePopulation) GetLocalProfile 

func (c *ManyNodePopulation) GetLocalProfile() profiles.LocalNode

func (*ManyNodePopulation) GetMistrustedCount 

func (c *ManyNodePopulation) GetMistrustedCount() int

func (*ManyNodePopulation) GetPoweredProfiles 

func (c *ManyNodePopulation) GetPoweredProfiles() []profiles.ActiveNode

func (*ManyNodePopulation) GetPoweredRoles 

func (c *ManyNodePopulation) GetPoweredRoles() []member.PrimaryRole

func (*ManyNodePopulation) GetProfile 

func (c *ManyNodePopulation) GetProfile(index member.Index) profiles.ActiveNode

func (*ManyNodePopulation) GetProfiles 

func (c *ManyNodePopulation) GetProfiles() []profiles.ActiveNode

func (*ManyNodePopulation) GetRolePopulation 

func (c *ManyNodePopulation) GetRolePopulation(role member.PrimaryRole) census.RolePopulation

func (*ManyNodePopulation) GetSuspendedCount 

func (c *ManyNodePopulation) GetSuspendedCount() int

func (*ManyNodePopulation) IsClean 

func (c *ManyNodePopulation) IsClean() bool

func (*ManyNodePopulation) IsValid 

func (c *ManyNodePopulation) IsValid() bool

func (ManyNodePopulation) String 

func (c ManyNodePopulation) String() string

type NodeProfileSlot 

type NodeProfileSlot struct {
	profiles.StaticProfile
	// contains filtered or unexported fields
}

func NewJoinerProfile 

func NewJoinerProfile(p profiles.StaticProfile, verifier cryptkit.SignatureVerifier) NodeProfileSlot

func NewNodeProfile 

func NewNodeProfile(index member.Index, p profiles.StaticProfile, verifier cryptkit.SignatureVerifier, pw member.Power) NodeProfileSlot

func NewNodeProfileExt 

func NewNodeProfileExt(index member.Index, p profiles.StaticProfile, verifier cryptkit.SignatureVerifier, pw member.Power,
	mode member.OpMode) NodeProfileSlot

func (*NodeProfileSlot) CanIntroduceJoiner 

func (c *NodeProfileSlot) CanIntroduceJoiner() bool

func (*NodeProfileSlot) GetDeclaredPower 

func (c *NodeProfileSlot) GetDeclaredPower() member.Power

func (*NodeProfileSlot) GetIndex 

func (c *NodeProfileSlot) GetIndex() member.Index

func (*NodeProfileSlot) GetNodeID 

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

func (*NodeProfileSlot) GetOpMode 

func (c *NodeProfileSlot) GetOpMode() member.OpMode

func (*NodeProfileSlot) GetSignatureVerifier 

func (c *NodeProfileSlot) GetSignatureVerifier() cryptkit.SignatureVerifier

func (*NodeProfileSlot) GetStatic 

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

func (*NodeProfileSlot) HasFullProfile 

func (c *NodeProfileSlot) HasFullProfile() bool

func (*NodeProfileSlot) IsJoiner 

func (c *NodeProfileSlot) IsJoiner() bool

func (*NodeProfileSlot) IsPowered 

func (c *NodeProfileSlot) IsPowered() bool

func (*NodeProfileSlot) IsStateful 

func (c *NodeProfileSlot) IsStateful() bool

func (*NodeProfileSlot) IsVoter 

func (c *NodeProfileSlot) IsVoter() bool

func (*NodeProfileSlot) LocalNodeProfile 

func (c *NodeProfileSlot) LocalNodeProfile()

func (NodeProfileSlot) String 

func (c NodeProfileSlot) String() string

type OneJoinerPopulation 

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

func NewJoinerPopulation 

func NewJoinerPopulation(localNode profiles.StaticProfile, vf cryptkit.SignatureVerifierFactory) OneJoinerPopulation

func (*OneJoinerPopulation) FindProfile 

func (c *OneJoinerPopulation) FindProfile(nodeID node.ShortNodeID) profiles.ActiveNode

func (*OneJoinerPopulation) GetIdleCount 

func (c *OneJoinerPopulation) GetIdleCount() int

func (*OneJoinerPopulation) GetIdleProfiles 

func (c *OneJoinerPopulation) GetIdleProfiles() []profiles.ActiveNode

func (*OneJoinerPopulation) GetIndexedCapacity 

func (c *OneJoinerPopulation) GetIndexedCapacity() int

func (*OneJoinerPopulation) GetIndexedCount 

func (c *OneJoinerPopulation) GetIndexedCount() int

func (*OneJoinerPopulation) GetLocalProfile 

func (c *OneJoinerPopulation) GetLocalProfile() profiles.LocalNode

func (*OneJoinerPopulation) GetMistrustedCount 

func (c *OneJoinerPopulation) GetMistrustedCount() int

func (*OneJoinerPopulation) GetPoweredProfiles 

func (c *OneJoinerPopulation) GetPoweredProfiles() []profiles.ActiveNode

func (*OneJoinerPopulation) GetPoweredRoles 

func (c *OneJoinerPopulation) GetPoweredRoles() []member.PrimaryRole

func (*OneJoinerPopulation) GetProfile 

func (c *OneJoinerPopulation) GetProfile(member.Index) profiles.ActiveNode

func (*OneJoinerPopulation) GetProfiles 

func (c *OneJoinerPopulation) GetProfiles() []profiles.ActiveNode

func (*OneJoinerPopulation) GetRolePopulation 

func (c *OneJoinerPopulation) GetRolePopulation(role member.PrimaryRole) census.RolePopulation

func (*OneJoinerPopulation) GetSuspendedCount 

func (c *OneJoinerPopulation) GetSuspendedCount() int

func (*OneJoinerPopulation) IsClean 

func (c *OneJoinerPopulation) IsClean() bool

func (*OneJoinerPopulation) IsValid 

func (c *OneJoinerPopulation) IsValid() bool

func (OneJoinerPopulation) String 

func (c OneJoinerPopulation) String() string

type PrimingCensusTemplate 

type PrimingCensusTemplate struct {
	CensusTemplate
}

func NewPrimingCensus 

func NewPrimingCensus(intros []profiles.StaticProfile, localProfile profiles.StaticProfile, registries census.VersionedRegistries,
	vf cryptkit.SignatureVerifierFactory, allowEphemeral bool) *PrimingCensusTemplate

func NewPrimingCensusForJoiner 

func NewPrimingCensusForJoiner(localProfile profiles.StaticProfile, registries census.VersionedRegistries,
	vf cryptkit.SignatureVerifierFactory, allowEphemeral bool) *PrimingCensusTemplate

func (*PrimingCensusTemplate) BuildCopy 

func (c *PrimingCensusTemplate) BuildCopy(pd pulse.Data, csh proofs.CloudStateHash, gsh proofs.GlobulaStateHash) census.Built

func (*PrimingCensusTemplate) CreateBuilder 

func (c *PrimingCensusTemplate) CreateBuilder(ctx context.Context, pn pulse.Number) census.Builder

func (*PrimingCensusTemplate) GetCensusState 

func (*PrimingCensusTemplate) GetCensusState() census.State

func (*PrimingCensusTemplate) GetCloudStateHash 

func (*PrimingCensusTemplate) GetCloudStateHash() proofs.CloudStateHash

func (*PrimingCensusTemplate) GetExpectedPulseNumber 

func (c *PrimingCensusTemplate) GetExpectedPulseNumber() pulse.Number

func (*PrimingCensusTemplate) GetGlobulaStateHash 

func (*PrimingCensusTemplate) GetGlobulaStateHash() proofs.GlobulaStateHash

func (*PrimingCensusTemplate) GetPulseData 

func (c *PrimingCensusTemplate) GetPulseData() pulse.Data

func (*PrimingCensusTemplate) GetPulseNumber 

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

func (*PrimingCensusTemplate) IsActive 

func (c *PrimingCensusTemplate) IsActive() bool

func (*PrimingCensusTemplate) SetAsActiveTo 

func (c *PrimingCensusTemplate) SetAsActiveTo(chronicles LocalConsensusChronicles)

func (PrimingCensusTemplate) String 

func (c PrimingCensusTemplate) String() string

type RecoverableReport 

type RecoverableReport func(e census.RecoverableErrorTypes, msg string, args ...interface{})

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.