Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

transport

package

Go to main page

Versions in this module

v0

v0.4.4

Sep 13, 2024

v0.4.3

Sep 11, 2024

v0.4.2

Aug 1, 2024

Changes in this version

+ const TxResponseErr

+ const TxResponseOK

+ type EventHandlerFunc func(e TransporterEvent)

+ type HTTP struct

+ func NewHTTPTransport(clientID string, server string, tlsConfig *tls.Config, userAgent string, ...) (*HTTP, error)

+ func (t *HTTP) Connect() error

+ func (t *HTTP) Disconnect(quiesce uint)

+ func (t *HTTP) ReloadTLSConfig(tlsConfig *tls.Config) error

+ func (t *HTTP) SetEventHandler(f EventHandlerFunc) error

+ func (t *HTTP) SetRxHandler(f RxHandlerFunc) error

+ func (t *HTTP) Tx(addr string, metadata map[string]string, data []byte) (responseCode int, responseMetadata map[string]string, responseData []byte, ...)

+ type HTTPResponse struct

+ Body json.RawMessage

+ Metadata map[string]string

+ StatusCode int

+ type MQTT struct

+ func NewMQTTTransport(clientID string, brokers []string, tlsConfig *tls.Config) (*MQTT, error)

+ func (t *MQTT) Connect() error

+ func (t *MQTT) Disconnect(quiesce uint)

+ func (t *MQTT) ReloadTLSConfig(tlsConfig *tls.Config) error

+ func (t *MQTT) SetEventHandler(f EventHandlerFunc) error

+ func (t *MQTT) SetRxHandler(f RxHandlerFunc) error

+ func (t *MQTT) Tx(addr string, metadata map[string]string, data []byte) (responseCode int, responseMetadata map[string]string, responseData []byte, ...)

+ type Noop struct

+ func NewNoopTransport() (*Noop, error)

+ func (t *Noop) Connect() error

+ func (t *Noop) Disconnect(quiesce uint)

+ func (t *Noop) ReloadTLSConfig(tlsConfig *tls.Config) error

+ func (t *Noop) SetEventHandler(f EventHandlerFunc) error

+ func (t *Noop) SetRxHandler(f RxHandlerFunc) error

+ func (t *Noop) Tx(addr string, metadata map[string]string, data []byte) (responseCode int, responseMetadata map[string]string, responseData []byte, ...)

+ type RxHandlerFunc func(addr string, metadata map[string]interface{}, data []byte) error

+ type Transporter interface

+ Connect func() error

+ Disconnect func(quiesce uint)

+ ReloadTLSConfig func(tlsConfig *tls.Config) error

+ SetEventHandler func(f EventHandlerFunc) error

+ SetRxHandler func(f RxHandlerFunc) error

+ Tx func(addr string, metadata map[string]string, data []byte) (responseCode int, responseMetadata map[string]string, responseData []byte, ...)

+ type TransporterEvent uint

+ const TransporterEventConnected

+ const TransporterEventDisconnected