Versions in this module Expand all Collapse all v0 v0.1.0 May 5, 2024 Changes in this version + func CheckMessageRoundTrip[M any, P MessagePointer[M]](t *rapid.T, logger *slog.Logger, nodeCount int, ...) + func RandomUniverse(logger *slog.Logger) *rapid.Generator[*Universe] + func RandomUniverseN(logger *slog.Logger, minSize, maxSize int) *rapid.Generator[*Universe] + type MessagePointer interface + type Universe struct + AllIdentifiers []pastry.Identifier + Local *node + MessageLibrary *pastry.MessageLibrary + Remote []*node + Router *pastry.Router + SentMessages *pastrytest.SentMessages + Transceiver *pastry.Transceiver + func NewUniverse(logger *slog.Logger, localID pastry.Identifier) *Universe + func (u *Universe) AddRemoteNode(nodeID pastry.Identifier, proximity pastry.Proximity) *node + func (u *Universe) Format(state fmt.State, verb rune) + func (u *Universe) GetNode(id pastry.Identifier) *node + func (u *Universe) GetOwner(dest pastry.Identifier) pastry.Node + func (u *Universe) GetOwningIdentifier(dest pastry.Identifier) pastry.Identifier + func (u *Universe) GetRemoteOwner(dest pastry.Identifier) pastry.Node + func (u *Universe) LocalNode() pastry.Node + func (u *Universe) Logger() *slog.Logger + func (u *Universe) RandomRemoteNode() *rapid.Generator[pastry.Node] + func (u *Universe) ReadNode(p *pastry.MessagePayload) (pastry.Node, error) + func (u *Universe) RouteLocal(ctx context.Context, source pastry.Identifier, target pastry.Identifier, ...) error + func (u *Universe) SaturateRouter() + func (u *Universe) SendLocal(ctx context.Context, msg pastry.Message) error