broker

type DownlinkSubscription struct {
	Ch chan *DownlinkMessage
	// contains filtered or unexported fields
}

type Metrics struct {
	UplinkIn   uint64
	DownlinkIn uint64
}

type ReferenceBrokerServer struct {
	DownlinkOut map[string]*DownlinkSubscription
	UplinkOut   map[string]*UplinkSubscription

	Metrics *Metrics
	// contains filtered or unexported fields
}

type UplinkSubscription struct {
	Ch chan *DeduplicatedUplinkMessage
	// contains filtered or unexported fields
}