broker

package
v0.0.0-...-228f33a Latest Latest
Warning

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

 Go to latest Published: Aug 18, 2021 License: MIT Imports: 27 Imported by: 36

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBroker        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBroker          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBroker = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterBrokerManagerServer 

func RegisterBrokerManagerServer(s *grpc.Server, srv BrokerManagerServer)

func RegisterBrokerServer 

func RegisterBrokerServer(s *grpc.Server, srv BrokerServer)

Types

type ActivationChallengeRequest 

type ActivationChallengeRequest struct {
	Payload              []byte                                            `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Message              *protocol.Message                                 `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	DevEUI               github_com_TheThingsNetwork_ttn_core_types.DevEUI `` /* 131-byte string literal not displayed */
	AppEUI               github_com_TheThingsNetwork_ttn_core_types.AppEUI `` /* 131-byte string literal not displayed */
	AppID                string                                            `protobuf:"bytes,13,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	DevID                string                                            `protobuf:"bytes,14,opt,name=dev_id,json=devId,proto3" json:"dev_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                          `json:"-"`
	XXX_sizecache        int32                                             `json:"-"`
}

func NewPopulatedActivationChallengeRequest 

func NewPopulatedActivationChallengeRequest(r randyBroker, easy bool) *ActivationChallengeRequest

func (*ActivationChallengeRequest) Descriptor 

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

func (*ActivationChallengeRequest) Equal 

func (this *ActivationChallengeRequest) Equal(that interface{}) bool

func (*ActivationChallengeRequest) GetAppEUI 

func (m *ActivationChallengeRequest) GetAppEUI() (eui types.AppEUI)

func (*ActivationChallengeRequest) GetAppID 

func (m *ActivationChallengeRequest) GetAppID() string

func (*ActivationChallengeRequest) GetDevEUI 

func (m *ActivationChallengeRequest) GetDevEUI() (eui types.DevEUI)

func (*ActivationChallengeRequest) GetDevID 

func (m *ActivationChallengeRequest) GetDevID() string

func (*ActivationChallengeRequest) GetMessage 

func (m *ActivationChallengeRequest) GetMessage() *protocol.Message

func (*ActivationChallengeRequest) GetPayload 

func (m *ActivationChallengeRequest) GetPayload() []byte

func (*ActivationChallengeRequest) Marshal 

func (m *ActivationChallengeRequest) Marshal() (dAtA []byte, err error)

func (*ActivationChallengeRequest) MarshalPayload 

func (m *ActivationChallengeRequest) MarshalPayload() error

MarshalPayload marshals the Message into Payload if Payload is nil

func (*ActivationChallengeRequest) MarshalTo 

func (m *ActivationChallengeRequest) MarshalTo(dAtA []byte) (int, error)

func (*ActivationChallengeRequest) MarshalToSizedBuffer 

func (m *ActivationChallengeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActivationChallengeRequest) ProtoMessage 

func (*ActivationChallengeRequest) ProtoMessage()

func (*ActivationChallengeRequest) Reset 

func (m *ActivationChallengeRequest) Reset()

func (*ActivationChallengeRequest) Size 

func (m *ActivationChallengeRequest) Size() (n int)

func (*ActivationChallengeRequest) String 

func (this *ActivationChallengeRequest) String() string

func (*ActivationChallengeRequest) Unmarshal 

func (m *ActivationChallengeRequest) Unmarshal(dAtA []byte) error

func (*ActivationChallengeRequest) UnmarshalPayload 

func (m *ActivationChallengeRequest) UnmarshalPayload() error

UnmarshalPayload unmarshals the Payload into Message if Message is nil

func (*ActivationChallengeRequest) Validate 

func (m *ActivationChallengeRequest) Validate() error

Validate implements the api.Validator interface

func (*ActivationChallengeRequest) XXX_DiscardUnknown 

func (m *ActivationChallengeRequest) XXX_DiscardUnknown()

func (*ActivationChallengeRequest) XXX_Marshal 

func (m *ActivationChallengeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivationChallengeRequest) XXX_Merge 

func (m *ActivationChallengeRequest) XXX_Merge(src proto.Message)

func (*ActivationChallengeRequest) XXX_Size 

func (m *ActivationChallengeRequest) XXX_Size() int

func (*ActivationChallengeRequest) XXX_Unmarshal 

func (m *ActivationChallengeRequest) XXX_Unmarshal(b []byte) error

type ActivationChallengeResponse 

