INNER CODE UNIT · Go

main

Edgenesis/shifu · cmd/deviceshifu/cmdmqtt/main.go:13

func main() {
	deviceName := os.Getenv("EDGEDEVICE_NAME")
	namespace := os.Getenv("EDGEDEVICE_NAMESPACE")

	deviceShifuMetadata := &deviceshifubase.DeviceShifuMetaData{
		Name:           deviceName,
		ConfigFilePath: deviceshifubase.DeviceConfigmapFolderPath,
		KubeConfigPath: deviceshifubase.KubernetesConfigDefault,
		Namespace:      namespace,
	}

	ds, err := deviceshifumqtt.New(deviceShifuMetadata)
	if err != nil {
		panic(err.Error())
	}

	if err = ds.Start(wait.NeverStop); err != nil {
		logger.Errorf("Error starting deviceshifu: %v", err)

View source record →