resonance

README

resonance

Communication library using proton messages

Documentation

Index

• func RunClient(ctx context.Context, addr string, config Config, ...) error
• func RunServer(ctx context.Context, ls net.Listener, config Config, ...) error
• type CA
  • func NewCA(r io.Reader) (*CA, error)
  • func (ca *CA) Generate() (*tls.Config, error)
• type CASource
• type Config
• type Connection
  • func NewConnection(peer Peer, config Config) *Connection
  • func (c *Connection) BufferReads()
  • func (c *Connection) BufferWrites()
  • func (c *Connection) Close()
  • func (c *Connection) ReceiveBytes() ([]byte, uint64, error)
  • func (c *Connection) ReceiveProton(m ProtonUnmarshaller) (any, uint64, error)
  • func (c *Connection) ReceiveRawBytes() ([]byte, uint64, error)
  • func (c *Connection) Run(ctx context.Context) error
  • func (c *Connection) SendBytes(msg []byte) (uint64, error)
  • func (c *Connection) SendProton(msg any, m ProtonMarshaller) (uint64, error)
  • func (c *Connection) SendRawBytes(msg []byte) (uint64, error)
  • func (c *Connection) SendStream(r io.Reader) error
• 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) RunReader(ctx context.Context, peer Peer) error
  • func (b PeerBuffer) RunWriter(ctx context.Context, peer Peer) error
  • func (b PeerBuffer) Write(buf []byte) (int, error)
  • func (b PeerBuffer) WriteTo(w io.Writer) (int64, error)
• type ProtonMarshaller
• type ProtonUnmarshaller

Functions

func RunClient

func RunClient(
	ctx context.Context,
	addr string,
	config Config,
	handler func(ctx context.Context, c *Connection) error,
) error

RunClient runs client.

func RunServer

func RunServer(
	ctx context.Context,
	ls net.Listener,
	config Config,
	handler func(ctx context.Context, c *Connection) error,
) error

RunServer runs server.

Types

type CA

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

CA represents certificate authority issuing TLS configs.

func NewCA

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

NewCA creates new CA.

func (*CA) Generate

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

Generate generates new TLS config with resh client certificate.

type CASource

type CASource interface {
	Generate() (*tls.Config, error)
}

CASource represents CA TLS config generator.

type Config

type Config struct {
	MaxMessageSize uint64
	CA             CASource
}

Config is the configuration of connection.

type Connection

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

Connection allows to communicate with the peer.

func NewConnection

func NewConnection(peer Peer, config Config) *Connection

NewConnection creates new connection.

func (*Connection) BufferReads

func (c *Connection) BufferReads()

BufferReads turns on read buffer.

func (*Connection) BufferWrites

func (c *Connection) BufferWrites()

BufferWrites turns on write buffer.

func (*Connection) Close

func (c *Connection) Close()

Close closes connection.

func (*Connection) ReceiveBytes

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

ReceiveBytes receives bytes.

func (*Connection) ReceiveProton

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

ReceiveProton receives proton message from the peer.

func (*Connection) ReceiveRawBytes

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

ReceiveRawBytes receives bytes and returns them with together with length prefix.

func (*Connection) Run

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

Run runs connection's goroutines.

func (*Connection) SendBytes

func (c *Connection) SendBytes(msg []byte) (uint64, error)

SendBytes sends bytes.

func (*Connection) SendProton

func (c *Connection) SendProton(msg any, m ProtonMarshaller) (uint64, error)

SendProton sends proton message to the peer.

func (*Connection) SendRawBytes

func (c *Connection) SendRawBytes(msg []byte) (uint64, error)

SendRawBytes sends bytes with length prefix already included.

func (*Connection) SendStream

func (c *Connection) SendStream(r io.Reader) error

SendStream sends stream of data taken from the reader.

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) RunReader

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

RunReader reads data from peer.

func (PeerBuffer) RunWriter

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

RunWriter writes data to peer.

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.

type ProtonMarshaller

type ProtonMarshaller interface {
	Size(msg any) (uint64, error)
	Marshal(msg any, buf []byte) (uint64, uint64, error)
}

ProtonMarshaller is the proton's interface marshalling messages.

type ProtonUnmarshaller

type ProtonUnmarshaller interface {
	Unmarshal(id uint64, buf []byte) (any, uint64, error)
}

ProtonUnmarshaller is the proton's interface unmarshalling messages.