type ActivationChallengeResponse struct {
	Payload              []byte            `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Message              *protocol.Message `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func NewPopulatedActivationChallengeResponse 

func NewPopulatedActivationChallengeResponse(r randyBroker, easy bool) *ActivationChallengeResponse

func (*ActivationChallengeResponse) Descriptor 

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

func (*ActivationChallengeResponse) Equal 

func (this *ActivationChallengeResponse) Equal(that interface{}) bool

func (*ActivationChallengeResponse) GetMessage 

func (m *ActivationChallengeResponse) GetMessage() *protocol.Message

func (*ActivationChallengeResponse) GetPayload 

func (m *ActivationChallengeResponse) GetPayload() []byte

func (*ActivationChallengeResponse) Marshal 

func (m *ActivationChallengeResponse) Marshal() (dAtA []byte, err error)

func (*ActivationChallengeResponse) MarshalPayload 

func (m *ActivationChallengeResponse) MarshalPayload() error

MarshalPayload marshals the Message into Payload if Payload is nil

func (*ActivationChallengeResponse) MarshalTo 

func (m *ActivationChallengeResponse) MarshalTo(dAtA []byte) (int, error)

func (*ActivationChallengeResponse) MarshalToSizedBuffer 

func (m *ActivationChallengeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActivationChallengeResponse) ProtoMessage 

func (*ActivationChallengeResponse) ProtoMessage()

func (*ActivationChallengeResponse) Reset 

func (m *ActivationChallengeResponse) Reset()

func (*ActivationChallengeResponse) Size 

func (m *ActivationChallengeResponse) Size() (n int)

func (*ActivationChallengeResponse) String 

func (this *ActivationChallengeResponse) String() string

func (*ActivationChallengeResponse) Unmarshal 

func (m *ActivationChallengeResponse) Unmarshal(dAtA []byte) error

func (*ActivationChallengeResponse) UnmarshalPayload 

func (m *ActivationChallengeResponse) UnmarshalPayload() error

UnmarshalPayload unmarshals the Payload into Message if Message is nil

func (*ActivationChallengeResponse) XXX_DiscardUnknown 

func (m *ActivationChallengeResponse) XXX_DiscardUnknown()

func (*ActivationChallengeResponse) XXX_Marshal 

func (m *ActivationChallengeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivationChallengeResponse) XXX_Merge 

func (m *ActivationChallengeResponse) XXX_Merge(src proto.Message)

func (*ActivationChallengeResponse) XXX_Size 

func (m *ActivationChallengeResponse) XXX_Size() int

func (*ActivationChallengeResponse) XXX_Unmarshal 

func (m *ActivationChallengeResponse) XXX_Unmarshal(b []byte) error

type ApplicationHandlerRegistration 

type ApplicationHandlerRegistration struct {
	AppID                string   `protobuf:"bytes,1,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	HandlerID            string   `protobuf:"bytes,2,opt,name=handler_id,json=handlerId,proto3" json:"handler_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedApplicationHandlerRegistration 

func NewPopulatedApplicationHandlerRegistration(r randyBroker, easy bool) *ApplicationHandlerRegistration

func (*ApplicationHandlerRegistration) Descriptor 

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

func (*ApplicationHandlerRegistration) Equal 

func (this *ApplicationHandlerRegistration) Equal(that interface{}) bool

func (*ApplicationHandlerRegistration) GetAppID 

func (m *ApplicationHandlerRegistration) GetAppID() string

func (*ApplicationHandlerRegistration) GetHandlerID 

func (m *ApplicationHandlerRegistration) GetHandlerID() string

func (*ApplicationHandlerRegistration) Marshal 

func (m *ApplicationHandlerRegistration) Marshal() (dAtA []byte, err error)

func (*ApplicationHandlerRegistration) MarshalTo 

func (m *ApplicationHandlerRegistration) MarshalTo(dAtA []byte) (int, error)

func (*ApplicationHandlerRegistration) MarshalToSizedBuffer 

func (m *ApplicationHandlerRegistration) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ApplicationHandlerRegistration) ProtoMessage 

func (*ApplicationHandlerRegistration) ProtoMessage()

func (*ApplicationHandlerRegistration) Reset 

func (m *ApplicationHandlerRegistration) Reset()

func (*ApplicationHandlerRegistration) Size 

func (m *ApplicationHandlerRegistration) Size() (n int)

func (*ApplicationHandlerRegistration) String 

func (this *ApplicationHandlerRegistration) String() string

func (*ApplicationHandlerRegistration) Unmarshal 

func (m *ApplicationHandlerRegistration) Unmarshal(dAtA []byte) error

func (*ApplicationHandlerRegistration) Validate 

func (m *ApplicationHandlerRegistration) Validate() error

Validate implements the api.Validator interface

func (*ApplicationHandlerRegistration) XXX_DiscardUnknown 

func (m *ApplicationHandlerRegistration) XXX_DiscardUnknown()

func (*ApplicationHandlerRegistration) XXX_Marshal 

func (m *ApplicationHandlerRegistration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplicationHandlerRegistration) XXX_Merge 

func (m *ApplicationHandlerRegistration) XXX_Merge(src proto.Message)

func (*ApplicationHandlerRegistration) XXX_Size 

func (m *ApplicationHandlerRegistration) XXX_Size() int

func (*ApplicationHandlerRegistration) XXX_Unmarshal 

func (m *ApplicationHandlerRegistration) XXX_Unmarshal(b []byte) error

type BrokerClient 

type BrokerClient interface {
	// Router initiates an Association with the Broker.
	Associate(ctx context.Context, opts ...grpc.CallOption) (Broker_AssociateClient, error)
	// Handler subscribes to uplink stream.
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Broker_SubscribeClient, error)
	// Handler initiates downlink stream.
	Publish(ctx context.Context, opts ...grpc.CallOption) (Broker_PublishClient, error)
	// Router requests device activation
	Activate(ctx context.Context, in *DeviceActivationRequest, opts ...grpc.CallOption) (*DeviceActivationResponse, error)
}

BrokerClient is the client API for Broker service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBrokerClient 

func NewBrokerClient(cc *grpc.ClientConn) BrokerClient

type BrokerManagerClient 

type BrokerManagerClient interface {
	// Handler announces a new application to Broker. This is a temporary method that will be removed
	// when we can push updates from the Discovery service to the routing services.
	RegisterApplicationHandler(ctx context.Context, in *ApplicationHandlerRegistration, opts ...grpc.CallOption) (*types.Empty, error)
	// Network operator requests Broker status
	GetStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*Status, error)
}

BrokerManagerClient is the client API for BrokerManager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBrokerManagerClient 

func NewBrokerManagerClient(cc *grpc.ClientConn) BrokerManagerClient

type BrokerManagerServer 

type BrokerManagerServer interface {
	// Handler announces a new application to Broker. This is a temporary method that will be removed
	// when we can push updates from the Discovery service to the routing services.
	RegisterApplicationHandler(context.Context, *ApplicationHandlerRegistration) (*types.Empty, error)
	// Network operator requests Broker status
	GetStatus(context.Context, *StatusRequest) (*Status, error)
}

BrokerManagerServer is the server API for BrokerManager service.

type BrokerServer 

type BrokerServer interface {
	// Router initiates an Association with the Broker.
	Associate(Broker_AssociateServer) error
	// Handler subscribes to uplink stream.
	Subscribe(*SubscribeRequest, Broker_SubscribeServer) error
	// Handler initiates downlink stream.
	Publish(Broker_PublishServer) error
	// Router requests device activation
	Activate(context.Context, *DeviceActivationRequest) (*DeviceActivationResponse, error)
}

BrokerServer is the server API for Broker service.

type Broker_AssociateClient 

type Broker_AssociateClient interface {
	Send(*UplinkMessage) error
	Recv() (*DownlinkMessage, error)
	grpc.ClientStream
}

type Broker_AssociateServer 

type Broker_AssociateServer interface {
	Send(*DownlinkMessage) error
	Recv() (*UplinkMessage, error)
	grpc.ServerStream
}

type Broker_PublishClient 

type Broker_PublishClient interface {
	Send(*DownlinkMessage) error
	CloseAndRecv() (*types.Empty, error)
	grpc.ClientStream
}

type Broker_PublishServer 

type Broker_PublishServer interface {
	SendAndClose(*types.Empty) error
	Recv() (*DownlinkMessage, error)
	grpc.ServerStream
}

type Broker_SubscribeClient 

type Broker_SubscribeClient interface {
	Recv() (*DeduplicatedUplinkMessage, error)
	grpc.ClientStream
}

type Broker_SubscribeServer 

type Broker_SubscribeServer interface {
	Send(*DeduplicatedUplinkMessage) error
	grpc.ServerStream
}

type DeduplicatedDeviceActivationRequest 

type DeduplicatedDeviceActivationRequest struct {
	Payload              []byte                                            `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Message              *protocol.Message                                 `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	DevEUI               github_com_TheThingsNetwork_ttn_core_types.DevEUI `` /* 131-byte string literal not displayed */
	AppEUI               github_com_TheThingsNetwork_ttn_core_types.AppEUI `` /* 131-byte string literal not displayed */
	AppID                string                                            `protobuf:"bytes,13,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	DevID                string                                            `protobuf:"bytes,14,opt,name=dev_id,json=devId,proto3" json:"dev_id,omitempty"`
	ProtocolMetadata     protocol.RxMetadata                               `protobuf:"bytes,21,opt,name=protocol_metadata,json=protocolMetadata,proto3" json:"protocol_metadata"`
	GatewayMetadata      []*gateway.RxMetadata                             `protobuf:"bytes,22,rep,name=gateway_metadata,json=gatewayMetadata,proto3" json:"gateway_metadata,omitempty"`
	ActivationMetadata   *protocol.ActivationMetadata                      `protobuf:"bytes,23,opt,name=activation_metadata,json=activationMetadata,proto3" json:"activation_metadata,omitempty"`
	ServerTime           int64                                             `protobuf:"varint,24,opt,name=server_time,json=serverTime,proto3" json:"server_time,omitempty"`
	ResponseTemplate     *DeviceActivationResponse                         `protobuf:"bytes,31,opt,name=response_template,json=responseTemplate,proto3" json:"response_template,omitempty"`
	Trace                *trace.Trace                                      `protobuf:"bytes,41,opt,name=trace,proto3" json:"trace,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                          `json:"-"`
	XXX_sizecache        int32                                             `json:"-"`
}

