Versions in this module Expand all Collapse all v1 v1.0.1 Oct 31, 2024 Changes in this version + const ManifestPubSubTopicName + const VersionCapability + var DefaultCatchUpAlignment = DefaultEcConfig.Period / 2 + var DefaultCommitteeLookback uint64 = 10 + var DefaultCxConfig = CxConfig + var DefaultEcConfig = EcConfig + var DefaultGpbftConfig = GpbftConfig + func DynamicManifestProviderWithDatastore(ds datastore.Datastore) func(cfg *dynamicManifestProviderConfig) error + func DynamicManifestProviderWithFilter(filter func(*Manifest) error) func(cfg *dynamicManifestProviderConfig) error + func DynamicManifestProviderWithInitialManifest(m *Manifest) func(cfg *dynamicManifestProviderConfig) error + func PubSubTopicFromNetworkName(nn gpbft.NetworkName) string + type CxConfig struct + ClientRequestTimeout time.Duration + MaximumPollInterval time.Duration + MinimumPollInterval time.Duration + ServerRequestTimeout time.Duration + func (c *CxConfig) Validate() error + type DynamicManifestProvider struct + func NewDynamicManifestProvider(pubsub *pubsub.PubSub, manifestServerID peer.ID, ...) (*DynamicManifestProvider, error) + func (m *DynamicManifestProvider) ManifestUpdates() <-chan *Manifest + func (m *DynamicManifestProvider) Start(startCtx context.Context) error + func (m *DynamicManifestProvider) Stop(ctx context.Context) error + type DynamicManifestProviderOption func(cfg *dynamicManifestProviderConfig) error + type EcConfig struct + BaseDecisionBackoffTable []float64 + DelayMultiplier float64 + Finality int64 + Finalize bool + HeadLookback int + Period time.Duration + func (e *EcConfig) Equal(o *EcConfig) bool + func (e *EcConfig) Validate() error + type FusingManifestProvider struct + func NewFusingManifestProvider(ctx context.Context, ec HeadGetter, dynamic ManifestProvider, static *Manifest) (*FusingManifestProvider, error) + func (m *FusingManifestProvider) ManifestUpdates() <-chan *Manifest + func (m *FusingManifestProvider) Start(ctx context.Context) error + func (m *FusingManifestProvider) Stop(ctx context.Context) error + type GpbftConfig struct + Delta time.Duration + DeltaBackOffExponent float64 + MaxLookaheadRounds uint64 + RebroadcastBackoffBase time.Duration + RebroadcastBackoffExponent float64 + RebroadcastBackoffMax time.Duration + RebroadcastBackoffSpread float64 + func (g *GpbftConfig) ToOptions() []gpbft.Option + func (g *GpbftConfig) Validate() error + type HeadGetter interface + GetHead func(context.Context) (ec.TipSet, error) + type Manifest struct + BootstrapEpoch int64 + CatchUpAlignment time.Duration + CertificateExchange CxConfig + CommitteeLookback uint64 + EC EcConfig + ExplicitPower gpbft.PowerEntries + Gpbft GpbftConfig + IgnoreECPower bool + InitialInstance uint64 + InitialPowerTable cid.Cid + NetworkName gpbft.NetworkName + Pause bool + ProtocolVersion uint64 + func LocalDevnetManifest() *Manifest + func Unmarshal(r io.Reader) (*Manifest, error) + func (m *Manifest) DatastorePrefix() datastore.Key + func (m *Manifest) Equal(o *Manifest) bool + func (m *Manifest) GpbftOptions() []gpbft.Option + func (m *Manifest) Marshal() ([]byte, error) + func (m *Manifest) PubSubTopic() string + func (m *Manifest) Validate() error + type ManifestProvider interface + ManifestUpdates func() <-chan *Manifest + Start func(context.Context) error + Stop func(context.Context) error + type ManifestSender struct + func NewManifestSender(ctx context.Context, h host.Host, ps *pubsub.PubSub, firstManifest *Manifest, ...) (*ManifestSender, error) + func (m *ManifestSender) PeerInfo() peer.AddrInfo + func (m *ManifestSender) Run(ctx context.Context) error + func (m *ManifestSender) SenderID() peer.ID + func (m *ManifestSender) UpdateManifest(manifest *Manifest) + type ManifestUpdateMessage struct + Manifest Manifest + MessageSequence uint64 + func (m *ManifestUpdateMessage) Unmarshal(r io.Reader) error + func (m ManifestUpdateMessage) Marshal() ([]byte, error) + type NoopManifestProvider struct + func (NoopManifestProvider) ManifestUpdates() <-chan *Manifest + func (NoopManifestProvider) Start(context.Context) error + func (NoopManifestProvider) Stop(context.Context) error + type StaticManifestProvider struct + func NewStaticManifestProvider(m *Manifest) (*StaticManifestProvider, error) + func (m *StaticManifestProvider) ManifestUpdates() <-chan *Manifest + func (m *StaticManifestProvider) Start(context.Context) error + func (m *StaticManifestProvider) Stop(context.Context) error
Go to main page