management

Documentation

Index

• func NewManagement(parentCtx context.Context, config Config, provider Provider, ...) *service
• type CommitteeTerm
• type Config
• type ProtocolVersionTerm
• type Provider
• type SubscriptionTerm
• type TopologyConsumer
• type VirtualChainManagementData

Functions

func NewManagement

func NewManagement(parentCtx context.Context, config Config, provider Provider, topologyConsumer TopologyConsumer, parentLogger log.Logger, metricFactory metric.Factory) *service

Types

type CommitteeTerm

type CommitteeTerm struct {
	AsOfReference primitives.TimestampSeconds
	Members       []primitives.NodeAddress
	Weights       []primitives.Weight
}

type Config

type Config interface {
	ManagementPollingInterval() time.Duration
}

type ProtocolVersionTerm

type ProtocolVersionTerm struct {
	AsOfReference primitives.TimestampSeconds
	Version       primitives.ProtocolVersion
}

type Provider

type Provider interface {
	Get(ctx context.Context, referenceTime primitives.TimestampSeconds) (*VirtualChainManagementData, error)
}

type SubscriptionTerm

type SubscriptionTerm struct {
	AsOfReference primitives.TimestampSeconds
	IsActive      bool
}

type TopologyConsumer

type TopologyConsumer interface {
	UpdateTopology(ctx context.Context, input *services.UpdateTopologyInput) (*services.UpdateTopologyOutput, error)
}

type VirtualChainManagementData

type VirtualChainManagementData struct {
	CurrentReference   primitives.TimestampSeconds
	GenesisReference   primitives.TimestampSeconds
	StartPageReference primitives.TimestampSeconds
	EndPageReference   primitives.TimestampSeconds
	CurrentTopology    []*services.GossipPeer
	Committees         []CommitteeTerm
	Subscriptions      []SubscriptionTerm
	ProtocolVersions   []ProtocolVersionTerm
}