routingpb

package module
v1.9.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: 12 Imported by: 7

Documentation

Index

Constants

View Source 
const (
	PolicyManager_ListDefaultPolicies_FullMethodName     = "/org.packetbroker.routing.v1.PolicyManager/ListDefaultPolicies"
	PolicyManager_GetDefaultPolicy_FullMethodName        = "/org.packetbroker.routing.v1.PolicyManager/GetDefaultPolicy"
	PolicyManager_SetDefaultPolicy_FullMethodName        = "/org.packetbroker.routing.v1.PolicyManager/SetDefaultPolicy"
	PolicyManager_ListHomeNetworkPolicies_FullMethodName = "/org.packetbroker.routing.v1.PolicyManager/ListHomeNetworkPolicies"
	PolicyManager_GetHomeNetworkPolicy_FullMethodName    = "/org.packetbroker.routing.v1.PolicyManager/GetHomeNetworkPolicy"
	PolicyManager_SetHomeNetworkPolicy_FullMethodName    = "/org.packetbroker.routing.v1.PolicyManager/SetHomeNetworkPolicy"
	PolicyManager_ListEffectivePolicies_FullMethodName   = "/org.packetbroker.routing.v1.PolicyManager/ListEffectivePolicies"
	PolicyManager_ListNetworksWithPolicy_FullMethodName  = "/org.packetbroker.routing.v1.PolicyManager/ListNetworksWithPolicy"
)
View Source 
const (
	ForwarderData_Publish_FullMethodName                            = "/org.packetbroker.routing.v1.ForwarderData/Publish"
	ForwarderData_Subscribe_FullMethodName                          = "/org.packetbroker.routing.v1.ForwarderData/Subscribe"
	ForwarderData_ReportDownlinkMessageDeliveryState_FullMethodName = "/org.packetbroker.routing.v1.ForwarderData/ReportDownlinkMessageDeliveryState"
)
View Source 
const (
	HomeNetworkData_Publish_FullMethodName                          = "/org.packetbroker.routing.v1.HomeNetworkData/Publish"
	HomeNetworkData_Subscribe_FullMethodName                        = "/org.packetbroker.routing.v1.HomeNetworkData/Subscribe"
	HomeNetworkData_ReportUplinkMessageDeliveryState_FullMethodName = "/org.packetbroker.routing.v1.HomeNetworkData/ReportUplinkMessageDeliveryState"
)

Variables

View Source 
var File_packetbroker_api_routing_v1_service_proto protoreflect.FileDescriptor
View Source 
var ForwarderData_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "org.packetbroker.routing.v1.ForwarderData",
	HandlerType: (*ForwarderDataServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Publish",
			Handler:    _ForwarderData_Publish_Handler,
		},
		{
			MethodName: "ReportDownlinkMessageDeliveryState",
			Handler:    _ForwarderData_ReportDownlinkMessageDeliveryState_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _ForwarderData_Subscribe_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "packetbroker/api/routing/v1/service.proto",
}

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

View Source 
var HomeNetworkData_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "org.packetbroker.routing.v1.HomeNetworkData",
	HandlerType: (*HomeNetworkDataServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Publish",
			Handler:    _HomeNetworkData_Publish_Handler,
		},
		{
			MethodName: "ReportUplinkMessageDeliveryState",
			Handler:    _HomeNetworkData_ReportUplinkMessageDeliveryState_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _HomeNetworkData_Subscribe_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "packetbroker/api/routing/v1/service.proto",
}

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

View Source 
var PolicyManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "org.packetbroker.routing.v1.PolicyManager",
	HandlerType: (*PolicyManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListDefaultPolicies",
			Handler:    _PolicyManager_ListDefaultPolicies_Handler,
		},
		{
			MethodName: "GetDefaultPolicy",
			Handler:    _PolicyManager_GetDefaultPolicy_Handler,
		},
		{
			MethodName: "SetDefaultPolicy",
			Handler:    _PolicyManager_SetDefaultPolicy_Handler,
		},
		{
			MethodName: "ListHomeNetworkPolicies",
			Handler:    _PolicyManager_ListHomeNetworkPolicies_Handler,
		},
		{
			MethodName: "GetHomeNetworkPolicy",
			Handler:    _PolicyManager_GetHomeNetworkPolicy_Handler,
		},
		{
			MethodName: "SetHomeNetworkPolicy",
			Handler:    _PolicyManager_SetHomeNetworkPolicy_Handler,
		},
		{
			MethodName: "ListEffectivePolicies",
			Handler:    _PolicyManager_ListEffectivePolicies_Handler,
		},
		{
			MethodName: "ListNetworksWithPolicy",
			Handler:    _PolicyManager_ListNetworksWithPolicy_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "packetbroker/api/routing/v1/service.proto",
}

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

Functions

func RegisterForwarderDataServer 

func RegisterForwarderDataServer(s grpc.ServiceRegistrar, srv ForwarderDataServer)

func RegisterHomeNetworkDataServer 

func RegisterHomeNetworkDataServer(s grpc.ServiceRegistrar, srv HomeNetworkDataServer)

func RegisterPolicyManagerServer 

func RegisterPolicyManagerServer(s grpc.ServiceRegistrar, srv PolicyManagerServer)

Types

type DownlinkMessageDeliveryStateChangeRequest added in v1.4.0 

type DownlinkMessageDeliveryStateChangeRequest struct {
	StateChange *v3.DownlinkMessageDeliveryStateChange `protobuf:"bytes,1,opt,name=state_change,json=stateChange,proto3" json:"state_change,omitempty"`
	// contains filtered or unexported fields
}

func (*DownlinkMessageDeliveryStateChangeRequest) Descriptor deprecated added in v1.4.0 

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

Deprecated: Use DownlinkMessageDeliveryStateChangeRequest.ProtoReflect.Descriptor instead.

func (*DownlinkMessageDeliveryStateChangeRequest) GetStateChange added in v1.4.0 

func (x *DownlinkMessageDeliveryStateChangeRequest) GetStateChange() *v3.DownlinkMessageDeliveryStateChange

func (*DownlinkMessageDeliveryStateChangeRequest) ProtoMessage added in v1.4.0 

func (*DownlinkMessageDeliveryStateChangeRequest) ProtoMessage()

func (*DownlinkMessageDeliveryStateChangeRequest) ProtoReflect added in v1.4.0 

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

func (*DownlinkMessageDeliveryStateChangeRequest) Reset added in v1.4.0 

func (x *DownlinkMessageDeliveryStateChangeRequest) Reset()

func (*DownlinkMessageDeliveryStateChangeRequest) String added in v1.4.0 

func (x *DownlinkMessageDeliveryStateChangeRequest) String() string

func (*DownlinkMessageDeliveryStateChangeRequest) Validate added in v1.4.0 

