Versions in this module Expand all Collapse all v0 v0.14.0 Nov 30, 2021 Changes in this version + func EncodeFrame(t FrameType, remoteChannel uint16, f frames.FrameBody) ([]byte, error) + func PerformBegin(remoteChannel uint16) ([]byte, error) + func PerformClose(e *encoding.Error) ([]byte, error) + func PerformDetach(remoteChannel uint16, linkHandle uint32, e *encoding.Error) ([]byte, error) + func PerformDisposition(role encoding.Role, remoteChannel uint16, deliveryID uint32, ...) ([]byte, error) + func PerformEnd(remoteChannel uint16, e *encoding.Error) ([]byte, error) + func PerformOpen(containerID string) ([]byte, error) + func PerformTransfer(remoteChannel uint16, linkHandle, deliveryID uint32, payload []byte) ([]byte, error) + func ProtoHeader(id ProtoID) ([]byte, error) + func ReceiverAttach(remoteChannel uint16, linkName string, linkHandle uint32, ...) ([]byte, error) + func SenderAttach(remoteChannel uint16, linkName string, linkHandle uint32, ...) ([]byte, error) + type AMQPProto struct + type FrameType uint8 + const FrameAMQP + const FrameSASL + type KeepAlive struct + type NetConn struct + OnClose func() error + ReadErr chan error + func NewNetConn(resp func(frames.FrameBody) ([]byte, error)) *NetConn + func (n *NetConn) Close() error + func (n *NetConn) LocalAddr() net.Addr + func (n *NetConn) Read(b []byte) (int, error) + func (n *NetConn) RemoteAddr() net.Addr + func (n *NetConn) SendFrame(f []byte) + func (n *NetConn) SendKeepAlive() + func (n *NetConn) SetDeadline(t time.Time) error + func (n *NetConn) SetReadDeadline(t time.Time) error + func (n *NetConn) SetWriteDeadline(t time.Time) error + func (n *NetConn) Write(b []byte) (int, error) + type ProtoID uint8 + const ProtoAMQP + const ProtoSASL + const ProtoTLS