Versions in this module Expand all Collapse all v2 v2.4.1 Aug 22, 2019 v2.4.0 Aug 15, 2019 Changes in this version + const APITypeHTTP + const APITypeMQTT + const CatalogBackendLevelDB + const CatalogBackendMemory + const DNSSDServiceType + const LoggerPrefix + const MaxPerPage + const MaxServiceTTL + var ControllerExpiryCleanupInterval = 60 * time.Second + var SupportedBackends = map[string]bool + func StartMQTTManager(controller *Controller, mqttConf MQTTConf, scID string) + type API struct + Protocol string + URL string + type BadRequestError struct + Msg string + func (e *BadRequestError) Error() string + type Collection struct + Description string + ID string + Page int + PerPage int + Services []Service + Total int + type ConflictError struct + Msg string + func (e *ConflictError) Error() string + type Controller struct + func NewController(storage Storage, listeners ...Listener) (*Controller, error) + func (c *Controller) AddListener(listener Listener) + func (c *Controller) RemoveListener(listener Listener) + func (c *Controller) Stop() error + type Doc struct + APIs []string + Description string + Type string + URL string + type Error struct + Code int + Message string + type HttpAPI struct + func NewHTTPAPI(controller *Controller, id, description, version string) *HttpAPI + func (a *HttpAPI) Delete(w http.ResponseWriter, req *http.Request) + func (a *HttpAPI) ErrorResponse(w http.ResponseWriter, code int, msgs ...string) + func (a *HttpAPI) Filter(w http.ResponseWriter, req *http.Request) + func (a *HttpAPI) Get(w http.ResponseWriter, req *http.Request) + func (a *HttpAPI) List(w http.ResponseWriter, req *http.Request) + func (a *HttpAPI) Post(w http.ResponseWriter, req *http.Request) + func (a *HttpAPI) Put(w http.ResponseWriter, req *http.Request) + type LevelDBStorage struct + func (s *LevelDBStorage) Close() error + type Listener interface + type MQTTClient struct + type MQTTClientConf struct + BrokerID string + BrokerURI string + CaFile string + CertFile string + KeyFile string + Password string + QoS byte + RegTopics []string + Username string + WillTopics []string + type MQTTConf struct + AdditionalClients []MQTTClientConf + Client MQTTClientConf + CommonRegTopics []string + CommonWillTopics []string + TopicPrefix string + func (c MQTTConf) Validate() error + type MQTTManager struct + type MemoryStorage struct + func NewMemoryStorage() *MemoryStorage + func (ms *MemoryStorage) Close() error + type NotFoundError struct + Msg string + func (e *NotFoundError) Error() string + type Service struct + APIs map[string]string + Created time.Time + Description string + Docs []Doc + Expires time.Time + ID string + Meta map[string]interface{} + Name string + TTL uint + Updated time.Time + type Storage interface + Close func() error + func NewLevelDBStorage(dsn string, opts *opt.Options) (Storage, error) Other modules containing this package github.com/linksmart/service-catalog github.com/linksmart/service-catalog/v3