ebt

package

v0.2.1 Latest Latest Go to latest Published: Aug 5, 2021 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cryptoscope/ssb

Links

Open Source Insights

Documentation ¶

Index ¶

type MUXRPCHandler
type Plugin
- func NewPlug(i logging.Interface, self refs.FeedRef, rootLog margaret.Log, ...) *Plugin
type Sessions

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type MUXRPCHandler ¶

type MUXRPCHandler struct {
	Sessions Sessions
	// contains filtered or unexported fields
}

func (*MUXRPCHandler) HandleCall ¶

func (h *MUXRPCHandler) HandleCall(ctx context.Context, req *muxrpc.Request)

HandleCall handles the server side (getting called by client)

func (*MUXRPCHandler) HandleConnect ¶

func (h *MUXRPCHandler) HandleConnect(ctx context.Context, e muxrpc.Endpoint)

HandleConnect does nothing. Feature negotiation is done by sbot

func (MUXRPCHandler) Handled ¶

func (MUXRPCHandler) Handled(m muxrpc.Method) bool

func (*MUXRPCHandler) Loop ¶

func (h *MUXRPCHandler) Loop(ctx context.Context, tx *muxrpc.ByteSink, rx *muxrpc.ByteSource, remoteAddr net.Addr)

Loop executes the ebt logic loop, reading from the peer and sending state and messages as requests

type Plugin ¶

type Plugin struct{ *MUXRPCHandler }

func NewPlug ¶

func NewPlug(
	i logging.Interface,
	self refs.FeedRef,
	rootLog margaret.Log,
	uf multilog.MultiLog,
	fm *gossip.FeedManager,
	sm *statematrix.StateMatrix,
	v *message.VerificationRouter,
) *Plugin

func (Plugin) Handler ¶

func (p Plugin) Handler() muxrpc.Handler

func (Plugin) Method ¶

func (p Plugin) Method() muxrpc.Method

func (Plugin) Name ¶

func (p Plugin) Name() string

type Sessions ¶

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

func (*Sessions) Ended ¶

func (s *Sessions) Ended(addr net.Addr)

Ended notifies the session store that a session has ended.

func (*Sessions) Started ¶

func (s *Sessions) Started(addr net.Addr) *session

Started registers a new session for the network address and returns it. It also closes open channels in waitingFor if they exist and thus makes WaitFor() calls return.

func (*Sessions) WaitFor ¶

func (s *Sessions) WaitFor(ctx context.Context, addr net.Addr, durr time.Duration) bool

WaitFor returns true if addr manages to start a session before durration passes

Source Files ¶

View all Source files

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