Documentation
¶
Index ¶
- type HTTPBrokerV1
- func (h *HTTPBrokerV1) Connect() error
- func (h *HTTPBrokerV1) Disconnect() error
- func (h *HTTPBrokerV1) Marshal() string
- func (h *HTTPBrokerV1) Publish(topic string, msg *broker.Message, opt ...broker.PublishOption) error
- func (h *HTTPBrokerV1) String() string
- func (h *HTTPBrokerV1) Subscribe(topics []string, callBack broker.CallBack, opt ...broker.SubscribeOption) (broker.Subscriber, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HTTPBrokerV1 ¶
type HTTPBrokerV1 struct {
PublishCallBack func(topic string, resp *http.Response) error `json:"-"`
CACertFile string
CertFile string
KeyFile string
Insecure bool
Logger log.Logger
// contains filtered or unexported fields
}
func (*HTTPBrokerV1) Connect ¶
func (h *HTTPBrokerV1) Connect() error
func (*HTTPBrokerV1) Disconnect ¶
func (h *HTTPBrokerV1) Disconnect() error
func (*HTTPBrokerV1) Marshal ¶
func (h *HTTPBrokerV1) Marshal() string
func (*HTTPBrokerV1) Publish ¶
func (h *HTTPBrokerV1) Publish(topic string, msg *broker.Message, opt ...broker.PublishOption) error
func (*HTTPBrokerV1) String ¶
func (h *HTTPBrokerV1) String() string
func (*HTTPBrokerV1) Subscribe ¶
func (h *HTTPBrokerV1) Subscribe(topics []string, callBack broker.CallBack, opt ...broker.SubscribeOption) (broker.Subscriber, error)
Source Files
Click to show internal directories.
Click to hide internal directories.