Versions in this module Expand all Collapse all v0 v0.2.1 Aug 11, 2021 Changes in this version + const ErrNoSingleFile + var ErrNoAnyFile = errors.New("field 'file' does not contains any item") + var ErrNoAuth = errors.New("This endpoint must be under AuthRequired") + func Unmarshal(data []byte, v interface{}) error + type Config struct + CookieMaxAge int + CookieName string + HeaderName string + type Message struct + Payload []byte + Topic string + type MessageStream chan Message + type Service struct + Config *Config + Log *log.SugaredLogger + func New(cfg Config, logger *log.SugaredLogger) *Service + func (srv *Service) Run() + func (srv Service) Close() + func (srv Service) Publish(topic string, data interface{}) error + func (srv Service) Subscribe(topic string) (Stream, error) + type Stream struct + Messages chan Message + Topic string + func (s Stream) Unsubscribe()