Documentation
¶
Overview ¶
Package multi implements a multi-integration handler. This handler can be used to combine the handling of multiple integrations.
Index ¶
- type Integration
- func (i *Integration) Add(intg integration.Integrator)
- func (i *Integration) Close() error
- func (i *Integration) DataDownChan() chan integration.DataDownPayload
- func (i *Integration) SendACKNotification(ctx context.Context, vars map[string]string, pl pb.AckEvent) error
- func (i *Integration) SendDataUp(ctx context.Context, vars map[string]string, pl pb.UplinkEvent) error
- func (i *Integration) SendErrorNotification(ctx context.Context, vars map[string]string, pl pb.ErrorEvent) error
- func (i *Integration) SendJoinNotification(ctx context.Context, vars map[string]string, pl pb.JoinEvent) error
- func (i *Integration) SendLocationNotification(ctx context.Context, vars map[string]string, pl pb.LocationEvent) error
- func (i *Integration) SendStatusNotification(ctx context.Context, vars map[string]string, pl pb.StatusEvent) error
- func (i *Integration) SendTxAckNotification(ctx context.Context, vars map[string]string, pl pb.TxAckEvent) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Integration ¶
type Integration struct {
// contains filtered or unexported fields
}
Integration implements the multi integration.
func New ¶
func New(m marshaler.Type, confs []interface{}) (*Integration, error)
New create a new multi integration. The argument that must be given is a slice of configuration objects for the handlers to setup.
func (*Integration) Add ¶
func (i *Integration) Add(intg integration.Integrator)
Add appends a new integration to the list.
func (*Integration) DataDownChan ¶
func (i *Integration) DataDownChan() chan integration.DataDownPayload
DataDownChan returns the channel containing the received DataDownPayload.
func (*Integration) SendACKNotification ¶
func (i *Integration) SendACKNotification(ctx context.Context, vars map[string]string, pl pb.AckEvent) error
SendACKNotification sends an ACK notification.
func (*Integration) SendDataUp ¶
func (i *Integration) SendDataUp(ctx context.Context, vars map[string]string, pl pb.UplinkEvent) error
SendDataUp sends a data-up payload.
func (*Integration) SendErrorNotification ¶
func (i *Integration) SendErrorNotification(ctx context.Context, vars map[string]string, pl pb.ErrorEvent) error
SendErrorNotification sends an error notification.
func (*Integration) SendJoinNotification ¶
func (i *Integration) SendJoinNotification(ctx context.Context, vars map[string]string, pl pb.JoinEvent) error
SendJoinNotification sends a join notification.
func (*Integration) SendLocationNotification ¶
func (i *Integration) SendLocationNotification(ctx context.Context, vars map[string]string, pl pb.LocationEvent) error
SendLocationNotification sends a location notification.
func (*Integration) SendStatusNotification ¶
func (i *Integration) SendStatusNotification(ctx context.Context, vars map[string]string, pl pb.StatusEvent) error
SendStatusNotification sends a status notification.
func (*Integration) SendTxAckNotification ¶
func (i *Integration) SendTxAckNotification(ctx context.Context, vars map[string]string, pl pb.TxAckEvent) error
SendTxAckNotification sends a tx ack notification.
Source Files