isolation

package
v0.5.21 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 18, 2025 License: AGPL-3.0, AGPL-3.0-or-later Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type IsolationProtocol

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

func NewIsolationProtocol

func NewIsolationProtocol(node StreamingNode, pub Publisher) *IsolationProtocol

func (*IsolationProtocol) IsolateTweet

func (ip *IsolationProtocol) IsolateTweet(nodeId warpnet.WarpPeerID, tweet domain.Tweet)

type Publisher

type Publisher interface {
	PublishUpdateToFollowers(ownerId, dest string, bt []byte) (err error)
}

type StreamingNode

type StreamingNode interface {
	GenericStream(string, stream.WarpRoute, any) ([]byte, error)
	Node() warpnet.P2PNode
}

Jump to

Keyboard shortcuts

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