messaging

Documentation

Index

• Constants
• func Connect() *nats.Conn
• func EncodedConnection(nc *nats.Conn) *nats.EncodedConn
• func JetStream(nc *nats.Conn) nats.JetStreamContext
• func KeyValueHorizon(js nats.JetStreamContext) nats.KeyValue
• type Location
• type PartSubMessage
• type SpotMessage
• type SpotSubMessage

Constants

const ERR_Q = "error"

const GROUP = "horizon-service"

const IN_Q = "spots"

const OUT_Q = "horizons"

const STORE_NAME = "horizons"

Functions

func Connect

func Connect() *nats.Conn

func EncodedConnection

func EncodedConnection(nc *nats.Conn) *nats.EncodedConn

func JetStream

func JetStream(nc *nats.Conn) nats.JetStreamContext

func KeyValueHorizon

func KeyValueHorizon(js nats.JetStreamContext) nats.KeyValue

Types

type Location

type Location struct {
	Lat float64 `json:"lat"`
	Lon float64 `json:"lon"`
}

type PartSubMessage

type PartSubMessage struct {
	Id uint `json:"id"`
	Of uint `json:"of"`
}

type SpotMessage

type SpotMessage struct {
	Part PartSubMessage `json:"part"`
	Spot SpotSubMessage `json:"spot"`
}

type SpotSubMessage

type SpotSubMessage struct {
	Dir  float64  `json:"dir"`
	Kind string   `json:"kind"`
	Loc  Location `json:"loc"`
}