reportingpb

package module
v1.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 7, 2023 License: Apache-2.0 Imports: 13 Imported by: 3

Documentation

Index

Constants

View Source
const (
	Reporter_GetRoutedMessages_FullMethodName = "/org.packetbroker.reporting.v1.Reporter/GetRoutedMessages"
)

Variables

View Source
var File_packetbroker_api_reporting_v1_service_proto protoreflect.FileDescriptor
View Source
var Reporter_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "org.packetbroker.reporting.v1.Reporter",
	HandlerType: (*ReporterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetRoutedMessages",
			Handler:    _Reporter_GetRoutedMessages_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "packetbroker/api/reporting/v1/service.proto",
}

Reporter_ServiceDesc is the grpc.ServiceDesc for Reporter service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterReporterServer

func RegisterReporterServer(s grpc.ServiceRegistrar, srv ReporterServer)

Types

type GetRoutedMessagesRequest

type GetRoutedMessagesRequest struct {

	// LoRa Alliance NetID of the Forwarder Member.
	// When unset, match any Forwarder.
	ForwarderNetId *wrapperspb.UInt32Value `protobuf:"bytes,1,opt,name=forwarder_net_id,json=forwarderNetId,proto3" json:"forwarder_net_id,omitempty"`
	// Tenant ID managed by the Forwarder Member.
	// When unset, match any Forwarder tenant.
	ForwarderTenantId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=forwarder_tenant_id,json=forwarderTenantId,proto3" json:"forwarder_tenant_id,omitempty"`
	// LoRa Alliance NetID of the Home Network Member.
	// When unset, match any Home Network.
	HomeNetworkNetId *wrapperspb.UInt32Value `protobuf:"bytes,3,opt,name=home_network_net_id,json=homeNetworkNetId,proto3" json:"home_network_net_id,omitempty"`
	// Tenant ID managed by the Home Network Member.
	// When unset, match any Home Network tenant.
	HomeNetworkTenantId *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=home_network_tenant_id,json=homeNetworkTenantId,proto3" json:"home_network_tenant_id,omitempty"`
	// Types that are assignable to Time:
	//
	//	*GetRoutedMessagesRequest_Today
	//	*GetRoutedMessagesRequest_Last_30Days
	//	*GetRoutedMessagesRequest_Period
	Time isGetRoutedMessagesRequest_Time `protobuf_oneof:"time"`
	// contains filtered or unexported fields
}

func (*GetRoutedMessagesRequest) Descriptor deprecated

