stream

package
v4.9.1 Latest Latest
Warning

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

 Go to latest Published: Sep 17, 2024 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_stream_api_request_proto protoreflect.FileDescriptor
View Source 
var File_stream_backend_interfaces_proto protoreflect.FileDescriptor
View Source 
var File_stream_frame_proto protoreflect.FileDescriptor
View Source 
var File_stream_meta_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ApiRequestLog 

type ApiRequestLog struct {

	// API service name.
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// API method name.
	Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	// Metadata.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ApiRequestLog) Descriptor deprecated 

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

Deprecated: Use ApiRequestLog.ProtoReflect.Descriptor instead.

func (*ApiRequestLog) GetMetadata 

func (x *ApiRequestLog) GetMetadata() map[string]string

func (*ApiRequestLog) GetMethod 

func (x *ApiRequestLog) GetMethod() string

func (*ApiRequestLog) GetService 

func (x *ApiRequestLog) GetService() string

func (*ApiRequestLog) ProtoMessage 

func (*ApiRequestLog) ProtoMessage()

func (*ApiRequestLog) ProtoReflect 

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

func (*ApiRequestLog) Reset 

func (x *ApiRequestLog) Reset()

func (*ApiRequestLog) String 

func (x *ApiRequestLog) String() string

type BackendInterfacesRequest 

type BackendInterfacesRequest struct {

	// Sender ID.
	SenderId string `protobuf:"bytes,1,opt,name=sender_id,json=senderId,proto3" json:"sender_id,omitempty"`
	// Receiver ID.
	ReceiverId string `protobuf:"bytes,2,opt,name=receiver_id,json=receiverId,proto3" json:"receiver_id,omitempty"`
	// Timestamp.
	Time *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// Transaction ID.
	TransactionId uint32 `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// Message-type.
	MessageType string `protobuf:"bytes,5,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"`
	// Result code.
	ResultCode string `protobuf:"bytes,6,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
	// Request body.
	RequestBody string `protobuf:"bytes,7,opt,name=request_body,json=requestBody,proto3" json:"request_body,omitempty"`
	// Request error.
	RequestError string `protobuf:"bytes,8,opt,name=request_error,json=requestError,proto3" json:"request_error,omitempty"`
	// Response body.
	ResponseBody string `protobuf:"bytes,9,opt,name=response_body,json=responseBody,proto3" json:"response_body,omitempty"`
	// contains filtered or unexported fields
}

func (*BackendInterfacesRequest) Descriptor deprecated 

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

Deprecated: Use BackendInterfacesRequest.ProtoReflect.Descriptor instead.

func (*BackendInterfacesRequest) GetMessageType 

func (x *BackendInterfacesRequest) GetMessageType() string

func (*BackendInterfacesRequest) GetReceiverId 

func (x *BackendInterfacesRequest) GetReceiverId() string

func (*BackendInterfacesRequest) GetRequestBody 

func (x *BackendInterfacesRequest) GetRequestBody() string

func (*BackendInterfacesRequest) GetRequestError 

func (x *BackendInterfacesRequest) GetRequestError() string

func (*BackendInterfacesRequest) GetResponseBody 

func (x *BackendInterfacesRequest) GetResponseBody() string

func (*BackendInterfacesRequest) GetResultCode 

func (x *BackendInterfacesRequest) GetResultCode() string

func (*BackendInterfacesRequest) GetSenderId 

func (x *BackendInterfacesRequest) GetSenderId() string

func (*BackendInterfacesRequest) GetTime 

func (x *BackendInterfacesRequest) GetTime() *timestamppb.Timestamp

func (*BackendInterfacesRequest) GetTransactionId 

func (x *BackendInterfacesRequest) GetTransactionId() uint32

func (*BackendInterfacesRequest) ProtoMessage 

func (*BackendInterfacesRequest) ProtoMessage()

func (*BackendInterfacesRequest) ProtoReflect 

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

func (*BackendInterfacesRequest) Reset 

func (x *BackendInterfacesRequest) Reset()

func (*BackendInterfacesRequest) String 

func (x *BackendInterfacesRequest) String() string

type DownlinkFrameLog 

type DownlinkFrameLog struct {

	// Time.
	Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	// PHYPayload.
	PhyPayload []byte `protobuf:"bytes,2,opt,name=phy_payload,json=phyPayload,proto3" json:"phy_payload,omitempty"`
	// TX meta-data.
	TxInfo *gw.DownlinkTxInfo `protobuf:"bytes,3,opt,name=tx_info,json=txInfo,proto3" json:"tx_info,omitempty"`
	// Downlink ID.
	DownlinkId uint32 `protobuf:"varint,4,opt,name=downlink_id,json=downlinkId,proto3" json:"downlink_id,omitempty"`
	// Gateway ID (EUI64).
	GatewayId string `protobuf:"bytes,5,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"`
	// Message type.
	MType common.MType `protobuf:"varint,6,opt,name=m_type,json=mType,proto3,enum=common.MType" json:"m_type,omitempty"`
	// Device address (optional).
	DevAddr string `protobuf:"bytes,7,opt,name=dev_addr,json=devAddr,proto3" json:"dev_addr,omitempty"`
	// Device EUI (optional).
	DevEui string `protobuf:"bytes,8,opt,name=dev_eui,json=devEui,proto3" json:"dev_eui,omitempty"`
	// Plaintext f_opts mac-commands.
	PlaintextFOpts bool `protobuf:"varint,9,opt,name=plaintext_f_opts,json=plaintextFOpts,proto3" json:"plaintext_f_opts,omitempty"`
	// Plaintext frm_payload.
	PlaintextFrmPayload bool `protobuf:"varint,10,opt,name=plaintext_frm_payload,json=plaintextFrmPayload,proto3" json:"plaintext_frm_payload,omitempty"`
	// contains filtered or unexported fields
}

func (*DownlinkFrameLog) Descriptor deprecated 

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

Deprecated: Use DownlinkFrameLog.ProtoReflect.Descriptor instead.

func (*DownlinkFrameLog) GetDevAddr 

func (x *DownlinkFrameLog) GetDevAddr() string

func (*DownlinkFrameLog) GetDevEui 

func (x *DownlinkFrameLog) GetDevEui() string

func (*DownlinkFrameLog) GetDownlinkId 

func (x *DownlinkFrameLog) GetDownlinkId() uint32

func (*DownlinkFrameLog) GetGatewayId 

func (x *DownlinkFrameLog) GetGatewayId() string

func (*DownlinkFrameLog) GetMType 

func (x *DownlinkFrameLog) GetMType() common.MType

func (*DownlinkFrameLog) GetPhyPayload 

func (x *DownlinkFrameLog) GetPhyPayload() []byte

func (*DownlinkFrameLog) GetPlaintextFOpts 

func (x *DownlinkFrameLog) GetPlaintextFOpts() bool

func (*DownlinkFrameLog) GetPlaintextFrmPayload 

func (x *DownlinkFrameLog) GetPlaintextFrmPayload() bool

func (*DownlinkFrameLog) GetTime 

func (x *DownlinkFrameLog) GetTime() *timestamppb.Timestamp

func (*DownlinkFrameLog) GetTxInfo 

func (x *DownlinkFrameLog) GetTxInfo() *gw.DownlinkTxInfo

func (*DownlinkFrameLog) ProtoMessage 

func (*DownlinkFrameLog) ProtoMessage()

func (*DownlinkFrameLog) ProtoReflect 

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

func (*DownlinkFrameLog) Reset 

func (x *DownlinkFrameLog) Reset()

func (*DownlinkFrameLog) String 

func (x *DownlinkFrameLog) String() string

type DownlinkMeta 

type DownlinkMeta struct {

	// Device EUI (EUI64).
	DevEui string `protobuf:"bytes,1,opt,name=dev_eui,json=devEui,proto3" json:"dev_eui,omitempty"`
	// Multicast Group ID (UUID).
	MulticastGroupId string `protobuf:"bytes,2,opt,name=multicast_group_id,json=multicastGroupId,proto3" json:"multicast_group_id,omitempty"`
	// TX meta-data.
	TxInfo *gw.DownlinkTxInfo `protobuf:"bytes,3,opt,name=tx_info,json=txInfo,proto3" json:"tx_info,omitempty"`
	// PHYPayload byte count.
	PhyPayloadByteCount uint32 `protobuf:"varint,4,opt,name=phy_payload_byte_count,json=phyPayloadByteCount,proto3" json:"phy_payload_byte_count,omitempty"`
	// MAC-Command byte count.
	MacCommandByteCount uint32 `protobuf:"varint,5,opt,name=mac_command_byte_count,json=macCommandByteCount,proto3" json:"mac_command_byte_count,omitempty"`
	// Application payload byte count.
	ApplicationPayloadByteCount uint32 `` /* 147-byte string literal not displayed */
	// Message type.
	MessageType common.MType `protobuf:"varint,7,opt,name=message_type,json=messageType,proto3,enum=common.MType" json:"message_type,omitempty"`
	// Gateway ID (EUI64).
	GatewayId string `protobuf:"bytes,8,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DownlinkMeta) Descriptor deprecated 

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

Deprecated: Use DownlinkMeta.ProtoReflect.Descriptor instead.

func (*DownlinkMeta) GetApplicationPayloadByteCount 

func (x *DownlinkMeta) GetApplicationPayloadByteCount() uint32

func (*DownlinkMeta) GetDevEui 

func (x *DownlinkMeta) GetDevEui() string

func (*DownlinkMeta) GetGatewayId 

func (x *DownlinkMeta) GetGatewayId() string

func (*DownlinkMeta) GetMacCommandByteCount 

func (x *DownlinkMeta) GetMacCommandByteCount() uint32

func (*DownlinkMeta) GetMessageType 

func (x *DownlinkMeta) GetMessageType() common.MType

func (*DownlinkMeta) GetMulticastGroupId 

func (x *DownlinkMeta) GetMulticastGroupId() string

func (*DownlinkMeta) GetPhyPayloadByteCount 

func (x *DownlinkMeta) GetPhyPayloadByteCount() uint32

func (*DownlinkMeta) GetTxInfo 

func (x *DownlinkMeta) GetTxInfo() *gw.DownlinkTxInfo

func (*DownlinkMeta) ProtoMessage 

func (*DownlinkMeta) ProtoMessage()

func (*DownlinkMeta) ProtoReflect 

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

func (*DownlinkMeta) Reset 

func (x *DownlinkMeta) Reset()

func (*DownlinkMeta) String 

func (x *DownlinkMeta) String() string

type UplinkFrameLog 

type UplinkFrameLog struct {

	// PHYPayload.
	PhyPayload []byte `protobuf:"bytes,1,opt,name=phy_payload,json=phyPayload,proto3" json:"phy_payload,omitempty"`
	// TX meta-data.
	TxInfo *gw.UplinkTxInfo `protobuf:"bytes,2,opt,name=tx_info,json=txInfo,proto3" json:"tx_info,omitempty"`
	// RX meta-data.
	RxInfo []*gw.UplinkRxInfo `protobuf:"bytes,3,rep,name=rx_info,json=rxInfo,proto3" json:"rx_info,omitempty"`
	// Message type.
	MType common.MType `protobuf:"varint,4,opt,name=m_type,json=mType,proto3,enum=common.MType" json:"m_type,omitempty"`
	// Device address (optional).
	DevAddr string `protobuf:"bytes,5,opt,name=dev_addr,json=devAddr,proto3" json:"dev_addr,omitempty"`
	// Device EUI (optional).
	DevEui string `protobuf:"bytes,6,opt,name=dev_eui,json=devEui,proto3" json:"dev_eui,omitempty"`
	// Time.
	Time *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=time,proto3" json:"time,omitempty"`
	// Plaintext f_opts mac-commands.
	PlaintextFOpts bool `protobuf:"varint,8,opt,name=plaintext_f_opts,json=plaintextFOpts,proto3" json:"plaintext_f_opts,omitempty"`
	// Plaintext frm_payload.
	PlaintextFrmPayload bool `protobuf:"varint,9,opt,name=plaintext_frm_payload,json=plaintextFrmPayload,proto3" json:"plaintext_frm_payload,omitempty"`
	// contains filtered or unexported fields
}

func (*UplinkFrameLog) Descriptor deprecated 

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

Deprecated: Use UplinkFrameLog.ProtoReflect.Descriptor instead.

func (*UplinkFrameLog) GetDevAddr 

func (x *UplinkFrameLog) GetDevAddr() string

func (*UplinkFrameLog) GetDevEui 

func (x *UplinkFrameLog) GetDevEui() string

func (*UplinkFrameLog) GetMType 

func (x *UplinkFrameLog) GetMType() common.MType

func (*UplinkFrameLog) GetPhyPayload 

func (x *UplinkFrameLog) GetPhyPayload() []byte

func (*UplinkFrameLog) GetPlaintextFOpts 

func (x *UplinkFrameLog) GetPlaintextFOpts() bool

func (*UplinkFrameLog) GetPlaintextFrmPayload 

func (x *UplinkFrameLog) GetPlaintextFrmPayload() bool

func (*UplinkFrameLog) GetRxInfo 

func (x *UplinkFrameLog) GetRxInfo() []*gw.UplinkRxInfo

func (*UplinkFrameLog) GetTime 

func (x *UplinkFrameLog) GetTime() *timestamppb.Timestamp

func (*UplinkFrameLog) GetTxInfo 

func (x *UplinkFrameLog) GetTxInfo() *gw.UplinkTxInfo

func (*UplinkFrameLog) ProtoMessage 

func (*UplinkFrameLog) ProtoMessage()

func (*UplinkFrameLog) ProtoReflect 

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

func (*UplinkFrameLog) Reset 

func (x *UplinkFrameLog) Reset()

func (*UplinkFrameLog) String 

func (x *UplinkFrameLog) String() string

type UplinkMeta 

type UplinkMeta struct {

	// Device EUI (EUI64).
	DevEui string `protobuf:"bytes,1,opt,name=dev_eui,json=devEui,proto3" json:"dev_eui,omitempty"`
	// TX meta-data.
	TxInfo *gw.UplinkTxInfo `protobuf:"bytes,2,opt,name=tx_info,json=txInfo,proto3" json:"tx_info,omitempty"`
	// RX meta-data.
	RxInfo []*gw.UplinkRxInfo `protobuf:"bytes,3,rep,name=rx_info,json=rxInfo,proto3" json:"rx_info,omitempty"`
	// PHYPayload byte count.
	PhyPayloadByteCount uint32 `protobuf:"varint,4,opt,name=phy_payload_byte_count,json=phyPayloadByteCount,proto3" json:"phy_payload_byte_count,omitempty"`
	// MAC-Command byte count.
	MacCommandByteCount uint32 `protobuf:"varint,5,opt,name=mac_command_byte_count,json=macCommandByteCount,proto3" json:"mac_command_byte_count,omitempty"`
	// Application payload byte count.
	ApplicationPayloadByteCount uint32 `` /* 147-byte string literal not displayed */
	// Message type.
	MessageType common.MType `protobuf:"varint,7,opt,name=message_type,json=messageType,proto3,enum=common.MType" json:"message_type,omitempty"`
	// contains filtered or unexported fields
}

func (*UplinkMeta) Descriptor deprecated 

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

Deprecated: Use UplinkMeta.ProtoReflect.Descriptor instead.

func (*UplinkMeta) GetApplicationPayloadByteCount 

func (x *UplinkMeta) GetApplicationPayloadByteCount() uint32

func (*UplinkMeta) GetDevEui 

func (x *UplinkMeta) GetDevEui() string

func (*UplinkMeta) GetMacCommandByteCount 

func (x *UplinkMeta) GetMacCommandByteCount() uint32

func (*UplinkMeta) GetMessageType 

func (x *UplinkMeta) GetMessageType() common.MType

func (*UplinkMeta) GetPhyPayloadByteCount 

func (x *UplinkMeta) GetPhyPayloadByteCount() uint32

func (*UplinkMeta) GetRxInfo 

func (x *UplinkMeta) GetRxInfo() []*gw.UplinkRxInfo

func (*UplinkMeta) GetTxInfo 

func (x *UplinkMeta) GetTxInfo() *gw.UplinkTxInfo

func (*UplinkMeta) ProtoMessage 

func (*UplinkMeta) ProtoMessage()

func (*UplinkMeta) ProtoReflect 

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

func (*UplinkMeta) Reset 

func (x *UplinkMeta) Reset()

func (*UplinkMeta) String 

func (x *UplinkMeta) String() string

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.