postgresql

Documentation

Index

• type Integration
  • func New(conf config.IntegrationPostgreSQLConfig) (*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

Types

type Integration

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

Integration implements a PostgreSQL integration.

func New

func New(conf config.IntegrationPostgreSQLConfig) (*Integration, error)

New creates a new PostgreSQL integration.

func (*Integration) Close

func (i *Integration) Close() error

Close closes the integration.

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 stores the ACK in the device_ack table.

func (*Integration) SendDataUp

func (i *Integration) SendDataUp(ctx context.Context, vars map[string]string, pl pb.UplinkEvent) error

SendDataUp stores the uplink data into the device_up table.

func (*Integration) SendErrorNotification

func (i *Integration) SendErrorNotification(ctx context.Context, vars map[string]string, pl pb.ErrorEvent) error

SendErrorNotification stores the error in the device_error table.

func (*Integration) SendJoinNotification

func (i *Integration) SendJoinNotification(ctx context.Context, vars map[string]string, pl pb.JoinEvent) error

SendJoinNotification stores the join in the device_join table.

func (*Integration) SendLocationNotification

func (i *Integration) SendLocationNotification(ctx context.Context, vars map[string]string, pl pb.LocationEvent) error

SendLocationNotification stores the location in the device_location table.

func (*Integration) SendStatusNotification

func (i *Integration) SendStatusNotification(ctx context.Context, vars map[string]string, pl pb.StatusEvent) error

SendStatusNotification stores the device-status in the device_status table.

func (*Integration) SendTxAckNotification

func (i *Integration) SendTxAckNotification(ctx context.Context, vars map[string]string, pl pb.TxAckEvent) error

SendAckNotification is currently not implemented. TODO: implement this + schema migrations for the PostgreSQL database!