transport

Documentation

Index

• type FramedStream
  • func NewFramedStreamFromTransport(t Transport) *FramedStream
  • func (fs *FramedStream) Close() error
  • func (fs *FramedStream) ReadMsg() ([]byte, error)
  • func (fs *FramedStream) WriteMsg(payload []byte) error
• type MsgStream
• type Transport

Types

type FramedStream

type FramedStream struct {
	Trans Transport
	// contains filtered or unexported fields
}

FramedStream represents a stream with message semantics

func NewFramedStreamFromTransport

func NewFramedStreamFromTransport(t Transport) *FramedStream

NewFramedStreamFromTransport creates a message stream from transport t

func (*FramedStream) Close

func (fs *FramedStream) Close() error

Close closes the transport stream

func (*FramedStream) ReadMsg

func (fs *FramedStream) ReadMsg() ([]byte, error)

ReadMsg reads a io4edge standard message from transport stream

func (*FramedStream) WriteMsg

func (fs *FramedStream) WriteMsg(payload []byte) error

WriteMsg writes io4edge standard message to the transport stream

type MsgStream

type MsgStream interface {
	ReadMsg() (payload []byte, err error)
	WriteMsg(payload []byte) (err error)
	Close() error
}

MsgStream is the interface used by a Channel to exchange message frames with the transport layer e.g. socket, websocket...

type Transport

type Transport interface {
	Read(p []byte) (n int, err error)
	Write(p []byte) (n int, err error)
	Close() error
}

Transport is the interface used by message stream to communicate with the underlying transport layer e.g. socket, websocket...