Documentation
¶
Overview ¶
Package awssns implements an AWS NSN integration.
Index ¶
- 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 ¶
This section is empty.
Types ¶
type Integration ¶
type Integration struct {
// contains filtered or unexported fields
}
Integration implements the AWS SNS integration.
func New ¶
func New(m marshaler.Type, conf config.IntegrationAWSSNSConfig) (*Integration, error)
New creates a new AWS SNS integration.
func (*Integration) DataDownChan ¶
func (i *Integration) DataDownChan() chan models.DataDownPayload
DataDownChan return nil.
func (*Integration) HandleAckEvent ¶
func (i *Integration) HandleAckEvent(ctx context.Context, _ models.Integration, vars map[string]string, pl pb.AckEvent) error
HandleAckEvent sends an AckEvent.
func (*Integration) HandleErrorEvent ¶
func (i *Integration) HandleErrorEvent(ctx context.Context, _ models.Integration, vars map[string]string, pl pb.ErrorEvent) error
HandleErrorEvent sends an ErrorEvent.
func (*Integration) HandleIntegrationEvent ¶
func (i *Integration) HandleIntegrationEvent(ctx context.Context, _ models.Integration, vars map[string]string, pl pb.IntegrationEvent) error
HandleIntegrationEvent sends an IntegrationEvent.
func (*Integration) HandleJoinEvent ¶
func (i *Integration) HandleJoinEvent(ctx context.Context, _ models.Integration, vars map[string]string, pl pb.JoinEvent) error
HandleJoinEvent sends a JoinEvent.
func (*Integration) HandleLocationEvent ¶
func (i *Integration) HandleLocationEvent(ctx context.Context, _ models.Integration, vars map[string]string, pl pb.LocationEvent) error
HandleLocationEvent sends a LocationEvent.
func (*Integration) HandleStatusEvent ¶
func (i *Integration) HandleStatusEvent(ctx context.Context, _ models.Integration, vars map[string]string, pl pb.StatusEvent) error
HandleStatusEvent sends a StatusEvent.
func (*Integration) HandleTxAckEvent ¶
func (i *Integration) HandleTxAckEvent(ctx context.Context, _ models.Integration, vars map[string]string, pl pb.TxAckEvent) error
HandleTxAckEvent sends a TxAckEevent.
func (*Integration) HandleUplinkEvent ¶
func (i *Integration) HandleUplinkEvent(ctx context.Context, _ models.Integration, vars map[string]string, pl pb.UplinkEvent) error
HandleUplinkEvent sends an UplinkEvent.
Source Files
Click to show internal directories.
Click to hide internal directories.