Documentation
      ¶
    
    
  
    
  
    Index ¶
- type Integration
 - func (i *Integration) Close() error
 - func (i *Integration) DataDownChan() chan models.DataDownPayload
 - func (i *Integration) HandleAckEvent(ctx context.Context, vars map[string]string, payload pb.AckEvent) error
 - func (i *Integration) HandleErrorEvent(ctx context.Context, vars map[string]string, payload pb.ErrorEvent) error
 - func (i *Integration) HandleIntegrationEvent(ctx context.Context, vars map[string]string, payload pb.IntegrationEvent) error
 - func (i *Integration) HandleJoinEvent(ctx context.Context, vars map[string]string, payload pb.JoinEvent) error
 - func (i *Integration) HandleLocationEvent(ctx context.Context, vars map[string]string, payload pb.LocationEvent) error
 - func (i *Integration) HandleStatusEvent(ctx context.Context, vars map[string]string, payload pb.StatusEvent) error
 - func (i *Integration) HandleTxAckEvent(ctx context.Context, vars map[string]string, payload pb.TxAckEvent) error
 - func (i *Integration) HandleUplinkEvent(ctx context.Context, vars map[string]string, payload pb.UplinkEvent) error
 
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Integration ¶
type Integration struct {
	SendDataUpChan                  chan pb.UplinkEvent
	SendJoinNotificationChan        chan pb.JoinEvent
	SendACKNotificationChan         chan pb.AckEvent
	SendErrorNotificationChan       chan pb.ErrorEvent
	DataDownPayloadChan             chan models.DataDownPayload
	SendStatusNotificationChan      chan pb.StatusEvent
	SendLocationNotificationChan    chan pb.LocationEvent
	SendTxAckNotificationChan       chan pb.TxAckEvent
	SendIntegrationNotificationChan chan pb.IntegrationEvent
}
    Integration implements a mock integration.
func (*Integration) DataDownChan ¶
func (i *Integration) DataDownChan() chan models.DataDownPayload
DataDownChan method.
func (*Integration) HandleAckEvent ¶
func (i *Integration) HandleAckEvent(ctx context.Context, vars map[string]string, payload pb.AckEvent) error
HandleAckEvent sends an AckEvent.
func (*Integration) HandleErrorEvent ¶
func (i *Integration) HandleErrorEvent(ctx context.Context, vars map[string]string, payload pb.ErrorEvent) error
HandleErrorEvent sends an ErrorEvent.
func (*Integration) HandleIntegrationEvent ¶
func (i *Integration) HandleIntegrationEvent(ctx context.Context, vars map[string]string, payload pb.IntegrationEvent) error
HandleIntegrationEvent sends an IntegrationEvent.
func (*Integration) HandleJoinEvent ¶
func (i *Integration) HandleJoinEvent(ctx context.Context, vars map[string]string, payload pb.JoinEvent) error
HandleJoinEvent sends a JoinEvent.
func (*Integration) HandleLocationEvent ¶
func (i *Integration) HandleLocationEvent(ctx context.Context, vars map[string]string, payload pb.LocationEvent) error
HandleLocationEvent sends a LocationEvent.
func (*Integration) HandleStatusEvent ¶
func (i *Integration) HandleStatusEvent(ctx context.Context, vars map[string]string, payload pb.StatusEvent) error
HandleStatusEvent sends a StatusEvent.
func (*Integration) HandleTxAckEvent ¶
func (i *Integration) HandleTxAckEvent(ctx context.Context, vars map[string]string, payload pb.TxAckEvent) error
HandleTxAckEvent sends a TxAckEvent.
func (*Integration) HandleUplinkEvent ¶
func (i *Integration) HandleUplinkEvent(ctx context.Context, vars map[string]string, payload pb.UplinkEvent) error
HandleUplinkEvent sends an UplinkEvent.
 Click to show internal directories. 
   Click to hide internal directories.