pilotthings

Documentation

Index

• type Config
  • func (cfg Config) Validate() error
• type Integration
  • func New(cfg Config) (*Integration, error)
  • 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

Types

type Config

type Config struct {
	Server string `json:"server"`
	Token  string `json:"token"`
}

Config contains the Pilot Things integration configuration.

func (Config) Validate

func (cfg Config) Validate() error

Validate verifies the config for errors.

type Integration

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

Integration is the actual implementation of the Pilot Things integration

func New

func New(cfg Config) (*Integration, error)

New creates the integration from a configuration

func (*Integration) Close

func (i *Integration) Close() error

Close is not needed.

func (*Integration) DataDownChan

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

DataDownChan is not implemented.

func (*Integration) HandleAckEvent

func (i *Integration) HandleAckEvent(ctx context.Context, _ models.Integration, vars map[string]string, event integration.AckEvent) error

HandleAckEvent is not implemented.

func (*Integration) HandleErrorEvent

func (i *Integration) HandleErrorEvent(ctx context.Context, _ models.Integration, vars map[string]string, event integration.ErrorEvent) error

HandleErrorEvent is not implemented.

func (*Integration) HandleIntegrationEvent

func (i *Integration) HandleIntegrationEvent(ctx context.Context, _ models.Integration, vars map[string]string, event integration.IntegrationEvent) error

HandleIntegrationEvent is not implemented.

func (*Integration) HandleJoinEvent

func (i *Integration) HandleJoinEvent(ctx context.Context, _ models.Integration, vars map[string]string, event integration.JoinEvent) error

HandleJoinEvent is not implemented.

func (*Integration) HandleLocationEvent

func (i *Integration) HandleLocationEvent(ctx context.Context, _ models.Integration, vars map[string]string, event integration.LocationEvent) error

HandleLocationEvent is not implemented.

func (*Integration) HandleStatusEvent

func (i *Integration) HandleStatusEvent(ctx context.Context, _ models.Integration, vars map[string]string, event integration.StatusEvent) error

HandleStatusEvent is not implemented.

func (*Integration) HandleTxAckEvent

func (i *Integration) HandleTxAckEvent(ctx context.Context, _ models.Integration, vars map[string]string, event integration.TxAckEvent) error

HandleTxAckEvent is not implemented.

func (*Integration) HandleUplinkEvent

func (i *Integration) HandleUplinkEvent(ctx context.Context, _ models.Integration, vars map[string]string, event integration.UplinkEvent) error

HandleUplinkEvent sends the data to Pilot Things.