Versions in this module Expand all Collapse all v0 v0.18.0 Jan 19, 2018 Changes in this version + type Message struct + Acks int + Attributes map[string]string + Data []byte + Deliveries int + ID string + PublishTime time.Time + type Server struct + Addr string + func NewServer() *Server + func (s *Server) Message(id string) *Message + func (s *Server) Messages() []*Message + func (s *Server) Publish(topic string, data []byte, attrs map[string]string) string + func (s *Server) SetStreamTimeout(d time.Duration) + func (s *Server) Wait() Incompatible versions in this module v9.1.0+incompatible Jan 30, 2018 v9.0.1+incompatible Jan 30, 2018
Go to main page