Documentation ¶
Index ¶
- type DownlinkSubscription
- type Metrics
- type ReferenceBrokerServer
- func (s *ReferenceBrokerServer) Activate(ctx context.Context, req *DeviceActivationRequest) (*DeviceActivationResponse, error)
- func (s *ReferenceBrokerServer) Associate(stream Broker_AssociateServer) error
- func (s *ReferenceBrokerServer) Publish(stream Broker_PublishServer) error
- func (s *ReferenceBrokerServer) Subscribe(req *SubscribeRequest, stream Broker_SubscribeServer) error
- type UplinkSubscription
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DownlinkSubscription ¶
type DownlinkSubscription struct { Ch chan *DownlinkMessage // contains filtered or unexported fields }
type ReferenceBrokerServer ¶
type ReferenceBrokerServer struct { DownlinkOut map[string]*DownlinkSubscription UplinkOut map[string]*UplinkSubscription Metrics *Metrics // contains filtered or unexported fields }
ReferenceBrokerServer is a new reference broker server
func NewReferenceBrokerServer ¶
func NewReferenceBrokerServer(bufferSize int) *ReferenceBrokerServer
NewReferenceBrokerServer creates a new reference broker server
func (*ReferenceBrokerServer) Activate ¶
func (s *ReferenceBrokerServer) Activate(ctx context.Context, req *DeviceActivationRequest) (*DeviceActivationResponse, error)
Activate RPC
func (*ReferenceBrokerServer) Associate ¶
func (s *ReferenceBrokerServer) Associate(stream Broker_AssociateServer) error
Associate RPC
func (*ReferenceBrokerServer) Publish ¶
func (s *ReferenceBrokerServer) Publish(stream Broker_PublishServer) error
Publish RPC
func (*ReferenceBrokerServer) Subscribe ¶
func (s *ReferenceBrokerServer) Subscribe(req *SubscribeRequest, stream Broker_SubscribeServer) error
Subscribe RPC
type UplinkSubscription ¶
type UplinkSubscription struct { Ch chan *DeduplicatedUplinkMessage // contains filtered or unexported fields }
Click to show internal directories.
Click to hide internal directories.