func (r *DownlinkMessageDeliveryStateChangeRequest) Validate() error

Validate returns whether the request is valid.

type ForwarderDataClient 

type ForwarderDataClient interface {
	// Publish an uplink message.
	Publish(ctx context.Context, in *PublishUplinkMessageRequest, opts ...grpc.CallOption) (*PublishUplinkMessageResponse, error)
	// Subscribe to routed downlink messages.
	Subscribe(ctx context.Context, in *SubscribeForwarderRequest, opts ...grpc.CallOption) (ForwarderData_SubscribeClient, error)
	// Report the message state change of a downlink message.
	ReportDownlinkMessageDeliveryState(ctx context.Context, in *DownlinkMessageDeliveryStateChangeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ForwarderDataClient is the client API for ForwarderData 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 NewForwarderDataClient 

func NewForwarderDataClient(cc grpc.ClientConnInterface) ForwarderDataClient

type ForwarderDataServer 

type ForwarderDataServer interface {
	// Publish an uplink message.
	Publish(context.Context, *PublishUplinkMessageRequest) (*PublishUplinkMessageResponse, error)
	// Subscribe to routed downlink messages.
	Subscribe(*SubscribeForwarderRequest, ForwarderData_SubscribeServer) error
	// Report the message state change of a downlink message.
	ReportDownlinkMessageDeliveryState(context.Context, *DownlinkMessageDeliveryStateChangeRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ForwarderDataServer is the server API for ForwarderData service. All implementations must embed UnimplementedForwarderDataServer for forward compatibility

type ForwarderData_SubscribeClient 

type ForwarderData_SubscribeClient interface {
	Recv() (*v3.RoutedDownlinkMessage, error)
	grpc.ClientStream
}

type ForwarderData_SubscribeServer 

type ForwarderData_SubscribeServer interface {
	Send(*v3.RoutedDownlinkMessage) error
	grpc.ServerStream
}

type GetDefaultPolicyRequest 

type GetDefaultPolicyRequest struct {

	// LoRa Alliance NetID of the Forwarder Member.
	ForwarderNetId uint32 `protobuf:"varint,1,opt,name=forwarder_net_id,json=forwarderNetId,proto3" json:"forwarder_net_id,omitempty"`
	// Tenant ID managed by the Forwarder Member.
	ForwarderTenantId string `protobuf:"bytes,2,opt,name=forwarder_tenant_id,json=forwarderTenantId,proto3" json:"forwarder_tenant_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDefaultPolicyRequest) Descriptor deprecated 

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

Deprecated: Use GetDefaultPolicyRequest.ProtoReflect.Descriptor instead.

func (*GetDefaultPolicyRequest) GetForwarderNetId 

func (x *GetDefaultPolicyRequest) GetForwarderNetId() uint32

func (*GetDefaultPolicyRequest) GetForwarderTenantId 

func (x *GetDefaultPolicyRequest) GetForwarderTenantId() string

func (*GetDefaultPolicyRequest) ProtoMessage 

func (*GetDefaultPolicyRequest) ProtoMessage()

func (*GetDefaultPolicyRequest) ProtoReflect 

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

func (*GetDefaultPolicyRequest) Reset 

func (x *GetDefaultPolicyRequest) Reset()

func (*GetDefaultPolicyRequest) String 

func (x *GetDefaultPolicyRequest) String() string

func (*GetDefaultPolicyRequest) Validate 

func (r *GetDefaultPolicyRequest) Validate() error

Validate returns whether the request is valid.

type GetHomeNetworkPolicyRequest 

type GetHomeNetworkPolicyRequest struct {

	// LoRa Alliance NetID of the Forwarder Member.
	ForwarderNetId uint32 `protobuf:"varint,1,opt,name=forwarder_net_id,json=forwarderNetId,proto3" json:"forwarder_net_id,omitempty"`
	// Tenant ID managed by the Forwarder Member.
	ForwarderTenantId string `protobuf:"bytes,2,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,3,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,4,opt,name=home_network_tenant_id,json=homeNetworkTenantId,proto3" json:"home_network_tenant_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetHomeNetworkPolicyRequest) Descriptor deprecated 

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

Deprecated: Use GetHomeNetworkPolicyRequest.ProtoReflect.Descriptor instead.

func (*GetHomeNetworkPolicyRequest) GetForwarderNetId 

func (x *GetHomeNetworkPolicyRequest) GetForwarderNetId() uint32

func (*GetHomeNetworkPolicyRequest) GetForwarderTenantId 

func (x *GetHomeNetworkPolicyRequest) GetForwarderTenantId() string

func (*GetHomeNetworkPolicyRequest) GetHomeNetworkNetId 

func (x *GetHomeNetworkPolicyRequest) GetHomeNetworkNetId() uint32

func (*GetHomeNetworkPolicyRequest) GetHomeNetworkTenantId 

func (x *GetHomeNetworkPolicyRequest) GetHomeNetworkTenantId() string

func (*GetHomeNetworkPolicyRequest) ProtoMessage 

func (*GetHomeNetworkPolicyRequest) ProtoMessage()

func (*GetHomeNetworkPolicyRequest) ProtoReflect 

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

func (*GetHomeNetworkPolicyRequest) Reset 

func (x *GetHomeNetworkPolicyRequest) Reset()

func (*GetHomeNetworkPolicyRequest) String 

func (x *GetHomeNetworkPolicyRequest) String() string

func (*GetHomeNetworkPolicyRequest) Validate 

func (r *GetHomeNetworkPolicyRequest) Validate() error

Validate returns whether the request is valid.

type GetPolicyResponse 

type GetPolicyResponse struct {
	Policy *v3.RoutingPolicy `protobuf:"bytes,1,opt,name=policy,proto3" json:"policy,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPolicyResponse) Descriptor deprecated 

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

Deprecated: Use GetPolicyResponse.ProtoReflect.Descriptor instead.

func (*GetPolicyResponse) GetPolicy 

func (x *GetPolicyResponse) GetPolicy() *v3.RoutingPolicy

func (*GetPolicyResponse) ProtoMessage 

func (*GetPolicyResponse) ProtoMessage()

func (*GetPolicyResponse) ProtoReflect 

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

func (*GetPolicyResponse) Reset 

func (x *GetPolicyResponse) Reset()

func (*GetPolicyResponse) String 

func (x *GetPolicyResponse) String() string

type HomeNetworkDataClient 

type HomeNetworkDataClient interface {
	// Publish a downlink message.
	Publish(ctx context.Context, in *PublishDownlinkMessageRequest, opts ...grpc.CallOption) (*PublishDownlinkMessageResponse, error)
	// Subscribe to routed uplink messages.
	Subscribe(ctx context.Context, in *SubscribeHomeNetworkRequest, opts ...grpc.CallOption) (HomeNetworkData_SubscribeClient, error)
	// Report the message state change of an uplink message.
	ReportUplinkMessageDeliveryState(ctx context.Context, in *UplinkMessageDeliveryStateChangeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

HomeNetworkDataClient is the client API for HomeNetworkData 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 NewHomeNetworkDataClient 

func NewHomeNetworkDataClient(cc grpc.ClientConnInterface) HomeNetworkDataClient

type HomeNetworkDataServer 

type HomeNetworkDataServer interface {
	// Publish a downlink message.
	Publish(context.Context, *PublishDownlinkMessageRequest) (*PublishDownlinkMessageResponse, error)
	// Subscribe to routed uplink messages.
	Subscribe(*SubscribeHomeNetworkRequest, HomeNetworkData_SubscribeServer) error
	// Report the message state change of an uplink message.
	ReportUplinkMessageDeliveryState(context.Context, *UplinkMessageDeliveryStateChangeRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

HomeNetworkDataServer is the server API for HomeNetworkData service. All implementations must embed UnimplementedHomeNetworkDataServer for forward compatibility

type HomeNetworkData_SubscribeClient 

type HomeNetworkData_SubscribeClient interface {
	Recv() (*v3.RoutedUplinkMessage, error)
	grpc.ClientStream
}

type HomeNetworkData_SubscribeServer 

type HomeNetworkData_SubscribeServer interface {
	Send(*v3.RoutedUplinkMessage) error
	grpc.ServerStream
}

type ListDefaultPoliciesRequest 

type ListDefaultPoliciesRequest struct {

	// Timestamp to list from for pagination.
	UpdatedSince *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=updated_since,json=updatedSince,proto3" json:"updated_since,omitempty"`
	// Limit number items for pagination.
	// If 0, use the server's default.
	// The actual limit may be capped by the server.
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDefaultPoliciesRequest) Descriptor deprecated 

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

Deprecated: Use ListDefaultPoliciesRequest.ProtoReflect.Descriptor instead.

func (*ListDefaultPoliciesRequest) GetLimit 

func (x *ListDefaultPoliciesRequest) GetLimit() uint32

func (*ListDefaultPoliciesRequest) GetUpdatedSince 

func (x *ListDefaultPoliciesRequest) GetUpdatedSince() *timestamppb.Timestamp

func (*ListDefaultPoliciesRequest) ProtoMessage 

func (*ListDefaultPoliciesRequest) ProtoMessage()

func (*ListDefaultPoliciesRequest) ProtoReflect 

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

func (*ListDefaultPoliciesRequest) Reset 

func (x *ListDefaultPoliciesRequest) Reset()

func (*ListDefaultPoliciesRequest) String 

func (x *ListDefaultPoliciesRequest) String() string

func (*ListDefaultPoliciesRequest) Validate 

func (r *ListDefaultPoliciesRequest) Validate() error

Validate returns whether the request is valid.

type ListDefaultPoliciesResponse 

type ListDefaultPoliciesResponse struct {
	Policies []*v3.RoutingPolicy `protobuf:"bytes,1,rep,name=policies,proto3" json:"policies,omitempty"`
	// Total number of items.
	Total uint32 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDefaultPoliciesResponse) Descriptor deprecated 

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

Deprecated: Use ListDefaultPoliciesResponse.ProtoReflect.Descriptor instead.

func (*ListDefaultPoliciesResponse) GetPolicies 

func (x *ListDefaultPoliciesResponse) GetPolicies() []*v3.RoutingPolicy

func (*ListDefaultPoliciesResponse) GetTotal 

func (x *ListDefaultPoliciesResponse) GetTotal() uint32

func (*ListDefaultPoliciesResponse) ProtoMessage 

func (*ListDefaultPoliciesResponse) ProtoMessage()

func (*ListDefaultPoliciesResponse) ProtoReflect 

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

func (*ListDefaultPoliciesResponse) Reset 

func (x *ListDefaultPoliciesResponse) Reset()

func (*ListDefaultPoliciesResponse) String 

func (x *ListDefaultPoliciesResponse) String() string

type ListEffectivePoliciesRequest added in v1.1.3 

type ListEffectivePoliciesRequest struct {

	// LoRa Alliance NetID of the Home Network Member.
	HomeNetworkNetId uint32 `protobuf:"varint,1,opt,name=home_network_net_id,json=homeNetworkNetId,proto3" json:"home_network_net_id,omitempty"`
	// ID assigned by the Home Network Member.
	HomeNetworkTenantId string `protobuf:"bytes,2,opt,name=home_network_tenant_id,json=homeNetworkTenantId,proto3" json:"home_network_tenant_id,omitempty"`
	// Number of items to skip.
	Offset uint32 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	// Limit the number of items.
	// If 0, use the server's default.
	// The actual limit may be capped by the server.
	Limit uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEffectivePoliciesRequest) Descriptor deprecated added in v1.1.3 

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

Deprecated: Use ListEffectivePoliciesRequest.ProtoReflect.Descriptor instead.

func (*ListEffectivePoliciesRequest) GetHomeNetworkNetId added in v1.1.3 

func (x *ListEffectivePoliciesRequest) GetHomeNetworkNetId() uint32

func (*ListEffectivePoliciesRequest) GetHomeNetworkTenantId added in v1.1.3 

func (x *ListEffectivePoliciesRequest) GetHomeNetworkTenantId() string

func (*ListEffectivePoliciesRequest) GetLimit added in v1.1.3 

func (x *ListEffectivePoliciesRequest) GetLimit() uint32

func (*ListEffectivePoliciesRequest) GetOffset added in v1.1.3 

func (x *ListEffectivePoliciesRequest) GetOffset() uint32

func (*ListEffectivePoliciesRequest) ProtoMessage added in v1.1.3 

func (*ListEffectivePoliciesRequest) ProtoMessage()

func (*ListEffectivePoliciesRequest) ProtoReflect added in v1.1.3 

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

func (*ListEffectivePoliciesRequest) Reset added in v1.1.3 

func (x *ListEffectivePoliciesRequest) Reset()

func (*ListEffectivePoliciesRequest) String added in v1.1.3 

func (x *ListEffectivePoliciesRequest) String() string

func (*ListEffectivePoliciesRequest) Validate added in v1.1.3 

func (r *ListEffectivePoliciesRequest) Validate() error

Validate returns whether the request is valid.

type ListEffectivePoliciesResponse added in v1.1.3 

type ListEffectivePoliciesResponse struct {
	Policies []*v3.RoutingPolicy `protobuf:"bytes,1,rep,name=policies,proto3" json:"policies,omitempty"`
	// Total number of items.
	Total uint32 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEffectivePoliciesResponse) Descriptor deprecated added in v1.1.3 

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

Deprecated: Use ListEffectivePoliciesResponse.ProtoReflect.Descriptor instead.

func (*ListEffectivePoliciesResponse) GetPolicies added in v1.1.3 

func (x *ListEffectivePoliciesResponse) GetPolicies() []*v3.RoutingPolicy

func (*ListEffectivePoliciesResponse) GetTotal added in v1.1.3 

func (x *ListEffectivePoliciesResponse) GetTotal() uint32

func (*ListEffectivePoliciesResponse) ProtoMessage added in v1.1.3 

func (*ListEffectivePoliciesResponse) ProtoMessage()

func (*ListEffectivePoliciesResponse) ProtoReflect added in v1.1.3 

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

func (*ListEffectivePoliciesResponse) Reset added in v1.1.3 

func (x *ListEffectivePoliciesResponse) Reset()

func (*ListEffectivePoliciesResponse) String added in v1.1.3 

func (x *ListEffectivePoliciesResponse) String() string

type ListHomeNetworkPoliciesRequest 

type ListHomeNetworkPoliciesRequest struct {

	// LoRa Alliance NetID of the Forwarder Member.
	ForwarderNetId uint32 `protobuf:"varint,1,opt,name=forwarder_net_id,json=forwarderNetId,proto3" json:"forwarder_net_id,omitempty"`
	// Tenant ID managed by the Forwarder Member.
	ForwarderTenantId string `protobuf:"bytes,2,opt,name=forwarder_tenant_id,json=forwarderTenantId,proto3" json:"forwarder_tenant_id,omitempty"`
	// Timestamp to list from for pagination.
	UpdatedSince *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=updated_since,json=updatedSince,proto3" json:"updated_since,omitempty"`
	// Limit number items for pagination.
	// If 0, use the server's default.
	// The actual limit may be capped by the server.
	Limit uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListHomeNetworkPoliciesRequest) Descriptor deprecated 

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

Deprecated: Use ListHomeNetworkPoliciesRequest.ProtoReflect.Descriptor instead.

func (*ListHomeNetworkPoliciesRequest) GetForwarderNetId 

func (x *ListHomeNetworkPoliciesRequest) GetForwarderNetId() uint32

func (*ListHomeNetworkPoliciesRequest) GetForwarderTenantId 

func (x *ListHomeNetworkPoliciesRequest) GetForwarderTenantId() string

func (*ListHomeNetworkPoliciesRequest) GetLimit 

func (x *ListHomeNetworkPoliciesRequest) GetLimit() uint32

func (*ListHomeNetworkPoliciesRequest) GetUpdatedSince 

func (x *ListHomeNetworkPoliciesRequest) GetUpdatedSince() *timestamppb.Timestamp

func (*ListHomeNetworkPoliciesRequest) ProtoMessage 

func (*ListHomeNetworkPoliciesRequest) ProtoMessage()

func (*ListHomeNetworkPoliciesRequest) ProtoReflect 

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

func (*ListHomeNetworkPoliciesRequest) Reset 

func (x *ListHomeNetworkPoliciesRequest) Reset()

func (*ListHomeNetworkPoliciesRequest) String 

func (x *ListHomeNetworkPoliciesRequest) String() string

func (*ListHomeNetworkPoliciesRequest) Validate 

func (r *ListHomeNetworkPoliciesRequest) Validate() error

Validate returns whether the request is valid.

type ListHomeNetworkPoliciesResponse 

type ListHomeNetworkPoliciesResponse struct {
	Policies []*v3.RoutingPolicy `protobuf:"bytes,1,rep,name=policies,proto3" json:"policies,omitempty"`
	// Total number of items.
	Total uint32 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*ListHomeNetworkPoliciesResponse) Descriptor deprecated 

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

Deprecated: Use ListHomeNetworkPoliciesResponse.ProtoReflect.Descriptor instead.

func (*ListHomeNetworkPoliciesResponse) GetPolicies 

func (x *ListHomeNetworkPoliciesResponse) GetPolicies() []*v3.RoutingPolicy

func (*ListHomeNetworkPoliciesResponse) GetTotal 

func (x *ListHomeNetworkPoliciesResponse) GetTotal() uint32

func (*ListHomeNetworkPoliciesResponse) ProtoMessage 

func (*ListHomeNetworkPoliciesResponse) ProtoMessage()

func (*ListHomeNetworkPoliciesResponse) ProtoReflect 

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

func (*ListHomeNetworkPoliciesResponse) Reset 

func (x *ListHomeNetworkPoliciesResponse) Reset()

func (*ListHomeNetworkPoliciesResponse) String 

func (x *ListHomeNetworkPoliciesResponse) String() string

type ListNetworksResponse added in v1.5.0 

type ListNetworksResponse struct {
	Networks []*v3.NetworkOrTenant `protobuf:"bytes,1,rep,name=networks,proto3" json:"networks,omitempty"`
	// Total number of networks.
	Total uint32 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNetworksResponse) Descriptor deprecated added in v1.5.0 

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

Deprecated: Use ListNetworksResponse.ProtoReflect.Descriptor instead.

func (*ListNetworksResponse) GetNetworks added in v1.5.0 

func (x *ListNetworksResponse) GetNetworks() []*v3.NetworkOrTenant

func (*ListNetworksResponse) GetTotal added in v1.5.0 

func (x *ListNetworksResponse) GetTotal() uint32

func (*ListNetworksResponse) ProtoMessage added in v1.5.0 

func (*ListNetworksResponse) ProtoMessage()

func (*ListNetworksResponse) ProtoReflect added in v1.5.0 

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

func (*ListNetworksResponse) Reset added in v1.5.0 

func (x *ListNetworksResponse) Reset()

func (*ListNetworksResponse) String added in v1.5.0 

func (x *ListNetworksResponse) String() string

type ListNetworksWithPolicyRequest added in v1.5.0 

type ListNetworksWithPolicyRequest struct {

	// LoRa Alliance NetID of the Member.
	NetId uint32 `protobuf:"varint,1,opt,name=net_id,json=netId,proto3" json:"net_id,omitempty"`
	// ID assigned by the Member.
	TenantId string `protobuf:"bytes,2,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// Number of items to skip.
	Offset uint32 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	// Limit the number of items.
	// If 0, use the server's default.
	// The actual limit may be capped by the server.
	Limit uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// Filter tenants by ID.
	TenantIdContains string `protobuf:"bytes,5,opt,name=tenant_id_contains,json=tenantIdContains,proto3" json:"tenant_id_contains,omitempty"`
	// Filter networks by name.
	NameContains string `protobuf:"bytes,6,opt,name=name_contains,json=nameContains,proto3" json:"name_contains,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNetworksWithPolicyRequest) Descriptor deprecated added in v1.5.0 

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

Deprecated: Use ListNetworksWithPolicyRequest.ProtoReflect.Descriptor instead.

func (*ListNetworksWithPolicyRequest) GetLimit added in v1.5.0 

func (x *ListNetworksWithPolicyRequest) GetLimit() uint32

func (*ListNetworksWithPolicyRequest) GetNameContains added in v1.5.1 

func (x *ListNetworksWithPolicyRequest) GetNameContains() string

func (*ListNetworksWithPolicyRequest) GetNetId added in v1.5.0 

func (x *ListNetworksWithPolicyRequest) GetNetId() uint32

func (*ListNetworksWithPolicyRequest) GetOffset added in v1.5.0 

func (x *ListNetworksWithPolicyRequest) GetOffset() uint32

func (*ListNetworksWithPolicyRequest) GetTenantId added in v1.5.0 

func (x *ListNetworksWithPolicyRequest) GetTenantId() string

func (*ListNetworksWithPolicyRequest) GetTenantIdContains added in v1.5.1 

func (x *ListNetworksWithPolicyRequest) GetTenantIdContains() string

func (*ListNetworksWithPolicyRequest) ProtoMessage added in v1.5.0 

func (*ListNetworksWithPolicyRequest) ProtoMessage()

func (*ListNetworksWithPolicyRequest) ProtoReflect added in v1.5.0 

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

func (*ListNetworksWithPolicyRequest) Reset added in v1.5.0 

func (x *ListNetworksWithPolicyRequest) Reset()

func (*ListNetworksWithPolicyRequest) String added in v1.5.0 

func (x *ListNetworksWithPolicyRequest) String() string

func (*ListNetworksWithPolicyRequest) Validate added in v1.5.0 

func (r *ListNetworksWithPolicyRequest) Validate() error

Validate returns whether the request is valid.

type PolicyManagerClient 

type PolicyManagerClient interface {
	// List the Default Routing Policies.
	ListDefaultPolicies(ctx context.Context, in *ListDefaultPoliciesRequest, opts ...grpc.CallOption) (*ListDefaultPoliciesResponse, error)
	// Get the Default Routing Policy.
	GetDefaultPolicy(ctx context.Context, in *GetDefaultPolicyRequest, opts ...grpc.CallOption) (*GetPolicyResponse, error)
	// Set the Default Routing Policy.
	SetDefaultPolicy(ctx context.Context, in *SetPolicyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// List the Routing Policies with Home Networks.
	ListHomeNetworkPolicies(ctx context.Context, in *ListHomeNetworkPoliciesRequest, opts ...grpc.CallOption) (*ListHomeNetworkPoliciesResponse, error)
	// Get the Routing Policy with the Home Network.
	GetHomeNetworkPolicy(ctx context.Context, in *GetHomeNetworkPolicyRequest, opts ...grpc.CallOption) (*GetPolicyResponse, error)
	// Set the Routing Policy with the Home Network.
	SetHomeNetworkPolicy(ctx context.Context, in *SetPolicyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// List the Routing Policies that Forwarders configured for the Home Network.
	ListEffectivePolicies(ctx context.Context, in *ListEffectivePoliciesRequest, opts ...grpc.CallOption) (*ListEffectivePoliciesResponse, error)
	// List the networks and tenants that have a policy defined, either as Home Network or as Forwarder.
	ListNetworksWithPolicy(ctx context.Context, in *ListNetworksWithPolicyRequest, opts ...grpc.CallOption) (*ListNetworksResponse, error)
}

PolicyManagerClient is the client API for PolicyManager 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 NewPolicyManagerClient 

func NewPolicyManagerClient(cc grpc.ClientConnInterface) PolicyManagerClient

type PolicyManagerServer 

type PolicyManagerServer interface {
	// List the Default Routing Policies.
	ListDefaultPolicies(context.Context, *ListDefaultPoliciesRequest) (*ListDefaultPoliciesResponse, error)
	// Get the Default Routing Policy.
	GetDefaultPolicy(context.Context, *GetDefaultPolicyRequest) (*GetPolicyResponse, error)
	// Set the Default Routing Policy.
	SetDefaultPolicy(context.Context, *SetPolicyRequest) (*emptypb.Empty, error)
	// List the Routing Policies with Home Networks.
	ListHomeNetworkPolicies(context.Context, *ListHomeNetworkPoliciesRequest) (*ListHomeNetworkPoliciesResponse, error)
	// Get the Routing Policy with the Home Network.
	GetHomeNetworkPolicy(context.Context, *GetHomeNetworkPolicyRequest) (*GetPolicyResponse, error)
	// Set the Routing Policy with the Home Network.
	SetHomeNetworkPolicy(context.Context, *SetPolicyRequest) (*emptypb.Empty, error)
	// List the Routing Policies that Forwarders configured for the Home Network.
	ListEffectivePolicies(context.Context, *ListEffectivePoliciesRequest) (*ListEffectivePoliciesResponse, error)
	// List the networks and tenants that have a policy defined, either as Home Network or as Forwarder.
	ListNetworksWithPolicy(context.Context, *ListNetworksWithPolicyRequest) (*ListNetworksResponse, error)
	// contains filtered or unexported methods
}

PolicyManagerServer is the server API for PolicyManager service. All implementations must embed UnimplementedPolicyManagerServer for forward compatibility

type PublishDownlinkMessageRequest 

type PublishDownlinkMessageRequest struct {

	// LoRa Alliance NetID of the Home Network Member.
	HomeNetworkNetId uint32 `protobuf:"varint,1,opt,name=home_network_net_id,json=homeNetworkNetId,proto3" json:"home_network_net_id,omitempty"`
	// Tenant ID managed by the Home Network Member.
	HomeNetworkClusterId string `protobuf:"bytes,2,opt,name=home_network_cluster_id,json=homeNetworkClusterId,proto3" json:"home_network_cluster_id,omitempty"`
	// LoRa Alliance NetID of the Forwarder Member.
	HomeNetworkTenantId string `protobuf:"bytes,3,opt,name=home_network_tenant_id,json=homeNetworkTenantId,proto3" json:"home_network_tenant_id,omitempty"`
	// Home Network cluster of the Home Network Member.
	ForwarderNetId uint32 `protobuf:"varint,4,opt,name=forwarder_net_id,json=forwarderNetId,proto3" json:"forwarder_net_id,omitempty"`
	// Forwarder cluster of the Forwarder Member.
	// In LoRaWAN Class A downlink, this value must be copied from the RoutedUplinkMessage.
	// In LoRaWAN Class C downlink, this value is typically copied from a recent RoutedUplinkMessage.
	ForwarderClusterId string `protobuf:"bytes,5,opt,name=forwarder_cluster_id,json=forwarderClusterId,proto3" json:"forwarder_cluster_id,omitempty"`
	// Tenant ID managed by the Forwarder Member.
	// In LoRaWAN Class A downlink, this value must be copied from the RoutedUplinkMessage.
	// In LoRaWAN Class C downlink, this value is typically copied from a recent RoutedUplinkMessage.
	ForwarderTenantId string `protobuf:"bytes,6,opt,name=forwarder_tenant_id,json=forwarderTenantId,proto3" json:"forwarder_tenant_id,omitempty"`
	// Downlink message to publish.
	Message *v3.DownlinkMessage `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishDownlinkMessageRequest) Descriptor deprecated 

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

Deprecated: Use PublishDownlinkMessageRequest.ProtoReflect.Descriptor instead.

func (*PublishDownlinkMessageRequest) GetForwarderClusterId 

func (x *PublishDownlinkMessageRequest) GetForwarderClusterId() string

func (*PublishDownlinkMessageRequest) GetForwarderNetId 

func (x *PublishDownlinkMessageRequest) GetForwarderNetId() uint32

func (*PublishDownlinkMessageRequest) GetForwarderTenantId 

func (x *PublishDownlinkMessageRequest) GetForwarderTenantId() string

func (*PublishDownlinkMessageRequest) GetHomeNetworkClusterId 

func (x *PublishDownlinkMessageRequest) GetHomeNetworkClusterId() string

func (*PublishDownlinkMessageRequest) GetHomeNetworkNetId 

func (x *PublishDownlinkMessageRequest) GetHomeNetworkNetId() uint32

func (*PublishDownlinkMessageRequest) GetHomeNetworkTenantId 

func (x *PublishDownlinkMessageRequest) GetHomeNetworkTenantId() string

func (*PublishDownlinkMessageRequest) GetMessage 

func (x *PublishDownlinkMessageRequest) GetMessage() *v3.DownlinkMessage

func (*PublishDownlinkMessageRequest) ProtoMessage 

func (*PublishDownlinkMessageRequest) ProtoMessage()

func (*PublishDownlinkMessageRequest) ProtoReflect 

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

func (*PublishDownlinkMessageRequest) Reset 

func (x *PublishDownlinkMessageRequest) Reset()

func (*PublishDownlinkMessageRequest) String 

func (x *PublishDownlinkMessageRequest) String() string

func (*PublishDownlinkMessageRequest) Validate 

func (r *PublishDownlinkMessageRequest) Validate() error

Validate returns whether the request is valid.

type PublishDownlinkMessageResponse 

type PublishDownlinkMessageResponse struct {

	// Message identifier generated by the Router.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishDownlinkMessageResponse) Descriptor deprecated 

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

Deprecated: Use PublishDownlinkMessageResponse.ProtoReflect.Descriptor instead.

func (*PublishDownlinkMessageResponse) GetId 

func (x *PublishDownlinkMessageResponse) GetId() string

func (*PublishDownlinkMessageResponse) ProtoMessage 

func (*PublishDownlinkMessageResponse) ProtoMessage()

func (*PublishDownlinkMessageResponse) ProtoReflect 

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

func (*PublishDownlinkMessageResponse) Reset 

func (x *PublishDownlinkMessageResponse) Reset()

func (*PublishDownlinkMessageResponse) String 

func (x *PublishDownlinkMessageResponse) String() string

type PublishUplinkMessageRequest 

type PublishUplinkMessageRequest struct {

	// LoRa Alliance NetID of the Forwarder Member.
	ForwarderNetId uint32 `protobuf:"varint,1,opt,name=forwarder_net_id,json=forwarderNetId,proto3" json:"forwarder_net_id,omitempty"`
	// Forwarder cluster of the Forwarder Member.
	ForwarderClusterId string `protobuf:"bytes,2,opt,name=forwarder_cluster_id,json=forwarderClusterId,proto3" json:"forwarder_cluster_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"`
	// Uplink message to publish.
	Message *v3.UplinkMessage `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishUplinkMessageRequest) Descriptor deprecated 

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

Deprecated: Use PublishUplinkMessageRequest.ProtoReflect.Descriptor instead.

func (*PublishUplinkMessageRequest) GetForwarderClusterId 

func (x *PublishUplinkMessageRequest) GetForwarderClusterId() string

func (*PublishUplinkMessageRequest) GetForwarderNetId 

func (x *PublishUplinkMessageRequest) GetForwarderNetId() uint32

func (*PublishUplinkMessageRequest) GetForwarderTenantId 

func (x *PublishUplinkMessageRequest) GetForwarderTenantId() string

func (*PublishUplinkMessageRequest) GetMessage 

func (x *PublishUplinkMessageRequest) GetMessage() *v3.UplinkMessage

func (*PublishUplinkMessageRequest) ProtoMessage 

func (*PublishUplinkMessageRequest) ProtoMessage()

func (*PublishUplinkMessageRequest) ProtoReflect 

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

func (*PublishUplinkMessageRequest) Reset 

func (x *PublishUplinkMessageRequest) Reset()

func (*PublishUplinkMessageRequest) String 

func (x *PublishUplinkMessageRequest) String() string

func (*PublishUplinkMessageRequest) Validate 

func (r *PublishUplinkMessageRequest) Validate() error

Validate returns whether the request is valid.

type PublishUplinkMessageResponse 

type PublishUplinkMessageResponse struct {

	// Message identifier generated by the Router.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishUplinkMessageResponse) Descriptor deprecated 

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

Deprecated: Use PublishUplinkMessageResponse.ProtoReflect.Descriptor instead.

func (*PublishUplinkMessageResponse) GetId 

func (x *PublishUplinkMessageResponse) GetId() string

func (*PublishUplinkMessageResponse) ProtoMessage 

func (*PublishUplinkMessageResponse) ProtoMessage()

func (*PublishUplinkMessageResponse) ProtoReflect 

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

func (*PublishUplinkMessageResponse) Reset 

func (x *PublishUplinkMessageResponse) Reset()

func (*PublishUplinkMessageResponse) String 

func (x *PublishUplinkMessageResponse) String() string

type RouteDownlinkMessageRequest 

type RouteDownlinkMessageRequest struct {

	// Downlink message to route.
	Message *v3.RoutedDownlinkMessage `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*RouteDownlinkMessageRequest) Descriptor deprecated 

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

Deprecated: Use RouteDownlinkMessageRequest.ProtoReflect.Descriptor instead.

func (*RouteDownlinkMessageRequest) GetMessage 

func (x *RouteDownlinkMessageRequest) GetMessage() *v3.RoutedDownlinkMessage

func (*RouteDownlinkMessageRequest) ProtoMessage 

func (*RouteDownlinkMessageRequest) ProtoMessage()

func (*RouteDownlinkMessageRequest) ProtoReflect 

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

func (*RouteDownlinkMessageRequest) Reset 

func (x *RouteDownlinkMessageRequest) Reset()

func (*RouteDownlinkMessageRequest) String 

func (x *RouteDownlinkMessageRequest) String() string

func (*RouteDownlinkMessageRequest) Validate 

func (r *RouteDownlinkMessageRequest) Validate() error

Validate returns whether the request is valid.

type RouteMessageResponse 

type RouteMessageResponse struct {

	// Delivery state of the message.
	State v3.MessageDeliveryState `protobuf:"varint,1,opt,name=state,proto3,enum=org.packetbroker.v3.MessageDeliveryState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*RouteMessageResponse) Descriptor deprecated 

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

Deprecated: Use RouteMessageResponse.ProtoReflect.Descriptor instead.

func (*RouteMessageResponse) GetState 

func (x *RouteMessageResponse) GetState() v3.MessageDeliveryState

func (*RouteMessageResponse) ProtoMessage 

func (*RouteMessageResponse) ProtoMessage()

func (*RouteMessageResponse) ProtoReflect 

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

func (*RouteMessageResponse) Reset 

func (x *RouteMessageResponse) Reset()

func (*RouteMessageResponse) String 

func (x *RouteMessageResponse) String() string

type RouteUplinkMessageRequest 

type RouteUplinkMessageRequest struct {

	// Uplink message to route.
	Message *v3.RoutedUplinkMessage `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*RouteUplinkMessageRequest) Descriptor deprecated 

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

Deprecated: Use RouteUplinkMessageRequest.ProtoReflect.Descriptor instead.

func (*RouteUplinkMessageRequest) GetMessage 

func (x *RouteUplinkMessageRequest) GetMessage() *v3.RoutedUplinkMessage

func (*RouteUplinkMessageRequest) ProtoMessage 

func (*RouteUplinkMessageRequest) ProtoMessage()

func (*RouteUplinkMessageRequest) ProtoReflect 

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

func (*RouteUplinkMessageRequest) Reset 

func (x *RouteUplinkMessageRequest) Reset()

func (*RouteUplinkMessageRequest) String 

func (x *RouteUplinkMessageRequest) String() string

func (*RouteUplinkMessageRequest) Validate 

func (r *RouteUplinkMessageRequest) Validate() error

Validate returns whether the request is valid.

type SetPolicyRequest 

type SetPolicyRequest struct {
	Policy *v3.RoutingPolicy `protobuf:"bytes,3,opt,name=policy,proto3" json:"policy,omitempty"`
	// contains filtered or unexported fields
}

func (*SetPolicyRequest) Descriptor deprecated 

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

Deprecated: Use SetPolicyRequest.ProtoReflect.Descriptor instead.

func (*SetPolicyRequest) GetPolicy 

func (x *SetPolicyRequest) GetPolicy() *v3.RoutingPolicy

func (*SetPolicyRequest) ProtoMessage 

func (*SetPolicyRequest) ProtoMessage()

func (*SetPolicyRequest) ProtoReflect 

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

func (*SetPolicyRequest) Reset 

func (x *SetPolicyRequest) Reset()

func (*SetPolicyRequest) String 

func (x *SetPolicyRequest) String() string

func (*SetPolicyRequest) Validate 

func (r *SetPolicyRequest) Validate() error

Validate returns whether the request is valid.

type SubscribeForwarderRequest 

type SubscribeForwarderRequest struct {

	// LoRa Alliance NetID of the Forwarder Member.
	ForwarderNetId uint32 `protobuf:"varint,1,opt,name=forwarder_net_id,json=forwarderNetId,proto3" json:"forwarder_net_id,omitempty"`
	// Forwarder cluster of the Forwarder Member.
	ForwarderClusterId string `protobuf:"bytes,2,opt,name=forwarder_cluster_id,json=forwarderClusterId,proto3" json:"forwarder_cluster_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"`
	// Shared subscription group (optional).
	// Queue durability depends on the Router configuration.
	Group string `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeForwarderRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeForwarderRequest.ProtoReflect.Descriptor instead.

func (*SubscribeForwarderRequest) GetForwarderClusterId 

func (x *SubscribeForwarderRequest) GetForwarderClusterId() string

func (*SubscribeForwarderRequest) GetForwarderNetId 

func (x *SubscribeForwarderRequest) GetForwarderNetId() uint32

func (*SubscribeForwarderRequest) GetForwarderTenantId 

func (x *SubscribeForwarderRequest) GetForwarderTenantId() string

func (*SubscribeForwarderRequest) GetGroup 

func (x *SubscribeForwarderRequest) GetGroup() string

func (*SubscribeForwarderRequest) ProtoMessage 

func (*SubscribeForwarderRequest) ProtoMessage()

func (*SubscribeForwarderRequest) ProtoReflect 

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

func (*SubscribeForwarderRequest) Reset 

func (x *SubscribeForwarderRequest) Reset()

func (*SubscribeForwarderRequest) String 

func (x *SubscribeForwarderRequest) String() string

func (*SubscribeForwarderRequest) Validate 

func (r *SubscribeForwarderRequest) Validate() error

Validate returns whether the request is valid.

type SubscribeHomeNetworkRequest 

type SubscribeHomeNetworkRequest struct {

	// LoRa Alliance NetID of the Home Network Member.
	HomeNetworkNetId uint32 `protobuf:"varint,1,opt,name=home_network_net_id,json=homeNetworkNetId,proto3" json:"home_network_net_id,omitempty"`
	// Home Network cluster of the Home Network Member.
	HomeNetworkClusterId string `protobuf:"bytes,2,opt,name=home_network_cluster_id,json=homeNetworkClusterId,proto3" json:"home_network_cluster_id,omitempty"`
	// Tenant ID managed by the Home Network Member.
	HomeNetworkTenantId string `protobuf:"bytes,3,opt,name=home_network_tenant_id,json=homeNetworkTenantId,proto3" json:"home_network_tenant_id,omitempty"`
	// Routing filters to configure the subscription.
	// A message gets delivered if any of the given filters pass.
	// If no filters are specified, all messages will be delivered.
	Filters []*v3.RoutingFilter `protobuf:"bytes,4,rep,name=filters,proto3" json:"filters,omitempty"`
	// Shared subscription group (optional).
	// Queue durability depends on the Router configuration.
	Group string `protobuf:"bytes,5,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeHomeNetworkRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeHomeNetworkRequest.ProtoReflect.Descriptor instead.

func (*SubscribeHomeNetworkRequest) GetFilters 

func (x *SubscribeHomeNetworkRequest) GetFilters() []*v3.RoutingFilter

func (*SubscribeHomeNetworkRequest) GetGroup 

func (x *SubscribeHomeNetworkRequest) GetGroup() string

func (*SubscribeHomeNetworkRequest) GetHomeNetworkClusterId 

func (x *SubscribeHomeNetworkRequest) GetHomeNetworkClusterId() string

func (*SubscribeHomeNetworkRequest) GetHomeNetworkNetId 

func (x *SubscribeHomeNetworkRequest) GetHomeNetworkNetId() uint32

func (*SubscribeHomeNetworkRequest) GetHomeNetworkTenantId 

func (x *SubscribeHomeNetworkRequest) GetHomeNetworkTenantId() string

func (*SubscribeHomeNetworkRequest) ProtoMessage 

func (*SubscribeHomeNetworkRequest) ProtoMessage()

func (*SubscribeHomeNetworkRequest) ProtoReflect 

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

func (*SubscribeHomeNetworkRequest) Reset 

func (x *SubscribeHomeNetworkRequest) Reset()

func (*SubscribeHomeNetworkRequest) String 

func (x *SubscribeHomeNetworkRequest) String() string

func (*SubscribeHomeNetworkRequest) Validate 

func (r *SubscribeHomeNetworkRequest) Validate() error

Validate returns whether the request is valid.

type UnimplementedForwarderDataServer 

type UnimplementedForwarderDataServer struct {
}

UnimplementedForwarderDataServer must be embedded to have forward compatible implementations.

func (UnimplementedForwarderDataServer) Publish 

func (UnimplementedForwarderDataServer) Publish(context.Context, *PublishUplinkMessageRequest) (*PublishUplinkMessageResponse, error)

func (UnimplementedForwarderDataServer) ReportDownlinkMessageDeliveryState added in v1.4.0 

func (UnimplementedForwarderDataServer) ReportDownlinkMessageDeliveryState(context.Context, *DownlinkMessageDeliveryStateChangeRequest) (*emptypb.Empty, error)

func (UnimplementedForwarderDataServer) Subscribe 

func (UnimplementedForwarderDataServer) Subscribe(*SubscribeForwarderRequest, ForwarderData_SubscribeServer) error

type UnimplementedHomeNetworkDataServer 

type UnimplementedHomeNetworkDataServer struct {
}

UnimplementedHomeNetworkDataServer must be embedded to have forward compatible implementations.

func (UnimplementedHomeNetworkDataServer) Publish 

func (UnimplementedHomeNetworkDataServer) Publish(context.Context, *PublishDownlinkMessageRequest) (*PublishDownlinkMessageResponse, error)

func (UnimplementedHomeNetworkDataServer) ReportUplinkMessageDeliveryState added in v1.4.0 

func (UnimplementedHomeNetworkDataServer) ReportUplinkMessageDeliveryState(context.Context, *UplinkMessageDeliveryStateChangeRequest) (*emptypb.Empty, error)

func (UnimplementedHomeNetworkDataServer) Subscribe 

func (UnimplementedHomeNetworkDataServer) Subscribe(*SubscribeHomeNetworkRequest, HomeNetworkData_SubscribeServer) error

type UnimplementedPolicyManagerServer 

type UnimplementedPolicyManagerServer struct {
}

UnimplementedPolicyManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedPolicyManagerServer) GetDefaultPolicy 

func (UnimplementedPolicyManagerServer) GetDefaultPolicy(context.Context, *GetDefaultPolicyRequest) (*GetPolicyResponse, error)

func (UnimplementedPolicyManagerServer) GetHomeNetworkPolicy 

func (UnimplementedPolicyManagerServer) GetHomeNetworkPolicy(context.Context, *GetHomeNetworkPolicyRequest) (*GetPolicyResponse, error)

func (UnimplementedPolicyManagerServer) ListDefaultPolicies 

func (UnimplementedPolicyManagerServer) ListDefaultPolicies(context.Context, *ListDefaultPoliciesRequest) (*ListDefaultPoliciesResponse, error)

func (UnimplementedPolicyManagerServer) ListEffectivePolicies added in v1.1.3 

func (UnimplementedPolicyManagerServer) ListEffectivePolicies(context.Context, *ListEffectivePoliciesRequest) (*ListEffectivePoliciesResponse, error)

func (UnimplementedPolicyManagerServer) ListHomeNetworkPolicies 

func (UnimplementedPolicyManagerServer) ListHomeNetworkPolicies(context.Context, *ListHomeNetworkPoliciesRequest) (*ListHomeNetworkPoliciesResponse, error)

func (UnimplementedPolicyManagerServer) ListNetworksWithPolicy added in v1.5.0 

func (UnimplementedPolicyManagerServer) ListNetworksWithPolicy(context.Context, *ListNetworksWithPolicyRequest) (*ListNetworksResponse, error)

func (UnimplementedPolicyManagerServer) SetDefaultPolicy 

func (UnimplementedPolicyManagerServer) SetDefaultPolicy(context.Context, *SetPolicyRequest) (*emptypb.Empty, error)

func (UnimplementedPolicyManagerServer) SetHomeNetworkPolicy 

func (UnimplementedPolicyManagerServer) SetHomeNetworkPolicy(context.Context, *SetPolicyRequest) (*emptypb.Empty, error)

type UnsafeForwarderDataServer 

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

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

type UnsafeHomeNetworkDataServer 

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

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

type UnsafePolicyManagerServer 

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

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

type UplinkMessageDeliveryStateChangeRequest added in v1.4.0 

type UplinkMessageDeliveryStateChangeRequest struct {
	StateChange *v3.UplinkMessageDeliveryStateChange `protobuf:"bytes,1,opt,name=state_change,json=stateChange,proto3" json:"state_change,omitempty"`
	// contains filtered or unexported fields
}

func (*UplinkMessageDeliveryStateChangeRequest) Descriptor deprecated added in v1.4.0 

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

Deprecated: Use UplinkMessageDeliveryStateChangeRequest.ProtoReflect.Descriptor instead.

func (*UplinkMessageDeliveryStateChangeRequest) GetStateChange added in v1.4.0 

func (x *UplinkMessageDeliveryStateChangeRequest) GetStateChange() *v3.UplinkMessageDeliveryStateChange

func (*UplinkMessageDeliveryStateChangeRequest) ProtoMessage added in v1.4.0 

func (*UplinkMessageDeliveryStateChangeRequest) ProtoMessage()

func (*UplinkMessageDeliveryStateChangeRequest) ProtoReflect added in v1.4.0 

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

func (*UplinkMessageDeliveryStateChangeRequest) Reset added in v1.4.0 

func (x *UplinkMessageDeliveryStateChangeRequest) Reset()

func (*UplinkMessageDeliveryStateChangeRequest) String added in v1.4.0 

func (x *UplinkMessageDeliveryStateChangeRequest) String() string

func (*UplinkMessageDeliveryStateChangeRequest) Validate added in v1.4.0 

func (r *UplinkMessageDeliveryStateChangeRequest) Validate() error

Validate returns whether the request is valid.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.