bssci_v1

package

v0.4.1 Latest Latest Go to latest Published: Dec 13, 2025 License: MIT Imports: 23 Imported by: 0

Documentation ¶

const CACHE_KEY_SUFFIX_ATT string = "att"

View Source

const CACHE_KEY_SUFFIX_DET string = "det"

View Source

const CACHE_KEY_SUFFIX_STATUS string = "status"

This section is empty.

func MarshalBssciMessage(msg messages.MessageMsgp) ([]byte, error)

convert msg to message pack and attach bssci header

func ReadBssciMessage(r io.Reader) (cmd structs.CommandHeader, raw msgp.Raw, err error)

func UnmarshalBssciMessage(buf []byte) (cmd structs.CommandHeader, raw msgp.Raw, err error)

read the bssci header and extract the raw message pack data

func WriteBssciMessage(w io.Writer, msg messages.MessageMsgp) (err error)

type Backend struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewBackend(conf config.Config) (backend *Backend, err error)

NewBackend creates a new Backend.

func (b *Backend) HandleServerCommand(pb *bs.ServerCommand) error

Handler for server commands

func (b *Backend) HandleServerResponse(pb *bs.ServerResponse) error

Handler for server response messages

func (b *Backend) SetBasestationMessageHandler(f func(common.EUI64, events.EventType, *bs.BasestationUplink))

Handler for connection messages from basestations

func (b *Backend) SetEndnodeMessageHandler(f func(common.EUI64, events.EventType, *bs.EndnodeUplink))

Handler for uplink messages from endnodes

func (b *Backend) SetSubscribeEventHandler(f func(events.Subscribe))

Handler for Subscribe events.

func (b *Backend) Start() error

Starts the backend.

func (b *Backend) Stop() error

Stops the backend.

type TcpKeepAliveListener struct {
	*net.TCPListener
	// contains filtered or unexported fields
}

func NewTcpKeepAliveListener(addr string, keepAlivePeriod time.Duration) (*TcpKeepAliveListener, error)

func (ln TcpKeepAliveListener) Accept() (c net.Conn, err error)

Path	Synopsis
structs
messages