Documentation
¶
Index ¶
- func GenerateClientCertificate(applicationID int64) (time.Time, []byte, []byte, []byte, error)
- func Setup(c config.Config) error
- type Integration
- func (i *Integration) Close() error
- func (i *Integration) DataDownChan() chan models.DataDownPayload
- func (i *Integration) HandleAckEvent(ctx context.Context, _ models.Integration, vars map[string]string, ...) error
- func (i *Integration) HandleErrorEvent(ctx context.Context, _ models.Integration, vars map[string]string, ...) error
- func (i *Integration) HandleIntegrationEvent(ctx context.Context, _ models.Integration, vars map[string]string, ...) error
- func (i *Integration) HandleJoinEvent(ctx context.Context, _ models.Integration, vars map[string]string, ...) error
- func (i *Integration) HandleLocationEvent(ctx context.Context, _ models.Integration, vars map[string]string, ...) error
- func (i *Integration) HandleStatusEvent(ctx context.Context, _ models.Integration, vars map[string]string, ...) error
- func (i *Integration) HandleTxAckEvent(ctx context.Context, _ models.Integration, vars map[string]string, ...) error
- func (i *Integration) HandleUplinkEvent(ctx context.Context, _ models.Integration, vars map[string]string, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GenerateClientCertificate ¶
GenerateClientCertificate returns a client-certificate for the given gateway ID.
Types ¶
type Integration ¶
type Integration struct {
// contains filtered or unexported fields
}
Integration implements a MQTT integration.
func New ¶
func New(m marshaler.Type, conf config.IntegrationMQTTConfig) (*Integration, error)
New creates a new MQTT integration.
func (*Integration) DataDownChan ¶
func (i *Integration) DataDownChan() chan models.DataDownPayload
DataDownChan returns the channel containing the received DataDownPayload.
func (*Integration) HandleAckEvent ¶
func (i *Integration) HandleAckEvent(ctx context.Context, _ models.Integration, vars map[string]string, payload pb.AckEvent) error
HandleAckEvent sends an AckEvent.
func (*Integration) HandleErrorEvent ¶
func (i *Integration) HandleErrorEvent(ctx context.Context, _ models.Integration, vars map[string]string, payload pb.ErrorEvent) error
HandleErrorEvent sends an ErrorEvent.
func (*Integration) HandleIntegrationEvent ¶
func (i *Integration) HandleIntegrationEvent(ctx context.Context, _ models.Integration, vars map[string]string, payload pb.IntegrationEvent) error
HandleIntegrationEvent sends an IntegrationEvent.
func (*Integration) HandleJoinEvent ¶
func (i *Integration) HandleJoinEvent(ctx context.Context, _ models.Integration, vars map[string]string, payload pb.JoinEvent) error
HandleJoinEvent sends a JoinEvent.
func (*Integration) HandleLocationEvent ¶
func (i *Integration) HandleLocationEvent(ctx context.Context, _ models.Integration, vars map[string]string, payload pb.LocationEvent) error
HandleLocationEvent sends a LocationEvent.
func (*Integration) HandleStatusEvent ¶
func (i *Integration) HandleStatusEvent(ctx context.Context, _ models.Integration, vars map[string]string, payload pb.StatusEvent) error
HandleStatusEvent sends a StatusEvent.
func (*Integration) HandleTxAckEvent ¶
func (i *Integration) HandleTxAckEvent(ctx context.Context, _ models.Integration, vars map[string]string, payload pb.TxAckEvent) error
HandleTxAckEvent sends a TxAckEvent.
func (*Integration) HandleUplinkEvent ¶
func (i *Integration) HandleUplinkEvent(ctx context.Context, _ models.Integration, vars map[string]string, payload pb.UplinkEvent) error
HandleUplinkEvent sends an UplinkEvent.
Source Files
Click to show internal directories.
Click to hide internal directories.