resonance

README

resonance

Communication library using proton messages

Documentation

Index

• 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
• type Config
• type Connection
  • func NewConnection[M proton.Marshaller](peer Peer, config Config[M]) *Connection[M]
  • func (c *Connection[M]) Receive() (any, bool)
  • func (c *Connection[M]) Run(ctx context.Context) error
  • func (c *Connection[M]) Send(msg proton.Marshallable) bool
• type Peer
• type PeerBuffer
  • func NewPeerBuffer() PeerBuffer
  • func (b PeerBuffer) Close() error
  • func (b PeerBuffer) OtherPeer() PeerBuffer
  • func (b PeerBuffer) Read(buf []byte) (int, error)
  • func (b PeerBuffer) ReadFrom(r io.Reader) (int64, error)
  • func (b PeerBuffer) Run(ctx context.Context, peer Peer) error
  • func (b PeerBuffer) Write(buf []byte) (int, error)
  • func (b PeerBuffer) WriteTo(w io.Writer) (int64, error)

Functions

func RunClient

func RunClient[M proton.Marshaller](
	ctx context.Context,
	addr string,
	config Config[M],
	handler func(ctx context.Context, c *Connection[M]) error,
) error

RunClient runs client.

func RunServer

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

RunServer runs server.

Types

type Config

type Config[M proton.Marshaller] struct {
	MaxMessageSize uint64
	Marshaller     M
}

Config is the configuration of connection.

type Connection

type Connection[M proton.Marshaller] struct {
	// contains filtered or unexported fields
}

Connection allows to communicate with the peer.

func NewConnection

func NewConnection[M proton.Marshaller](peer Peer, config Config[M]) *Connection[M]

NewConnection creates new connection.

func (*Connection[M]) Receive

func (c *Connection[M]) Receive() (any, bool)

Receive receives message from the peer.

func (*Connection[M]) Run

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

Run runs the connection.

func (*Connection[M]) Send

func (c *Connection[M]) Send(msg proton.Marshallable) bool

Send sends message to the peer.

type Peer

type Peer io.ReadWriteCloser

Peer represents the connected peer.

type PeerBuffer

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

PeerBuffer simulates the network connection from the peer's view.

func NewPeerBuffer

func NewPeerBuffer() PeerBuffer

NewPeerBuffer returns new peer buffer.

func (PeerBuffer) Close

func (b PeerBuffer) Close() error

Close closes the streams.

func (PeerBuffer) OtherPeer

func (b PeerBuffer) OtherPeer() PeerBuffer

OtherPeer returns the corresponding buffer for the other peer in the connection.

func (PeerBuffer) Read

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

Read reads data from the read buffer.

func (PeerBuffer) ReadFrom

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

ReadFrom reads data from the incoming stream.

func (PeerBuffer) Run

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

Run runs the goroutines responsible for copying data between this buffer and the external one.

func (PeerBuffer) Write

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

Write writes data to the write buffer.

func (PeerBuffer) WriteTo

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

WriteTo writes data to the outgoing stream.