sent to the Handler

func NewPopulatedDeduplicatedDeviceActivationRequest 

func NewPopulatedDeduplicatedDeviceActivationRequest(r randyBroker, easy bool) *DeduplicatedDeviceActivationRequest

func (*DeduplicatedDeviceActivationRequest) Descriptor 

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

func (*DeduplicatedDeviceActivationRequest) Equal 

func (this *DeduplicatedDeviceActivationRequest) Equal(that interface{}) bool

func (*DeduplicatedDeviceActivationRequest) GetActivationMetadata 

func (m *DeduplicatedDeviceActivationRequest) GetActivationMetadata() *protocol.ActivationMetadata

func (*DeduplicatedDeviceActivationRequest) GetAppEUI 

func (m *DeduplicatedDeviceActivationRequest) GetAppEUI() (eui types.AppEUI)

func (*DeduplicatedDeviceActivationRequest) GetAppID 

func (m *DeduplicatedDeviceActivationRequest) GetAppID() string

func (*DeduplicatedDeviceActivationRequest) GetDevEUI 

func (m *DeduplicatedDeviceActivationRequest) GetDevEUI() (eui types.DevEUI)

func (*DeduplicatedDeviceActivationRequest) GetDevID 

func (m *DeduplicatedDeviceActivationRequest) GetDevID() string

func (*DeduplicatedDeviceActivationRequest) GetGatewayMetadata 

func (m *DeduplicatedDeviceActivationRequest) GetGatewayMetadata() []*gateway.RxMetadata

func (*DeduplicatedDeviceActivationRequest) GetMessage 

func (m *DeduplicatedDeviceActivationRequest) GetMessage() *protocol.Message

func (*DeduplicatedDeviceActivationRequest) GetPayload 

func (m *DeduplicatedDeviceActivationRequest) GetPayload() []byte

func (*DeduplicatedDeviceActivationRequest) GetProtocolMetadata 

func (m *DeduplicatedDeviceActivationRequest) GetProtocolMetadata() protocol.RxMetadata

func (*DeduplicatedDeviceActivationRequest) GetResponseTemplate 

func (m *DeduplicatedDeviceActivationRequest) GetResponseTemplate() *DeviceActivationResponse

func (*DeduplicatedDeviceActivationRequest) GetServerTime 

func (m *DeduplicatedDeviceActivationRequest) GetServerTime() int64

func (*DeduplicatedDeviceActivationRequest) GetTrace 

func (m *DeduplicatedDeviceActivationRequest) GetTrace() *trace.Trace

func (*DeduplicatedDeviceActivationRequest) Marshal 

func (m *DeduplicatedDeviceActivationRequest) Marshal() (dAtA []byte, err error)

func (*DeduplicatedDeviceActivationRequest) MarshalPayload 

func (m *DeduplicatedDeviceActivationRequest) MarshalPayload() error

MarshalPayload marshals the Message into Payload if Payload is nil

func (*DeduplicatedDeviceActivationRequest) MarshalTo 

func (m *DeduplicatedDeviceActivationRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeduplicatedDeviceActivationRequest) MarshalToSizedBuffer 

func (m *DeduplicatedDeviceActivationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeduplicatedDeviceActivationRequest) ProtoMessage 

func (*DeduplicatedDeviceActivationRequest) ProtoMessage()

func (*DeduplicatedDeviceActivationRequest) Reset 

func (m *DeduplicatedDeviceActivationRequest) Reset()

func (*DeduplicatedDeviceActivationRequest) Size 

func (m *DeduplicatedDeviceActivationRequest) Size() (n int)

func (*DeduplicatedDeviceActivationRequest) String 

func (this *DeduplicatedDeviceActivationRequest) String() string

func (*DeduplicatedDeviceActivationRequest) Unmarshal 

func (m *DeduplicatedDeviceActivationRequest) Unmarshal(dAtA []byte) error

func (*DeduplicatedDeviceActivationRequest) UnmarshalPayload 

func (m *DeduplicatedDeviceActivationRequest) UnmarshalPayload() error

UnmarshalPayload unmarshals the Payload into Message if Message is nil

func (*DeduplicatedDeviceActivationRequest) Validate 

func (m *DeduplicatedDeviceActivationRequest) Validate() error

Validate implements the api.Validator interface

func (*DeduplicatedDeviceActivationRequest) XXX_DiscardUnknown 

func (m *DeduplicatedDeviceActivationRequest) XXX_DiscardUnknown()

func (*DeduplicatedDeviceActivationRequest) XXX_Marshal 

func (m *DeduplicatedDeviceActivationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeduplicatedDeviceActivationRequest) XXX_Merge 

func (m *DeduplicatedDeviceActivationRequest) XXX_Merge(src proto.Message)

func (*DeduplicatedDeviceActivationRequest) XXX_Size 

func (m *DeduplicatedDeviceActivationRequest) XXX_Size() int

func (*DeduplicatedDeviceActivationRequest) XXX_Unmarshal 

func (m *DeduplicatedDeviceActivationRequest) XXX_Unmarshal(b []byte) error

type DeduplicatedUplinkMessage 

type DeduplicatedUplinkMessage struct {
	Payload              []byte                                             `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Message              *protocol.Message                                  `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	DevEUI               *github_com_TheThingsNetwork_ttn_core_types.DevEUI `` /* 141-byte string literal not displayed */
	AppEUI               *github_com_TheThingsNetwork_ttn_core_types.AppEUI `` /* 141-byte string literal not displayed */
	AppID                string                                             `protobuf:"bytes,13,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	DevID                string                                             `protobuf:"bytes,14,opt,name=dev_id,json=devId,proto3" json:"dev_id,omitempty"`
	ProtocolMetadata     protocol.RxMetadata                                `protobuf:"bytes,21,opt,name=protocol_metadata,json=protocolMetadata,proto3" json:"protocol_metadata"`
	GatewayMetadata      []*gateway.RxMetadata                              `protobuf:"bytes,22,rep,name=gateway_metadata,json=gatewayMetadata,proto3" json:"gateway_metadata,omitempty"`
	ServerTime           int64                                              `protobuf:"varint,23,opt,name=server_time,json=serverTime,proto3" json:"server_time,omitempty"`
	ResponseTemplate     *DownlinkMessage                                   `protobuf:"bytes,31,opt,name=response_template,json=responseTemplate,proto3" json:"response_template,omitempty"`
	Trace                *trace.Trace                                       `protobuf:"bytes,41,opt,name=trace,proto3" json:"trace,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                           `json:"-"`
	XXX_sizecache        int32                                              `json:"-"`
}

sent to the Handler

func NewPopulatedDeduplicatedUplinkMessage 

func NewPopulatedDeduplicatedUplinkMessage(r randyBroker, easy bool) *DeduplicatedUplinkMessage

func RandomDeduplicatedUplinkMessage 

func RandomDeduplicatedUplinkMessage() *DeduplicatedUplinkMessage

RandomDeduplicatedUplinkMessage returns randomly generated uplink message. Used for testing. 

func RandomLoRaWANConfirmedDeduplicatedUplink(modulation ...lorawan.Modulation) *DeduplicatedUplinkMessage

RandomLoRaWANConfirmedDeduplicatedUplink returns randomly generated confirmed lorawan uplink message. Used for testing.

func RandomLoRaWANDeduplicatedJoinRequest 

func RandomLoRaWANDeduplicatedJoinRequest(modulation ...lorawan.Modulation) *DeduplicatedUplinkMessage

RandomLoRaWANDeduplicatedJoinRequest returns randomly generated lorawan join request. Used for testing.

func RandomLoRaWANDeduplicatedUplinkMessage 

func RandomLoRaWANDeduplicatedUplinkMessage(modulation ...lorawan.Modulation) *DeduplicatedUplinkMessage

RandomLoRaWANDeduplicatedUplinkMessage returns randomly generated lorawan uplink message(join request, confirmed or unconfirmed uplink). Used for testing. 

func RandomLoRaWANUnconfirmedDeduplicatedUplink(modulation ...lorawan.Modulation) *DeduplicatedUplinkMessage

RandomLoRaWANUnconfirmedDeduplicatedUplink returns randomly generated unconfirmed lorawan uplink message. Used for testing.

func (*DeduplicatedUplinkMessage) Descriptor 

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

func (*DeduplicatedUplinkMessage) Equal 

func (this *DeduplicatedUplinkMessage) Equal(that interface{}) bool

func (*DeduplicatedUplinkMessage) GetAppEUI 

func (m *DeduplicatedUplinkMessage) GetAppEUI() (eui types.AppEUI)

func (*DeduplicatedUplinkMessage) GetAppID 

func (m *DeduplicatedUplinkMessage) GetAppID() string

func (*DeduplicatedUplinkMessage) GetDevEUI 

func (m *DeduplicatedUplinkMessage) GetDevEUI() (eui types.DevEUI)

func (*DeduplicatedUplinkMessage) GetDevID 

func (m *DeduplicatedUplinkMessage) GetDevID() string

func (*DeduplicatedUplinkMessage) GetGatewayMetadata 

func (m *DeduplicatedUplinkMessage) GetGatewayMetadata() []*gateway.RxMetadata

func (*DeduplicatedUplinkMessage) GetMessage 

func (m *DeduplicatedUplinkMessage) GetMessage() *protocol.Message

func (*DeduplicatedUplinkMessage) GetPayload 

func (m *DeduplicatedUplinkMessage) GetPayload() []byte

func (*DeduplicatedUplinkMessage) GetProtocolMetadata 

func (m *DeduplicatedUplinkMessage) GetProtocolMetadata() protocol.RxMetadata

func (*DeduplicatedUplinkMessage) GetResponseTemplate 

func (m *DeduplicatedUplinkMessage) GetResponseTemplate() *DownlinkMessage

func (*DeduplicatedUplinkMessage) GetServerTime 

func (m *DeduplicatedUplinkMessage) GetServerTime() int64

func (*DeduplicatedUplinkMessage) GetTrace 

func (m *DeduplicatedUplinkMessage) GetTrace() *trace.Trace

func (*DeduplicatedUplinkMessage) InitResponseTemplate 

func (m *DeduplicatedUplinkMessage) InitResponseTemplate() *DownlinkMessage

func (*DeduplicatedUplinkMessage) Marshal 

func (m *DeduplicatedUplinkMessage) Marshal() (dAtA []byte, err error)

func (*DeduplicatedUplinkMessage) MarshalPayload 

func (m *DeduplicatedUplinkMessage) MarshalPayload() error

MarshalPayload marshals the Message into Payload if Payload is nil

func (*DeduplicatedUplinkMessage) MarshalTo 

func (m *DeduplicatedUplinkMessage) MarshalTo(dAtA []byte) (int, error)

func (*DeduplicatedUplinkMessage) MarshalToSizedBuffer 

func (m *DeduplicatedUplinkMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeduplicatedUplinkMessage) ProtoMessage 

func (*DeduplicatedUplinkMessage) ProtoMessage()

func (*DeduplicatedUplinkMessage) Reset 

func (m *DeduplicatedUplinkMessage) Reset()

func (*DeduplicatedUplinkMessage) Size 

func (m *DeduplicatedUplinkMessage) Size() (n int)

func (*DeduplicatedUplinkMessage) String 

func (this *DeduplicatedUplinkMessage) String() string

func (*DeduplicatedUplinkMessage) Unmarshal 

func (m *DeduplicatedUplinkMessage) Unmarshal(dAtA []byte) error

func (*DeduplicatedUplinkMessage) UnmarshalPayload 

func (m *DeduplicatedUplinkMessage) UnmarshalPayload() error

UnmarshalPayload unmarshals the Payload into Message if Message is nil

func (*DeduplicatedUplinkMessage) Validate 

func (m *DeduplicatedUplinkMessage) Validate() error

Validate implements the api.Validator interface

func (*DeduplicatedUplinkMessage) XXX_DiscardUnknown 

func (m *DeduplicatedUplinkMessage) XXX_DiscardUnknown()

func (*DeduplicatedUplinkMessage) XXX_Marshal 

func (m *DeduplicatedUplinkMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeduplicatedUplinkMessage) XXX_Merge 

func (m *DeduplicatedUplinkMessage) XXX_Merge(src proto.Message)

func (*DeduplicatedUplinkMessage) XXX_Size 

func (m *DeduplicatedUplinkMessage) XXX_Size() int

func (*DeduplicatedUplinkMessage) XXX_Unmarshal 

func (m *DeduplicatedUplinkMessage) XXX_Unmarshal(b []byte) error

type DeviceActivationRequest 

