Versions in this module Expand all Collapse all v1 v1.0.1 Aug 23, 2014 Changes in this version + const DefaultReadHeartBeatError + type AckMode int + const AckAuto + const AckClient + const AckClientIndividual + func (a AckMode) ShouldAck() bool + func (a AckMode) String() string + type Conn struct + func Connect(conn io.ReadWriteCloser, opts Options) (*Conn, error) + func Dial(network, addr string, opts Options) (*Conn, error) + func (c *Conn) Ack(m *Message) error + func (c *Conn) Begin() *Transaction + func (c *Conn) Disconnect() error + func (c *Conn) Nack(m *Message) error + func (c *Conn) Send(destination, contentType string, body []byte, userDefined *Header) error + func (c *Conn) SendWithReceipt(destination, contentType string, body []byte, userDefined *Header) error + func (c *Conn) Server() string + func (c *Conn) Session() string + func (c *Conn) Subscribe(destination string, ack AckMode) (*Subscription, error) + func (c *Conn) Version() Version + type Error struct + Frame *Frame + Message string + func (e Error) Error() string + type Frame struct + Body []byte + Command string + func NewFrame(command string, headers ...string) *Frame + func (f *Frame) Clone() *Frame + type Header struct + func NewHeader(headerEntries ...string) *Header + func (h *Header) Add(key, value string) + func (h *Header) Clone() *Header + func (h *Header) Contains(key string) (value string, ok bool) + func (h *Header) ContentLength() (value int, ok bool, err error) + func (h *Header) Del(key string) + func (h *Header) Get(key string) string + func (h *Header) GetAll(key string) []string + func (h *Header) GetAt(index int) (key, value string) + func (h *Header) Len() int + func (h *Header) Set(key, value string) + type Message struct + Body []byte + Conn *Conn + ContentType string + Destination string + Err error + Subscription *Subscription + func (msg *Message) ShouldAck() bool + type Options struct + AcceptVersion string + HeartBeat string + Host string + Login string + NonStandard *Header + Passcode string + ReadHeartBeatError time.Duration + type Reader struct + func NewReader(reader io.Reader) *Reader + func NewReaderSize(reader io.Reader, bufferSize int) *Reader + func (r *Reader) Read() (*Frame, error) + type Subscription struct + C chan *Message + func (s *Subscription) AckMode() AckMode + func (s *Subscription) Active() bool + func (s *Subscription) Destination() string + func (s *Subscription) Id() string + func (s *Subscription) Read() (*Message, error) + func (s *Subscription) Unsubscribe() error + type Transaction struct + func (tx *Transaction) Abort() error + func (tx *Transaction) Ack(msg *Message) error + func (tx *Transaction) Commit() error + func (tx *Transaction) Conn() *Conn + func (tx *Transaction) Id() string + func (tx *Transaction) Nack(msg *Message) error + func (tx *Transaction) Send(destination, contentType string, body []byte, userDefined *Header) error + func (tx *Transaction) SendWithReceipt(destination, contentType string, body []byte, userDefined *Header) error + type Validator interface + Validate func(f *Frame) error + func NewValidator(version Version) Validator + type Version string + const V10 + const V11 + const V12 + func (v Version) String() string + func (v Version) SupportsNack() bool + type Writer struct + func NewWriter(writer io.Writer) *Writer + func NewWriterSize(writer io.Writer, bufferSize int) *Writer + func (w *Writer) Write(f *Frame) error
Go to main page