gcppubsub

package

v1.0.1 Latest Latest Go to latest Published: Apr 5, 2020 License: MIT Imports: 14 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type Integration struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Integration implements a GCP Pub/Sub integration.

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

New creates a new Pub/Sub integration.

func (i *Integration) Close() error

Close closes the integration.

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

DataDownChan return nil.

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

SendACKNotification sends an ack notification.

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

SendDataUp sends an uplink data payload.

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

SendErrorNotification sends an error notification.

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

SendJoinNotification sends a join notification.

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

SendLocationNotification sends a location notification.

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

SendStatusNotification sends a status notification.

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

SendTxAckNotification sends a tx ack notification.