http

Documentation

Overview

Package http implements a HTTP integration.

Index

• Variables
• type Config
  • func (c Config) Validate() error
• type Integration
  • func New(m marshaler.Type, conf Config) (*Integration, error)
  • 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

Variables

var (
	ErrInvalidHeaderName = errors.New("Invalid header name")
)

errors

Types

type Config

type Config struct {
	Headers                 map[string]string `json:"headers"`
	DataUpURL               string            `json:"dataUpURL"`
	JoinNotificationURL     string            `json:"joinNotificationURL"`
	ACKNotificationURL      string            `json:"ackNotificationURL"`
	ErrorNotificationURL    string            `json:"errorNotificationURL"`
	StatusNotificationURL   string            `json:"statusNotificationURL"`
	LocationNotificationURL string            `json:"locationNotificationURL"`
	TxAckNotificationURL    string            `json:"txAckNotificationURL"`
}

Config contains the configuration for the HTTP integration.

func (Config) Validate

func (c Config) Validate() error

Validate validates the HandlerConfig data.

type Integration

type Integration struct {
	// contains filtered or unexported fields
}

Integration implements a HTTP integration.

func New

func New(m marshaler.Type, conf Config) (*Integration, error)

New creates a new HTTP integration.

func (*Integration) Close

func (i *Integration) Close() error

Close closes the handler.

func (*Integration) DataDownChan

func (i *Integration) DataDownChan() chan integration.DataDownPayload

DataDownChan return nil.

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.