broker

Documentation

Index

• type DownlinkSubscription
• type Metrics
• type ReferenceBrokerServer
  • func NewReferenceBrokerServer(bufferSize int) *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

Types

type DownlinkSubscription

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

type Metrics

type Metrics struct {
	UplinkIn   uint64
	DownlinkIn uint64
}

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
}