eddnc

Dec 27, 2024

Changes in this version

+ const ConnTimeout

+ const NoTimout

+ const RecvTimeout

+ const TheRelay

+ var ScmInfos = []ScmInfo

+ func Decode(zmqmsg []byte, limit int64, into []byte) ([]byte, error)

+ func MessageEnd(event []byte) int

+ func MessageStart(event []byte) int

+ func NqDrop(q chan<- []byte, b []byte)

+ func Schema(raw []byte) []byte

+ func SchemaString(event []byte) string

type Event

+ ID string

type ScmID

+ func (sid ScmID) Info() ScmInfo

+ type ScmInfo struct

+ Ref string

+ Topic string

+ Version int

+ type Subscriber struct

+ ConnTimeout time.Duration

+ LogError func(format string, args ...any)

+ LogInfo func(format string, args ...any)

+ Nq func(chan<- []byte, []byte)

+ RecvTimeout time.Duration

+ Relay string

+ func (zc *Subscriber) LastRecv() time.Time

+ func (zc *Subscriber) Run(q chan<- []byte) (err error)

+ func (zc *Subscriber) Stop()

Feb 1, 2024

Changes in this version

type ScmID

+ const Sdockingdenied

+ const Sdockinggranted

Oct 3, 2023

Changes in this version

+ func SetLog(logger *slog.Logger)

Sep 12, 2022

Changes in this version

type ScmID

+ const Sfcmaterials_capi

+ const Sfcmaterials_journal

Jul 5, 2022

Changes in this version

type ScmID

+ const Sfsssignaldiscovered

Jun 13, 2022

Changes in this version

type ScmID

+ const Sfssbodysignals

Mar 12, 2022

Changes in this version

+ const BuildNo

+ const Major

+ const Minor

+ const Patch

+ const Quality

+ const ScmNo

+ var LogCfg = qbsllm.NewConfig(log)

+ var ScmDefs = []string

+ var ScmMap = map[string]ScmID

+ var ScmURLs = []string

+ type CodexMsg struct

+ BodyID int16

+ BodyName string

+ Category string

+ EntryID int64

+ Latitude float32

+ Longitude float32

+ Name string

+ Region int16

+ StarPos [3]float32

+ SubCategory string

+ SystemAddress int64

+ func (cdx *CodexMsg) Wrap(msg ggja.Obj) error

+ func (m *CodexMsg) SystemName() string

+ func (m *CodexMsg) Timestamp() time.Time

+ type Commodity struct

+ BuyPrice int

+ Demand int

+ DemandBracket int

+ MeanPrice int

+ Name string

+ SellPrice int

+ StatusFlags []string

+ Stock int

+ StockBracket int

+ type CommodityMsg struct

+ Commodities []*Commodity

+ MarketID int64

+ func (cm *CommodityMsg) Wrap(msg ggja.Obj) error

+ type Event struct

+ Header Header

+ Message Message

+ SchemaRef string

+ func (e *Event) Parse(txt []byte) error

+ func (e *Event) Wrap(evt ggja.Obj) (err error)

+ type FSSDiscoScanMsg struct

+ BodyCount int16

+ NonBodyCount int16

+ StarPos [3]float32

+ SystemAddress int64

+ func (fds *FSSDiscoScanMsg) Wrap(msg ggja.Obj) error

+ func (m *FSSDiscoScanMsg) SystemName() string

+ func (m *FSSDiscoScanMsg) Timestamp() time.Time

+ type Header struct

+ GatewayTimestamp time.Time

+ SoftwareName string

+ SoftwareVersion string

+ UploaderID string

+ func (h *Header) Wrap(hdr ggja.Obj)

+ type JournalMsg struct

+ Event string

+ StarPos [3]float64

+ SystemAddr int64

+ func (je *JournalMsg) Wrap(msg ggja.Obj) error

+ func (m *JournalMsg) SystemName() string

+ func (m *JournalMsg) Timestamp() time.Time

+ type Message interface

+ SystemName func() string

+ Timestamp func() time.Time

+ type ScmID int

+ const Sapproachsettlement

+ const Sblackmarket

+ const Scodexentry

+ const Scommodity

+ const Sfssallbodiesfound

+ const Sfssdiscoveryscan

+ const Sjournal

+ const Snavbeaconscan

+ const Snavroute

+ const Soutfitting

+ const Sscanbarycentre

+ const Sshipyard

+ func (i ScmID) String() string