type DeviceActivationRequest struct {
	Payload              []byte                                            `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Message              *protocol.Message                                 `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	DevEUI               github_com_TheThingsNetwork_ttn_core_types.DevEUI `` /* 131-byte string literal not displayed */
	AppEUI               github_com_TheThingsNetwork_ttn_core_types.AppEUI `` /* 131-byte string literal not displayed */
	ProtocolMetadata     protocol.RxMetadata                               `protobuf:"bytes,21,opt,name=protocol_metadata,json=protocolMetadata,proto3" json:"protocol_metadata"`
	GatewayMetadata      gateway.RxMetadata                                `protobuf:"bytes,22,opt,name=gateway_metadata,json=gatewayMetadata,proto3" json:"gateway_metadata"`
	ActivationMetadata   *protocol.ActivationMetadata                      `protobuf:"bytes,23,opt,name=activation_metadata,json=activationMetadata,proto3" json:"activation_metadata,omitempty"`
	DownlinkOptions      []*DownlinkOption                                 `protobuf:"bytes,31,rep,name=downlink_options,json=downlinkOptions,proto3" json:"downlink_options,omitempty"`
	Trace                *trace.Trace                                      `protobuf:"bytes,41,opt,name=trace,proto3" json:"trace,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                          `json:"-"`
	XXX_sizecache        int32                                             `json:"-"`
}

received from the Router

func NewPopulatedDeviceActivationRequest 

func NewPopulatedDeviceActivationRequest(r randyBroker, easy bool) *DeviceActivationRequest

func (*DeviceActivationRequest) Descriptor 

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

func (*DeviceActivationRequest) Equal 

func (this *DeviceActivationRequest) Equal(that interface{}) bool

func (*DeviceActivationRequest) GetActivationMetadata 

func (m *DeviceActivationRequest) GetActivationMetadata() *protocol.ActivationMetadata

func (*DeviceActivationRequest) GetAppEUI 

func (m *DeviceActivationRequest) GetAppEUI() (eui types.AppEUI)

func (*DeviceActivationRequest) GetDevEUI 

func (m *DeviceActivationRequest) GetDevEUI() (eui types.DevEUI)

func (*DeviceActivationRequest) GetDownlinkOptions 

func (m *DeviceActivationRequest) GetDownlinkOptions() []*DownlinkOption

func (*DeviceActivationRequest) GetGatewayMetadata 

func (m *DeviceActivationRequest) GetGatewayMetadata() gateway.RxMetadata

func (*DeviceActivationRequest) GetMessage 

func (m *DeviceActivationRequest) GetMessage() *protocol.Message

func (*DeviceActivationRequest) GetPayload 

func (m *DeviceActivationRequest) GetPayload() []byte

func (*DeviceActivationRequest) GetProtocolMetadata 

func (m *DeviceActivationRequest) GetProtocolMetadata() protocol.RxMetadata

func (*DeviceActivationRequest) GetTrace 

func (m *DeviceActivationRequest) GetTrace() *trace.Trace

func (*DeviceActivationRequest) Marshal 

func (m *DeviceActivationRequest) Marshal() (dAtA []byte, err error)

func (*DeviceActivationRequest) MarshalPayload 

func (m *DeviceActivationRequest) MarshalPayload() error

MarshalPayload marshals the Message into Payload if Payload is nil

func (*DeviceActivationRequest) MarshalTo 

func (m *DeviceActivationRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeviceActivationRequest) MarshalToSizedBuffer 

func (m *DeviceActivationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeviceActivationRequest) ProtoMessage 

func (*DeviceActivationRequest) ProtoMessage()

func (*DeviceActivationRequest) Reset 

func (m *DeviceActivationRequest) Reset()

func (*DeviceActivationRequest) Size 

func (m *DeviceActivationRequest) Size() (n int)

func (*DeviceActivationRequest) String 

func (this *DeviceActivationRequest) String() string

func (*DeviceActivationRequest) Unmarshal 

func (m *DeviceActivationRequest) Unmarshal(dAtA []byte) error

func (*DeviceActivationRequest) UnmarshalPayload 

func (m *DeviceActivationRequest) UnmarshalPayload() error

UnmarshalPayload unmarshals the Payload into Message if Message is nil

func (*DeviceActivationRequest) Validate 

func (m *DeviceActivationRequest) Validate() error

Validate implements the api.Validator interface

func (*DeviceActivationRequest) XXX_DiscardUnknown 

func (m *DeviceActivationRequest) XXX_DiscardUnknown()

func (*DeviceActivationRequest) XXX_Marshal 

func (m *DeviceActivationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeviceActivationRequest) XXX_Merge 

func (m *DeviceActivationRequest) XXX_Merge(src proto.Message)

func (*DeviceActivationRequest) XXX_Size 

func (m *DeviceActivationRequest) XXX_Size() int

func (*DeviceActivationRequest) XXX_Unmarshal 

func (m *DeviceActivationRequest) XXX_Unmarshal(b []byte) error

type DeviceActivationResponse 

type DeviceActivationResponse struct {
	Payload              []byte            `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Message              *protocol.Message `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	DownlinkOption       *DownlinkOption   `protobuf:"bytes,11,opt,name=downlink_option,json=downlinkOption,proto3" json:"downlink_option,omitempty"`
	Trace                *trace.Trace      `protobuf:"bytes,21,opt,name=trace,proto3" json:"trace,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

sent to the Router, used as Template

func NewPopulatedDeviceActivationResponse 

func NewPopulatedDeviceActivationResponse(r randyBroker, easy bool) *DeviceActivationResponse

func (*DeviceActivationResponse) Descriptor 

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

func (*DeviceActivationResponse) Equal 

func (this *DeviceActivationResponse) Equal(that interface{}) bool

func (*DeviceActivationResponse) GetDownlinkOption 

func (m *DeviceActivationResponse) GetDownlinkOption() *DownlinkOption

func (*DeviceActivationResponse) GetMessage 

func (m *DeviceActivationResponse) GetMessage() *protocol.Message

func (*DeviceActivationResponse) GetPayload 

func (m *DeviceActivationResponse) GetPayload() []byte

func (*DeviceActivationResponse) GetTrace 

func (m *DeviceActivationResponse) GetTrace() *trace.Trace

func (*DeviceActivationResponse) Marshal 

func (m *DeviceActivationResponse) Marshal() (dAtA []byte, err error)

func (*DeviceActivationResponse) MarshalPayload 

func (m *DeviceActivationResponse) MarshalPayload() error

MarshalPayload marshals the Message into Payload if Payload is nil

func (*DeviceActivationResponse) MarshalTo 

func (m *DeviceActivationResponse) MarshalTo(dAtA []byte) (int, error)

func (*DeviceActivationResponse) MarshalToSizedBuffer 

func (m *DeviceActivationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeviceActivationResponse) ProtoMessage 

func (*DeviceActivationResponse) ProtoMessage()

func (*DeviceActivationResponse) Reset 

func (m *DeviceActivationResponse) Reset()

func (*DeviceActivationResponse) Size 

func (m *DeviceActivationResponse) Size() (n int)

func (*DeviceActivationResponse) String 

func (this *DeviceActivationResponse) String() string

func (*DeviceActivationResponse) Unmarshal 

func (m *DeviceActivationResponse) Unmarshal(dAtA []byte) error

func (*DeviceActivationResponse) UnmarshalPayload 

func (m *DeviceActivationResponse) UnmarshalPayload() error

UnmarshalPayload unmarshals the Payload into Message if Message is nil

func (*DeviceActivationResponse) XXX_DiscardUnknown 

func (m *DeviceActivationResponse) XXX_DiscardUnknown()

func (*DeviceActivationResponse) XXX_Marshal 

func (m *DeviceActivationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeviceActivationResponse) XXX_Merge 

func (m *DeviceActivationResponse) XXX_Merge(src proto.Message)

func (*DeviceActivationResponse) XXX_Size 

func (m *DeviceActivationResponse) XXX_Size() int

func (*DeviceActivationResponse) XXX_Unmarshal 

func (m *DeviceActivationResponse) XXX_Unmarshal(b []byte) error

type DownlinkMessage 

type DownlinkMessage struct {
	Payload              []byte                                            `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Message              *protocol.Message                                 `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	DevEUI               github_com_TheThingsNetwork_ttn_core_types.DevEUI `` /* 131-byte string literal not displayed */
	AppEUI               github_com_TheThingsNetwork_ttn_core_types.AppEUI `` /* 131-byte string literal not displayed */
	AppID                string                                            `protobuf:"bytes,13,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	DevID                string                                            `protobuf:"bytes,14,opt,name=dev_id,json=devId,proto3" json:"dev_id,omitempty"`
	DownlinkOption       *DownlinkOption                                   `protobuf:"bytes,21,opt,name=downlink_option,json=downlinkOption,proto3" json:"downlink_option,omitempty"`
	Trace                *trace.Trace                                      `protobuf:"bytes,31,opt,name=trace,proto3" json:"trace,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                          `json:"-"`
	XXX_sizecache        int32                                             `json:"-"`
}

received from the Handler, sent to the Router, used as Template

func NewPopulatedDownlinkMessage 

func NewPopulatedDownlinkMessage(r randyBroker, easy bool) *DownlinkMessage

func RandomDownlinkMessage 

func RandomDownlinkMessage() *DownlinkMessage

RandomDownlinkMessage returns randomly generated downlink message. Used for testing. 

func RandomLoRaWANConfirmedDownlink() *DownlinkMessage

RandomLoRaWANConfirmedDownlink returns randomly generated confirmed lorawan uplink message. Used for testing.

func RandomLoRaWANDownlinkMessage 

func RandomLoRaWANDownlinkMessage() *DownlinkMessage

RandomLoRaWANDownlinkMessage returns randomly generated lorawan downlink message(join request, confirmed or unconfirmed downlink). Used for testing.

func RandomLoRaWANJoinAccept 

func RandomLoRaWANJoinAccept() *DownlinkMessage

RandomLoRaWANJoinAccept returns randomly generated lorawan join request. Used for testing. 

func RandomLoRaWANUnconfirmedDownlink() *DownlinkMessage

RandomLoRaWANUnconfirmedDownlink returns randomly generated unconfirmed lorawan uplink message. Used for testing.

func (*DownlinkMessage) Descriptor 

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

func (*DownlinkMessage) Equal 

func (this *DownlinkMessage) Equal(that interface{}) bool

func (*DownlinkMessage) GetAppEUI 

func (m *DownlinkMessage) GetAppEUI() (eui types.AppEUI)

func (*DownlinkMessage) GetAppID 

func (m *DownlinkMessage) GetAppID() string

func (*DownlinkMessage) GetDevEUI 

func (m *DownlinkMessage) GetDevEUI() (eui types.DevEUI)

func (*DownlinkMessage) GetDevID 

func (m *DownlinkMessage) GetDevID() string

func (*DownlinkMessage) GetDownlinkOption 

func (m *DownlinkMessage) GetDownlinkOption() *DownlinkOption

func (*DownlinkMessage) GetMessage 

func (m *DownlinkMessage) GetMessage() *protocol.Message

func (*DownlinkMessage) GetPayload 

func (m *DownlinkMessage) GetPayload() []byte

func (*DownlinkMessage) GetTrace 

func (m *DownlinkMessage) GetTrace() *trace.Trace

func (*DownlinkMessage) Marshal 

func (m *DownlinkMessage) Marshal() (dAtA []byte, err error)

func (*DownlinkMessage) MarshalPayload 

func (m *DownlinkMessage) MarshalPayload() error

MarshalPayload marshals the Message into Payload if Payload is nil

func (*DownlinkMessage) MarshalTo 

func (m *DownlinkMessage) MarshalTo(dAtA []byte) (int, error)

func (*DownlinkMessage) MarshalToSizedBuffer 

func (m *DownlinkMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DownlinkMessage) ProtoMessage 

func (*DownlinkMessage) ProtoMessage()

func (*DownlinkMessage) Reset 

func (m *DownlinkMessage) Reset()

func (*DownlinkMessage) Size 

func (m *DownlinkMessage) Size() (n int)

func (*DownlinkMessage) String 

func (this *DownlinkMessage) String() string

func (*DownlinkMessage) Unmarshal 

func (m *DownlinkMessage) Unmarshal(dAtA []byte) error

func (*DownlinkMessage) UnmarshalPayload 

func (m *DownlinkMessage) UnmarshalPayload() error

UnmarshalPayload unmarshals the Payload into Message if Message is nil

func (*DownlinkMessage) Validate 

func (m *DownlinkMessage) Validate() error

Validate implements the api.Validator interface

func (*DownlinkMessage) XXX_DiscardUnknown 

func (m *DownlinkMessage) XXX_DiscardUnknown()

func (*DownlinkMessage) XXX_Marshal 

func (m *DownlinkMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DownlinkMessage) XXX_Merge 

func (m *DownlinkMessage) XXX_Merge(src proto.Message)

func (*DownlinkMessage) XXX_Size 

func (m *DownlinkMessage) XXX_Size() int

func (*DownlinkMessage) XXX_Unmarshal 

func (m *DownlinkMessage) XXX_Unmarshal(b []byte) error

type DownlinkOption 

type DownlinkOption struct {
	// String that identifies this downlink option in the Router
	Identifier string `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	// ID of the gateway where this downlink should be sent
	GatewayID string `protobuf:"bytes,2,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"`
	// Score of this downlink option. Lower is better.
	Score uint32 `protobuf:"varint,3,opt,name=score,proto3" json:"score,omitempty"`
	// deadline time at server represented as Unix nanoseconds
	Deadline              int64                    `protobuf:"varint,4,opt,name=deadline,proto3" json:"deadline,omitempty"`
	ProtocolConfiguration protocol.TxConfiguration `protobuf:"bytes,5,opt,name=protocol_configuration,json=protocolConfiguration,proto3" json:"protocol_configuration"`
	GatewayConfiguration  gateway.TxConfiguration  `protobuf:"bytes,6,opt,name=gateway_configuration,json=gatewayConfiguration,proto3" json:"gateway_configuration"`
	XXX_NoUnkeyedLiteral  struct{}                 `json:"-"`
	XXX_sizecache         int32                    `json:"-"`
}

func NewPopulatedDownlinkOption 

func NewPopulatedDownlinkOption(r randyBroker, easy bool) *DownlinkOption

func (*DownlinkOption) Descriptor 

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

func (*DownlinkOption) Equal 

func (this *DownlinkOption) Equal(that interface{}) bool

func (*DownlinkOption) GetDeadline 

func (m *DownlinkOption) GetDeadline() int64

func (*DownlinkOption) GetGatewayConfiguration 

func (m *DownlinkOption) GetGatewayConfiguration() gateway.TxConfiguration

func (*DownlinkOption) GetGatewayID 

func (m *DownlinkOption) GetGatewayID() string

func (*DownlinkOption) GetIdentifier 

func (m *DownlinkOption) GetIdentifier() string

func (*DownlinkOption) GetProtocolConfiguration 

func (m *DownlinkOption) GetProtocolConfiguration() protocol.TxConfiguration

func (*DownlinkOption) GetScore 

func (m *DownlinkOption) GetScore() uint32

func (*DownlinkOption) Marshal 

func (m *DownlinkOption) Marshal() (dAtA []byte, err error)

func (*DownlinkOption) MarshalTo 

func (m *DownlinkOption) MarshalTo(dAtA []byte) (int, error)

func (*DownlinkOption) MarshalToSizedBuffer 

func (m *DownlinkOption) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DownlinkOption) ProtoMessage 

func (*DownlinkOption) ProtoMessage()

func (*DownlinkOption) Reset 

func (m *DownlinkOption) Reset()

func (*DownlinkOption) Size 

func (m *DownlinkOption) Size() (n int)

func (*DownlinkOption) String 

func (this *DownlinkOption) String() string

func (*DownlinkOption) Unmarshal 

func (m *DownlinkOption) Unmarshal(dAtA []byte) error

func (*DownlinkOption) Validate 

func (m *DownlinkOption) Validate() error

Validate implements the api.Validator interface

func (*DownlinkOption) XXX_DiscardUnknown 

func (m *DownlinkOption) XXX_DiscardUnknown()

func (*DownlinkOption) XXX_Marshal 

func (m *DownlinkOption) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DownlinkOption) XXX_Merge 

func (m *DownlinkOption) XXX_Merge(src proto.Message)

func (*DownlinkOption) XXX_Size 

func (m *DownlinkOption) XXX_Size() int

func (*DownlinkOption) XXX_Unmarshal 

func (m *DownlinkOption) XXX_Unmarshal(b []byte) error

type Status 

type Status struct {
	System            api.SystemStats    `protobuf:"bytes,1,opt,name=system,proto3" json:"system"`
	Component         api.ComponentStats `protobuf:"bytes,2,opt,name=component,proto3" json:"component"`
	Uplink            *api.Rates         `protobuf:"bytes,11,opt,name=uplink,proto3" json:"uplink,omitempty"`
	UplinkUnique      *api.Rates         `protobuf:"bytes,12,opt,name=uplink_unique,json=uplinkUnique,proto3" json:"uplink_unique,omitempty"`
	Downlink          *api.Rates         `protobuf:"bytes,13,opt,name=downlink,proto3" json:"downlink,omitempty"`
	Activations       *api.Rates         `protobuf:"bytes,14,opt,name=activations,proto3" json:"activations,omitempty"`
	ActivationsUnique *api.Rates         `protobuf:"bytes,15,opt,name=activations_unique,json=activationsUnique,proto3" json:"activations_unique,omitempty"`
	Deduplication     *api.Percentiles   `protobuf:"bytes,16,opt,name=deduplication,proto3" json:"deduplication,omitempty"`
	// Connections
	ConnectedRouters     uint32   `protobuf:"varint,21,opt,name=connected_routers,json=connectedRouters,proto3" json:"connected_routers,omitempty"`
	ConnectedHandlers    uint32   `protobuf:"varint,22,opt,name=connected_handlers,json=connectedHandlers,proto3" json:"connected_handlers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedStatus 

func NewPopulatedStatus(r randyBroker, easy bool) *Status

func (*Status) Descriptor 

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

func (*Status) Equal 

func (this *Status) Equal(that interface{}) bool

func (*Status) GetActivations 

func (m *Status) GetActivations() *api.Rates

func (*Status) GetActivationsUnique 

func (m *Status) GetActivationsUnique() *api.Rates

func (*Status) GetComponent 

func (m *Status) GetComponent() api.ComponentStats

func (*Status) GetConnectedHandlers 

func (m *Status) GetConnectedHandlers() uint32

func (*Status) GetConnectedRouters 

func (m *Status) GetConnectedRouters() uint32

func (*Status) GetDeduplication 

func (m *Status) GetDeduplication() *api.Percentiles
func (m *Status) GetDownlink() *api.Rates

func (*Status) GetSystem 

func (m *Status) GetSystem() api.SystemStats
func (m *Status) GetUplink() *api.Rates

func (*Status) GetUplinkUnique 

func (m *Status) GetUplinkUnique() *api.Rates

func (*Status) Marshal 

func (m *Status) Marshal() (dAtA []byte, err error)

func (*Status) MarshalTo 

func (m *Status) MarshalTo(dAtA []byte) (int, error)

func (*Status) MarshalToSizedBuffer 

func (m *Status) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) Size 

func (m *Status) Size() (n int)

func (*Status) String 

func (this *Status) String() string

func (*Status) Unmarshal 

func (m *Status) Unmarshal(dAtA []byte) error

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Status) XXX_Merge 

