This library is designed to make integrating with TAU in go, taking care of parsing out the messages and calling the registered receivers. From there all you have to do is create the logic around the various events that you can receive.
You can implement any/all of these callbacks in your own code to take advantage of this library allowing you to take care of the business logic, while this library takes care of parsing messages into usable structs.
RawCallback(msg []byte)
- All websocket messages received will be forwarded to this callback untouched. Note this will not stop processing via more specific callbacks.ErrorCallback(err error)
- Used to handle websocket type errors like when the websocket is closed by the remote source, if this is not handled then errors here will cause apanic
.StreamOnlineCallback(msg *StreamOnlineMsg)
- Called when a streamer goes onlineStreamOfflineCallback(msg *StreamOnlineMsg)
- Called when a streamer goes offlineFollowCallback(msg *FollowMsg)
- Called when a new follow event is received.StreamUpdateCallback(msg *StreamUpdateMsg)
- Called when a stream update event is received.CheerCallback(msg *CheerMsg)
- Called when a cheer event is received.RaidCallback(msg *RaidMsg)
- Called when a raid event is received.SubscriptionCallback(msg *SubscriptionMsg)
- Called when a subscription event is received.PointsRedemptionCallback(msg *PointsRedemptionMsg)
- Called when a points redemption event is received. Breaking change coming in a future version based on an upcoming TAU changeHypeTrainBeginCallback(msg *HypeTrainBeginMsg)
- Called when a hype train beginning event is received.HypeTrainProgressCallback(msg *HypeTrainProgressMsg)
- Called when a hype train progress event is received.HypeTrainEndCallback(msg *HypeTrainEndedMsg)
- Called when a hype train end event is received.
GetAuthToken
- Allows for getting your auth token via username and password. Ideally you would keep your auth token in your config, but this just gives you another option of how to get the data.SetParallelProcessing
- Allows you to process messages in parallel, defaults tofalse
.Reconnect
- Can be used to reconnect to the websocket on a connection error via theErrorCallback
.