Versions in this module Expand all Collapse all v0 v0.7.6 Oct 23, 2025 v0.7.5 Jun 30, 2025 Changes in this version + var Counters = []prometheus.CounterDefinition + var DefaultConfig = Config + var DirectMessagePipeline = Pipeline + var Gauges = []prometheus.GaugeDefinition + var NodeInfoMetric = []string + func HandleMessage[T bls.Message](ctx context.Context, from peer.ID, payload []byte, ...) error + func NewCore(log zerolog.Logger, host *host.Host, opts ...Option) *core + type Config struct + Concurrency uint + HealthInterval time.Duration + Topics []string + type Core interface + ID func() string + type Logger interface + Log func() *zerolog.Logger + type Messaging interface + JoinTopic func(string) error + Publish func(context.Context, bls.Message) error + PublishToTopic func(context.Context, string, bls.Message) error + Send func(context.Context, peer.ID, bls.Message) error + SendToMany func(context.Context, []peer.ID, bls.Message, bool) error + Subscribe func(context.Context, string) error + type Network interface + Connected func(peer.ID) bool + Host func() *host.Host + type NodeOps interface + Run func(context.Context, func(context.Context, peer.ID, string, []byte) error) error + type Option func(*Config) + func Concurrency(n uint) Option + func HealthInterval(d time.Duration) Option + func Topics(topics []string) Option + type Pipeline struct + ID PipelineID + Topic string + func PubSubPipeline(topic string) Pipeline + func (p Pipeline) String() string + type PipelineID int + const DirectMessage + const PubSub + func (i PipelineID) String() string + type Telemetry interface + Metrics func() *metrics.Metrics + Tracer func() *tracing.Tracer
Go to main page