common

package

v0.0.1 Latest Latest Go to latest Published: Nov 15, 2023 License: BSD-3-Clause Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ml4wireless/specpipe

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func ClusterSubject(sdrType SDRType, deviceName string, cmd ClusterCmd) string
func DataSubject(sdrType SDRType, deviceName string) string
func DeviceNameFromKey(key string) string
func KVStoreKey(sdrType SDRType, deviceName string) string
func NewNATSConn(natsUrl string) (*nc.Conn, error)
func NewNatsPublisher(natsUrl string) (message.Publisher, error)
type ClusterCmd
type Device
type EdgeLogrus
- func NewEdgeLogrus(level string) (EdgeLogrus, error)
type FMDevice
- func (*FMDevice) Device()
type IQDevice
- func (*IQDevice) Device()
type SDRType
type ServerLogrus
- func NewServerLogrus(level string) (ServerLogrus, error)

Constants ¶

View Source

const (
	DataSubjectPrefix    string = "specpipe.data"    // stream subject
	IqDataSubjectPrefix  string = "specpipe-iq.data" // stream subject
	ClusterSubjectPrefix string = "specpipe-cluster" // simple subject

	KVStoreBucket string = "specpipe"
)

View Source

const OkMsg string = "ok"

Variables ¶

View Source

var (
	TimestampHeader string = "ts"
)

Functions ¶

func ClusterSubject ¶

func ClusterSubject(sdrType SDRType, deviceName string, cmd ClusterCmd) string

func DataSubject ¶

func DataSubject(sdrType SDRType, deviceName string) string

func DeviceNameFromKey ¶

func DeviceNameFromKey(key string) string

func KVStoreKey ¶

func KVStoreKey(sdrType SDRType, deviceName string) string

func NewNATSConn ¶

func NewNATSConn(natsUrl string) (*nc.Conn, error)

func NewNatsPublisher ¶

func NewNatsPublisher(natsUrl string) (message.Publisher, error)

Types ¶

type ClusterCmd ¶

type ClusterCmd string

const (
	HealthCheckCmd ClusterCmd = "health"
	WatchConfigCmd ClusterCmd = "watchcfg"
)

type Device ¶

type Device interface {
	Device()
}

type EdgeLogrus ¶

type EdgeLogrus struct {
	*log.Entry
}

func NewEdgeLogrus ¶

func NewEdgeLogrus(level string) (EdgeLogrus, error)

type FMDevice ¶

type FMDevice struct {
	Name       string  `json:"name"`
	Freq       string  `json:"freq"`
	SampleRate string  `json:"sample_rate"`
	Latitude   float32 `json:"latitude"`
	Longitude  float32 `json:"longitude"`
}

func (*FMDevice) Device ¶

func (*FMDevice) Device()

type IQDevice ¶

type IQDevice struct {
	Name       string  `json:"name"`
	Freq       string  `json:"freq"`
	SampleRate string  `json:"sample_rate"`
	Latitude   float32 `json:"latitude"`
	Longitude  float32 `json:"longitude"`
}

func (*IQDevice) Device ¶

func (*IQDevice) Device()

type SDRType ¶

type SDRType string

const (
	FM SDRType = "fm"
	IQ SDRType = "iq"
)

type ServerLogrus ¶

type ServerLogrus struct {
	*log.Entry
}

func NewServerLogrus ¶

func NewServerLogrus(level string) (ServerLogrus, error)

Source Files ¶

View all Source files

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