protocol

type Call struct {
	F Function
	M proto.Message
}

type Function byte

type Gossip struct {
	Spores  []string `protobuf:"bytes,1,rep,name=spores" json:"spores,omitempty"`
	Request bool     `protobuf:"varint,2,opt,name=request" json:"request,omitempty"`
}

type Hello struct {
	Version   uint64                     `protobuf:"varint,1,opt,name=version" json:"version,omitempty"`
	Identity  string                     `protobuf:"bytes,2,opt,name=identity" json:"identity,omitempty"`
	Timestamp *google_protobuf.Timestamp `protobuf:"bytes,3,opt,name=timestamp" json:"timestamp,omitempty"`
	// The public key is used in the ECDHE key exchange.
	// It MUST be a curve25519 public key.
	PublicKey []byte `protobuf:"bytes,9,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// The signature of the Hello message is computed on the message with an empty signature.
	// signature = signature by emitter ( marshal ( hello without signature ) )
	//
	// It is used as the authentication block of the ECDHE key exchange.
	// If the used signature key is not trusted by one peer, the connection MAY BE established
	// in "untrusted" mode, meaning that sensible operations MUST NOT be executed with the
	// connected peer (vulnerable to MitM attacks).
	Signature []byte `protobuf:"bytes,10,opt,name=signature,proto3" json:"signature,omitempty"`
}

type InputStream interface {
	io.Reader
	io.ByteReader
}

type Node struct {
	Identity string `protobuf:"bytes,1,opt,name=identity" json:"identity,omitempty"`
	Address  string `protobuf:"bytes,2,opt,name=address" json:"address,omitempty"`
}

type Nodes struct {
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes" json:"nodes,omitempty"`
}

type Raw struct {
	Key       string     `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Version   *version.V `protobuf:"bytes,2,opt,name=version" json:"version,omitempty"`
	Data      []byte     `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Signature []byte     `protobuf:"bytes,10,opt,name=signature,proto3" json:"signature,omitempty"`
}

type Session interface {
	// A Session can acts as a Transport itself, being transparent for the application.
	Transport

	// Hello builds a new Hello message (handshake).
	// It might be called several times, in case of connection reset.
	Hello() (*Hello, error)

	// Verify verifies Hello messages for conformity.
	// It might be called several times, in case of connection reset.
	Verify(*Hello) error

	// Open MUST be called after sending an Hello message and having received
	// a verified Hello message from the peer. It opens incoming and outgoing
	// encrypted channel.
	Open(Transport) error

	// IsTrusted returns weither the peer shall be trusted (is correctly authenticated).
	IsTrusted() bool
}

type Transport interface {
	io.ReadWriteCloser
	io.ByteReader
}