mock

Documentation

Index

• type Integration
  • func New() *Integration
  • func (i *Integration) Close() error
  • func (i *Integration) DataDownChan() chan models.DataDownPayload
  • func (i *Integration) HandleAckEvent(ctx context.Context, vars map[string]string, payload pb.AckEvent) error
  • func (i *Integration) HandleErrorEvent(ctx context.Context, vars map[string]string, payload pb.ErrorEvent) error
  • func (i *Integration) HandleIntegrationEvent(ctx context.Context, vars map[string]string, payload pb.IntegrationEvent) error
  • func (i *Integration) HandleJoinEvent(ctx context.Context, vars map[string]string, payload pb.JoinEvent) error
  • func (i *Integration) HandleLocationEvent(ctx context.Context, vars map[string]string, payload pb.LocationEvent) error
  • func (i *Integration) HandleStatusEvent(ctx context.Context, vars map[string]string, payload pb.StatusEvent) error
  • func (i *Integration) HandleTxAckEvent(ctx context.Context, vars map[string]string, payload pb.TxAckEvent) error
  • func (i *Integration) HandleUplinkEvent(ctx context.Context, vars map[string]string, payload pb.UplinkEvent) error

Types

type Integration

type Integration struct {
	SendDataUpChan                  chan pb.UplinkEvent
	SendJoinNotificationChan        chan pb.JoinEvent
	SendACKNotificationChan         chan pb.AckEvent
	SendErrorNotificationChan       chan pb.ErrorEvent
	DataDownPayloadChan             chan models.DataDownPayload
	SendStatusNotificationChan      chan pb.StatusEvent
	SendLocationNotificationChan    chan pb.LocationEvent
	SendTxAckNotificationChan       chan pb.TxAckEvent
	SendIntegrationNotificationChan chan pb.IntegrationEvent
}

Integration implements a mock integration.

func New

func New() *Integration

New creates a new mock integration.

func (*Integration) Close

func (i *Integration) Close() error

Close method.

func (*Integration) DataDownChan

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

DataDownChan method.

func (*Integration) HandleAckEvent

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

HandleAckEvent sends an AckEvent.

func (*Integration) HandleErrorEvent

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

HandleErrorEvent sends an ErrorEvent.

func (*Integration) HandleIntegrationEvent

func (i *Integration) HandleIntegrationEvent(ctx context.Context, vars map[string]string, payload pb.IntegrationEvent) error

HandleIntegrationEvent sends an IntegrationEvent.

func (*Integration) HandleJoinEvent

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

HandleJoinEvent sends a JoinEvent.

func (*Integration) HandleLocationEvent

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

HandleLocationEvent sends a LocationEvent.

func (*Integration) HandleStatusEvent

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

HandleStatusEvent sends a StatusEvent.

func (*Integration) HandleTxAckEvent

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

HandleTxAckEvent sends a TxAckEvent.

func (*Integration) HandleUplinkEvent

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

HandleUplinkEvent sends an UplinkEvent.