rt

Nov 18, 2024

Changes in this version

+ const MSG_RT_AUTH_REQUIRED

+ const ServiceName

+ func SetDirectMessageCallback(reciveFn func(ws.Message))

+ func SetReconnectCallback(reciveFn func(c *ws.Client))

Nov 16, 2024

Changes in this version

+ const MSG_RT_HOST_REQUIRED

Nov 15, 2024

Changes in this version

+ const MSG_RT_URL_REQUIRED

Nov 12, 2024

Changes in this version

+ func Data(channel string, data et.Json) error

+ func HttpEventWork(w http.ResponseWriter, r *http.Request)

+ func Log(event string, data et.Json)

+ func Overflow(data et.Json)

+ func Source(channel string, reciveFn func(ws.Message)) error

+ func Stack(channel string, reciveFn func(ws.Message))

+ func Telemetry(data et.Json)

+ func TokenLastUse(data et.Json)

+ func Work(event string, data et.Json) et.Json

+ func WorkState(work_id string, status event.WorkStatus, data et.Json)

Oct 16, 2024

Changes in this version

+ const ERR_INVALID_ID

+ const ERR_INVALID_NAME

+ const ERR_NOT_CONNECT_WS

+ func Close()

+ func From() et.Json

+ func IsConnected() bool

+ func Load() error

+ func Ping()

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

+ func Queue(channel, queue string, reciveFn func(ws.Message))

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

+ func SetFrom(name string) error

+ func Subscribe(channel string, reciveFn func(ws.Message))

+ func Unsubscribe(channel string)

+ type ClientWS struct

+ ClientId string

+ Host string

+ Name string