event

package

v0.0.2 Latest Latest Go to latest Published: Jun 29, 2024 License: MIT Imports: 7 Imported by: 5

Details

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

Repository

github.com/cgalvisleon/et

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func ChannelPrune(channel string) string
func Close()
func Connect() (bool, error)
func IsConnected() bool
func Load() error
func Log(message interface{}) error
func Overflow(message interface{}) error
func Params(params et.Json) error
func Ping()
func Publish(channel string, message interface{}) error
func SendMessage(clientId string, message interface{}) error
func Stack(channel string, reciveFn func(message.Message)) error
func Subscribe(channel string, reciveFn func(message.Message)) error
func Telemetry(message interface{}) error
func TokeLastUse(message interface{}) error
func Type() string
func Unsubscribe(channel string) error
func Worker(event string, data interface{}) error

Constants ¶

View Source

const ERR_NOT_PUBSUB_SERVICE = "PubSub service not found func:%s"

Variables ¶

This section is empty.

Functions ¶

func ChannelPrune ¶ added in v0.0.2

func ChannelPrune(channel string) string

Prune a channel

func Close ¶

func Close()

Close the client websocket connection

func Connect ¶ added in v0.0.2

func Connect() (bool, error)

Connect to the service pubsub

func IsConnected ¶ added in v0.0.2

func IsConnected() bool

Check if the client is connected

func Load ¶

func Load() error

Load the event adapter

func Log ¶

func Log(message interface{}) error

Send a log message

func Overflow ¶

func Overflow(message interface{}) error

Send a overflow message

func Params ¶ added in v0.0.2

func Params(params et.Json) error

Set the params of the service pubsub

func Ping ¶ added in v0.0.2

func Ping()

Ping the service pubsub

func Publish ¶

func Publish(channel string, message interface{}) error

Publish a message to a channel

func SendMessage ¶ added in v0.0.2

func SendMessage(clientId string, message interface{}) error

Send a message to a client

func Stack ¶

func Stack(channel string, reciveFn func(message.Message)) error

Stack a client to a channel

func Subscribe(channel string, reciveFn func(message.Message)) error

Subscribe a client to a channel

func Telemetry ¶

func Telemetry(message interface{}) error

Send a telemetry message

func TokeLastUse ¶ added in v0.0.2

func TokeLastUse(message interface{}) error

Send a token last use message

func Type ¶ added in v0.0.2

func Type() string

Return the connection pubsub type

func Unsubscribe ¶ added in v0.0.2

func Unsubscribe(channel string) error

Unsubscribe a client from a channel

func Worker ¶ added in v0.0.2

func Worker(event string, data interface{}) error

Send a message to a event worker

Types ¶