transport

Feb 4, 2023

Changes in this version

+ func ParsePublicKey(encodedPublicKey string) ([]byte, error)

type Conn

+ func (c *Conn) LocalAddr() net.Addr

+ func (c *Conn) RemoteAddr() net.Addr

+ func (c *Conn) SetDeadline(t time.Time) error

+ func (c *Conn) SetReadDeadline(t time.Time) error

+ func (c *Conn) SetWriteDeadline(t time.Time) error

+ type CredentialsBuilder struct

+ func Builder() *CredentialsBuilder

+ func (b *CredentialsBuilder) Build() credentials.TransportCredentials

+ func (b *CredentialsBuilder) WithKey(key Key) *CredentialsBuilder

+ func (b *CredentialsBuilder) WithKnownPeers(knownPeers KnownPeersFunc) *CredentialsBuilder

+ func (b *CredentialsBuilder) WithLogger(logger *zap.Logger) *CredentialsBuilder

+ func (b *CredentialsBuilder) WithVerifyPeer(verify VerifyPeerFunc) *CredentialsBuilder

+ type Key noise.DHKey

+ type KnownPeersFunc func(address string) ([]byte, error)

+ type VerifyPeerFunc func(publicKey []byte) error

Feb 2, 2023

Changes in this version

+ const MaxPacketLength

+ func ParsePrivateKey(encodedPrivateKey string) (*noise.DHKey, error)

+ type ClientFactory struct

+ func NewClientFactory(key noise.DHKey) *ClientFactory

+ func (c *ClientFactory) Dial(raw io.ReadWriteCloser, serverPublicKey []byte) (*Conn, error)

+ type ClientVerifyFunc func(publicKey []byte) error

+ type Conn struct

+ func (c *Conn) Close() error

+ func (c *Conn) Read(data []byte) (int, error)

+ func (c *Conn) Write(data []byte) (int, error)

+ type Server struct

+ func NewServer(key noise.DHKey, verify ClientVerifyFunc) *Server

+ func (s *Server) Accept(raw io.ReadWriteCloser) (io.ReadWriteCloser, error)