net

Documentation

Index

• Constants
• func GetProfile(pk keys.PK) (programs []string, err error)
• func PeerFromFindString(find string) (p *keys.Peer, err error)
• func StartWebProgram(pk keys.PK, name string, args WebArgs) (rets WebRets, err error)
• func StoreProgram(pk keys.PK, name string, b []byte) (hash [32]byte, err error)
• type AddressedMsg
• type AnyMsg
  • func (m AnyMsg) Deserialise() (SentMsg, error)
• type EncryptedMsg
  • func (e EncryptedMsg) Decode(kp keys.Keypair) (am AnyMsg, err error)
• type InputName
• type MessageType
• type Net
  • func NewTestNet() Net
• type Node
  • func NewNode(kp keys.Keypair, mainAddr keys.Address, altAddrs ...keys.Address) (node *Node)
  • func (n *Node) AddPeer(p *keys.Peer)
  • func (n Node) FindString() string
  • func (n *Node) RunWebProgram(pk keys.PK, name string, input WebArgs, useLocal bool) (res WebRets, err error)
  • func (n *Node) Start()
  • func (n *Node) Stop()
  • func (n *Node) StoreProgram(pk keys.PK, name string, sig keys.HashSig, b []byte) (err error)
• type Receiver
• type Sender
• type SentMsg
• type TestNet
  • func (n *TestNet) AddNode(node *Node)

Constants

const FindStart = "cofind:"

Functions

func GetProfile

func GetProfile(pk keys.PK) (programs []string, err error)

func PeerFromFindString

func PeerFromFindString(find string) (p *keys.Peer, err error)

func StartWebProgram

func StartWebProgram(pk keys.PK, name string, args WebArgs) (rets WebRets, err error)

func StoreProgram

func StoreProgram(pk keys.PK, name string, b []byte) (hash [32]byte, err error)

Types

type AddressedMsg

type AddressedMsg struct {
	EncryptedMsg
	*keys.Peer
}

type AnyMsg

type AnyMsg struct {
	From *keys.Peer
	Type MessageType
	Body []byte
}

func (AnyMsg) Deserialise

func (m AnyMsg) Deserialise() (SentMsg, error)

type EncryptedMsg

type EncryptedMsg []byte

func (EncryptedMsg) Decode

func (e EncryptedMsg) Decode(kp keys.Keypair) (am AnyMsg, err error)

type InputName

type InputName struct {
	Pk        keys.PK
	Name      string
	InputHash [32]byte
}

struct keys > nested maps

type MessageType

type MessageType = byte

type Net

type Net interface {
	AddNode(node *Node)
}

func NewTestNet

func NewTestNet() Net

type Node

type Node struct {
	keys.ThisPeer

	Peers      map[keys.PK]*keys.Peer // known peers
	SendRaw    Sender
	ReceiveRaw Receiver
	// contains filtered or unexported fields
}

func NewNode

func NewNode(kp keys.Keypair, mainAddr keys.Address, altAddrs ...keys.Address) (node *Node)

func (*Node) AddPeer

func (n *Node) AddPeer(p *keys.Peer)

func (Node) FindString

func (n Node) FindString() string

A find string encodes the pk and addresses

func (*Node) RunWebProgram

func (n *Node) RunWebProgram(pk keys.PK, name string, input WebArgs, useLocal bool) (res WebRets, err error)

func (*Node) Start

func (n *Node) Start()

func (*Node) Stop

func (n *Node) Stop()

func (*Node) StoreProgram

func (n *Node) StoreProgram(pk keys.PK, name string, sig keys.HashSig, b []byte) (err error)

type Receiver

type Receiver chan EncryptedMsg

type Sender

type Sender chan AddressedMsg

type SentMsg

type SentMsg interface {
	Serialise() ([]byte, error)
}

sent messages

type TestNet

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

func (*TestNet) AddNode

func (n *TestNet) AddNode(node *Node)