resonance

Jul 15, 2026

Changes in this version

+ type CA struct

+ func NewCA(r io.Reader) (*CA, error)

+ func (ca *CA) Generate() (*tls.Config, error)

+ type CASource interface

+ Generate func() (*tls.Config, error)

type Config

+ CA CASource

Mar 25, 2025

Changes in this version

type Connection

+ func (c *Connection) BufferReads()

+ func (c *Connection) BufferWrites()

Mar 14, 2025

Changes in this version

type Connection

+ func (c *Connection) BytesSent() uint64

Mar 11, 2025

Changes in this version

type Config

+ BufferedReads bool

+ BufferedWrites bool

type PeerBuffer

+ func (b PeerBuffer) RunReader(ctx context.Context, peer Peer) error

+ func (b PeerBuffer) RunWriter(ctx context.Context, peer Peer) error

Mar 5, 2025

Changes in this version

type Connection

+ func (c *Connection) ReceiveRawBytes() ([]byte, error)

+ func (c *Connection) SendRawBytes(msg []byte) (retErr error)

Mar 4, 2025

Changes in this version

type ProtonMarshaller

+ Size func(msg any) (uint64, error)

Mar 2, 2025

Changes in this version

type Connection

+ func (c *Connection) Close()

Mar 2, 2025

Changes in this version

type Connection

+ func (c *Connection) SendStream(r io.Reader) bool

Mar 1, 2025

Changes in this version

type Connection

+ func (c *Connection) ReceiveBytes() ([]byte, error)

+ func (c *Connection) ReceiveProton(m ProtonUnmarshaller) (any, error)

+ func (c *Connection) SendBytes(msg []byte) bool

+ func (c *Connection) SendProton(msg any, m ProtonMarshaller) bool

+ type ProtonMarshaller interface

+ Marshal func(msg any, buf []byte) (uint64, uint64, error)

+ type ProtonUnmarshaller interface

+ Unmarshal func(id uint64, buf []byte) (any, uint64, error)

Sep 7, 2024

Changes in this version

type Connection

+ func (c *Connection[M]) SendIfPossible(msg proton.Marshallable) (bool, bool)

Sep 7, 2024

Changes in this version

type Config

+ ReceiveChannel chan any

Sep 4, 2024

Changes in this version

type Config

+ MarshallerFactory func(capacity uint64) M

Aug 27, 2024

Changes in this version

+ func RunClient[M proton.Marshaller](ctx context.Context, addr string, config Config[M], ...) error

+ func RunServer[M proton.Marshaller](ctx context.Context, ls net.Listener, config Config[M], ...) error

Aug 27, 2024

Changes in this version

type Config

+ Marshaller M

type Connection

+ func (c *Connection[M]) Run(ctx context.Context) error

+ type Peer io.ReadWriteCloser

type PeerBuffer

+ func (b PeerBuffer) Close() error

+ func (b PeerBuffer) ReadFrom(r io.Reader) (int64, error)

+ func (b PeerBuffer) Run(ctx context.Context, peer Peer) error

+ func (b PeerBuffer) WriteTo(w io.Writer) (int64, error)

Aug 24, 2024

Changes in this version

+ type Config struct

+ IDToMsgFunc func(id uint64) (any, error)

+ MaxMessageSize uint64

+ MsgToIDFunc func(m any) (uint64, error)

+ type Connection struct

+ func NewConnection(peer io.ReadWriter, config Config) *Connection

+ func (c *Connection) Ping() error

+ func (c *Connection) Receive() (any, error)

+ func (c *Connection) Send(msg Marshalable) error

+ type Marshalable interface

+ Marshal func(buf []byte) uint64

+ type PeerBuffer struct

+ func NewPeerBuffer() PeerBuffer

+ func (b PeerBuffer) OtherPeer() PeerBuffer

+ func (b PeerBuffer) Read(buf []byte) (n int, err error)

+ func (b PeerBuffer) ReadByte() (byte, error)

+ func (b PeerBuffer) Write(buf []byte) (n int, err error)