server

type Client interface {
	// Close the client and clean up all connections
	Close() error
	// GetPahoPubSub PubSub Subscribe to uplink and events, publish downlink
	GetPahoPubSub() (*PahoPubSub, error)
}

type ClientConfig struct {
	ClientName     string
	ClientVersion  string
	TLSConfig      *tls.Config
	RequestTimeout time.Duration
	// contains filtered or unexported fields
}

type GooglePubSub struct {
	Joins        *pubsub.Topic
	Uplinks      *pubsub.Topic
	UplinkErrors *pubsub.Topic

	Downlinks        *pubsub.Subscription
	DownlinkReceipts *pubsub.Topic
	DownlinkErrors   *pubsub.Topic

	Location *pubsub.Topic
	Signal   *pubsub.Topic
}

type MqttProxyConfig struct {
	AppID           string
	AppKey          string
	MqttAddress     string
	Username        string
	CanDownlink     bool
	GooglePubSub    GooglePubSub
	Transformer     lib.PahoTransformer
	PayloadAdjuster lib.PayloadAdjuster
}

type PahoProxy struct {
	// contains filtered or unexported fields
}

type PahoPubSub struct {
	AppID   string
	DevID   string
	SubPubs map[string]string
	Errors  chan error
	// contains filtered or unexported fields
}