psser

Documentation

Overview

Package psser exposes functionalities needed to communicate with other peers on the network. Pss uses pushsync and pullsync for message delivery and mailboxing. All messages are disguised as content-addressed chunks. Sending and receiving of messages is exposed over the HTTP API, with websocket subscriptions for incoming messages.

Index

• Variables
• type Handler
• type Interface
  • func New(key *ecdsa.PrivateKey, logger log.Logger) Interface
• type Sender

Variables

var (
	ErrNoHandler = errors.New("no handler found")
)

Types

type Handler

type Handler func(context.Context, []byte)

Handler defines code to be executed upon reception of a trojan message.

type Interface

type Interface interface {
	Sender
	// Register a Handler for a given Topic.
	Register(trojan.Topic, Handler) func()
	// TryUnwrap tries to unwrap a wrapped trojan message.
	TryUnwrap(cluster.Chunk)

	SetPushSyncer(pushSyncer pushsync.PushSyncer)
	io.Closer
}

func New

func New(key *ecdsa.PrivateKey, logger log.Logger) Interface

New returns a new psser service.

type Sender

type Sender interface {
	// Send arbitrary byte slice with the given topic to Targets.
	Send(context.Context, trojan.Topic, []byte, voucher.Stamper, *ecdsa.PublicKey, trojan.Targets) error
}