aranyagoconst

Documentation

Index

• Constants
• func AMQPTopics(ns string) (cmdTopic, msgTopic, statusTopic string)
• func CoAPTopics(ns string) (cmdPath, msgPath, statusPath string)
• func MQTTTopics(ns string) (cmdTopic, msgTopic, statusTopic string)
• func NatsTopics(ns string) (cmdTopic, msgTopic, statusTopic string)
• type CustomPortForwardOptions

Constants

const (
	// max gRPC message size
	// https://github.com/grpc/grpc.github.io/issues/371
	MaxGRPCDataSize = 64 * 1024

	// max MQTT message size (make it compatible with aws mqtt)
	MaxMQTTDataSize = MaxAwsIoTCoreC2DDataSize

	// https://docs.aws.amazon.com/general/latest/gr/aws_service_limits.html#protocol
	MaxAwsIoTCoreD2CDataSize = 128 * 1024 // device to cloud
	MaxAwsIoTCoreC2DDataSize = 128 * 1024 // cloud to device

	// https://docs.microsoft.com/en-us/azure/iot-hub/iot-hub-devguide-quotas-throttling
	MaxAzureIoTHubD2CDataSize = 256 * 1024 // device to cloud
	MaxAzureIoTHubC2DDataSize = 64 * 1024  // cloud to device

	// https://cloud.google.com/iot/quotas
	MaxGCPIoTCoreD2CDataSize = 256 * 1024 // device to cloud
	MaxGCPIoTCoreC2DDataSize = 256 * 1024 // cloud to device

	// max CoAP message (will split into chunks)
	MaxCoAPDataSize = 64 * 1024

	MaxNatsDataSize = 1024 * 1024
)

const (
	VariantAzureIoTHub = "azure-iot-hub"
	VariantGCPIoTCore  = "gcp-iot-core"
	VariantAWSIoTCore  = "aws-iot-core"
)

const (
	ConnectivityMethodGRPC = "grpc"
	ConnectivityMethodMQTT = "mqtt"
	ConnectivityMethodCoAP = "coap"
)

const (
	HeaderSessionID      = "X-Aranya-Session-ID"
	HeaderMaxPayloadSize = "X-Aranya-Max-Payload-Size"
)

const (
	TimeLayout = time.RFC3339Nano
)

Functions

func AMQPTopics

func AMQPTopics(ns string) (cmdTopic, msgTopic, statusTopic string)

func CoAPTopics

func CoAPTopics(ns string) (cmdPath, msgPath, statusPath string)

func MQTTTopics

func MQTTTopics(ns string) (cmdTopic, msgTopic, statusTopic string)

func NatsTopics

func NatsTopics(ns string) (cmdTopic, msgTopic, statusTopic string)

Types

type CustomPortForwardOptions

type CustomPortForwardOptions struct {
	Network string `json:"network"`
	Address string `json:"address"`
	Port    int32  `json:"port"`
	// is packet stream
	Packet bool `json:"packet"`
}