router

package
v1.2.1 Latest Latest
Warning

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

Go to latest
Published: Jul 6, 2023 License: Apache-2.0 Imports: 44 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GenerateKey

func GenerateKey(cmd *cobra.Command, args []string)

func Run

func Run(cmd *cobra.Command, args []string)

Types

type Config

type Config struct {
	Log struct {
		Level     logrus.Level
		Timestamp bool
	}

	Router RouterConfig `mapstructure:"router"`

	Metrics *struct {
		Prometheus *struct {
			Address string
			Path    string
		}
	}
}

func (Config) MetricsPrometheusAddress

func (cfg Config) MetricsPrometheusAddress() string

func (Config) MetricsPrometheusPath

func (cfg Config) MetricsPrometheusPath() string

func (Config) PrometheusEnabled

func (cfg Config) PrometheusEnabled() bool

type Identity

type Identity struct {
	ID         string            `yaml:"id"`
	PrivateKey *ecdsa.PrivateKey `yaml:"private_key"`
}

type JoinFilterGenerator

type JoinFilterGenerator interface {
	JoinFilter(ctx context.Context) (*router.JoinFilter, error)
	UpdateFilter(ctx context.Context) error
}

func NewJoinFilterGenerator

func NewJoinFilterGenerator(config RouterConfig) (JoinFilterGenerator, error)

type Keyfile

type Keyfile struct {
	Router struct {
		ID         string `yaml:"id"`
		PrivateKey string `yaml:"private_key"`
	}
}

type Router

type Router struct {
	router.UnimplementedRouterV1Server
	// contains filtered or unexported fields
}

Router accepts connections from forwarders and can exchange message between gateways and the integration layer this router is configured for. It ensures that messages from the integrations layer are send to the correct forwarder that can deliver the packet to the targeted gateways.

func NewRouter

func NewRouter(cfg *Config, in integration.Integration) (*Router, error)

func (*Router) DownlinkFrame added in v1.0.3

func (r *Router) DownlinkFrame(frame *gw.DownlinkFrame)

func (*Router) Events

func (r *Router) Events(forwarder router.RouterV1_EventsServer) error

Called by the forwarder to start bi-directional communication stream on which events from gateways are send through the forwarder to this router or in reverse from the integrations connected to this router to the forwarder and eventually to its gateways that the event is targeted for.

func (*Router) GatewayCommandExecHandler

func (r *Router) GatewayCommandExecHandler(cmdExec *gw.GatewayCommandExecRequest)

func (*Router) GatewayConfigurationHandler

func (r *Router) GatewayConfigurationHandler(conf *gw.GatewayConfiguration)

func (*Router) JoinFilter

func (*Router) MustRun

func (r *Router) MustRun(ctx context.Context)

func (*Router) RawPacketForwarderCommandHandler

func (r *Router) RawPacketForwarderCommandHandler(cmd *gw.RawPacketForwarderCommand)

func (*Router) Run

func (r *Router) Run(ctx context.Context) error

type RouterConfig

type RouterConfig struct {
	Keyfile string `yaml:"key_file"`

	JoinFilterGenerator struct {
		RenewInterval time.Duration `mapstructure:"renew_interval"`
		ChirpStack    struct {
			Target   string `mapstructure:"target"`
			Insecure bool
			APIKey   string `mapstructure:"api_key"`
		} `mapstructure:"chirpstack"`
	}

	Forwarder struct {
		Endpoint struct {
			Host string
			Port uint16
		}
	}

	Integration struct {
		Marshaler string `mapstructure:"marshaler"`

		MQTT *struct {
			EventTopicTemplate      string        `mapstructure:"event_topic_template"`
			CommandTopicTemplate    string        `mapstructure:"command_topic_template"`
			StateTopicTemplate      string        `mapstructure:"state_topic_template"`
			StateRetained           bool          `mapstructure:"state_retained"`
			KeepAlive               time.Duration `mapstructure:"keep_alive"`
			MaxReconnectInterval    time.Duration `mapstructure:"max_reconnect_interval"`
			TerminateOnConnectError bool          `mapstructure:"terminate_on_connect_error"`
			MaxTokenWait            time.Duration `mapstructure:"max_token_wait"`

			Auth *struct {
				Generic *struct {
					Server       string   `mapstructure:"server"`
					Servers      []string `mapstructure:"servers"`
					Username     string   `mapstructure:"username"`
					Password     string   `mapstrucure:"password"`
					CACert       string   `mapstructure:"ca_cert"`
					TLSCert      string   `mapstructure:"tls_cert"`
					TLSKey       string   `mapstructure:"tls_key"`
					QOS          uint8    `mapstructure:"qos"`
					CleanSession bool     `mapstructure:"clean_session"`
					ClientID     string   `mapstructure:"client_id"`
				} `mapstructure:"generic"`

				GCPCloudIoTCore *struct {
					Server        string        `mapstructure:"server"`
					DeviceID      string        `mapstructure:"device_id"`
					ProjectID     string        `mapstructure:"project_id"`
					CloudRegion   string        `mapstructure:"cloud_region"`
					RegistryID    string        `mapstructure:"registry_id"`
					JWTExpiration time.Duration `mapstructure:"jwt_expiration"`
					JWTKeyFile    string        `mapstructure:"jwt_key_file"`
				} `mapstructure:"gcp_cloud_iot_core"`

				AzureIoTHub *struct {
					DeviceConnectionString string        `mapstructure:"device_connection_string"`
					DeviceID               string        `mapstructure:"device_id"`
					Hostname               string        `mapstructure:"hostname"`
					DeviceKey              string        `mapstructure:"-"`
					SASTokenExpiration     time.Duration `mapstructure:"sas_token_expiration"`
					TLSCert                string        `mapstructure:"tls_cert"`
					TLSKey                 string        `mapstructure:"tls_key"`
				} `mapstructure:"azure_iot_hub"`
			} `mapstructure:"auth"`
		} `mapstructure:"mqtt"`
	} `mapstructure:"integration"`
}

func (RouterConfig) ForwarderListenerAddress

func (rc RouterConfig) ForwarderListenerAddress() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL