buffered

package

v0.15.18 Latest Latest Go to latest Published: Jan 30, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/NethermindEth/juno

Links

Open Source Insights

Documentation ¶

Index ¶

type ProtoBroadcaster
- func NewProtoBroadcaster[M proto.Message](log utils.Logger, bufferSize int, retryInterval time.Duration, ...) ProtoBroadcaster[M]
- func (b ProtoBroadcaster[M]) Broadcast(ctx context.Context, msg M)
- func (b ProtoBroadcaster[M]) Loop(ctx context.Context, topic *pubsub.Topic)
type RebroadcastStrategy
- func NewRebroadcastStrategy[M proto.Message, K comparable](rebroadcastInterval time.Duration, getKey func(M) K) RebroadcastStrategy[M]
type TopicSubscription
- func NewTopicSubscription(log utils.Logger, bufferSize int, ...) TopicSubscription
- func (b TopicSubscription) Loop(ctx context.Context, topic *pubsub.Topic)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ProtoBroadcaster ¶ added in v0.14.7

type ProtoBroadcaster[M proto.Message] struct {
	// contains filtered or unexported fields
}

func NewProtoBroadcaster ¶ added in v0.14.7

func NewProtoBroadcaster[M proto.Message](
	log utils.Logger,
	bufferSize int,
	retryInterval time.Duration,
	rebroadcastStrategy RebroadcastStrategy[M],
) ProtoBroadcaster[M]

func (ProtoBroadcaster[M]) Broadcast ¶ added in v0.14.7

func (b ProtoBroadcaster[M]) Broadcast(ctx context.Context, msg M)

func (ProtoBroadcaster[M]) Loop ¶ added in v0.14.7

func (b ProtoBroadcaster[M]) Loop(ctx context.Context, topic *pubsub.Topic)

type RebroadcastStrategy ¶ added in v0.15.2

type RebroadcastStrategy[M proto.Message] interface {
	Receive(msg M, msgBytes []byte) rebroadcastMessages
}

func NewRebroadcastStrategy ¶ added in v0.15.2

func NewRebroadcastStrategy[M proto.Message, K comparable](rebroadcastInterval time.Duration, getKey func(M) K) RebroadcastStrategy[M]

type TopicSubscription ¶

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

func NewTopicSubscription ¶

func NewTopicSubscription(log utils.Logger, bufferSize int, callback func(context.Context, *pubsub.Message)) TopicSubscription

func (TopicSubscription) Loop ¶

func (b TopicSubscription) Loop(ctx context.Context, topic *pubsub.Topic)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL