go-sondehub's Introduction

SondeHub Go Package

Example Streaming live telemetry data

package main

import (
	"fmt"
	"github.com/EvanParden/go-sondehub/sondehub"
)

func onMessage(message []byte) {
	fmt.Println(string(message))
}

func main() {
	sondehub.NewStream(onMessage)

	select {}
}

functions

`NewStream(_MessageHandler func([]byte)) *Stream`

Creates a new SondeHub stream with the specified message handler.

Parameters:
- _MessageHandler: A function that handles incoming MQTT messages.

`AddSonde(sonde string)`

Adds a sonde to the list of subscribed sondes.

Parameters:
- sonde: The name of the sonde to add.

`RemoveSonde(sonde string)`

Removes a sonde from the list of subscribed sondes.

Parameters:
- sonde: The name of the sonde to remove.

`ContainsSonde(sonde string) bool`

Checks if a specific sonde is present in the list of subscribed sondes.

Parameters:
- sonde: The name of the sonde to check.
Returns:
- true if the sonde is present, false otherwise.

`Disconnect()`

Disconnects the SondeHub stream from the MQTT server.

Example Usage:

package main

import (
	"fmt"
	"time"
	"github.com/EvanParden/go-sondehub/sondehub"
)

func main() {
    // Create a new Stream with a message handler
    stream := sondehub.NewStream(onMessage)

    // Add sondes
    stream.AddSonde("sonde1")
    stream.AddSonde("sonde2")

    // Check if a sonde is present
    if stream.ContainsSonde("sonde1") {
        fmt.Println("sonde1 is present")
    } else {
        fmt.Println("sonde1 is not present")
    }

    // Remove a sonde
    stream.RemoveSonde("sonde1")

    // Check again after removal
    if stream.ContainsSonde("sonde1") {
        fmt.Println("sonde1 is present")
    } else {
        fmt.Println("sonde1 is not present")
    }

    // Keep the program running
    time.Sleep(30 * time.Second)
}

func onMessage(message []byte) {
    fmt.Println("Received message:", string(message))
}

Recommend Projects