pubsub

package
v0.1.18 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 8, 2022 License: GPL-3.0 Imports: 4 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Channel

func Channel(name string) (channel, error)

func GetMessageChannel

func GetMessageChannel(eventId uint32, channelPtr *byte) (error errno.Error)

func GetMessageChannelSize

func GetMessageChannelSize(eventId uint32, channelSizePtr *uint32) (error errno.Error)

func GetMessageData

func GetMessageData(eventId uint32, buf *byte) (error errno.Error)

func GetMessageDataSize

func GetMessageDataSize(eventId uint32, sizePtr *uint32) (error errno.Error)

func GetWebSocketURL

func GetWebSocketURL(channel string, socketURLPtr *byte) (error errno.Error)

func GetWebSocketURLSize

func GetWebSocketURLSize(channel string, sizePtr *uint32) (error errno.Error)

func PublishToChannel

func PublishToChannel(channel string, data *byte, dataSize uint32) (error errno.Error)

func SetSubscriptionChannel

func SetSubscriptionChannel(channel string) (error errno.Error)

Types

type PubSubEvent

type PubSubEvent uint32

func (PubSubEvent) Channel

func (e PubSubEvent) Channel() (*channel, error)

func (PubSubEvent) Data

func (e PubSubEvent) Data() ([]byte, error)

type PubSubEventMessage

type PubSubEventMessage uint32

Jump to

Keyboard shortcuts

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