func (*GetRoutedMessagesRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRoutedMessagesRequest.ProtoReflect.Descriptor instead.

func (*GetRoutedMessagesRequest) GetForwarderNetId

func (x *GetRoutedMessagesRequest) GetForwarderNetId() *wrapperspb.UInt32Value

func (*GetRoutedMessagesRequest) GetForwarderTenantId

func (x *GetRoutedMessagesRequest) GetForwarderTenantId() *wrapperspb.StringValue

func (*GetRoutedMessagesRequest) GetHomeNetworkNetId

func (x *GetRoutedMessagesRequest) GetHomeNetworkNetId() *wrapperspb.UInt32Value

func (*GetRoutedMessagesRequest) GetHomeNetworkTenantId

func (x *GetRoutedMessagesRequest) GetHomeNetworkTenantId() *wrapperspb.StringValue

func (*GetRoutedMessagesRequest) GetLast_30Days

func (x *GetRoutedMessagesRequest) GetLast_30Days() *Last30Days

func (*GetRoutedMessagesRequest) GetPeriod

func (x *GetRoutedMessagesRequest) GetPeriod() *MonthPeriod

func (*GetRoutedMessagesRequest) GetTime

func (m *GetRoutedMessagesRequest) GetTime() isGetRoutedMessagesRequest_Time

func (*GetRoutedMessagesRequest) GetToday

func (x *GetRoutedMessagesRequest) GetToday() *Today

func (*GetRoutedMessagesRequest) ProtoMessage

func (*GetRoutedMessagesRequest) ProtoMessage()

func (*GetRoutedMessagesRequest) ProtoReflect

func (x *GetRoutedMessagesRequest) ProtoReflect() protoreflect.Message

func (*GetRoutedMessagesRequest) Reset

func (x *GetRoutedMessagesRequest) Reset()

func (*GetRoutedMessagesRequest) String

func (x *GetRoutedMessagesRequest) String() string

func (*GetRoutedMessagesRequest) Validate

func (r *GetRoutedMessagesRequest) Validate() error

Validate returns whether the request is valid.

type GetRoutedMessagesRequest_Last_30Days

type GetRoutedMessagesRequest_Last_30Days struct {
	Last_30Days *Last30Days `protobuf:"bytes,6,opt,name=last_30_days,json=last30Days,proto3,oneof"`
}

type GetRoutedMessagesRequest_Period

type GetRoutedMessagesRequest_Period struct {
	Period *MonthPeriod `protobuf:"bytes,7,opt,name=period,proto3,oneof"`
}

type GetRoutedMessagesRequest_Today

type GetRoutedMessagesRequest_Today struct {
	Today *Today `protobuf:"bytes,5,opt,name=today,proto3,oneof"`
}

type GetRoutedMessagesResponse

type GetRoutedMessagesResponse struct {
	Records []*RoutedMessagesRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRoutedMessagesResponse) Descriptor deprecated

func (*GetRoutedMessagesResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetRoutedMessagesResponse.ProtoReflect.Descriptor instead.

func (*GetRoutedMessagesResponse) GetRecords

func (*GetRoutedMessagesResponse) ProtoMessage

func (*GetRoutedMessagesResponse) ProtoMessage()

func (*GetRoutedMessagesResponse) ProtoReflect

func (*GetRoutedMessagesResponse) Reset

func (x *GetRoutedMessagesResponse) Reset()

func (*GetRoutedMessagesResponse) String

func (x *GetRoutedMessagesResponse) String() string

type Last30Days

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

func (*Last30Days) Descriptor deprecated

func (*Last30Days) Descriptor() ([]byte, []int)

Deprecated: Use Last30Days.ProtoReflect.Descriptor instead.

func (*Last30Days) ProtoMessage

func (*Last30Days) ProtoMessage()

func (*Last30Days) ProtoReflect

func (x *Last30Days) ProtoReflect() protoreflect.Message

func (*Last30Days) Reset

func (x *Last30Days) Reset()

func (*Last30Days) String

func (x *Last30Days) String() string

type MonthPeriod

type MonthPeriod struct {

	// From month (inclusive).
	From *MonthYear `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// To month (inclusive).
	To *MonthYear `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

func (*MonthPeriod) Descriptor deprecated

func (*MonthPeriod) Descriptor() ([]byte, []int)

Deprecated: Use MonthPeriod.ProtoReflect.Descriptor instead.

func (*MonthPeriod) GetFrom

func (x *MonthPeriod) GetFrom() *MonthYear

func (*MonthPeriod) GetTo

func (x *MonthPeriod) GetTo() *MonthYear

func (*MonthPeriod) ProtoMessage

func (*MonthPeriod) ProtoMessage()

func (*MonthPeriod) ProtoReflect

func (x *MonthPeriod) ProtoReflect() protoreflect.Message

func (*MonthPeriod) Reset

func (x *MonthPeriod) Reset()

func (*MonthPeriod) String

func (x *MonthPeriod) String() string

type MonthYear

type MonthYear struct {

	// Calendar month (1 tot 12).
	Month uint32 `protobuf:"varint,1,opt,name=month,proto3" json:"month,omitempty"`
	// Calendar year.
	Year uint32 `protobuf:"varint,2,opt,name=year,proto3" json:"year,omitempty"`
	// contains filtered or unexported fields
}

func (*MonthYear) Descriptor deprecated

func (*MonthYear) Descriptor() ([]byte, []int)

Deprecated: Use MonthYear.ProtoReflect.Descriptor instead.

func (*MonthYear) GetMonth

func (x *MonthYear) GetMonth() uint32

func (*MonthYear) GetYear

func (x *MonthYear) GetYear() uint32

func (*MonthYear) ProtoMessage

func (*MonthYear) ProtoMessage()

func (*MonthYear) ProtoReflect

func (x *MonthYear) ProtoReflect() protoreflect.Message

func (*MonthYear) Reset

func (x *MonthYear) Reset()

func (*MonthYear) String

func (x *MonthYear) String() string

type ReporterClient

type ReporterClient interface {
	GetRoutedMessages(ctx context.Context, in *GetRoutedMessagesRequest, opts ...grpc.CallOption) (*GetRoutedMessagesResponse, error)
}

ReporterClient is the client API for Reporter service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewReporterClient

func NewReporterClient(cc grpc.ClientConnInterface) ReporterClient

type ReporterServer

type ReporterServer interface {
	GetRoutedMessages(context.Context, *GetRoutedMessagesRequest) (*GetRoutedMessagesResponse, error)
	// contains filtered or unexported methods
}

ReporterServer is the server API for Reporter service. All implementations must embed UnimplementedReporterServer for forward compatibility

type RoutedMessagesRecord

type RoutedMessagesRecord struct {

	// End date that the time window applies to.
	// If the queried time is today, this contains the current date.
	// If the queried time is the last 30 days, this contains the last day.
	// If the queried time is a period in months, this contains the last day of the month this record applies to.
	To *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=to,proto3" json:"to,omitempty"`
	// LoRa Alliance NetID of the Forwarder Member.
	ForwarderNetId uint32 `protobuf:"varint,2,opt,name=forwarder_net_id,json=forwarderNetId,proto3" json:"forwarder_net_id,omitempty"`
	// Tenant ID managed by the Forwarder Member.
	ForwarderTenantId string `protobuf:"bytes,3,opt,name=forwarder_tenant_id,json=forwarderTenantId,proto3" json:"forwarder_tenant_id,omitempty"`
	// LoRa Alliance NetID of the Home Network Member.
	HomeNetworkNetId uint32 `protobuf:"varint,4,opt,name=home_network_net_id,json=homeNetworkNetId,proto3" json:"home_network_net_id,omitempty"`
	// Tenant ID managed by the Home Network Member.
	HomeNetworkTenantId string                         `protobuf:"bytes,5,opt,name=home_network_tenant_id,json=homeNetworkTenantId,proto3" json:"home_network_tenant_id,omitempty"`
	Uplink              *RoutedMessagesRecord_Uplink   `protobuf:"bytes,6,opt,name=uplink,proto3" json:"uplink,omitempty"`
	Downlink            *RoutedMessagesRecord_Downlink `protobuf:"bytes,7,opt,name=downlink,proto3" json:"downlink,omitempty"`
	// contains filtered or unexported fields
}

func (*RoutedMessagesRecord) Descriptor deprecated

func (*RoutedMessagesRecord) Descriptor() ([]byte, []int)

Deprecated: Use RoutedMessagesRecord.ProtoReflect.Descriptor instead.

func (*RoutedMessagesRecord) GetForwarderNetId

func (x *RoutedMessagesRecord) GetForwarderNetId() uint32

func (*RoutedMessagesRecord) GetForwarderTenantId

func (x *RoutedMessagesRecord) GetForwarderTenantId() string

func (*RoutedMessagesRecord) GetHomeNetworkNetId

func (x *RoutedMessagesRecord) GetHomeNetworkNetId() uint32

func (*RoutedMessagesRecord) GetHomeNetworkTenantId

func (x *RoutedMessagesRecord) GetHomeNetworkTenantId() string

func (*RoutedMessagesRecord) GetTo

func (*RoutedMessagesRecord) ProtoMessage

func (*RoutedMessagesRecord) ProtoMessage()

func (*RoutedMessagesRecord) ProtoReflect

func (x *RoutedMessagesRecord) ProtoReflect() protoreflect.Message

func (*RoutedMessagesRecord) Reset

func (x *RoutedMessagesRecord) Reset()

func (*RoutedMessagesRecord) String

func (x *RoutedMessagesRecord) String() string
type RoutedMessagesRecord_Downlink struct {

	// Count of join-accepts that are routed by Packet Broker.
	JoinAcceptsRoutedCount uint64 `` /* 132-byte string literal not displayed */
	// Count of join-accepts processed successfully by the Forwarder.
	JoinAcceptsProcessedSuccessCount uint64 `` /* 164-byte string literal not displayed */
	// Count of join-accepts processed with an error by the Forwarder.
	JoinAcceptsProcessedErrorCount []*RoutedMessagesRecord_Downlink_ErrorCount `` /* 157-byte string literal not displayed */
	// Count of data downlink messages that are routed by Packet Broker.
	DataMessagesRoutedCount uint64 `` /* 135-byte string literal not displayed */
	// Count of data downlink messages processed successfully by the Forwarder.
	DataMessagesProcessedSuccessCount uint64 `` /* 167-byte string literal not displayed */
	// Count of data downlink messages processed with an error by the Forwarder.
	DataMessagesProcessedErrorCount []*RoutedMessagesRecord_Downlink_ErrorCount `` /* 160-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RoutedMessagesRecord_Downlink) Descriptor deprecated

func (*RoutedMessagesRecord_Downlink) Descriptor() ([]byte, []int)

Deprecated: Use RoutedMessagesRecord_Downlink.ProtoReflect.Descriptor instead.

func (*RoutedMessagesRecord_Downlink) GetDataMessagesProcessedErrorCount

func (x *RoutedMessagesRecord_Downlink) GetDataMessagesProcessedErrorCount() []*RoutedMessagesRecord_Downlink_ErrorCount

func (*RoutedMessagesRecord_Downlink) GetDataMessagesProcessedSuccessCount

func (x *RoutedMessagesRecord_Downlink) GetDataMessagesProcessedSuccessCount() uint64

func (*RoutedMessagesRecord_Downlink) GetDataMessagesRoutedCount

func (x *RoutedMessagesRecord_Downlink) GetDataMessagesRoutedCount() uint64

func (*RoutedMessagesRecord_Downlink) GetJoinAcceptsProcessedErrorCount

func (x *RoutedMessagesRecord_Downlink) GetJoinAcceptsProcessedErrorCount() []*RoutedMessagesRecord_Downlink_ErrorCount

func (*RoutedMessagesRecord_Downlink) GetJoinAcceptsProcessedSuccessCount

func (x *RoutedMessagesRecord_Downlink) GetJoinAcceptsProcessedSuccessCount() uint64

func (*RoutedMessagesRecord_Downlink) GetJoinAcceptsRoutedCount

func (x *RoutedMessagesRecord_Downlink) GetJoinAcceptsRoutedCount() uint64

func (*RoutedMessagesRecord_Downlink) ProtoMessage

func (*RoutedMessagesRecord_Downlink) ProtoMessage()

func (*RoutedMessagesRecord_Downlink) ProtoReflect

func (*RoutedMessagesRecord_Downlink) Reset

func (x *RoutedMessagesRecord_Downlink) Reset()

func (*RoutedMessagesRecord_Downlink) String

type RoutedMessagesRecord_Downlink_ErrorCount struct {
	ErrorType v3.DownlinkMessageProcessingError `` /* 145-byte string literal not displayed */
	Count     uint64                            `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}
func (*RoutedMessagesRecord_Downlink_ErrorCount) Descriptor() ([]byte, []int)

Deprecated: Use RoutedMessagesRecord_Downlink_ErrorCount.ProtoReflect.Descriptor instead.

type RoutedMessagesRecord_Uplink struct {

	// Count of join-requests that are routed by Packet Broker.
	JoinRequestsRoutedCount uint64 `` /* 135-byte string literal not displayed */
	// Count of join-requests processed successfully by the Home Network.
	JoinRequestsProcessedSuccessCount uint64 `` /* 167-byte string literal not displayed */
	// Count of join-requests processed with an error by the Home Network.
	JoinRequestsProcessedErrorCount []*RoutedMessagesRecord_Uplink_ErrorCount `` /* 160-byte string literal not displayed */
	// Count of data uplink messages that are routed by Packet Broker.
	DataMessagesRoutedCount uint64 `` /* 135-byte string literal not displayed */
	// Count of data uplink messages processed successfully by the Home Network.
	DataMessagesProcessedSuccessCount uint64 `` /* 167-byte string literal not displayed */
	// Count of data uplink messages processed with an error by the Home Network.
	DataMessagesProcessedErrorCount []*RoutedMessagesRecord_Uplink_ErrorCount `` /* 160-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RoutedMessagesRecord_Uplink) Descriptor deprecated

func (*RoutedMessagesRecord_Uplink) Descriptor() ([]byte, []int)

Deprecated: Use RoutedMessagesRecord_Uplink.ProtoReflect.Descriptor instead.

func (*RoutedMessagesRecord_Uplink) GetDataMessagesProcessedErrorCount

func (x *RoutedMessagesRecord_Uplink) GetDataMessagesProcessedErrorCount() []*RoutedMessagesRecord_Uplink_ErrorCount

func (*RoutedMessagesRecord_Uplink) GetDataMessagesProcessedSuccessCount

func (x *RoutedMessagesRecord_Uplink) GetDataMessagesProcessedSuccessCount() uint64

func (*RoutedMessagesRecord_Uplink) GetDataMessagesRoutedCount

func (x *RoutedMessagesRecord_Uplink) GetDataMessagesRoutedCount() uint64

func (*RoutedMessagesRecord_Uplink) GetJoinRequestsProcessedErrorCount

func (x *RoutedMessagesRecord_Uplink) GetJoinRequestsProcessedErrorCount() []*RoutedMessagesRecord_Uplink_ErrorCount

func (*RoutedMessagesRecord_Uplink) GetJoinRequestsProcessedSuccessCount

func (x *RoutedMessagesRecord_Uplink) GetJoinRequestsProcessedSuccessCount() uint64

func (*RoutedMessagesRecord_Uplink) GetJoinRequestsRoutedCount

func (x *RoutedMessagesRecord_Uplink) GetJoinRequestsRoutedCount() uint64

func (*RoutedMessagesRecord_Uplink) ProtoMessage

func (*RoutedMessagesRecord_Uplink) ProtoMessage()

func (*RoutedMessagesRecord_Uplink) ProtoReflect

func (*RoutedMessagesRecord_Uplink) Reset

func (x *RoutedMessagesRecord_Uplink) Reset()

func (*RoutedMessagesRecord_Uplink) String

func (x *RoutedMessagesRecord_Uplink) String() string
type RoutedMessagesRecord_Uplink_ErrorCount struct {
	ErrorType v3.UplinkMessageProcessingError `` /* 143-byte string literal not displayed */
	Count     uint64                          `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}
func (*RoutedMessagesRecord_Uplink_ErrorCount) Descriptor() ([]byte, []int)

Deprecated: Use RoutedMessagesRecord_Uplink_ErrorCount.ProtoReflect.Descriptor instead.

type Today

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

func (*Today) Descriptor deprecated

func (*Today) Descriptor() ([]byte, []int)

Deprecated: Use Today.ProtoReflect.Descriptor instead.

func (*Today) ProtoMessage

func (*Today) ProtoMessage()

func (*Today) ProtoReflect

func (x *Today) ProtoReflect() protoreflect.Message

func (*Today) Reset

func (x *Today) Reset()

func (*Today) String

func (x *Today) String() string

type UnimplementedReporterServer

type UnimplementedReporterServer struct {
}

UnimplementedReporterServer must be embedded to have forward compatible implementations.

func (UnimplementedReporterServer) GetRoutedMessages

type UnsafeReporterServer

type UnsafeReporterServer interface {
	// contains filtered or unexported methods
}

UnsafeReporterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReporterServer will result in compilation errors.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL