messageprocessors

Documentation

Overview

Package messageprocessors provides interfaces and implementations for processing uplink and downlink messages.

Index

• type PayloadDecoder
• type PayloadDecoderRPC
  • func (r *PayloadDecoderRPC) Process(ctx context.Context, req *ttnpb.ProcessUplinkMessageRequest) (*ttnpb.ApplicationUplink, error)
• type PayloadEncodeDecoder
• type PayloadEncoder
• type PayloadEncoderRPC
  • func (r *PayloadEncoderRPC) Process(ctx context.Context, req *ttnpb.ProcessDownlinkMessageRequest) (*ttnpb.ApplicationDownlink, error)

Types

type PayloadDecoder

type PayloadDecoder interface {
	Decode(ctx context.Context, ids ttnpb.EndDeviceIdentifiers, version *ttnpb.EndDeviceVersionIdentifiers, message *ttnpb.ApplicationUplink, parameter string) error
}

PayloadDecoder represents a payload decoder message processor.

type PayloadDecoderRPC

type PayloadDecoderRPC struct {
	PayloadDecoder
}

PayloadDecoderRPC implements the UplinkMessageProcessorServer using a payload decoder.

func (*PayloadDecoderRPC) Process

func (r *PayloadDecoderRPC) Process(ctx context.Context, req *ttnpb.ProcessUplinkMessageRequest) (*ttnpb.ApplicationUplink, error)

Process implements the UplinkMessageProcessorServer interface.

type PayloadEncodeDecoder

type PayloadEncodeDecoder interface {
	PayloadEncoder
	PayloadDecoder
}

PayloadEncodeDecoder is the interface that groups the Encode and Decode methods.

type PayloadEncoder

type PayloadEncoder interface {
	Encode(ctx context.Context, ids ttnpb.EndDeviceIdentifiers, version *ttnpb.EndDeviceVersionIdentifiers, message *ttnpb.ApplicationDownlink, parameter string) error
}

PayloadEncoder represents a payload encoder message processor.

type PayloadEncoderRPC

type PayloadEncoderRPC struct {
	PayloadEncoder
}

PayloadEncoderRPC implements the DownlinkMessageProcessorServer using a payload encoder.

func (*PayloadEncoderRPC) Process

func (r *PayloadEncoderRPC) Process(ctx context.Context, req *ttnpb.ProcessDownlinkMessageRequest) (*ttnpb.ApplicationDownlink, error)

Process implements the DownlinkMessageProcessorServer interface.