ebt

Documentation

Index

• type MUXRPCHandler
  • func (h *MUXRPCHandler) HandleCall(ctx context.Context, req *muxrpc.Request)
  • func (h *MUXRPCHandler) HandleConnect(ctx context.Context, e muxrpc.Endpoint)
  • func (MUXRPCHandler) Handled(m muxrpc.Method) bool
  • func (h *MUXRPCHandler) Loop(ctx context.Context, tx *muxrpc.ByteSink, rx *muxrpc.ByteSource, ...)
• type Plugin
  • func NewPlug(i logging.Interface, self refs.FeedRef, rootLog margaret.Log, ...) *Plugin
  • func (p Plugin) Handler() muxrpc.Handler
  • func (p Plugin) Method() muxrpc.Method
  • func (p Plugin) Name() string
• type Sessions
  • func (s *Sessions) Ended(addr net.Addr)
  • func (s *Sessions) Started(addr net.Addr) *session
  • func (s *Sessions) WaitFor(ctx context.Context, addr net.Addr, durr time.Duration) bool

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