grpc

Documentation

Index

• func New(server io.Server, opts ...Option) ttnpb.AppAsServer
• type EndDeviceFetcher
• type Option
  • func WithEndDeviceFetcher(f EndDeviceFetcher) Option
  • func WithMQTTConfigProvider(provider config.MQTTConfigProvider) Option
  • func WithPayloadProcessor(processor messageprocessors.PayloadProcessor) Option
  • func WithSkipPayloadCrypto(f SkipPayloadCryptoFunc) Option
• type SkipPayloadCryptoFunc

Functions

func New

func New(server io.Server, opts ...Option) ttnpb.AppAsServer

New returns a new gRPC frontend.

Types

type EndDeviceFetcher

type EndDeviceFetcher interface {
	Get(ctx context.Context, ids ttnpb.EndDeviceIdentifiers, fieldMaskPaths ...string) (*ttnpb.EndDevice, error)
}

EndDeviceFetcher retrieves end device information from identifiers.

type Option

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

Option represents an option for the gRPC frontend.

func WithEndDeviceFetcher

func WithEndDeviceFetcher(f EndDeviceFetcher) Option

WithEndDeviceFetcher sets the EndDeviceFetcher that will be used by the gRPC frontend.

func WithMQTTConfigProvider

func WithMQTTConfigProvider(provider config.MQTTConfigProvider) Option

WithMQTTConfigProvider sets the MQTT configuration provider for the gRPC frontend.

func WithPayloadProcessor

func WithPayloadProcessor(processor messageprocessors.PayloadProcessor) Option

WithPayloadProcessor sets the PayloadProcessor that will be used by the gRPC frontend.

func WithSkipPayloadCrypto

func WithSkipPayloadCrypto(f SkipPayloadCryptoFunc) Option

WithSkipPayloadCrypto sets the skip payload crypto predicate that will be used by the gRPC frontend.

type SkipPayloadCryptoFunc

type SkipPayloadCryptoFunc func(ctx context.Context, ids ttnpb.EndDeviceIdentifiers) (bool, error)

SkipPayloadCryptoFunc is a function that checks if the end device should skip payload crypto operations.