manifest

Oct 3, 2024

Changes in this version

+ 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

+ type DynamicManifestProviderOption func(cfg *dynamicManifestProviderConfig) error

type EcConfig

+ Finalize bool

+ 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 HeadGetter interface

+ GetHead func(context.Context) (ec.TipSet, error)

+ type NoopManifestProvider struct

+ func (NoopManifestProvider) ManifestUpdates() <-chan *Manifest

+ func (NoopManifestProvider) Start(context.Context) error

+ func (NoopManifestProvider) Stop(context.Context) error

Sep 18, 2024

Changes in this version

type GpbftConfig

+ RebroadcastBackoffSpread float64

Aug 13, 2024

Changes in this version

+ var DefaultCatchUpAlignment time.Duration = 0

type GpbftConfig

+ RebroadcastBackoffBase time.Duration

+ RebroadcastBackoffExponent float64

+ RebroadcastBackoffMax time.Duration

+ func (g *GpbftConfig) ToOptions() []gpbft.Option

type Manifest

+ CatchUpAlignment time.Duration

Jul 24, 2024

Changes in this version

+ const VersionCapability

+ var DefaultCommitteeLookback uint64 = 10

type CxConfig

+ func (c *CxConfig) Validate() error

type EcConfig

+ DelayMultiplier float64

+ Finality int64

+ HeadLookback int

+ Period time.Duration

+ func (e *EcConfig) Validate() error

type GpbftConfig

+ func (g *GpbftConfig) Validate() error

type Manifest

+ CertificateExchange CxConfig

+ CommitteeLookback uint64

+ EC EcConfig

+ Gpbft GpbftConfig

+ InitialPowerTable cid.Cid

+ Pause bool

+ ProtocolVersion uint64

+ func Unmarshal(r io.Reader) (*Manifest, error)

+ func (m *Manifest) Validate() error

Jul 15, 2024

Changes in this version

+ var DefaultCxConfig = CxConfig

type EcConfig

+ CommitteeLookback uint64

+ func (e *EcConfig) Equal(o *EcConfig) bool

type Manifest

+ ExplicitPower gpbft.PowerEntries

+ IgnoreECPower bool

+ func (m *Manifest) Equal(o *Manifest) bool

Jul 11, 2024

Changes in this version

+ const ManifestPubSubTopicName

+ var DefaultEcConfig = &EcConfig

+ var DefaultGpbftConfig = &GpbftConfig

+ var DefaultGpbftOptions = []gpbft.Option

+ func PubSubTopicFromNetworkName(nn gpbft.NetworkName) string

+ type CxConfig struct

+ ClientRequestTimeout time.Duration

+ MaximumPollInterval time.Duration

+ MinimumPollInterval time.Duration

+ ServerRequestTimeout time.Duration

+ type DynamicManifestProvider struct

+ func (m *DynamicManifestProvider) ManifestUpdates() <-chan *Manifest

+ func (m *DynamicManifestProvider) Start(startCtx context.Context) (_err error)

+ func (m *DynamicManifestProvider) Stop(ctx context.Context) (_err error)

+ type EcConfig struct

+ BaseDecisionBackoffTable []float64

+ CommiteeLookback uint64

+ ECDelayMultiplier float64

+ ECFinality int64

+ ECPeriod time.Duration

+ type GpbftConfig struct

+ Delta time.Duration

+ DeltaBackOffExponent float64

+ MaxLookaheadRounds uint64

+ type Manifest struct

+ BootstrapEpoch int64

+ InitialInstance uint64

+ NetworkName gpbft.NetworkName

+ PowerUpdate []certs.PowerTableDelta

+ func LocalDevnetManifest() *Manifest

+ func (m *Manifest) DatastorePrefix() datastore.Key

+ func (m *Manifest) GpbftOptions() []gpbft.Option

+ func (m *Manifest) Marshal() ([]byte, error)

+ func (m *Manifest) PubSubTopic() string

+ func (m *Manifest) Unmarshal(r io.Reader) error

+ func (m *Manifest) Version() (Version, error)

+ type ManifestProvider interface

+ ManifestUpdates func() <-chan *Manifest

+ Start func(context.Context) error

+ Stop func(context.Context) error

+ func NewDynamicManifestProvider(initialManifest *Manifest, pubsub *pubsub.PubSub, ec ec.Backend, ...) ManifestProvider

+ func NewStaticManifestProvider(m *Manifest) ManifestProvider

+ type ManifestSender struct

+ func NewManifestSender(h host.Host, pubsub *pubsub.PubSub, firstManifest *Manifest, ...) (*ManifestSender, error)

+ func (m *ManifestSender) Pause()

+ func (m *ManifestSender) PeerInfo() peer.AddrInfo

+ func (m *ManifestSender) Resume()

+ 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

+ ManifestVersion uint64

+ MessageSequence uint64

+ func (m *ManifestUpdateMessage) Unmarshal(r io.Reader) error

+ func (m ManifestUpdateMessage) Marshal() ([]byte, error)

+ type OnManifestChange func(ctx context.Context, prevManifest Manifest) error

+ type StaticManifestProvider struct

+ func (m *StaticManifestProvider) ManifestUpdates() <-chan *Manifest

+ func (m *StaticManifestProvider) Start(context.Context) error

+ func (m *StaticManifestProvider) Stop(context.Context) error

+ type Version string