Skip to content

Commit

Permalink
as: Fix names for downlink events
Browse files Browse the repository at this point in the history
  • Loading branch information
Vlad Vitan committed Aug 29, 2024
1 parent 99201a4 commit e5e8b62
Showing 1 changed file with 30 additions and 30 deletions.
60 changes: 30 additions & 30 deletions pkg/applicationserver/observability.go
Original file line number Diff line number Diff line change
Expand Up @@ -101,36 +101,6 @@ var (
events.WithDataType(&ttnpb.ApplicationUp{}),
events.WithPropagateToParent(),
)
evtForwardDownlinkQueueInvalidated = events.Define(
"as.up.downlink.queue.invalidated.forward", "forward downlink queue invalidated",
events.WithVisibility(ttnpb.Right_RIGHT_APPLICATION_TRAFFIC_READ),
events.WithDataType(&ttnpb.ApplicationUp{}),
events.WithPropagateToParent(),
)
evtForwardDownlinkFailed = events.Define(
"as.up.downlink.failed.forward", "forward downlink failed",
events.WithVisibility(ttnpb.Right_RIGHT_APPLICATION_TRAFFIC_READ),
events.WithDataType(&ttnpb.ApplicationUp{}),
events.WithPropagateToParent(),
)
evtForwardDownlinkSent = events.Define(
"as.up.downlink.sent.forward", "forward downlink sent",
events.WithVisibility(ttnpb.Right_RIGHT_APPLICATION_TRAFFIC_READ),
events.WithDataType(&ttnpb.ApplicationUp{}),
events.WithPropagateToParent(),
)
evtForwardDownlinkAck = events.Define(
"as.up.downlink.ack.forward", "forward downlink acknowledged",
events.WithVisibility(ttnpb.Right_RIGHT_APPLICATION_TRAFFIC_READ),
events.WithDataType(&ttnpb.ApplicationUp{}),
events.WithPropagateToParent(),
)
evtForwardDownlinkNack = events.Define(
"as.up.downlink.nack.forward", "forward downlink not acknowledged",
events.WithVisibility(ttnpb.Right_RIGHT_APPLICATION_TRAFFIC_READ),
events.WithDataType(&ttnpb.ApplicationUp{}),
events.WithPropagateToParent(),
)
evtReceiveDataDown = events.Define(
"as.down.data.receive", "receive downlink data message",
events.WithVisibility(ttnpb.Right_RIGHT_APPLICATION_TRAFFIC_READ),
Expand Down Expand Up @@ -176,6 +146,36 @@ var (
events.WithDataType(&ttnpb.ApplicationDownlink{}),
events.WithPropagateToParent(),
)
evtForwardDownlinkQueueInvalidated = events.Define(
"as.down.data.queue.invalidated.forward", "forward downlink queue invalidated",
events.WithVisibility(ttnpb.Right_RIGHT_APPLICATION_TRAFFIC_READ),
events.WithDataType(&ttnpb.ApplicationUp{}),
events.WithPropagateToParent(),
)
evtForwardDownlinkFailed = events.Define(
"as.down.data.failed.forward", "forward downlink failed",
events.WithVisibility(ttnpb.Right_RIGHT_APPLICATION_TRAFFIC_READ),
events.WithDataType(&ttnpb.ApplicationUp{}),
events.WithPropagateToParent(),
)
evtForwardDownlinkSent = events.Define(
"as.down.data.sent.forward", "forward downlink sent",
events.WithVisibility(ttnpb.Right_RIGHT_APPLICATION_TRAFFIC_READ),
events.WithDataType(&ttnpb.ApplicationUp{}),
events.WithPropagateToParent(),
)
evtForwardDownlinkAck = events.Define(
"as.down.data.ack.forward", "forward downlink acknowledged",
events.WithVisibility(ttnpb.Right_RIGHT_APPLICATION_TRAFFIC_READ),
events.WithDataType(&ttnpb.ApplicationUp{}),
events.WithPropagateToParent(),
)
evtForwardDownlinkNack = events.Define(
"as.down.data.nack.forward", "forward downlink not acknowledged",
events.WithVisibility(ttnpb.Right_RIGHT_APPLICATION_TRAFFIC_READ),
events.WithDataType(&ttnpb.ApplicationUp{}),
events.WithPropagateToParent(),
)
)

const (
Expand Down

0 comments on commit e5e8b62

Please sign in to comment.