116 lines
3.0 KiB
Go
116 lines
3.0 KiB
Go
// Code generated by internal/gen/api/main.go. DO NOT EDIT.
|
|
|
|
package apiproto
|
|
|
|
import "encoding/json"
|
|
|
|
var _ ResultEncoder = (*JSONResultEncoder)(nil)
|
|
|
|
// JSONResultEncoder ...
|
|
type JSONResultEncoder struct{}
|
|
|
|
// NewJSONResultEncoder ...
|
|
func NewJSONResultEncoder() *JSONResultEncoder {
|
|
return &JSONResultEncoder{}
|
|
}
|
|
|
|
// EncodePublish ...
|
|
func (e *JSONResultEncoder) EncodePublish(res *PublishResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodeBroadcast ...
|
|
func (e *JSONResultEncoder) EncodeBroadcast(res *BroadcastResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodeSubscribe ...
|
|
func (e *JSONResultEncoder) EncodeSubscribe(res *SubscribeResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodeUnsubscribe ...
|
|
func (e *JSONResultEncoder) EncodeUnsubscribe(res *UnsubscribeResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodeDisconnect ...
|
|
func (e *JSONResultEncoder) EncodeDisconnect(res *DisconnectResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodePresence ...
|
|
func (e *JSONResultEncoder) EncodePresence(res *PresenceResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodePresenceStats ...
|
|
func (e *JSONResultEncoder) EncodePresenceStats(res *PresenceStatsResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodeHistory ...
|
|
func (e *JSONResultEncoder) EncodeHistory(res *HistoryResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodeHistoryRemove ...
|
|
func (e *JSONResultEncoder) EncodeHistoryRemove(res *HistoryRemoveResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodeInfo ...
|
|
func (e *JSONResultEncoder) EncodeInfo(res *InfoResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodeRPC ...
|
|
func (e *JSONResultEncoder) EncodeRPC(res *RPCResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodeRefresh ...
|
|
func (e *JSONResultEncoder) EncodeRefresh(res *RefreshResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodeChannels ...
|
|
func (e *JSONResultEncoder) EncodeChannels(res *ChannelsResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodeMapPublish ...
|
|
func (e *JSONResultEncoder) EncodeMapPublish(res *MapPublishResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodeMapRemove ...
|
|
func (e *JSONResultEncoder) EncodeMapRemove(res *MapRemoveResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodeMapReadState ...
|
|
func (e *JSONResultEncoder) EncodeMapReadState(res *MapReadStateResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodeMapReadStream ...
|
|
func (e *JSONResultEncoder) EncodeMapReadStream(res *MapReadStreamResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodeMapStats ...
|
|
func (e *JSONResultEncoder) EncodeMapStats(res *MapStatsResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodeMapClear ...
|
|
func (e *JSONResultEncoder) EncodeMapClear(res *MapClearResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|
|
|
|
// EncodeSharedPollPublish ...
|
|
func (e *JSONResultEncoder) EncodeSharedPollPublish(res *SharedPollPublishResult) ([]byte, error) {
|
|
return json.Marshal(res)
|
|
}
|