func (m *Status) XXX_Merge(src proto.Message)

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

func (m *Status) XXX_Unmarshal(b []byte) error

type StatusRequest 

type StatusRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

message StatusRequest is used to request the status of this Broker

func NewPopulatedStatusRequest 

func NewPopulatedStatusRequest(r randyBroker, easy bool) *StatusRequest

func (*StatusRequest) Descriptor 

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

func (*StatusRequest) Equal 

func (this *StatusRequest) Equal(that interface{}) bool

func (*StatusRequest) Marshal 

func (m *StatusRequest) Marshal() (dAtA []byte, err error)

func (*StatusRequest) MarshalTo 

func (m *StatusRequest) MarshalTo(dAtA []byte) (int, error)

func (*StatusRequest) MarshalToSizedBuffer 

func (m *StatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset 

func (m *StatusRequest) Reset()

func (*StatusRequest) Size 

func (m *StatusRequest) Size() (n int)

func (*StatusRequest) String 

func (this *StatusRequest) String() string

func (*StatusRequest) Unmarshal 

func (m *StatusRequest) Unmarshal(dAtA []byte) error

func (*StatusRequest) XXX_DiscardUnknown 

func (m *StatusRequest) XXX_DiscardUnknown()

func (*StatusRequest) XXX_Marshal 

func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatusRequest) XXX_Merge 

func (m *StatusRequest) XXX_Merge(src proto.Message)

func (*StatusRequest) XXX_Size 

func (m *StatusRequest) XXX_Size() int

func (*StatusRequest) XXX_Unmarshal 

func (m *StatusRequest) XXX_Unmarshal(b []byte) error

type SubscribeRequest 

type SubscribeRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

message SubscribeRequest is used by a Handler to subscribe to uplink messages

func NewPopulatedSubscribeRequest 

func NewPopulatedSubscribeRequest(r randyBroker, easy bool) *SubscribeRequest

func (*SubscribeRequest) Descriptor 

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

func (*SubscribeRequest) Equal 

func (this *SubscribeRequest) Equal(that interface{}) bool

func (*SubscribeRequest) Marshal 

func (m *SubscribeRequest) Marshal() (dAtA []byte, err error)

func (*SubscribeRequest) MarshalTo 

func (m *SubscribeRequest) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeRequest) MarshalToSizedBuffer 

func (m *SubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset 

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) Size 

func (m *SubscribeRequest) Size() (n int)

func (*SubscribeRequest) String 

func (this *SubscribeRequest) String() string

func (*SubscribeRequest) Unmarshal 

func (m *SubscribeRequest) Unmarshal(dAtA []byte) error

func (*SubscribeRequest) XXX_DiscardUnknown 

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal 

func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeRequest) XXX_Merge 

func (m *SubscribeRequest) XXX_Merge(src proto.Message)

func (*SubscribeRequest) XXX_Size 

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal 

func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error

type UnimplementedBrokerManagerServer 

type UnimplementedBrokerManagerServer struct {
}

UnimplementedBrokerManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedBrokerManagerServer) GetStatus 

func (*UnimplementedBrokerManagerServer) GetStatus(ctx context.Context, req *StatusRequest) (*Status, error)

func (*UnimplementedBrokerManagerServer) RegisterApplicationHandler 

func (*UnimplementedBrokerManagerServer) RegisterApplicationHandler(ctx context.Context, req *ApplicationHandlerRegistration) (*types.Empty, error)

type UnimplementedBrokerServer 

type UnimplementedBrokerServer struct {
}

UnimplementedBrokerServer can be embedded to have forward compatible implementations.

func (*UnimplementedBrokerServer) Activate 

func (*UnimplementedBrokerServer) Activate(ctx context.Context, req *DeviceActivationRequest) (*DeviceActivationResponse, error)

func (*UnimplementedBrokerServer) Associate 

func (*UnimplementedBrokerServer) Associate(srv Broker_AssociateServer) error

func (*UnimplementedBrokerServer) Publish 

func (*UnimplementedBrokerServer) Publish(srv Broker_PublishServer) error

func (*UnimplementedBrokerServer) Subscribe 

func (*UnimplementedBrokerServer) Subscribe(req *SubscribeRequest, srv Broker_SubscribeServer) error

type UplinkMessage 

type UplinkMessage struct {
	Payload              []byte                                             `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Message              *protocol.Message                                  `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	DevEUI               *github_com_TheThingsNetwork_ttn_core_types.DevEUI `` /* 141-byte string literal not displayed */
	AppEUI               *github_com_TheThingsNetwork_ttn_core_types.AppEUI `` /* 141-byte string literal not displayed */
	AppID                string                                             `protobuf:"bytes,13,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	DevID                string                                             `protobuf:"bytes,14,opt,name=dev_id,json=devId,proto3" json:"dev_id,omitempty"`
	ProtocolMetadata     protocol.RxMetadata                                `protobuf:"bytes,21,opt,name=protocol_metadata,json=protocolMetadata,proto3" json:"protocol_metadata"`
	GatewayMetadata      gateway.RxMetadata                                 `protobuf:"bytes,22,opt,name=gateway_metadata,json=gatewayMetadata,proto3" json:"gateway_metadata"`
	DownlinkOptions      []*DownlinkOption                                  `protobuf:"bytes,31,rep,name=downlink_options,json=downlinkOptions,proto3" json:"downlink_options,omitempty"`
	Trace                *trace.Trace                                       `protobuf:"bytes,41,opt,name=trace,proto3" json:"trace,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                           `json:"-"`
	XXX_sizecache        int32                                              `json:"-"`
}

received from the Router

func NewPopulatedUplinkMessage 

func NewPopulatedUplinkMessage(r randyBroker, easy bool) *UplinkMessage

func (*UplinkMessage) Descriptor 

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

func (*UplinkMessage) Equal 

func (this *UplinkMessage) Equal(that interface{}) bool

func (*UplinkMessage) GetAppEUI 

func (m *UplinkMessage) GetAppEUI() (eui types.AppEUI)

func (*UplinkMessage) GetAppID 

func (m *UplinkMessage) GetAppID() string

func (*UplinkMessage) GetDevEUI 

func (m *UplinkMessage) GetDevEUI() (eui types.DevEUI)

func (*UplinkMessage) GetDevID 

func (m *UplinkMessage) GetDevID() string

func (*UplinkMessage) GetDownlinkOptions 

func (m *UplinkMessage) GetDownlinkOptions() []*DownlinkOption

func (*UplinkMessage) GetGatewayMetadata 

func (m *UplinkMessage) GetGatewayMetadata() gateway.RxMetadata

func (*UplinkMessage) GetMessage 

func (m *UplinkMessage) GetMessage() *protocol.Message

func (*UplinkMessage) GetPayload 

func (m *UplinkMessage) GetPayload() []byte

func (*UplinkMessage) GetProtocolMetadata 

func (m *UplinkMessage) GetProtocolMetadata() protocol.RxMetadata

func (*UplinkMessage) GetTrace 

func (m *UplinkMessage) GetTrace() *trace.Trace

func (*UplinkMessage) Marshal 

func (m *UplinkMessage) Marshal() (dAtA []byte, err error)

func (*UplinkMessage) MarshalPayload 

func (m *UplinkMessage) MarshalPayload() error

MarshalPayload marshals the Message into Payload if Payload is nil

func (*UplinkMessage) MarshalTo 

func (m *UplinkMessage) MarshalTo(dAtA []byte) (int, error)

func (*UplinkMessage) MarshalToSizedBuffer 

func (m *UplinkMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UplinkMessage) ProtoMessage 

func (*UplinkMessage) ProtoMessage()

func (*UplinkMessage) Reset 

func (m *UplinkMessage) Reset()

func (*UplinkMessage) Size 

func (m *UplinkMessage) Size() (n int)

func (*UplinkMessage) String 

func (this *UplinkMessage) String() string

func (*UplinkMessage) Unmarshal 

func (m *UplinkMessage) Unmarshal(dAtA []byte) error

func (*UplinkMessage) UnmarshalPayload 

func (m *UplinkMessage) UnmarshalPayload() error

UnmarshalPayload unmarshals the Payload into Message if Message is nil

func (*UplinkMessage) Validate 

func (m *UplinkMessage) Validate() error

Validate implements the api.Validator interface

func (*UplinkMessage) XXX_DiscardUnknown 

func (m *UplinkMessage) XXX_DiscardUnknown()

func (*UplinkMessage) XXX_Marshal 

func (m *UplinkMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UplinkMessage) XXX_Merge 

func (m *UplinkMessage) XXX_Merge(src proto.Message)

func (*UplinkMessage) XXX_Size 

func (m *UplinkMessage) XXX_Size() int

func (*UplinkMessage) XXX_Unmarshal 

func (m *UplinkMessage) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Directories

Path Synopsis

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.